xfox111/TabsAsideExtension
1
0
Fork 0
mirror of https://github.com/XFox111/TabsAsideExtension.git synced 2026-04-22 07:58:01 +03:00
Code Wiki Activity

chore: messenger refactoring

Browse Source
This commit is contained in:
Eugene Fox
2025-05-07 00:04:19 +03:00
parent 8b77159abe
commit aa2ee02c79
1 changed files with 24 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
utils/messaging.ts
+13 -6
View File
@@ -1,6 +1,6 @@
import { trackError } from "@/features/analytics"; import { trackError } from "@/features/analytics";
import { GraphicsStorage } from "@/models/CollectionModels"; import { GraphicsStorage } from "@/models/CollectionModels";
import { defineExtensionMessaging, ExtensionMessenger } from "@webext-core/messaging"; import { defineExtensionMessaging, ExtensionMessagingConfig, ExtensionMessenger } from "@webext-core/messaging";
type ProtocolMap = type ProtocolMap =
{ {
@@ -9,15 +9,18 @@ type ProtocolMap =
refreshCollections(): void; refreshCollections(): void;
}; };
const protocol: ExtensionMessenger<ProtocolMap> = defineExtensionMessaging<ProtocolMap>(); function defineMessaging(config?: ExtensionMessagingConfig): ExtensionMessenger<ProtocolMap>
{
const { onMessage, sendMessage, removeAllListeners } = defineExtensionMessaging<ProtocolMap>(config);
export const onMessage = protocol.onMessage; return {
onMessage,
export const sendMessage: ExtensionMessenger<ProtocolMap>["sendMessage"] = async (...args) => removeAllListeners,
sendMessage: async (type, data, args): Promise<any> =>
{ {
try try
{ {
return await protocol.sendMessage(...args); return await sendMessage(type, data, args);
} }
catch (ex) catch (ex)
{ {
@@ -25,4 +28,8 @@ export const sendMessage: ExtensionMessenger<ProtocolMap>["sendMessage"] = async
trackError("messaging_error", ex as Error); trackError("messaging_error", ex as Error);
return undefined!; return undefined!;
} }
}
}; };
}
export const { onMessage, sendMessage } = defineMessaging({ logger: console });