feat: tag webWorker

zextras · Mar 28, 2022 · a4a7944 · a4a7944
1 parent 293586b
commit a4a7944
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 8 deletions.
diff --git a/src/store/network/utils.ts b/src/store/network/utils.ts
@@ -21,17 +21,17 @@ export const handleSync = ({ refresh, notify }: SoapContext): Promise<void> =>
 		const { seq } = useNetworkStore.getState();
 		if (refresh) {
 			tagWorker.postMessage({
-				type: 'refresh',
+				op: 'refresh',
 				tags: refresh.tags?.tag ?? []
 			});
 		}
 		if (notify?.length) {
 			forEach(notify, (item) => {
 				if (item.seq > seq) {
 					tagWorker.postMessage({
-						type: 'notify',
+						op: 'notify',
 						notify: item,
-						state: useTagStore.getState()
+						state: useTagStore.getState().tags
 					});
 				}
 			});

diff --git a/src/store/tags/store.ts b/src/store/tags/store.ts
@@ -12,4 +12,6 @@ export const useTagStore = create<TagState>(() => ({
 	tags: {}
 })) as UseBoundStore<TagState, StoreApi<TagState>>;
 
-tagWorker.onmessage = ({ data }): void => useTagStore.setState(data);
+tagWorker.onmessage = ({ data }): void => {
+	useTagStore.setState(data);
+};
diff --git a/src/workers/tag.ts b/src/workers/tag.ts
@@ -34,17 +34,16 @@ export const handleTagDeleted = (tags: Tags, deleted: string[]): Tags =>
 		delete acc[val];
 		return acc;
 	}, tags);
-export const handleTagNotify = (notify: SoapNotify, state: Tags): void => {
+export const handleTagNotify = (notify: SoapNotify, state: Tags): Tags =>
 	handleTagDeleted(
 		handleTagModified(
 			handleTagCreated(state, notify.created?.tag ?? []),
 			notify.modified?.tag ?? []
 		),
 		notify.deleted ?? []
 	);
-};
 
 self.onmessage = ({ data }: TagMessage): void => {
-	if (data.op === 'refresh' && data.tags) self.postMessage(handleTagRefresh(data.tags));
-	if (data.op === 'notify') self.postMessage(handleTagNotify(data.notify, data.state));
+	if (data.op === 'refresh' && data.tags) self.postMessage({ tags: handleTagRefresh(data.tags) });
+	if (data.op === 'notify') self.postMessage({ tags: handleTagNotify(data.notify, data.state) });
 };