Skip to content

Commit 6d6c556

Browse files
fix on filter load
1 parent 90a9645 commit 6d6c556

File tree

1 file changed

+11
-4
lines changed

1 file changed

+11
-4
lines changed

server/src/users/filters.rs

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,6 @@ impl Filters {
7777
let mut this = vec![];
7878
let store = CONFIG.storage().get_object_store();
7979
let all_filters = store.get_all_saved_filters().await.unwrap_or_default();
80-
8180
for (filter_relative_path, filters) in all_filters {
8281
for filter in filters {
8382
if filter.is_empty() {
@@ -92,11 +91,19 @@ impl Filters {
9291
store.delete_object(&filter_relative_path).await?;
9392

9493
filter_value = migrate_v1_v2(filter_value);
95-
let user_id = meta.get("user_id").and_then(|user_id| user_id.as_str());
96-
let filter_id = meta
94+
let user_id = filter_value
95+
.as_object()
96+
.unwrap()
97+
.get("user_id")
98+
.and_then(|user_id| user_id.as_str());
99+
let filter_id = filter_value
100+
.as_object()
101+
.unwrap()
97102
.get("filter_id")
98103
.and_then(|filter_id| filter_id.as_str());
99-
let stream_name = meta
104+
let stream_name = filter_value
105+
.as_object()
106+
.unwrap()
100107
.get("stream_name")
101108
.and_then(|stream_name| stream_name.as_str());
102109
if let (Some(user_id), Some(stream_name), Some(filter_id)) =

0 commit comments

Comments
 (0)