ye

Author: Axp3cter

src/index.d.ts

@@ -186,11 +186,11 @@ export interface Namespace {
     ): Connection;
     onSend(
         this: Namespace,
-        handler: (data: unknown, name: string, player: Player | undefined) => unknown | undefined,
+        handler: (data: unknown, name: string, player: Player | undefined) => unknown | DropSentinel | undefined,
     ): () => void;
     onReceive(
         this: Namespace,
-        handler: (data: unknown, name: string, player: Player | undefined) => unknown | undefined,
+        handler: (data: unknown, name: string, player: Player | undefined) => unknown | DropSentinel | undefined,
     ): () => void;
     disconnectAll(this: Namespace): void;
     destroy(this: Namespace): void;

test/codec/Map.test.luau

@@ -61,6 +61,47 @@ describe("deltaMap", function(): ()
         c.write(ch, { a = 1, b = 2 })
         expect(ch.cursor):toBeLessThan(w1)
     end)
+    it("numeric keys full round-trip", function(): ()
+        Baseline.setReadKey(false)
+        local c = Lync.deltaMap(Lync.u16, Lync.string)
+        local r = roundTrip(c, { [1] = "one", [2] = "two", [300] = "three hundred" })
+        expect(r[1]):toBe("one")
+        expect(r[2]):toBe("two")
+        expect(r[300]):toBe("three hundred")
+    end)
+    it("numeric keys unchanged is smaller", function(): ()
+        Baseline.setReadKey(false)
+        local c = Lync.deltaMap(Lync.u16, Lync.string)
+        local ch = Channel.create()
+        c.write(ch, { [1] = "one", [2] = "two" })
+        local fullSize = ch.cursor
+        ch.cursor = 0
+        c.write(ch, { [1] = "one", [2] = "two" })
+        expect(ch.cursor):toBeLessThan(fullSize)
+    end)
+    it("numeric keys upsert and remove", function(): ()
+        Baseline.setReadKey(false)
+        local c = Lync.deltaMap(Lync.u16, Lync.u8)
+        local ch = Channel.create()
+
+        -- First write: full frame
+        c.write(ch, { [10] = 100, [20] = 200 })
+        local buf1 = buffer.create(ch.cursor)
+        buffer.copy(buf1, 0, ch.buff, 0, ch.cursor)
+        local r1 = c.read(buf1, 0, nil)
+        expect(r1[10]):toBe(100)
+        expect(r1[20]):toBe(200)
+
+        -- Second write: remove key 20, add key 30, change key 10
+        ch.cursor = 0
+        c.write(ch, { [10] = 50, [30] = 150 })
+        local buf2 = buffer.create(ch.cursor)
+        buffer.copy(buf2, 0, ch.buff, 0, ch.cursor)
+        local r2 = c.read(buf2, 0, nil)
+        expect(r2[10]):toBe(50)
+        expect(r2[30]):toBe(150)
+        expect(r2[20]):toBe(nil)
+    end)
 end)
 
 return nil