feat: Implement UnstorageDb for match storage and retrieval

- Added UnstorageDb class for managing game state, metadata, and logs using Unstorage.
- Created unit tests for UnstorageDb to validate match creation, fetching, and filtering.
- Introduced BroadcastChannelPubSub for pub/sub messaging using BroadcastChannel API.
- Implemented InMemoryPubSub for local pub/sub functionality.
- Integrated SocketIO transport layer for real-time communication in the game server.
- Updated transport and socket handling to support new pub/sub mechanisms.
- Removed deprecated pubsub implementation and added tests for new pub/sub classes.
- Updated deno.json to include new dependencies for socket.io and rfc6902.

Author: mblonyox

deno.json

@@ -21,5 +21,6 @@
       "./dist"
     ],
     "entrypoint": "dist/server.js"
-  }
+  },
+  "unstable": ["broadcast-channel", "kv"]
 }

deno.lock

@@ -1,4 +1,5 @@
-import { UnstorageDb } from "./db.ts";
+// deno-lint-ignore-file no-explicit-any
+import { UnstorageDb } from "./unstorage-db.ts";
 import type { LogEntry, Server, State } from "boardgame.io";
 import {
   afterEach,
@@ -10,7 +11,7 @@ import {
 import { expect } from "jsr:@std/expect";
 import { createStorage } from "unstorage";
 
-describe("FlatFile", () => {
+describe("UnstorageDb", () => {
   let db: UnstorageDb;
 
   beforeAll(async () => {

server/bgio/db.test.ts server/bgio/db/unstorage-db.test.tsserver/bgio/db.test.ts renamed to server/bgio/db/unstorage-db.test.ts

@@ -1,17 +1,20 @@
 import type { LogEntry, Server, State, StorageAPI } from "boardgame.io";
-import { Async } from "boardgame.io/internal";
-import { prefixStorage, type Storage } from "unstorage";
+import { createStorage, prefixStorage, type Storage } from "unstorage";
 
-export class UnstorageDb extends Async {
+export class UnstorageDb implements StorageAPI.Async {
   private store: Storage;
-  constructor(store: Storage) {
-    super();
+  constructor(store?: Storage) {
+    if (!store) store = createStorage();
     this.store = prefixStorage(store, "bgio");
   }
 
-  override async connect() {}
+  type(): StorageAPI.Type {
+    return 1;
+  }
+
+  async connect() {}
 
-  override async createMatch(
+  async createMatch(
     matchID: string,
     opts: StorageAPI.CreateMatchOpts,
   ): Promise<void> {
@@ -22,29 +25,29 @@ export class UnstorageDb extends Async {
     await this.setMetadata(matchID, opts.metadata);
   }
 
-  override async setState(
+  async setState(
     matchID: string,
     state: State,
     deltalog?: LogEntry[],
   ) {
     if (deltalog && deltalog.length > 0) {
       const key = LogKey(matchID);
-      const log: LogEntry[] = ((await this.store.getItem(key)) as LogEntry[]) ||
+      const log: LogEntry[] = (await this.store.getItem<LogEntry[]>(key)) ||
         [];
       await this.store.setItem(key, [...log, ...deltalog]);
     }
     return await this.store.setItem(matchID, state);
   }
 
-  override async setMetadata(
+  async setMetadata(
     matchID: string,
     metadata: Server.MatchData,
   ) {
     const key = MetadataKey(matchID);
     return await this.store.setItem(key, metadata);
   }
 
-  override async fetch<O extends StorageAPI.FetchOpts>(
+  async fetch<O extends StorageAPI.FetchOpts>(
     matchID: string,
     opts: O,
   ): Promise<StorageAPI.FetchResult<O>> {
@@ -76,17 +79,17 @@ export class UnstorageDb extends Async {
     return result as StorageAPI.FetchResult<O>;
   }
 
-  override async wipe(matchID: string) {
+  async wipe(matchID: string) {
     await this.store.removeItem(matchID);
     await this.store.removeItem(InitialStateKey(matchID));
     await this.store.removeItem(LogKey(matchID));
     await this.store.removeItem(MetadataKey(matchID));
   }
 
-  override async listMatches(
+  async listMatches(
     opts?: StorageAPI.ListMatchesOpts,
   ): Promise<string[]> {
-    const keys = await this.store.keys();
+    const keys = await this.store.getKeys();
     const suffix = ":metadata";
 
     const arr = await Promise.all(