test(dispatcher): some more tests

packages/dispatcher/src/callback-data-builder.test.ts

@@ -0,0 +1,101 @@
+import { describe, expect, it } from 'vitest'
+
+import { CallbackQuery, MtArgumentError, PeersIndex } from '@mtcute/client'
+import { utf8EncodeToBuffer } from '@mtcute/client/utils.js'
+import { createStub } from '@mtcute/test'
+
+import { CallbackDataBuilder } from './callback-data-builder.js'
+import { UpdateFilter } from './filters/index.js'
+
+describe('CallbackDataBuilder', () => {
+    it('should correctly build data', () => {
+        const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+        expect(cdb.build({ foo: 'foo', bar: 'bar' })).toEqual('prefix:foo:bar')
+    })
+
+    it('should correctly throw on invalid data when building', () => {
+        const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+        expect(() => cdb.build({ foo: 'foo:1', bar: 'bar' })).toThrow(MtArgumentError)
+    })
+
+    it('should correctly throw on too long data when building', () => {
+        const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+        expect(() =>
+            cdb.build({
+                foo: 'foooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooooo',
+                bar: 'bar',
+            }),
+        ).toThrow(MtArgumentError)
+    })
+
+    it('should correctly parse data', () => {
+        const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+        expect(cdb.parse('prefix:foo:bar')).toEqual({ foo: 'foo', bar: 'bar' })
+    })
+
+    it('should throw on invalid prefix when parsing', () => {
+        const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+        expect(() => cdb.parse('123:foo:bar')).toThrow(MtArgumentError)
+    })
+
+    it('should throw on invalid parts count when parsing', () => {
+        const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+        expect(() => cdb.parse('prefix:foo:bar:baz')).toThrow(MtArgumentError)
+    })
+
+    describe('filter', () => {
+        const createCb = (data: string) =>
+            new CallbackQuery(
+                createStub('updateBotCallbackQuery', {
+                    data: utf8EncodeToBuffer(data),
+                }),
+                new PeersIndex(),
+            )
+
+        const getFilterMatch = (filter: UpdateFilter<CallbackQuery>, data: string) => {
+            const cb = createCb(data)
+
+            const matched = filter(cb)
+            if (!matched) return null
+
+            // eslint-disable-next-line
+            return (cb as any).match
+        }
+
+        it('should create a filter without params', () => {
+            const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+            expect(getFilterMatch(cdb.filter(), 'prefix:foo:bar')).toEqual({
+                foo: 'foo',
+                bar: 'bar',
+            })
+            expect(getFilterMatch(cdb.filter(), 'prefix:foo:bar:baz')).toEqual(null)
+        })
+
+        it('should create a filter with params', () => {
+            const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+            expect(getFilterMatch(cdb.filter({ foo: 'foo' }), 'prefix:foo:bar')).toEqual({
+                foo: 'foo',
+                bar: 'bar',
+            })
+            expect(getFilterMatch(cdb.filter({ foo: 'foo' }), 'prefix:bar:bar')).toEqual(null)
+        })
+
+        it('should create a filter with regex params', () => {
+            const cdb = new CallbackDataBuilder('prefix', 'foo', 'bar')
+
+            expect(getFilterMatch(cdb.filter({ foo: /\d+/ }), 'prefix:123:bar')).toEqual({
+                foo: '123',
+                bar: 'bar',
+            })
+            expect(getFilterMatch(cdb.filter({ foo: /\d+/ }), 'prefix:bar:bar')).toEqual(null)
+        })
+    })
+})

packages/dispatcher/src/callback-data-builder.ts

@@ -73,6 +73,8 @@ export class CallbackDataBuilder<T extends string> {
 
         const ret = {} as Record<T, string>
         parts.forEach((it, idx) => {
+            if (idx === 0) return // skip prefix
+
             ret[this._fields[idx - 1]] = it
         })