From 6d37868ae83a63616fc1e744d8a383e830703ddb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Fri, 15 Nov 2024 13:57:45 +0800 Subject: [PATCH] refactor: nnetwork -> network --- src/onebot/nnetwork/httpClientAdapter.ts | 0 src/onebot/nnetwork/httpServerAdapter.ts | 0 src/onebot/nnetwork/index.ts | 52 ------------------------ src/onebot/nnetwork/wsClientAdapter.ts | 0 src/onebot/nnetwork/wsServerAdapter.ts | 0 5 files changed, 52 deletions(-) delete mode 100644 src/onebot/nnetwork/httpClientAdapter.ts delete mode 100644 src/onebot/nnetwork/httpServerAdapter.ts delete mode 100644 src/onebot/nnetwork/index.ts delete mode 100644 src/onebot/nnetwork/wsClientAdapter.ts delete mode 100644 src/onebot/nnetwork/wsServerAdapter.ts diff --git a/src/onebot/nnetwork/httpClientAdapter.ts b/src/onebot/nnetwork/httpClientAdapter.ts deleted file mode 100644 index e69de29b..00000000 diff --git a/src/onebot/nnetwork/httpServerAdapter.ts b/src/onebot/nnetwork/httpServerAdapter.ts deleted file mode 100644 index e69de29b..00000000 diff --git a/src/onebot/nnetwork/index.ts b/src/onebot/nnetwork/index.ts deleted file mode 100644 index 4a2a597d..00000000 --- a/src/onebot/nnetwork/index.ts +++ /dev/null @@ -1,52 +0,0 @@ -import { OB11BaseEvent } from '@/onebot/event/OB11BaseEvent'; -import { OB11Message } from '@/onebot'; - -export type OB11EmitEventContent = OB11BaseEvent | OB11Message; - -export interface IOB11NetworkAdapter { - - onEvent(event: T): void; - - open(): void | Promise; - - close(): void | Promise; - -} -export class OneBotNetworkManager { - adapters: IOB11NetworkAdapter[] = []; - - async openAllAdapters() { - return Promise.all(this.adapters.map(adapter => adapter.open())); - } - - async emitEvent(event: OB11EmitEventContent) { - //console.log('adapters', this.adapters.length); - return Promise.all(this.adapters.map(adapter => adapter.onEvent(event))); - } - - registerAdapter(adapter: IOB11NetworkAdapter) { - this.adapters.push(adapter); - } - - async registerAdapterAndOpen(adapter: IOB11NetworkAdapter) { - this.registerAdapter(adapter); - await adapter.open(); - } - - async closeSomeAdapters(adaptersToClose: IOB11NetworkAdapter[]) { - this.adapters = this.adapters.filter(adapter => !adaptersToClose.includes(adapter)); - await Promise.all(adaptersToClose.map(adapter => adapter.close())); - } - - /** - * Close all adapters that satisfy the predicate. - */ - async closeAdapterByPredicate(closeFilter: (adapter: IOB11NetworkAdapter) => boolean) { - await this.closeSomeAdapters(this.adapters.filter(closeFilter)); - } - - async closeAllAdapters() { - await Promise.all(this.adapters.map(adapter => adapter.close())); - this.adapters = []; - } -} \ No newline at end of file diff --git a/src/onebot/nnetwork/wsClientAdapter.ts b/src/onebot/nnetwork/wsClientAdapter.ts deleted file mode 100644 index e69de29b..00000000 diff --git a/src/onebot/nnetwork/wsServerAdapter.ts b/src/onebot/nnetwork/wsServerAdapter.ts deleted file mode 100644 index e69de29b..00000000