|
1 | | -import { PollingMode } from 'generated-sources'; |
2 | 1 | import { MessagesFilterKeysTypes } from 'lib/types'; |
3 | 2 | import { MessagesFilterKeys } from 'lib/constants'; |
4 | 3 | import { useLocalStorage } from 'lib/hooks/useLocalStorage'; |
@@ -47,108 +46,42 @@ export function useMessagesFiltersFields(topicName: string) { |
47 | 46 |
|
48 | 47 | const initMessagesFiltersFields = (params: URLSearchParams) => { |
49 | 48 | const topicMessagesFilters = messageFilters[topicName]; |
50 | | - if (params.size === 0 && !!topicMessagesFilters) { |
51 | | - if (topicMessagesFilters.mode) { |
52 | | - params.set(MessagesFilterKeys.mode, topicMessagesFilters.mode); |
53 | | - if ( |
54 | | - topicMessagesFilters.mode === PollingMode.FROM_OFFSET || |
55 | | - topicMessagesFilters.mode === PollingMode.TO_OFFSET |
56 | | - ) { |
57 | | - if (topicMessagesFilters.offset) { |
58 | | - params.set(MessagesFilterKeys.offset, topicMessagesFilters.offset); |
59 | | - } |
60 | | - } |
61 | 49 |
|
62 | | - if ( |
63 | | - topicMessagesFilters.mode === PollingMode.FROM_TIMESTAMP || |
64 | | - topicMessagesFilters.mode === PollingMode.TO_TIMESTAMP |
65 | | - ) { |
66 | | - if (topicMessagesFilters.timestamp) { |
67 | | - params.set( |
68 | | - MessagesFilterKeys.timestamp, |
69 | | - topicMessagesFilters.timestamp |
70 | | - ); |
71 | | - } |
72 | | - } |
73 | | - } |
74 | | - if (topicMessagesFilters.partitions) { |
75 | | - params.set( |
76 | | - MessagesFilterKeys.partitions, |
77 | | - topicMessagesFilters.partitions |
78 | | - ); |
79 | | - } |
80 | | - if (topicMessagesFilters.keySerde) { |
81 | | - params.set(MessagesFilterKeys.keySerde, topicMessagesFilters.keySerde); |
82 | | - } |
83 | | - if (topicMessagesFilters.valueSerde) { |
84 | | - params.set( |
85 | | - MessagesFilterKeys.valueSerde, |
86 | | - topicMessagesFilters.valueSerde |
87 | | - ); |
88 | | - } |
89 | | - if (topicMessagesFilters.stringFilter) { |
90 | | - params.set( |
91 | | - MessagesFilterKeys.stringFilter, |
92 | | - topicMessagesFilters.stringFilter |
93 | | - ); |
94 | | - } |
95 | | - } else { |
96 | | - const MessagesFiltersMode = params.get(MessagesFilterKeys.mode); |
97 | | - if (MessagesFiltersMode) { |
98 | | - removeMessagesFilterFields(); |
99 | | - setMessagesFiltersField(MessagesFilterKeys.mode, MessagesFiltersMode); |
100 | | - const MessagesFiltersOffset = params.get(MessagesFilterKeys.offset); |
101 | | - if (MessagesFiltersOffset) { |
102 | | - setMessagesFiltersField( |
103 | | - MessagesFilterKeys.offset, |
104 | | - MessagesFiltersOffset |
105 | | - ); |
106 | | - } |
107 | | - const MessagesFiltersTimestamp = params.get( |
108 | | - MessagesFilterKeys.timestamp |
109 | | - ); |
110 | | - if (MessagesFiltersTimestamp) { |
111 | | - setMessagesFiltersField( |
112 | | - MessagesFilterKeys.timestamp, |
113 | | - MessagesFiltersTimestamp |
114 | | - ); |
115 | | - } |
| 50 | + const setTopicMessageFiltersFromLocalStorage = ( |
| 51 | + key: keyof MessagesFilterFieldsType |
| 52 | + ) => { |
| 53 | + if (topicMessagesFilters[key]) { |
| 54 | + params.set(MessagesFilterKeys[key], topicMessagesFilters[key]); |
116 | 55 | } |
| 56 | + }; |
117 | 57 |
|
118 | | - const MessageFiltersPartitions = params.get( |
119 | | - MessagesFilterKeys.partitions |
120 | | - ); |
121 | | - if (MessageFiltersPartitions) { |
122 | | - setMessagesFiltersField( |
123 | | - MessagesFilterKeys.partitions, |
124 | | - MessageFiltersPartitions |
125 | | - ); |
126 | | - } |
127 | | - const MessagesFiltersKeySerde = params.get(MessagesFilterKeys.keySerde); |
128 | | - if (MessagesFiltersKeySerde) { |
129 | | - setMessagesFiltersField( |
130 | | - MessagesFilterKeys.keySerde, |
131 | | - MessagesFiltersKeySerde |
132 | | - ); |
133 | | - } |
134 | | - const MessagesFiltersValueSerde = params.get( |
135 | | - MessagesFilterKeys.valueSerde |
136 | | - ); |
137 | | - if (MessagesFiltersValueSerde) { |
138 | | - setMessagesFiltersField( |
139 | | - MessagesFilterKeys.valueSerde, |
140 | | - MessagesFiltersValueSerde |
141 | | - ); |
142 | | - } |
143 | | - const MessagesFiltersStringFilter = params.get( |
144 | | - MessagesFilterKeys.stringFilter |
145 | | - ); |
146 | | - if (MessagesFiltersStringFilter) { |
147 | | - setMessagesFiltersField( |
148 | | - MessagesFilterKeys.stringFilter, |
149 | | - MessagesFiltersStringFilter |
150 | | - ); |
| 58 | + const setTopicMessageFiltersFromUrlParams = ( |
| 59 | + key: keyof MessagesFilterFieldsType |
| 60 | + ) => { |
| 61 | + const filters = params.get(MessagesFilterKeys[key]); |
| 62 | + if (filters) { |
| 63 | + setMessagesFiltersField(key, filters); |
151 | 64 | } |
| 65 | + }; |
| 66 | + |
| 67 | + // if url params are empty and topicMessagesFilters from local storage are existing then we apply them |
| 68 | + if (params.size === 0 && !!topicMessagesFilters) { |
| 69 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.mode); |
| 70 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.offset); |
| 71 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.timestamp); |
| 72 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.partitions); |
| 73 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.keySerde); |
| 74 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.valueSerde); |
| 75 | + setTopicMessageFiltersFromLocalStorage(MessagesFilterKeys.stringFilter); |
| 76 | + } else { |
| 77 | + removeMessagesFilterFields(); |
| 78 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.mode); |
| 79 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.offset); |
| 80 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.timestamp); |
| 81 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.partitions); |
| 82 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.keySerde); |
| 83 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.valueSerde); |
| 84 | + setTopicMessageFiltersFromUrlParams(MessagesFilterKeys.stringFilter); |
152 | 85 | } |
153 | 86 | }; |
154 | 87 |
|
|
0 commit comments