commit 38d5d78202f2b0210c2b9028d07b5724048ac83e · gmstn.systems/prism

+24 -141

bun.lock

···

       6
       6
        
             "name": "prism",

     

       7
       7
        
             "dependencies": {

     

       8
       8
        
               "@atcute/repo": "^0.1.0",

     

       9
       9
       -
               "@atproto/xrpc-server": "^0.10.1",

     

       9
       9
       +
               "@atcute/xrpc-server": "^0.1.3",

     

       10
       10
       +
               "@atcute/xrpc-server-bun": "^0.1.1",

     

       10
       11
        
               "@skyware/firehose": "^0.5.2",

     

       11
       12
        
               "compression": "^1.8.1",

     

       12
       13
        
               "dotenv": "^17.2.3",

     
···

       38
       39
        
       

     

       39
       40
        
           "@atcute/crypto": ["@atcute/crypto@2.2.6", "", { "dependencies": { "@atcute/multibase": "^1.1.6", "@atcute/uint8array": "^1.0.5", "@noble/secp256k1": "^3.0.0" } }, "sha512-vkuexF+kmrKE1/Uqzub99Qi4QpnxA2jbu60E6PTgL4XypELQ6rb59MB/J1VbY2gs0kd3ET7+L3+NWpKD5nXyfA=="],

     

       40
       41
        
       

     

       42
       42
       +
           "@atcute/identity": ["@atcute/identity@1.1.3", "", { "dependencies": { "@atcute/lexicons": "^1.2.4", "@badrap/valita": "^0.4.6" } }, "sha512-oIqPoI8TwWeQxvcLmFEZLdN2XdWcaLVtlm8pNk0E72As9HNzzD9pwKPrLr3rmTLRIoULPPFmq9iFNsTeCIU9ng=="],

     

       43
       43
       +
       

     

       44
       44
       +
           "@atcute/identity-resolver": ["@atcute/identity-resolver@1.1.4", "", { "dependencies": { "@atcute/lexicons": "^1.2.2", "@atcute/util-fetch": "^1.0.3", "@badrap/valita": "^0.4.6" }, "peerDependencies": { "@atcute/identity": "^1.0.0" } }, "sha512-/SVh8vf2cXFJenmBnGeYF2aY3WGQm3cJeew5NWTlkqoy3LvJ5wkvKq9PWu4Tv653VF40rPOp6LOdVr9Fa+q5rA=="],

     

       45
       45
       +
       

     

       41
       46
        
           "@atcute/lexicons": ["@atcute/lexicons@1.2.2", "", { "dependencies": { "@standard-schema/spec": "^1.0.0", "esm-env": "^1.2.2" } }, "sha512-bgEhJq5Z70/0TbK5sx+tAkrR8FsCODNiL2gUEvS5PuJfPxmFmRYNWaMGehxSPaXWpU2+Oa9ckceHiYbrItDTkA=="],

     

       42
       47
        
       

     

       43
       48
        
           "@atcute/mst": ["@atcute/mst@0.1.0", "", { "dependencies": { "@atcute/cbor": "^2.2.7", "@atcute/cid": "^2.2.6", "@atcute/uint8array": "^1.0.5" } }, "sha512-h+iDToKEnBpigk2DOHjSqY63vJtjYKUIztqu1CZ0P+I54wV2SrgoqAXAT1xrW6A1Iup8cjTv+U2H5WVG4KxPLw=="],

     
···

       48
       53
        
       

     

       49
       54
        
           "@atcute/uint8array": ["@atcute/uint8array@1.0.5", "", {}, "sha512-XLWWxoR2HNl2qU+FCr0rp1APwJXci7HnzbOQLxK55OaMNBXZ19+xNC5ii4QCsThsDxa4JS/JTzuiQLziITWf2Q=="],

     

       50
       55
        
       

     

       51
       51
       -
           "@atcute/varint": ["@atcute/varint@1.0.3", "", {}, "sha512-fdvMPyBB+McDT+Ai5e9RwEbwYV4yjZ60S2Dn5PTjGqUyxvoCH1z42viuheDZRUDkmfQehXJTZ5az7dSozVNtog=="],

     

       52
       52
       -
       

     

       53
       53
       -
           "@atproto/common": ["@atproto/common@0.5.1", "", { "dependencies": { "@atproto/common-web": "^0.4.5", "@atproto/lex-cbor": "0.0.1", "@atproto/lex-data": "0.0.1", "iso-datestring-validator": "^2.2.2", "multiformats": "^9.9.0", "pino": "^8.21.0" } }, "sha512-0S57sjzw4r9OLc5srJFi6uAz/aTKYl6btz3x36tSnGriL716m6h0x2IVtgd+FhUfIQfisevrqcqw8SfaGk8VTw=="],

     

       54
       54
       -
       

     

       55
       55
       -
           "@atproto/common-web": ["@atproto/common-web@0.4.5", "", { "dependencies": { "@atproto/lex-data": "0.0.1", "@atproto/lex-json": "0.0.1", "zod": "^3.23.8" } }, "sha512-Tx0xUafLm3vRvOQpbBl5eb9V8xlC7TaRXs6dAulHRkDG3Kb+P9qn3pkDteq+aeMshbVXbVa1rm3Ok4vFyuoyYA=="],

     

       56
       56
       -
       

     

       57
       57
       -
           "@atproto/crypto": ["@atproto/crypto@0.4.4", "", { "dependencies": { "@noble/curves": "^1.7.0", "@noble/hashes": "^1.6.1", "uint8arrays": "3.0.0" } }, "sha512-Yq9+crJ7WQl7sxStVpHgie5Z51R05etaK9DLWYG/7bR5T4bhdcIgF6IfklLShtZwLYdVVj+K15s0BqW9a8PSDA=="],

     

       58
       58
       -
       

     

       59
       59
       -
           "@atproto/lex-cbor": ["@atproto/lex-cbor@0.0.1", "", { "dependencies": { "@atproto/lex-data": "0.0.1", "multiformats": "^9.9.0", "tslib": "^2.8.1" } }, "sha512-GCgowcC041tYmsoIxalIECJq4ZRHgREk6lFa4BzNRUZarMqwz57YF/7eUlo2Q6hoaMUL7Bjr6FvXwcZFaKrhvA=="],

     

       60
       60
       -
       

     

       61
       61
       -
           "@atproto/lex-data": ["@atproto/lex-data@0.0.1", "", { "dependencies": { "@atproto/syntax": "0.4.1", "multiformats": "^9.9.0", "tslib": "^2.8.1", "uint8arrays": "3.0.0", "unicode-segmenter": "^0.14.0" } }, "sha512-DrS/8cQcQs3s5t9ELAFNtyDZ8/PdiCx47ALtFEP2GnX2uCBHZRkqWG7xmu6ehjc787nsFzZBvlnz3T/gov5fGA=="],

     

       62
       62
       -
       

     

       63
       63
       -
           "@atproto/lex-json": ["@atproto/lex-json@0.0.1", "", { "dependencies": { "@atproto/lex-data": "0.0.1", "tslib": "^2.8.1" } }, "sha512-ivcF7+pDRuD/P97IEKQ/9TruunXj0w58Khvwk3M6psaI5eZT6LRsRZ4cWcKaXiFX4SHnjy+x43g0f7pPtIsERg=="],

     

       64
       64
       -
       

     

       65
       65
       -
           "@atproto/lexicon": ["@atproto/lexicon@0.5.2", "", { "dependencies": { "@atproto/common-web": "^0.4.4", "@atproto/syntax": "^0.4.1", "iso-datestring-validator": "^2.2.2", "multiformats": "^9.9.0", "zod": "^3.23.8" } }, "sha512-lRmJgMA8f5j7VB5Iu5cp188ald5FuI4FlmZ7nn6EBrk1dgOstWVrI5Ft6K3z2vjyLZRG6nzknlsw+tDP63p7bQ=="],

     

       56
       56
       +
           "@atcute/util-fetch": ["@atcute/util-fetch@1.0.4", "", { "dependencies": { "@badrap/valita": "^0.4.6" } }, "sha512-sIU9Qk0dE8PLEXSfhy+gIJV+HpiiknMytCI2SqLlqd0vgZUtEKI/EQfP+23LHWvP+CLCzVDOa6cpH045OlmNBg=="],

     

       66
       57
        
       

     

       67
       67
       -
           "@atproto/syntax": ["@atproto/syntax@0.4.1", "", {}, "sha512-CJdImtLAiFO+0z3BWTtxwk6aY5w4t8orHTMVJgkf++QRJWTxPbIFko/0hrkADB7n2EruDxDSeAgfUGehpH6ngw=="],

     

       58
       58
       +
           "@atcute/varint": ["@atcute/varint@1.0.3", "", {}, "sha512-fdvMPyBB+McDT+Ai5e9RwEbwYV4yjZ60S2Dn5PTjGqUyxvoCH1z42viuheDZRUDkmfQehXJTZ5az7dSozVNtog=="],

     

       68
       59
        
       

     

       69
       69
       -
           "@atproto/ws-client": ["@atproto/ws-client@0.0.3", "", { "dependencies": { "@atproto/common": "^0.5.0", "ws": "^8.12.0" } }, "sha512-eKqkTWBk6zuMY+6gs02eT7mS8Btewm8/qaL/Dp00NDCqpNC+U59MWvQsOWT3xkNGfd9Eip+V6VI4oyPvAfsfTA=="],

     

       60
       60
       +
           "@atcute/xrpc-server": ["@atcute/xrpc-server@0.1.3", "", { "dependencies": { "@atcute/cbor": "^2.2.7", "@atcute/crypto": "^2.2.5", "@atcute/identity": "^1.1.1", "@atcute/identity-resolver": "^1.1.4", "@atcute/lexicons": "^1.2.2", "@atcute/multibase": "^1.1.6", "@atcute/uint8array": "^1.0.5", "@badrap/valita": "^0.4.6", "nanoid": "^5.1.5" } }, "sha512-AMig6MuAL5VfXRZVsQqQXKCXnZgpjTc6UM6RggvyE1qVT8y9tZPFXdP5tt/p6Jf+h4cAw+XMu2uyrGpUmnTSyQ=="],

     

       70
       61
        
       

     

       71
       71
       -
           "@atproto/xrpc": ["@atproto/xrpc@0.7.6", "", { "dependencies": { "@atproto/lexicon": "^0.5.2", "zod": "^3.23.8" } }, "sha512-RvCf4j0JnKYWuz3QzsYCntJi3VuiAAybQsMIUw2wLWcHhchO9F7UaBZINLL2z0qc/cYWPv5NSwcVydMseoCZLA=="],

     

       62
       62
       +
           "@atcute/xrpc-server-bun": ["@atcute/xrpc-server-bun@0.1.1", "", { "peerDependencies": { "@atcute/xrpc-server": "^0.1.3" } }, "sha512-fAn93prgn+yldeSeaGEaU37irPCvIFWSc1Dm6D7ip5KiaINWhkdEkln+IuRCklo3slC4hcjHIgZnIigHy/p8HA=="],

     

       72
       63
        
       

     

       73
       73
       -
           "@atproto/xrpc-server": ["@atproto/xrpc-server@0.10.1", "", { "dependencies": { "@atproto/common": "^0.5.1", "@atproto/crypto": "^0.4.4", "@atproto/lex-cbor": "0.0.1", "@atproto/lex-data": "0.0.1", "@atproto/lexicon": "^0.5.2", "@atproto/ws-client": "^0.0.3", "@atproto/xrpc": "^0.7.6", "express": "^4.17.2", "http-errors": "^2.0.0", "mime-types": "^2.1.35", "rate-limiter-flexible": "^2.4.1", "ws": "^8.12.0", "zod": "^3.23.8" } }, "sha512-kHXykL4inBV/49vefn5zR5zv/VM1//+BIRqk9OvB3+mbERw0jkFiHhc6PWyY/81VD4ciu7FZwUCpRy/mtQtIaA=="],

     

       74
       74
       -
       

     

       75
       75
       -
           "@noble/curves": ["@noble/curves@1.9.7", "", { "dependencies": { "@noble/hashes": "1.8.0" } }, "sha512-gbKGcRUYIjA3/zCCNaWDciTMFI0dCkvou3TL8Zmy5Nc7sJ47a0jtOeZoTaMxkuqRo9cRhjOdZJXegxYE5FN/xw=="],

     

       76
       76
       -
       

     

       77
       77
       -
           "@noble/hashes": ["@noble/hashes@1.8.0", "", {}, "sha512-jCs9ldd7NwzpgXDIf6P3+NrHh9/sD6CQdxHyjQI+h/6rDNo88ypBxxz45UDuZHz9r3tNz7N/VInSVoVdtXEI4A=="],

     

       64
       64
       +
           "@badrap/valita": ["@badrap/valita@0.4.6", "", {}, "sha512-4kdqcjyxo/8RQ8ayjms47HCWZIF5981oE5nIenbfThKDxWXtEHKipAOWlflpPJzZx9y/JWYQkp18Awr7VuepFg=="],

     

       78
       65
        
       

     

       79
       66
        
           "@noble/secp256k1": ["@noble/secp256k1@3.0.0", "", {}, "sha512-NJBaR352KyIvj3t6sgT/+7xrNyF9Xk9QlLSIqUGVUYlsnDTAUqY8LOmwpcgEx4AMJXRITQ5XEVHD+mMaPfr3mg=="],

     

       80
       67
        
       

     
···

       113
       100
        
           "@types/serve-static": ["@types/serve-static@1.15.10", "", { "dependencies": { "@types/http-errors": "*", "@types/node": "*", "@types/send": "<1" } }, "sha512-tRs1dB+g8Itk72rlSI2ZrW6vZg0YrLI81iQSTkMmOqnqCaNr/8Ek4VwWcN5vZgCYWbg/JJSGBlUaYGAOP73qBw=="],

     

       114
       101
        
       

     

       115
       102
        
           "@types/ws": ["@types/ws@8.18.1", "", { "dependencies": { "@types/node": "*" } }, "sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg=="],

     

       116
       116
       -
       

     

       117
       117
       -
           "abort-controller": ["abort-controller@3.0.0", "", { "dependencies": { "event-target-shim": "^5.0.0" } }, "sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg=="],

     

       118
       103
        
       

     

       119
       104
        
           "accepts": ["accepts@2.0.0", "", { "dependencies": { "mime-types": "^3.0.0", "negotiator": "^1.0.0" } }, "sha512-5cvg6CtKwfgdmVqY1WIiXKc3Q1bkRqGLi+2W/6ao+6Y7gu/RCwRuAhGEzh5B4KlszSuTLgZYuqFqo5bImjNKng=="],

     

       120
       105
        
       

     
···

       128
       113
        
       

     

       129
       114
        
           "any-promise": ["any-promise@1.3.0", "", {}, "sha512-7UvmKalWRt1wgjL1RrGxoSJW/0QZFIegpeGvZG9kjp8vrRu55XTHbwnqq2GpXm9uLbcuhxm3IqX9OB4MZR1b2A=="],

     

       130
       115
        
       

     

       131
       131
       -
           "array-flatten": ["array-flatten@1.1.1", "", {}, "sha512-PCVAQswWemu6UdxsDFFX/+gVeYqKAod3D3UVm91jHwynguOwAvYPhx8nNlM++NqRcK6CxxpUafjmhIdKiHibqg=="],

     

       132
       132
       -
       

     

       133
       116
        
           "asn1": ["asn1@0.2.6", "", { "dependencies": { "safer-buffer": "~2.1.0" } }, "sha512-ix/FxPn0MDjeyJ7i/yoHGFt/EX6LyNbxSEhPPXODPL+KB0VPk86UYfL0lMdy+KCnv+fmvIzySwaK5COwqVbWTQ=="],

     

       134
       117
        
       

     

       135
       118
        
           "assert-plus": ["assert-plus@1.0.0", "", {}, "sha512-NfJ4UzBCcQGLDlQq7nHxH+tv3kyZ0hHQqF5BO6J7tNJeP5do1llPr8dZ8zHonfhAu0PHAdMkSo+8o0wxg9lZWw=="],

     
···

       144
       127
        
       

     

       145
       128
        
           "balanced-match": ["balanced-match@1.0.2", "", {}, "sha512-3oSeUO0TMV67hN1AmbXsK4yaqU7tjiHlbxRDZOpH0KW9+CeX4bRAaX0Anxt0tx2MrpRpWwQaPwIlISEJhYU5Pw=="],

     

       146
       129
        
       

     

       147
       147
       -
           "base64-js": ["base64-js@1.5.1", "", {}, "sha512-AKpaYlHn8t4SVbOHCy+b5+KKgvR4vrsD8vbvrbiQJps7fKDTkjkDry6ji0rUJjC0kzbNePLwzxq8iypo41qeWA=="],

     

       148
       148
       -
       

     

       149
       130
        
           "bcrypt-pbkdf": ["bcrypt-pbkdf@1.0.2", "", { "dependencies": { "tweetnacl": "^0.14.3" } }, "sha512-qeFIXtP4MSoi6NLqO12WfqARWWuCKi2Rn/9hJLEmtB5yTNr9DqFWkJRCf2qShWzPeAMRnOgCrq0sg/KLv5ES9w=="],

     

       150
       131
        
       

     

       151
       132
        
           "biome": ["biome@0.3.3", "", { "dependencies": { "bluebird": "^3.4.1", "chalk": "^1.1.3", "commander": "^2.9.0", "editor": "^1.0.0", "fs-promise": "^0.5.0", "inquirer-promise": "0.0.3", "request-promise": "^3.0.0", "untildify": "^3.0.2", "user-home": "^2.0.0" }, "bin": { "biome": "./dist/index.js" } }, "sha512-4LXjrQYbn9iTXu9Y4SKT7ABzTV0WnLDHCVSd2fPUOKsy1gQ+E4xPFmlY1zcWexoi0j7fGHItlL6OWA2CZ/yYAQ=="],

     
···

       156
       137
        
       

     

       157
       138
        
           "brace-expansion": ["brace-expansion@1.1.12", "", { "dependencies": { "balanced-match": "^1.0.0", "concat-map": "0.0.1" } }, "sha512-9T9UjW3r0UW5c1Q7GTwllptXwhvYmEzFhzMfZ9H7FQWt+uZePjZPjBP/W1ZEyZ1twGWom5/56TF4lPcqjnDHcg=="],

     

       158
       139
        
       

     

       159
       159
       -
           "buffer": ["buffer@6.0.3", "", { "dependencies": { "base64-js": "^1.3.1", "ieee754": "^1.2.1" } }, "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA=="],

     

       160
       160
       -
       

     

       161
       140
        
           "bun-types": ["bun-types@1.3.3", "", { "dependencies": { "@types/node": "*" } }, "sha512-z3Xwlg7j2l9JY27x5Qn3Wlyos8YAp0kKRlrePAOjgjMGS5IG6E7Jnlx736vH9UVI4wUICwwhC9anYL++XeOgTQ=="],

     

       162
       141
        
       

     

       163
       142
        
           "bytes": ["bytes@3.1.2", "", {}, "sha512-/Nf7TyzTx6S3yRJObOAV7956r8cr2+Oj8AC5dt8wSP3BQAoeX58NoHyCU8P8zGkNXStjTSi6fzO6F0pBdcYbEg=="],

     
···

       210
       189
        
       

     

       211
       190
        
           "depd": ["depd@2.0.0", "", {}, "sha512-g7nH6P6dyDioJogAAGprGpCtVImJhpPk/roCzdb3fIh61/s/nPsfR6onyMwkCAR/OlC3yBC0lESvUoQEAssIrw=="],

     

       212
       191
        
       

     

       213
       213
       -
           "destroy": ["destroy@1.2.0", "", {}, "sha512-2sJGJTaXIIaR1w4iJSNoN0hnMY7Gpc/n8D4qSCJw8QqFWXf7cuAgnEHxBpweaVcPevC2l3KpjYCx3NypQQgaJg=="],

     

       214
       214
       -
       

     

       215
       192
        
           "dotenv": ["dotenv@17.2.3", "", {}, "sha512-JVUnt+DUIzu87TABbhPmNfVdBDt18BLOWjMUFJMSi/Qqg7NTYtabbvSNJGOJ7afbRuv9D/lngizHtP7QyLQ+9w=="],

     

       216
       193
        
       

     

       217
       194
        
           "dunder-proto": ["dunder-proto@1.0.1", "", { "dependencies": { "call-bind-apply-helpers": "^1.0.1", "es-errors": "^1.3.0", "gopd": "^1.2.0" } }, "sha512-KIN/nDJBQRcXw0MLVhZE9iQHmG68qAVIBg9CqmUYjmQIhgij9U5MFvrqkUL5FbtyyzZuOeOt0zdeRe4UY7ct+A=="],

     
···

       242
       219
        
       

     

       243
       220
        
           "etag": ["etag@1.8.1", "", {}, "sha512-aIL5Fx7mawVa300al2BnEE4iNvo1qETxLrPI/o05L7z6go7fCw1J6EQmbK4FmJ2AS7kgVF/KEZWufBfdClMcPg=="],

     

       244
       221
        
       

     

       245
       245
       -
           "event-target-shim": ["event-target-shim@5.0.1", "", {}, "sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ=="],

     

       246
       246
       -
       

     

       247
       247
       -
           "events": ["events@3.3.0", "", {}, "sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q=="],

     

       248
       248
       -
       

     

       249
       222
        
           "exit-hook": ["exit-hook@1.1.1", "", {}, "sha512-MsG3prOVw1WtLXAZbM3KiYtooKR1LvxHh3VHsVtIy0uiUu8usxgB/94DP2HxtD/661lLdB6yzQ09lGJSQr6nkg=="],

     

       250
       223
        
       

     

       251
       224
        
           "express": ["express@5.1.0", "", { "dependencies": { "accepts": "^2.0.0", "body-parser": "^2.2.0", "content-disposition": "^1.0.0", "content-type": "^1.0.5", "cookie": "^0.7.1", "cookie-signature": "^1.2.1", "debug": "^4.4.0", "encodeurl": "^2.0.0", "escape-html": "^1.0.3", "etag": "^1.8.1", "finalhandler": "^2.1.0", "fresh": "^2.0.0", "http-errors": "^2.0.0", "merge-descriptors": "^2.0.0", "mime-types": "^3.0.0", "on-finished": "^2.4.1", "once": "^1.4.0", "parseurl": "^1.3.3", "proxy-addr": "^2.0.7", "qs": "^6.14.0", "range-parser": "^1.2.1", "router": "^2.2.0", "send": "^1.1.0", "serve-static": "^2.2.0", "statuses": "^2.0.1", "type-is": "^2.0.1", "vary": "^1.1.2" } }, "sha512-DT9ck5YIRU+8GYzzU5kT3eHGA5iL+1Zd0EutOmTE9Dtk+Tvuzd23VBU+ec7HPNSTxXYO55gPV/hq4pSBJDjFpA=="],

     
···

       259
       232
        
           "fast-deep-equal": ["fast-deep-equal@3.1.3", "", {}, "sha512-f3qQ9oQy9j2AhBe/H9VC91wLmKBCCU/gDOnKNAYG5hswO7BLKj09Hc5HYNz9cGI++xlpDCIgDaitVs03ATR84Q=="],

     

       260
       233
        
       

     

       261
       234
        
           "fast-json-stable-stringify": ["fast-json-stable-stringify@2.1.0", "", {}, "sha512-lhd/wF+Lk98HZoTCtlVraHtfh5XYijIjalXck7saUtuanSDyLMxnHhSXEDJqHxD7msR8D0uCmqlkwjCV8xvwHw=="],

     

       262
       262
       -
       

     

       263
       263
       -
           "fast-redact": ["fast-redact@3.5.0", "", {}, "sha512-dwsoQlS7h9hMeYUq1W++23NDcBLV4KqONnITDV9DjfS3q1SgDGVrBdvvTLUotWtPSD7asWDV9/CmsZPy8Hf70A=="],

     

       264
       235
        
       

     

       265
       236
        
           "fast-safe-stringify": ["fast-safe-stringify@2.1.1", "", {}, "sha512-W+KJc2dmILlPplD/H4K9l9LcAHAfPtP6BY84uVLXQ6Evcz9Lcg33Y2z1IVblT6xdY54PXYVHEv+0Wpq8Io6zkA=="],

     

       266
       237
        
       

     
···

       315
       286
        
           "http-signature": ["http-signature@1.2.0", "", { "dependencies": { "assert-plus": "^1.0.0", "jsprim": "^1.2.2", "sshpk": "^1.7.0" } }, "sha512-CAbnr6Rz4CYQkLYUtSNXxQPUH2gK8f3iWexVlsnMeD+GjlsQ0Xsy1cOX+mN3dtxYomRy21CiOzU8Uhw6OwncEQ=="],

     

       316
       287
        
       

     

       317
       288
        
           "iconv-lite": ["iconv-lite@0.6.3", "", { "dependencies": { "safer-buffer": ">= 2.1.2 < 3.0.0" } }, "sha512-4fCk79wshMdzMp2rH06qWrJE4iolqLhCUH+OiuIgU++RB0+94NlDL81atO7GX55uUKueo0txHNtvEyI6D7WdMw=="],

     

       318
       318
       -
       

     

       319
       319
       -
           "ieee754": ["ieee754@1.2.1", "", {}, "sha512-dcyqhDvX1C46lXZcVqCpK+FtMRQVdIMN6/Df5js2zouUsqG7I6sFxitIC+7KYK29KdXOLHdu9zL4sFnoVQnqaA=="],

     

       320
       289
        
       

     

       321
       290
        
           "inflight": ["inflight@1.0.6", "", { "dependencies": { "once": "^1.3.0", "wrappy": "1" } }, "sha512-k92I/b08q4wvFscXCLvqfsHCrjrF7yiXsQuIVvVE7N82W3+aqpzuUdBbfhWcy/FZR3/4IgflMgKLOsvPDrGCJA=="],

     

       322
       291
        
       

     
···

       334
       303
        
       

     

       335
       304
        
           "is-typedarray": ["is-typedarray@1.0.0", "", {}, "sha512-cyA56iCMHAh5CdzjJIa4aohJyeO1YbwLi3Jc35MmRU6poroFjIGZzUzupGiRPOjgHg9TLu43xbpwXk523fMxKA=="],

     

       336
       305
        
       

     

       337
       337
       -
           "iso-datestring-validator": ["iso-datestring-validator@2.2.2", "", {}, "sha512-yLEMkBbLZTlVQqOnQ4FiMujR6T4DEcCb1xizmvXS+OxuhwcbtynoosRzdMA69zZCShCNAbi+gJ71FxZBBXx1SA=="],

     

       338
       338
       -
       

     

       339
       306
        
           "isstream": ["isstream@0.1.2", "", {}, "sha512-Yljz7ffyPbrLpLngrMtZ7NduUgVvi6wG9RJ9IUcyCd59YQ911PBJphODUcbOVbqYfxe1wuYf/LJ8PauMRwsM/g=="],

     

       340
       307
        
       

     

       341
       308
        
           "joycon": ["joycon@3.1.1", "", {}, "sha512-34wB/Y7MW7bzjKRjUKTa46I2Z7eV62Rkhva+KkopW7Qvv/OSWBqvkSY7vusOPrNuZcUG3tApvdVgNB8POj3SPw=="],

     
···

       366
       333
        
       

     

       367
       334
        
           "merge-descriptors": ["merge-descriptors@2.0.0", "", {}, "sha512-Snk314V5ayFLhp3fkUREub6WtjBfPdCPY1Ln8/8munuLuiYhsABgBVWsozAG+MWMbVEvcdcpbi9R7ww22l9Q3g=="],

     

       368
       335
        
       

     

       369
       369
       -
           "methods": ["methods@1.1.2", "", {}, "sha512-iclAHeNqNm68zFtnZ0e+1L2yUIdvzNoauKU4WBA3VvH/vPFieF7qfRlwUZU+DA9P9bPXIS90ulxoUoCH23sV2w=="],

     

       370
       370
       -
       

     

       371
       371
       -
           "mime": ["mime@1.6.0", "", { "bin": { "mime": "cli.js" } }, "sha512-x0Vn8spI+wuJ1O6S7gnbaQg8Pxh4NNHb7KSINmEWKiPE4RKOplvijn+NkmYmmRgP68mc70j2EbeTFRsrswaQeg=="],

     

       372
       372
       -
       

     

       373
       373
       -
           "mime-db": ["mime-db@1.52.0", "", {}, "sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg=="],

     

       336
       336
       +
           "mime-db": ["mime-db@1.54.0", "", {}, "sha512-aU5EJuIN2WDemCcAp2vFBfp/m4EAhWJnUNSSw0ixs7/kXbd6Pg64EmwJkNdFhB8aWt1sH2CTXrLxo/iAGV3oPQ=="],

     

       374
       337
        
       

     

       375
       375
       -
           "mime-types": ["mime-types@2.1.35", "", { "dependencies": { "mime-db": "1.52.0" } }, "sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw=="],

     

       338
       338
       +
           "mime-types": ["mime-types@3.0.1", "", { "dependencies": { "mime-db": "^1.54.0" } }, "sha512-xRc4oEhT6eaBpU1XF7AjpOFD+xQmXNB5OVKwp4tqCuBpHLS/ZbBDrc07mYTDqVMg6PfxUjjNp85O6Cd2Z/5HWA=="],

     

       376
       339
        
       

     

       377
       340
        
           "minimatch": ["minimatch@3.1.2", "", { "dependencies": { "brace-expansion": "^1.1.7" } }, "sha512-J7p63hRiAjw1NDEww1W7i37+ByIrOWO5XQQAzZ3VOcL0PNybwpfmV/N05zFAzwQ9USyEcX6t3UO+K5aqBQOIHw=="],

     

       378
       341
        
       

     
···

       380
       343
        
       

     

       381
       344
        
           "ms": ["ms@2.0.0", "", {}, "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A=="],

     

       382
       345
        
       

     

       383
       383
       -
           "multiformats": ["multiformats@9.9.0", "", {}, "sha512-HoMUjhH9T8DDBNT+6xzkrd9ga/XiBI4xLr58LJACwK6G3HTOPeMz4nB4KJs33L2BelrIJa7P0VuNaVF3hMYfjg=="],

     

       384
       384
       -
       

     

       385
       346
        
           "mute-stream": ["mute-stream@0.0.5", "", {}, "sha512-EbrziT4s8cWPmzr47eYVW3wimS4HsvlnV5ri1xw1aR6JQo/OrJX5rkl32K/QQHdxeabJETtfeaROGhd8W7uBgg=="],

     

       386
       347
        
       

     

       387
       348
        
           "mz": ["mz@2.7.0", "", { "dependencies": { "any-promise": "^1.0.0", "object-assign": "^4.0.1", "thenify-all": "^1.0.0" } }, "sha512-z81GNO7nnYMEhrGh9LeymoE4+Yr0Wn5McHIZMK5cfQCl+NDX08sCZgUc9/6MHni9IWuFLm1Z3HTCXu2z9fN62Q=="],

     

       388
       349
        
       

     

       389
       350
        
           "nanoevents": ["nanoevents@9.1.0", "", {}, "sha512-Jd0fILWG44a9luj8v5kED4WI+zfkkgwKyRQKItTtlPfEsh7Lznfi1kr8/iZ+XAIss4Qq5GqRB0qtWbaz9ceO/A=="],

     

       351
       351
       +
       

     

       352
       352
       +
           "nanoid": ["nanoid@5.1.6", "", { "bin": { "nanoid": "bin/nanoid.js" } }, "sha512-c7+7RQ+dMB5dPwwCp4ee1/iV/q2P6aK1mTZcfr1BTuVlyW9hJYiMPybJCcnBlQtuSmTIWNeazm/zqNoZSSElBg=="],

     

       390
       353
        
       

     

       391
       354
        
           "negotiator": ["negotiator@0.6.4", "", {}, "sha512-myRT3DiWPHqho5PrJaIRyaMv2kgYf0mUVgBNOYMuCH5Ki1yEiQaf/ZJuQ62nvpc44wL5WDbTX7yGJi1Neevw8w=="],

     

       392
       355
        
       

     
···

       414
       377
        
       

     

       415
       378
        
           "path-is-absolute": ["path-is-absolute@1.0.1", "", {}, "sha512-AVbw3UJ2e9bq64vSaS9Am0fje1Pa8pbGqTTsmXfaIiMpnr5DlDhfJOuLj9Sf95ZPVDAUerDfEk88MPmPe7UCQg=="],

     

       416
       379
        
       

     

       417
       417
       -
           "path-to-regexp": ["path-to-regexp@0.1.12", "", {}, "sha512-RA1GjUVMnvYFxuqovrEqZoxxW5NUZqbwKtYz/Tt7nXerk0LbLblQmrsgdeOxV5SFHf0UDggjS/bSeOZwt1pmEQ=="],

     

       380
       380
       +
           "path-to-regexp": ["path-to-regexp@8.3.0", "", {}, "sha512-7jdwVIRtsP8MYpdXSwOS0YdD0Du+qOoF/AEPIt88PcCFrZCzx41oxku1jD88hZBwbNUIEfpqvuhjFaMAqMTWnA=="],

     

       418
       381
        
       

     

       419
       382
        
           "performance-now": ["performance-now@2.1.0", "", {}, "sha512-7EAHlyLHI56VEIdK57uwHdHKIaAGbnXPiw0yWbarQZOKaKpvUIgW0jWRVLiatnM+XXlSwsanIBH/hzGMJulMow=="],

     

       420
       383
        
       

     
···

       450
       413
        
       

     

       451
       414
        
           "postgres-interval": ["postgres-interval@1.2.0", "", { "dependencies": { "xtend": "^4.0.0" } }, "sha512-9ZhXKM/rw350N1ovuWHbGxnGh/SNJ4cnxHiM0rxE4VN41wsg8P8zWn9hv/buK00RP4WvlOyr/RBDiptyxVbkZQ=="],

     

       452
       415
        
       

     

       453
       453
       -
           "process": ["process@0.11.10", "", {}, "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A=="],

     

       454
       454
       -
       

     

       455
       416
        
           "process-warning": ["process-warning@5.0.0", "", {}, "sha512-a39t9ApHNx2L4+HBnQKqxxHNs1r7KF+Intd8Q/g1bUh6q0WIp9voPXJ/x0j+ZL45KF1pJd9+q2jLIRMfvEshkA=="],

     

       456
       417
        
       

     

       457
       418
        
           "proxy-addr": ["proxy-addr@2.0.7", "", { "dependencies": { "forwarded": "0.2.0", "ipaddr.js": "1.9.1" } }, "sha512-llQsMLSUDUPT44jdrU/O37qlnifitDP+ZwrmmZcoSKyLKvtZxpyV0n2/bD/N4tBAAZ/gJEdZU7KMraoK1+XYAg=="],

     
···

       467
       428
        
           "quick-format-unescaped": ["quick-format-unescaped@4.0.4", "", {}, "sha512-tYC1Q1hgyRuHgloV/YXs2w15unPVh8qfu/qCTfhTYamaw7fyhumKa2yGpdSo87vY32rIclj+4fWYQXUMs9EHvg=="],

     

       468
       429
        
       

     

       469
       430
        
           "range-parser": ["range-parser@1.2.1", "", {}, "sha512-Hrgsx+orqoygnmhFbKaHE6c296J+HTAQXoxEF6gNupROmmGJRoyzfG3ccAveqCBrwr/2yxQ5BVd/GTl5agOwSg=="],

     

       470
       470
       -
       

     

       471
       471
       -
           "rate-limiter-flexible": ["rate-limiter-flexible@2.4.2", "", {}, "sha512-rMATGGOdO1suFyf/mI5LYhts71g1sbdhmd6YvdiXO2gJnd42Tt6QS4JUKJKSWVVkMtBacm6l40FR7Trjo6Iruw=="],

     

       472
       431
        
       

     

       473
       432
        
           "raw-body": ["raw-body@3.0.1", "", { "dependencies": { "bytes": "3.1.2", "http-errors": "2.0.0", "iconv-lite": "0.7.0", "unpipe": "1.0.0" } }, "sha512-9G8cA+tuMS75+6G/TzW8OtLzmBDMo8p1JRxN5AZ+LAp8uxGA8V8GZm4GQ4/N5QNQEnLmg6SS7wyuSmbKepiKqA=="],

     

       474
       433
        
       

     

       475
       475
       -
           "readable-stream": ["readable-stream@4.7.0", "", { "dependencies": { "abort-controller": "^3.0.0", "buffer": "^6.0.3", "events": "^3.3.0", "process": "^0.11.10", "string_decoder": "^1.3.0" } }, "sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg=="],

     

       476
       476
       -
       

     

       477
       434
        
           "readline2": ["readline2@1.0.1", "", { "dependencies": { "code-point-at": "^1.0.0", "is-fullwidth-code-point": "^1.0.0", "mute-stream": "0.0.5" } }, "sha512-8/td4MmwUB6PkZUbV25uKz7dfrmjYWxsW8DVfibWdlHRk/l/DfHKn4pU+dfcoGLFgWOdyGCzINRQD7jn+Bv+/g=="],

     

       478
       435
        
       

     

       479
       436
        
           "real-require": ["real-require@0.2.0", "", {}, "sha512-57frrGM/OCTLqLOAh0mhVA9VBMHd+9U7Zb2THMGdBUoZVOtGbJzjxsYGDJ3A9AYYCP4hn6y1TVbaOfzWtm5GFg=="],

     
···

       526
       483
        
       

     

       527
       484
        
           "string-width": ["string-width@1.0.2", "", { "dependencies": { "code-point-at": "^1.0.0", "is-fullwidth-code-point": "^1.0.0", "strip-ansi": "^3.0.0" } }, "sha512-0XsVpQLnVCXHJfyEs8tC0zpTVIr5PKKsQtkT29IwupnPTjtPmQ3xT/4yCREF9hYkV/3M3kzcUTSAZT6a6h81tw=="],

     

       528
       485
        
       

     

       529
       529
       -
           "string_decoder": ["string_decoder@1.3.0", "", { "dependencies": { "safe-buffer": "~5.2.0" } }, "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA=="],

     

       530
       530
       -
       

     

       531
       486
        
           "strip-ansi": ["strip-ansi@3.0.1", "", { "dependencies": { "ansi-regex": "^2.0.0" } }, "sha512-VhumSSbBqDTP8p2ZLKj40UjBCV4+v8bUSEpUb4KjRgWk9pbqGF4REFj6KEagidb2f/M6AzC0EmFyDNGaw9OCzg=="],

     

       532
       487
        
       

     

       533
       488
        
           "strip-json-comments": ["strip-json-comments@5.0.3", "", {}, "sha512-1tB5mhVo7U+ETBKNf92xT4hrQa3pm0MZ0PQvuDnWgAAGHDsfp4lPSpiS6psrSiet87wyGPh9ft6wmhOMQ0hDiw=="],

     
···

       546
       501
        
       

     

       547
       502
        
           "tough-cookie": ["tough-cookie@2.5.0", "", { "dependencies": { "psl": "^1.1.28", "punycode": "^2.1.1" } }, "sha512-nlLsUzgm1kfLXSXfRZMc1KLAugd4hqJHDTvc2hDIwS3mZAfMEuMbc03SujMF+GEcpaX/qboeycw6iO8JwVv2+g=="],

     

       548
       503
        
       

     

       549
       549
       -
           "tslib": ["tslib@2.8.1", "", {}, "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w=="],

     

       550
       550
       -
       

     

       551
       504
        
           "tunnel-agent": ["tunnel-agent@0.6.0", "", { "dependencies": { "safe-buffer": "^5.0.1" } }, "sha512-McnNiV1l8RYeY8tBgEpuodCC1mLUdbSN+CYBL7kJsJNInOP8UjDDEwdk6Mw60vdLLrr5NHKZhMAOSrR2NZuQ+w=="],

     

       552
       505
        
       

     

       553
       506
        
           "tweetnacl": ["tweetnacl@0.14.5", "", {}, "sha512-KXXFFdAbFXY4geFIwoyNK+f5Z1b7swfXABfL7HXCmoIWMKU3dmS26672A4EeQtDzLKy7SXmfBu51JolvEKwtGA=="],

     
···

       556
       509
        
       

     

       557
       510
        
           "typescript": ["typescript@5.9.3", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-jl1vZzPDinLr9eUt3J/t7V6FgNEw9QjvBPdysz9KfQDD41fQrC2Y4vKQdiaUpFT4bXlb1RHhLpp8wtm6M5TgSw=="],

     

       558
       511
        
       

     

       559
       559
       -
           "uint8arrays": ["uint8arrays@3.0.0", "", { "dependencies": { "multiformats": "^9.4.2" } }, "sha512-HRCx0q6O9Bfbp+HHSfQQKD7wU70+lydKVt4EghkdOvlK/NlrF90z+eXV34mUd48rNvVJXwkrMSPpCATkct8fJA=="],

     

       560
       560
       -
       

     

       561
       512
        
           "undici-types": ["undici-types@7.16.0", "", {}, "sha512-Zz+aZWSj8LE6zoxD+xrjh4VfkIG8Ya6LvYkZqtUQGJPZjYl53ypCaUwWqo7eI0x66KBGeRo+mlBEkMSeSZ38Nw=="],

     

       562
       562
       -
       

     

       563
       563
       -
           "unicode-segmenter": ["unicode-segmenter@0.14.0", "", {}, "sha512-AH4lhPCJANUnSLEKnM4byboctePJzltF4xj8b+NbNiYeAkAXGh7px2K/4NANFp7dnr6+zB3e6HLu8Jj8SKyvYg=="],

     

       564
       513
        
       

     

       565
       514
        
           "unpipe": ["unpipe@1.0.0", "", {}, "sha512-pjy2bYhSsufwWlKwPc+l3cN7+wuJlK6uz0YdJEOlQDbl6jo/YlPi4mb8agUkVC8BF7V8NuzeyPNqRksA3hztKQ=="],

     

       566
       515
        
       

     
···

       570
       519
        
       

     

       571
       520
        
           "user-home": ["user-home@2.0.0", "", { "dependencies": { "os-homedir": "^1.0.0" } }, "sha512-KMWqdlOcjCYdtIJpicDSFBQ8nFwS2i9sslAd6f4+CBGcU4gist2REnr2fxj2YocvJFxSF3ZOHLYLVZnUxv4BZQ=="],

     

       572
       521
        
       

     

       573
       573
       -
           "utils-merge": ["utils-merge@1.0.1", "", {}, "sha512-pMZTvIkT1d+TFGvDOqodOclx0QWkkgi6Tdoa8gC8ffGAAqz9pzPTZWAybbsHHoED/ztMtkv/VoYTYyShUn81hA=="],

     

       574
       574
       -
       

     

       575
       522
        
           "uuid": ["uuid@3.4.0", "", { "bin": { "uuid": "./bin/uuid" } }, "sha512-HjSDRw6gZE5JMggctHBcjVak08+KEVhSIiDzFnT9S9aegmp85S/bReBVTb4QTFaRNptJ9kuYaNhnbNEOkbKb/A=="],

     

       576
       523
        
       

     

       577
       524
        
           "vary": ["vary@1.1.2", "", {}, "sha512-BNGbWLfd0eUPabhkXUVm0j8uuvREyTh5ovRa/dyow/BqAbZJyC+5fU+IzQOzmAKzYqYRAISoRhdQr3eIZ/PXqg=="],

     
···

       586
       533
        
       

     

       587
       534
        
           "yocto-queue": ["yocto-queue@1.2.2", "", {}, "sha512-4LCcse/U2MHZ63HAJVE+v71o7yOdIe4cZ70Wpf8D/IyjDKYQLV5GD46B+hSTjJsvV5PztjvHoU580EftxjDZFQ=="],

     

       588
       535
        
       

     

       589
       589
       -
           "zod": ["zod@3.25.76", "", {}, "sha512-gzUt/qt81nXsFGKIFcC3YnfEAx5NkunCfnDlvuBSSFS02bcXu4Lmea0AFIUwbLWxWPx3d9p8S5QoaujKcNQxcQ=="],

     

       590
       590
       -
       

     

       591
       591
       -
           "@atproto/common/pino": ["pino@8.21.0", "", { "dependencies": { "atomic-sleep": "^1.0.0", "fast-redact": "^3.1.1", "on-exit-leak-free": "^2.1.0", "pino-abstract-transport": "^1.2.0", "pino-std-serializers": "^6.0.0", "process-warning": "^3.0.0", "quick-format-unescaped": "^4.0.3", "real-require": "^0.2.0", "safe-stable-stringify": "^2.3.1", "sonic-boom": "^3.7.0", "thread-stream": "^2.6.0" }, "bin": { "pino": "bin.js" } }, "sha512-ip4qdzjkAyDDZklUaZkcRFb2iA118H9SgRh8yzTkSQK8HilsOJF7rSY8HoW5+I0M46AZgX/pxbprf2vvzQCE0Q=="],

     

       592
       592
       -
       

     

       593
       593
       -
           "@atproto/xrpc-server/express": ["express@4.21.2", "", { "dependencies": { "accepts": "~1.3.8", "array-flatten": "1.1.1", "body-parser": "1.20.3", "content-disposition": "0.5.4", "content-type": "~1.0.4", "cookie": "0.7.1", "cookie-signature": "1.0.6", "debug": "2.6.9", "depd": "2.0.0", "encodeurl": "~2.0.0", "escape-html": "~1.0.3", "etag": "~1.8.1", "finalhandler": "1.3.1", "fresh": "0.5.2", "http-errors": "2.0.0", "merge-descriptors": "1.0.3", "methods": "~1.1.2", "on-finished": "2.4.1", "parseurl": "~1.3.3", "path-to-regexp": "0.1.12", "proxy-addr": "~2.0.7", "qs": "6.13.0", "range-parser": "~1.2.1", "safe-buffer": "5.2.1", "send": "0.19.0", "serve-static": "1.16.2", "setprototypeof": "1.2.0", "statuses": "2.0.1", "type-is": "~1.6.18", "utils-merge": "1.0.1", "vary": "~1.1.2" } }, "sha512-28HqgMZAmih1Czt9ny7qr6ek2qddF4FclbMzwhCREB6OFfH+rXAnuNCwo1/wFvrtbgsQDb4kSbX9de9lFbrXnA=="],

     

       536
       536
       +
           "@atcute/identity/@atcute/lexicons": ["@atcute/lexicons@1.2.5", "", { "dependencies": { "@standard-schema/spec": "^1.0.0", "esm-env": "^1.2.2" } }, "sha512-9yO9WdgxW8jZ7SbzUycH710z+JmsQ9W9n5S6i6eghYju32kkluFmgBeS47r8e8p2+Dv4DemS7o/3SUGsX9FR5Q=="],

     

       594
       537
        
       

     

       595
       538
        
           "@skyware/firehose/@atcute/car": ["@atcute/car@3.1.3", "", { "dependencies": { "@atcute/cbor": "^2.2.7", "@atcute/cid": "^2.2.5", "@atcute/uint8array": "^1.0.5", "@atcute/varint": "^1.0.3", "yocto-queue": "^1.2.1" } }, "sha512-WJ13bAEt7TjDMVi09ubjLtvhdljbWInGm9Kfy7Y6NhrmiyC/aZYaA/zHX/bHI6xv1c/h3SQduWqxOr4ae49eqA=="],

     

       596
       539
        
       

     

       597
       540
        
           "@types/serve-static/@types/send": ["@types/send@0.17.6", "", { "dependencies": { "@types/mime": "^1", "@types/node": "*" } }, "sha512-Uqt8rPBE8SY0RK8JB1EzVOIZ32uqy8HwdxCnoCOsYrvnswqmFZ/k+9Ikidlk/ImhsdvBsloHbAlewb2IEBV/Og=="],

     

       598
       541
        
       

     

       599
       599
       -
           "accepts/mime-types": ["mime-types@3.0.1", "", { "dependencies": { "mime-db": "^1.54.0" } }, "sha512-xRc4oEhT6eaBpU1XF7AjpOFD+xQmXNB5OVKwp4tqCuBpHLS/ZbBDrc07mYTDqVMg6PfxUjjNp85O6Cd2Z/5HWA=="],

     

       600
       600
       -
       

     

       601
       542
        
           "accepts/negotiator": ["negotiator@1.0.0", "", {}, "sha512-8Ofs/AUQh8MaEcrlq5xOX0CQ9ypTF5dl78mjlMNfOK08fzpgTHQRQPBxcPlEtIw0yRpws+Zo/3r+5WRby7u3Gg=="],

     

       602
       543
        
       

     

       603
       544
        
           "body-parser/debug": ["debug@4.4.3", "", { "dependencies": { "ms": "^2.1.3" } }, "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA=="],

     

       604
       545
        
       

     

       605
       605
       -
           "compressible/mime-db": ["mime-db@1.54.0", "", {}, "sha512-aU5EJuIN2WDemCcAp2vFBfp/m4EAhWJnUNSSw0ixs7/kXbd6Pg64EmwJkNdFhB8aWt1sH2CTXrLxo/iAGV3oPQ=="],

     

       606
       606
       -
       

     

       607
       546
        
           "express/debug": ["debug@4.4.3", "", { "dependencies": { "ms": "^2.1.3" } }, "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA=="],

     

       608
       547
        
       

     

       609
       609
       -
           "express/mime-types": ["mime-types@3.0.1", "", { "dependencies": { "mime-db": "^1.54.0" } }, "sha512-xRc4oEhT6eaBpU1XF7AjpOFD+xQmXNB5OVKwp4tqCuBpHLS/ZbBDrc07mYTDqVMg6PfxUjjNp85O6Cd2Z/5HWA=="],

     

       548
       548
       +
           "finalhandler/debug": ["debug@4.4.3", "", { "dependencies": { "ms": "^2.1.3" } }, "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA=="],

     

       610
       549
        
       

     

       611
       611
       -
           "finalhandler/debug": ["debug@4.4.3", "", { "dependencies": { "ms": "^2.1.3" } }, "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA=="],

     

       550
       550
       +
           "form-data/mime-types": ["mime-types@2.1.35", "", { "dependencies": { "mime-db": "1.52.0" } }, "sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw=="],

     

       612
       551
        
       

     

       613
       552
        
           "http-errors/statuses": ["statuses@2.0.1", "", {}, "sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ=="],

     

       614
       553
        
       

     
···

       616
       555
        
       

     

       617
       556
        
           "raw-body/iconv-lite": ["iconv-lite@0.7.0", "", { "dependencies": { "safer-buffer": ">= 2.1.2 < 3.0.0" } }, "sha512-cf6L2Ds3h57VVmkZe+Pn+5APsT7FpqJtEhhieDCvrE2MK5Qk9MyffgQyuxQTm6BChfeZNtcOLHp9IcWRVcIcBQ=="],

     

       618
       557
        
       

     

       558
       558
       +
           "request/mime-types": ["mime-types@2.1.35", "", { "dependencies": { "mime-db": "1.52.0" } }, "sha512-ZDY+bPm5zTTF+YpCrAU9nK0UgICYPT0QtT1NZWFv4s++TNkcgVaT0g6+4R2uI4MjQjzysHB1zxuWL50hzaeXiw=="],

     

       559
       559
       +
       

     

       619
       560
        
           "request/qs": ["qs@6.5.3", "", {}, "sha512-qxXIEh4pCGfHICj1mAJQ2/2XVZkjCDTcEgfoSQxc/fYivUZxTkk7L3bDBJSoNrEzXI17oUO5Dp07ktqE5KzczA=="],

     

       620
       561
        
       

     

       621
       562
        
           "router/debug": ["debug@4.4.3", "", { "dependencies": { "ms": "^2.1.3" } }, "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA=="],

     

       622
       563
        
       

     

       623
       623
       -
           "router/path-to-regexp": ["path-to-regexp@8.3.0", "", {}, "sha512-7jdwVIRtsP8MYpdXSwOS0YdD0Du+qOoF/AEPIt88PcCFrZCzx41oxku1jD88hZBwbNUIEfpqvuhjFaMAqMTWnA=="],

     

       624
       624
       -
       

     

       625
       564
        
           "send/debug": ["debug@4.4.3", "", { "dependencies": { "ms": "^2.1.3" } }, "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA=="],

     

       626
       565
        
       

     

       627
       627
       -
           "send/mime-types": ["mime-types@3.0.1", "", { "dependencies": { "mime-db": "^1.54.0" } }, "sha512-xRc4oEhT6eaBpU1XF7AjpOFD+xQmXNB5OVKwp4tqCuBpHLS/ZbBDrc07mYTDqVMg6PfxUjjNp85O6Cd2Z/5HWA=="],

     

       628
       628
       -
       

     

       629
       566
        
           "send/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       630
       567
        
       

     

       631
       631
       -
           "type-is/mime-types": ["mime-types@3.0.1", "", { "dependencies": { "mime-db": "^1.54.0" } }, "sha512-xRc4oEhT6eaBpU1XF7AjpOFD+xQmXNB5OVKwp4tqCuBpHLS/ZbBDrc07mYTDqVMg6PfxUjjNp85O6Cd2Z/5HWA=="],

     

       632
       632
       -
       

     

       633
       633
       -
           "@atproto/common/pino/pino-abstract-transport": ["pino-abstract-transport@1.2.0", "", { "dependencies": { "readable-stream": "^4.0.0", "split2": "^4.0.0" } }, "sha512-Guhh8EZfPCfH+PMXAb6rKOjGQEoy0xlAIn+irODG5kgfYV+BQ0rGYYWTIel3P5mmyXqkYkPmdIkywsn6QKUR1Q=="],

     

       634
       634
       -
       

     

       635
       635
       -
           "@atproto/common/pino/pino-std-serializers": ["pino-std-serializers@6.2.2", "", {}, "sha512-cHjPPsE+vhj/tnhCy/wiMh3M3z3h/j15zHQX+S9GkTBgqJuTuJzYJ4gUyACLhDaJ7kk9ba9iRDmbH2tJU03OiA=="],

     

       636
       636
       -
       

     

       637
       637
       -
           "@atproto/common/pino/process-warning": ["process-warning@3.0.0", "", {}, "sha512-mqn0kFRl0EoqhnL0GQ0veqFHyIN1yig9RHh/InzORTUiZHFRAur+aMtRkELNwGs9aNwKS6tg/An4NYBPGwvtzQ=="],

     

       638
       638
       -
       

     

       639
       639
       -
           "@atproto/common/pino/sonic-boom": ["sonic-boom@3.8.1", "", { "dependencies": { "atomic-sleep": "^1.0.0" } }, "sha512-y4Z8LCDBuum+PBP3lSV7RHrXscqksve/bi0as7mhwVnBW+/wUqKT/2Kb7um8yqcFy0duYbbPxzt89Zy2nOCaxg=="],

     

       640
       640
       -
       

     

       641
       641
       -
           "@atproto/common/pino/thread-stream": ["thread-stream@2.7.0", "", { "dependencies": { "real-require": "^0.2.0" } }, "sha512-qQiRWsU/wvNolI6tbbCKd9iKaTnCXsTwVxhhKM6nctPdujTyztjlbUkUTUymidWcMnZ5pWR0ej4a0tjsW021vw=="],

     

       642
       642
       -
       

     

       643
       643
       -
           "@atproto/xrpc-server/express/accepts": ["accepts@1.3.8", "", { "dependencies": { "mime-types": "~2.1.34", "negotiator": "0.6.3" } }, "sha512-PYAthTa2m2VKxuvSD3DPC/Gy+U+sOA1LAuT8mkmRuvw+NACSaeXEQ+NHcVF7rONl6qcaxV3Uuemwawk+7+SJLw=="],

     

       644
       644
       -
       

     

       645
       645
       -
           "@atproto/xrpc-server/express/body-parser": ["body-parser@1.20.3", "", { "dependencies": { "bytes": "3.1.2", "content-type": "~1.0.5", "debug": "2.6.9", "depd": "2.0.0", "destroy": "1.2.0", "http-errors": "2.0.0", "iconv-lite": "0.4.24", "on-finished": "2.4.1", "qs": "6.13.0", "raw-body": "2.5.2", "type-is": "~1.6.18", "unpipe": "1.0.0" } }, "sha512-7rAxByjUMqQ3/bHJy7D6OGXvx/MMc4IqBn/X0fcM1QUcAItpZrBEYhWGem+tzXH90c+G01ypMcYJBO9Y30203g=="],

     

       646
       646
       -
       

     

       647
       647
       -
           "@atproto/xrpc-server/express/content-disposition": ["content-disposition@0.5.4", "", { "dependencies": { "safe-buffer": "5.2.1" } }, "sha512-FveZTNuGw04cxlAiWbzi6zTAL/lhehaWbTtgluJh4/E95DqMwTmha3KZN1aAWA8cFIhHzMZUvLevkw5Rqk+tSQ=="],

     

       648
       648
       -
       

     

       649
       649
       -
           "@atproto/xrpc-server/express/cookie": ["cookie@0.7.1", "", {}, "sha512-6DnInpx7SJ2AK3+CTUE/ZM0vWTUboZCegxhC2xiIydHR9jNuTAASBrfEpHhiGOZw/nX51bHt6YQl8jsGo4y/0w=="],

     

       650
       650
       -
       

     

       651
       651
       -
           "@atproto/xrpc-server/express/cookie-signature": ["cookie-signature@1.0.6", "", {}, "sha512-QADzlaHc8icV8I7vbaJXJwod9HWYp8uCqf1xa4OfNu1T7JVxQIrUgOWtHdNDtPiywmFbiS12VjotIXLrKM3orQ=="],

     

       652
       652
       -
       

     

       653
       653
       -
           "@atproto/xrpc-server/express/finalhandler": ["finalhandler@1.3.1", "", { "dependencies": { "debug": "2.6.9", "encodeurl": "~2.0.0", "escape-html": "~1.0.3", "on-finished": "2.4.1", "parseurl": "~1.3.3", "statuses": "2.0.1", "unpipe": "~1.0.0" } }, "sha512-6BN9trH7bp3qvnrRyzsBz+g3lZxTNZTbVO2EV1CS0WIcDbawYVdYvGflME/9QP0h0pYlCDBCTjYa9nZzMDpyxQ=="],

     

       654
       654
       -
       

     

       655
       655
       -
           "@atproto/xrpc-server/express/fresh": ["fresh@0.5.2", "", {}, "sha512-zJ2mQYM18rEFOudeV4GShTGIQ7RbzA7ozbU9I/XBpm7kqgMywgmylMwXHxZJmkVoYkna9d2pVXVXPdYTP9ej8Q=="],

     

       656
       656
       -
       

     

       657
       657
       -
           "@atproto/xrpc-server/express/merge-descriptors": ["merge-descriptors@1.0.3", "", {}, "sha512-gaNvAS7TZ897/rVaZ0nMtAyxNyi/pdbjbAwUpFQpN70GqnVfOiXpeUUMKRBmzXaSQ8DdTX4/0ms62r2K+hE6mQ=="],

     

       658
       658
       -
       

     

       659
       659
       -
           "@atproto/xrpc-server/express/qs": ["qs@6.13.0", "", { "dependencies": { "side-channel": "^1.0.6" } }, "sha512-+38qI9SOr8tfZ4QmJNplMUxqjbe7LKvvZgWdExBOmd+egZTtjLB67Gu0HRX3u/XOq7UU2Nx6nsjvS16Z9uwfpg=="],

     

       660
       660
       -
       

     

       661
       661
       -
           "@atproto/xrpc-server/express/send": ["send@0.19.0", "", { "dependencies": { "debug": "2.6.9", "depd": "2.0.0", "destroy": "1.2.0", "encodeurl": "~1.0.2", "escape-html": "~1.0.3", "etag": "~1.8.1", "fresh": "0.5.2", "http-errors": "2.0.0", "mime": "1.6.0", "ms": "2.1.3", "on-finished": "2.4.1", "range-parser": "~1.2.1", "statuses": "2.0.1" } }, "sha512-dW41u5VfLXu8SJh5bwRmyYUbAoSB3c9uQh6L8h/KtsFREPWpbX1lrljJo186Jc4nmci/sGUZ9a0a0J2zgfq2hw=="],

     

       662
       662
       -
       

     

       663
       663
       -
           "@atproto/xrpc-server/express/serve-static": ["serve-static@1.16.2", "", { "dependencies": { "encodeurl": "~2.0.0", "escape-html": "~1.0.3", "parseurl": "~1.3.3", "send": "0.19.0" } }, "sha512-VqpjJZKadQB/PEbEwvFdO43Ax5dFBZ2UECszz8bQ7pi7wt//PWe1P6MN7eCnjsatYtBT6EuiClbjSWP2WrIoTw=="],

     

       664
       664
       -
       

     

       665
       665
       -
           "@atproto/xrpc-server/express/statuses": ["statuses@2.0.1", "", {}, "sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ=="],

     

       666
       666
       -
       

     

       667
       667
       -
           "@atproto/xrpc-server/express/type-is": ["type-is@1.6.18", "", { "dependencies": { "media-typer": "0.3.0", "mime-types": "~2.1.24" } }, "sha512-TkRKr9sUTxEH8MdfuCSP7VizJyzRNMjj2J2do2Jr3Kym598JVdEksuzPQCnlFPW4ky9Q+iA+ma9BGm06XQBy8g=="],

     

       668
       668
       -
       

     

       669
       669
       -
           "accepts/mime-types/mime-db": ["mime-db@1.54.0", "", {}, "sha512-aU5EJuIN2WDemCcAp2vFBfp/m4EAhWJnUNSSw0ixs7/kXbd6Pg64EmwJkNdFhB8aWt1sH2CTXrLxo/iAGV3oPQ=="],

     

       670
       670
       -
       

     

       671
       568
        
           "body-parser/debug/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       672
       569
        
       

     

       673
       570
        
           "express/debug/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       674
       571
        
       

     

       675
       675
       -
           "express/mime-types/mime-db": ["mime-db@1.54.0", "", {}, "sha512-aU5EJuIN2WDemCcAp2vFBfp/m4EAhWJnUNSSw0ixs7/kXbd6Pg64EmwJkNdFhB8aWt1sH2CTXrLxo/iAGV3oPQ=="],

     

       676
       676
       -
       

     

       677
       572
        
           "finalhandler/debug/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       678
       573
        
       

     

       679
       679
       -
           "router/debug/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       680
       680
       -
       

     

       681
       681
       -
           "send/mime-types/mime-db": ["mime-db@1.54.0", "", {}, "sha512-aU5EJuIN2WDemCcAp2vFBfp/m4EAhWJnUNSSw0ixs7/kXbd6Pg64EmwJkNdFhB8aWt1sH2CTXrLxo/iAGV3oPQ=="],

     

       682
       682
       -
       

     

       683
       683
       -
           "type-is/mime-types/mime-db": ["mime-db@1.54.0", "", {}, "sha512-aU5EJuIN2WDemCcAp2vFBfp/m4EAhWJnUNSSw0ixs7/kXbd6Pg64EmwJkNdFhB8aWt1sH2CTXrLxo/iAGV3oPQ=="],

     

       684
       684
       -
       

     

       685
       685
       -
           "@atproto/xrpc-server/express/accepts/negotiator": ["negotiator@0.6.3", "", {}, "sha512-+EUsqGPLsM+j/zdChZjsnX51g4XrHFOIXwfnCVPGlQk/k5giakcKsuxCObBRu6DSm9opw/O6slWbJdghQM4bBg=="],

     

       686
       686
       -
       

     

       687
       687
       -
           "@atproto/xrpc-server/express/body-parser/iconv-lite": ["iconv-lite@0.4.24", "", { "dependencies": { "safer-buffer": ">= 2.1.2 < 3" } }, "sha512-v3MXnZAcvnywkTUEZomIActle7RXXeedOR31wwl7VlyoXO4Qi9arvSenNQWne1TcRwhCL1HwLI21bEqdpj8/rA=="],

     

       688
       688
       -
       

     

       689
       689
       -
           "@atproto/xrpc-server/express/body-parser/raw-body": ["raw-body@2.5.2", "", { "dependencies": { "bytes": "3.1.2", "http-errors": "2.0.0", "iconv-lite": "0.4.24", "unpipe": "1.0.0" } }, "sha512-8zGqypfENjCIqGhgXToC8aB2r7YrBX+AQAfIPs/Mlk+BtPTztOvTS01NRW/3Eh60J+a48lt8qsCzirQ6loCVfA=="],

     

       690
       690
       -
       

     

       691
       691
       -
           "@atproto/xrpc-server/express/send/encodeurl": ["encodeurl@1.0.2", "", {}, "sha512-TPJXq8JqFaVYm2CWmPvnP2Iyo4ZSM7/QKcSmuMLDObfpH5fi7RUGmd/rTDf+rut/saiDiQEeVTNgAmJEdAOx0w=="],

     

       574
       574
       +
           "form-data/mime-types/mime-db": ["mime-db@1.52.0", "", {}, "sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg=="],

     

       692
       575
        
       

     

       693
       693
       -
           "@atproto/xrpc-server/express/send/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       576
       576
       +
           "request/mime-types/mime-db": ["mime-db@1.52.0", "", {}, "sha512-sPU4uV7dYlvtWJxwwxHD0PuihVNiE7TyAbQ5SWxDCB9mUYvOgroQOwYQQOKPJ8CIbE+1ETVlOoK1UC2nU3gYvg=="],

     

       694
       577
        
       

     

       695
       695
       -
           "@atproto/xrpc-server/express/type-is/media-typer": ["media-typer@0.3.0", "", {}, "sha512-dq+qelQ9akHpcOl/gUVRTxVIOkAJ1wR3QAvb4RsVjS8oVoFjDGTc679wJYmUmknUF5HwMLOgb5O+a3KxfWapPQ=="],

     

       578
       578
       +
           "router/debug/ms": ["ms@2.1.3", "", {}, "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="],

     

       696
       579
        
         }

     

       697
       580
        
       }

+2 -1

package.json

···

       21
       21
        
         "packageManager": "pnpm@10.20.0",

     

       22
       22
        
         "dependencies": {

     

       23
       23
        
           "@atcute/repo": "^0.1.0",

     

       24
       24
       -
           "@atproto/xrpc-server": "^0.10.1",

     

       24
       24
       +
           "@atcute/xrpc-server": "^0.1.3",

     

       25
       25
       +
           "@atcute/xrpc-server-bun": "^0.1.1",

     

       25
       26
        
           "@skyware/firehose": "^0.5.2",

     

       26
       27
        
           "compression": "^1.8.1",

     

       27
       28
        
           "dotenv": "^17.2.3",

+28 -43

src/api/channel.ts

···

       1
       1
       -
       import * as xrpc from '@atproto/xrpc-server';

     

       1
       1
       +
       import { InvalidRequestError, json } from '@atcute/xrpc-server';

     

       2
       2
        
       import { db } from '../db';

     

       3
       3
        
       import { parseLimit } from '../util/params';

     

       4
       4
        
       import { logger } from '../util/logger';

     

       5
       5
        
       

     

       6
       6
       -
       export async function listInvitesHandler(ctx: {

     

       7
       7
       -
         params: xrpc.Params;

     

       8
       8
       -
       }) {

     

       6
       6
       +
       export async function listInvitesHandler({ params }: { params: any }) {

     

       9
       7
        
         try {

     

       10
       10
       -
           const { limit: rawLimit, cursor, recipient } = ctx.params;

     

       8
       8
       +
           const { limit: rawLimit, cursor, recipient } = params;

     

       11
       9
        
           const limit = parseLimit(rawLimit);

     

       12
       10
        
       

     

       13
       11
        
           if (!recipient) {

     

       14
       14
       -
             throw new xrpc.InvalidRequestError('Missing required parameter: recipient');

     

       12
       12
       +
             throw new InvalidRequestError({ description: 'Missing required parameter: recipient' });

     

       15
       13
        
           }

     

       16
       14
        
       

     

       17
       15
        
           if (typeof recipient !== 'string') {

     

       18
       18
       -
             throw new xrpc.InvalidRequestError('Parameter "recipient" must be a string');

     

       16
       16
       +
             throw new InvalidRequestError({ description: 'Parameter "recipient" must be a string' });

     

       19
       17
        
           }

     

       20
       18
        
       

     

       21
       19
        
           let query = db

     
···

       36
       34
        
       

     

       37
       35
        
           if (cursor) {

     

       38
       36
        
             if (typeof cursor !== 'string') {

     

       39
       39
       -
               throw new xrpc.InvalidRequestError('Parameter "cursor" must be a string');

     

       37
       37
       +
               throw new InvalidRequestError({ description: 'Parameter "cursor" must be a string' });

     

       40
       38
        
             }

     

       41
       39
        
             query = query.where('ci.indexed_at', '<', new Date(cursor));

     

       42
       40
        
           }

     
···

       59
       57
        
           const lastResult = results.at(-1);

     

       60
       58
        
           const nextCursor = lastResult ? lastResult.indexed_at.toISOString() : undefined;

     

       61
       59
        
       

     

       62
       62
       -
           return {

     

       63
       63
       -
             encoding: 'application/json',

     

       64
       64
       -
             body: {

     

       65
       65
       -
               invites,

     

       66
       66
       -
               cursor: nextCursor,

     

       67
       67
       -
             },

     

       68
       68
       -
           };

     

       60
       60
       +
           return json({

     

       61
       61
       +
             invites,

     

       62
       62
       +
             cursor: nextCursor,

     

       63
       63
       +
           });

     

       69
       64
        
       

     

       70
       65
        
         } catch (error) {

     

       71
       66
        
           logger.error({ err: error }, 'Internal server error in listInvitesHandler');

     
···

       73
       68
        
         }

     

       74
       69
        
       }

     

       75
       70
        
       

     

       76
       76
       -
       export async function listChannelsHandler(ctx: {

     

       77
       77
       -
         params: xrpc.Params;

     

       78
       78
       -
       }) {

     

       71
       71
       +
       export async function listChannelsHandler({ params }: { params: any }) {

     

       79
       72
        
         try {

     

       80
       80
       -
           const { limit: rawLimit, cursor, author } = ctx.params;

     

       73
       73
       +
           const { limit: rawLimit, cursor, author } = params;

     

       81
       74
        
           const limit = parseLimit(rawLimit);

     

       82
       75
        
       

     

       83
       76
        
           if (!author) {

     

       84
       84
       -
             throw new xrpc.InvalidRequestError('Missing required parameter: author');

     

       77
       77
       +
             throw new InvalidRequestError({ description: 'Missing required parameter: author' });

     

       85
       78
        
           }

     

       86
       79
        
       

     

       87
       80
        
           if (typeof author !== 'string') {

     

       88
       88
       -
             throw new xrpc.InvalidRequestError('Parameter "author" must be a string');

     

       81
       81
       +
             throw new InvalidRequestError({ description: 'Parameter "author" must be a string' });

     

       89
       82
        
           }

     

       90
       83
        
       

     

       91
       84
        
           let query = db

     
···

       105
       98
        
       

     

       106
       99
        
           if (cursor) {

     

       107
       100
        
             if (typeof cursor !== 'string') {

     

       108
       108
       -
               throw new xrpc.InvalidRequestError('Parameter "cursor" must be a string');

     

       101
       101
       +
               throw new InvalidRequestError({ description: 'Parameter "cursor" must be a string' });

     

       109
       102
        
             }

     

       110
       103
        
             query = query.where('indexed_at', '<', new Date(cursor));

     

       111
       104
        
           }

     
···

       127
       120
        
           const lastResult = results.at(-1);

     

       128
       121
        
           const nextCursor = lastResult ? lastResult.indexed_at.toISOString() : undefined;

     

       129
       122
        
       

     

       130
       130
       -
           return {

     

       131
       131
       -
             encoding: 'application/json',

     

       132
       132
       -
             body: {

     

       133
       133
       -
               channels,

     

       134
       134
       -
               cursor: nextCursor,

     

       135
       135
       -
             },

     

       136
       136
       -
           };

     

       123
       123
       +
           return json({

     

       124
       124
       +
             channels,

     

       125
       125
       +
             cursor: nextCursor,

     

       126
       126
       +
           });

     

       137
       127
        
       

     

       138
       128
        
         } catch (error) {

     

       139
       129
        
           logger.error({ err: error }, 'Internal server error in listChannelsHandler');

     
···

       141
       131
        
         }

     

       142
       132
        
       }

     

       143
       133
        
       

     

       144
       144
       -
       export async function listMembershipsHandler(ctx: {

     

       145
       145
       -
         params: xrpc.Params;

     

       146
       146
       -
       }) {

     

       134
       134
       +
       export async function listMembershipsHandler({ params }: { params: any }) {

     

       147
       135
        
         try {

     

       148
       148
       -
           const { limit: rawLimit, cursor, recipient } = ctx.params;

     

       136
       136
       +
           const { limit: rawLimit, cursor, recipient } = params;

     

       149
       137
        
           const limit = parseLimit(rawLimit);

     

       150
       138
        
       

     

       151
       139
        
           if (!recipient) {

     

       152
       152
       -
             throw new xrpc.InvalidRequestError('Missing required parameter: recipient');

     

       140
       140
       +
             throw new InvalidRequestError({ description: 'Missing required parameter: recipient' });

     

       153
       141
        
           }

     

       154
       142
        
       

     

       155
       143
        
           if (typeof recipient !== 'string') {

     

       156
       156
       -
             throw new xrpc.InvalidRequestError('Parameter "recipient" must be a string');

     

       144
       144
       +
             throw new InvalidRequestError({ description: 'Parameter "recipient" must be a string' });

     

       157
       145
        
           }

     

       158
       146
        
       

     

       159
       147
        
           let query = db

     
···

       178
       166
        
       

     

       179
       167
        
           if (cursor) {

     

       180
       168
        
             if (typeof cursor !== 'string') {

     

       181
       181
       -
               throw new xrpc.InvalidRequestError('Parameter "cursor" must be a string');

     

       169
       169
       +
               throw new InvalidRequestError({ description: 'Parameter "cursor" must be a string' });

     

       182
       170
        
             }

     

       183
       171
        
             query = query.where('cm.indexed_at', '<', new Date(cursor));

     

       184
       172
        
           }

     
···

       206
       194
        
           const lastResult = results.at(-1);

     

       207
       195
        
           const nextCursor = lastResult ? lastResult.indexed_at.toISOString() : undefined;

     

       208
       196
        
       

     

       209
       209
       -
           return {

     

       210
       210
       -
             encoding: 'application/json',

     

       211
       211
       -
             body: {

     

       212
       212
       -
               memberships,

     

       213
       213
       -
               cursor: nextCursor,

     

       214
       214
       -
             },

     

       215
       215
       -
           };

     

       197
       197
       +
           return json({

     

       198
       198
       +
             memberships,

     

       199
       199
       +
             cursor: nextCursor,

     

       200
       200
       +
           });

     

       216
       201
        
       

     

       217
       202
        
         } catch (error) {

     

       218
       203
        
           logger.error({ err: error }, 'Internal server error in listMembershipsHandler');

+17 -9

src/api/index.ts

···

       1
       1
       -
       import * as xrpc from '@atproto/xrpc-server';

     

       1
       1
       +
       import { XRPCRouter, json } from '@atcute/xrpc-server';

     

       2
       2
       +
       import { createBunWebSocket } from '@atcute/xrpc-server-bun';

     

       2
       3
        
       import { listInvitesHandler, listChannelsHandler, listMembershipsHandler } from './channel';

     

       3
       4
        
       import { listLatticesHandler } from './lattice';

     

       4
       5
        
       import { listShardsHandler } from './shard';

     

       5
       5
       -
       import { allLexicons } from '../lexicons';

     

       6
       6
       +
       import {

     

       7
       7
       +
         listInvitesSchema,

     

       8
       8
       +
         listChannelsSchema,

     

       9
       9
       +
         listMembershipsSchema,

     

       10
       10
       +
         listLatticesSchema,

     

       11
       11
       +
         listShardsSchema

     

       12
       12
       +
       } from './schemas';

     

       6
       13
        
       

     

       7
       14
        
       export function createServer() {

     

       8
       8
       -
         const server = xrpc.createServer(allLexicons);

     

       15
       15
       +
         const { adapter, wrap } = createBunWebSocket();

     

       16
       16
       +
         const router = new XRPCRouter({ websocket: adapter });

     

       9
       17
        
       

     

       10
       10
       -
         server.method('systems.gmstn.development.channel.listInvites', listInvitesHandler);

     

       11
       11
       -
         server.method('systems.gmstn.development.channel.listChannels', listChannelsHandler);

     

       12
       12
       -
         server.method('systems.gmstn.development.channel.listMemberships', listMembershipsHandler);

     

       13
       13
       -
         server.method('systems.gmstn.development.lattice.listLattices', listLatticesHandler);

     

       14
       14
       -
         server.method('systems.gmstn.development.shard.listShards', listShardsHandler);

     

       18
       18
       +
         router.add(listInvitesSchema, { handler: listInvitesHandler });

     

       19
       19
       +
         router.add(listChannelsSchema, { handler: listChannelsHandler });

     

       20
       20
       +
         router.add(listMembershipsSchema, { handler: listMembershipsHandler });

     

       21
       21
       +
         router.add(listLatticesSchema, { handler: listLatticesHandler });

     

       22
       22
       +
         router.add(listShardsSchema, { handler: listShardsHandler });

     

       15
       23
        
       

     

       16
       16
       -
         return server;

     

       24
       24
       +
         return wrap(router);

     

       17
       25
        
       }

+9 -12

src/api/lattice.ts

···

       1
       1
       -
       import * as xrpc from '@atproto/xrpc-server';

     

       1
       1
       +
       import { InvalidRequestError, json } from '@atcute/xrpc-server';

     

       2
       2
        
       import { db } from '../db';

     

       3
       3
        
       import { parseLimit } from '../util/params';

     

       4
       4
        
       import { logger } from '../util/logger';

     

       5
       5
        
       

     

       6
       6
        
       export async function listLatticesHandler(ctx: {

     

       7
       7
       -
         params: xrpc.Params;

     

       7
       7
       +
         params: any;

     

       8
       8
        
       }) {

     

       9
       9
        
         try {

     

       10
       10
        
           const { limit: rawLimit, cursor, author } = ctx.params;

     

       11
       11
        
           const limit = parseLimit(rawLimit);

     

       12
       12
        
       

     

       13
       13
        
           if (!author) {

     

       14
       14
       -
             throw new xrpc.InvalidRequestError('Missing required parameter: author');

     

       14
       14
       +
             throw new InvalidRequestError({ description: 'Missing required parameter: author' });

     

       15
       15
        
           }

     

       16
       16
        
       

     

       17
       17
        
           if (typeof author !== 'string') {

     

       18
       18
       -
             throw new xrpc.InvalidRequestError('Parameter "author" must be a string');

     

       18
       18
       +
             throw new InvalidRequestError({ description: 'Parameter "author" must be a string' });

     

       19
       19
        
           }

     

       20
       20
        
       

     

       21
       21
        
           let query = db

     
···

       34
       34
        
       

     

       35
       35
        
           if (cursor) {

     

       36
       36
        
             if (typeof cursor !== 'string') {

     

       37
       37
       -
               throw new xrpc.InvalidRequestError('Parameter "cursor" must be a string');

     

       37
       37
       +
               throw new InvalidRequestError({ description: 'Parameter "cursor" must be a string' });

     

       38
       38
        
             }

     

       39
       39
        
             query = query.where('indexed_at', '<', new Date(cursor));

     

       40
       40
        
           }

     
···

       55
       55
        
           const lastResult = results.at(-1);

     

       56
       56
        
           const nextCursor = lastResult ? lastResult.indexed_at.toISOString() : undefined;

     

       57
       57
        
       

     

       58
       58
       -
           return {

     

       59
       59
       -
             encoding: 'application/json',

     

       60
       60
       -
             body: {

     

       61
       61
       -
               lattices,

     

       62
       62
       -
               cursor: nextCursor,

     

       63
       63
       -
             },

     

       64
       64
       -
           };

     

       58
       58
       +
           return json({

     

       59
       59
       +
             lattices,

     

       60
       60
       +
             cursor: nextCursor,

     

       61
       61
       +
           });

     

       65
       62
        
       

     

       66
       63
        
         } catch (error) {

     

       67
       64
        
           logger.error({ err: error }, 'Internal server error in listLatticesHandler');

+126

src/api/schemas.ts

···

       1
       1
       +
       import { query, object, string, integer, optional, array, didString, resourceUriString, datetimeString, constrain, integerRange } from '@atcute/lexicons/validations';

     

       2
       2
       +
       

     

       3
       3
       +
       const commonParams = {

     

       4
       4
       +
         limit: optional(constrain(integer(), [integerRange(1, 100)]), 50),

     

       5
       5
       +
         cursor: optional(string()),

     

       6
       6
       +
       };

     

       7
       7
       +
       

     

       8
       8
       +
       export const listInvitesSchema = query('systems.gmstn.development.channel.listInvites', {

     

       9
       9
       +
         params: object({

     

       10
       10
       +
           recipient: didString(),

     

       11
       11
       +
           limit: optional(constrain(integer(), [integerRange(1, 100)]), 50),

     

       12
       12
       +
           cursor: optional(string()),

     

       13
       13
       +
         }),

     

       14
       14
       +
         output: {

     

       15
       15
       +
           type: 'lex',

     

       16
       16
       +
           schema: object({

     

       17
       17
       +
             cursor: optional(string()),

     

       18
       18
       +
             invites: array(object({

     

       19
       19
       +
               uri: string(),

     

       20
       20
       +
               cid: string(),

     

       21
       21
       +
               author: didString(),

     

       22
       22
       +
               channel: object({

     

       23
       23
       +
                 uri: resourceUriString(),

     

       24
       24
       +
                 cid: string(),

     

       25
       25
       +
               }),

     

       26
       26
       +
               createdAt: datetimeString(),

     

       27
       27
       +
             })),

     

       28
       28
       +
           }),

     

       29
       29
       +
         },

     

       30
       30
       +
       });

     

       31
       31
       +
       

     

       32
       32
       +
       export const listChannelsSchema = query('systems.gmstn.development.channel.listChannels', {

     

       33
       33
       +
         params: object({

     

       34
       34
       +
           author: didString(),

     

       35
       35
       +
           limit: optional(constrain(integer(), [integerRange(1, 100)]), 50),

     

       36
       36
       +
           cursor: optional(string()),

     

       37
       37
       +
         }),

     

       38
       38
       +
         output: {

     

       39
       39
       +
           type: 'lex',

     

       40
       40
       +
           schema: object({

     

       41
       41
       +
             cursor: optional(string()),

     

       42
       42
       +
             channels: array(object({

     

       43
       43
       +
               uri: resourceUriString(),

     

       44
       44
       +
               cid: string(),

     

       45
       45
       +
               author: didString(),

     

       46
       46
       +
               displayName: string(),

     

       47
       47
       +
               description: optional(string()),

     

       48
       48
       +
               createdAt: datetimeString(),

     

       49
       49
       +
               indexedAt: datetimeString(),

     

       50
       50
       +
             })),

     

       51
       51
       +
           }),

     

       52
       52
       +
         },

     

       53
       53
       +
       });

     

       54
       54
       +
       

     

       55
       55
       +
       export const listMembershipsSchema = query('systems.gmstn.development.channel.listMemberships', {

     

       56
       56
       +
         params: object({

     

       57
       57
       +
           recipient: didString(),

     

       58
       58
       +
           limit: optional(constrain(integer(), [integerRange(1, 100)]), 50),

     

       59
       59
       +
           cursor: optional(string()),

     

       60
       60
       +
         }),

     

       61
       61
       +
         output: {

     

       62
       62
       +
           type: 'lex',

     

       63
       63
       +
           schema: object({

     

       64
       64
       +
             cursor: optional(string()),

     

       65
       65
       +
             memberships: array(object({

     

       66
       66
       +
               uri: string(),

     

       67
       67
       +
               cid: string(),

     

       68
       68
       +
               state: string(),

     

       69
       69
       +
               createdAt: datetimeString(),

     

       70
       70
       +
               updatedAt: datetimeString(),

     

       71
       71
       +
               channel: object({

     

       72
       72
       +
                 uri: resourceUriString(),

     

       73
       73
       +
                 cid: string(),

     

       74
       74
       +
               }),

     

       75
       75
       +
               invite: object({

     

       76
       76
       +
                 uri: resourceUriString(),

     

       77
       77
       +
                 cid: string(),

     

       78
       78
       +
               }),

     

       79
       79
       +
             })),

     

       80
       80
       +
           }),

     

       81
       81
       +
         },

     

       82
       82
       +
       });

     

       83
       83
       +
       

     

       84
       84
       +
       export const listLatticesSchema = query('systems.gmstn.development.lattice.listLattices', {

     

       85
       85
       +
         params: object({

     

       86
       86
       +
           author: didString(),

     

       87
       87
       +
           limit: optional(constrain(integer(), [integerRange(1, 100)]), 50),

     

       88
       88
       +
           cursor: optional(string()),

     

       89
       89
       +
         }),

     

       90
       90
       +
         output: {

     

       91
       91
       +
           type: 'lex',

     

       92
       92
       +
           schema: object({

     

       93
       93
       +
             cursor: optional(string()),

     

       94
       94
       +
             lattices: array(object({

     

       95
       95
       +
               uri: resourceUriString(),

     

       96
       96
       +
               cid: string(),

     

       97
       97
       +
               author: didString(),

     

       98
       98
       +
               description: optional(string()),

     

       99
       99
       +
               createdAt: datetimeString(),

     

       100
       100
       +
               indexedAt: datetimeString(),

     

       101
       101
       +
             })),

     

       102
       102
       +
           }),

     

       103
       103
       +
         },

     

       104
       104
       +
       });

     

       105
       105
       +
       

     

       106
       106
       +
       export const listShardsSchema = query('systems.gmstn.development.shard.listShards', {

     

       107
       107
       +
         params: object({

     

       108
       108
       +
           author: didString(),

     

       109
       109
       +
           limit: optional(constrain(integer(), [integerRange(1, 100)]), 50),

     

       110
       110
       +
           cursor: optional(string()),

     

       111
       111
       +
         }),

     

       112
       112
       +
         output: {

     

       113
       113
       +
           type: 'lex',

     

       114
       114
       +
           schema: object({

     

       115
       115
       +
             cursor: optional(string()),

     

       116
       116
       +
             shards: array(object({

     

       117
       117
       +
               uri: resourceUriString(),

     

       118
       118
       +
               cid: string(),

     

       119
       119
       +
               author: didString(),

     

       120
       120
       +
               description: optional(string()),

     

       121
       121
       +
               createdAt: datetimeString(),

     

       122
       122
       +
               indexedAt: datetimeString(),

     

       123
       123
       +
             })),

     

       124
       124
       +
           }),

     

       125
       125
       +
         },

     

       126
       126
       +
       });

+9 -12

src/api/shard.ts

···

       1
       1
       -
       import * as xrpc from '@atproto/xrpc-server';

     

       1
       1
       +
       import { InvalidRequestError, json } from '@atcute/xrpc-server';

     

       2
       2
        
       import { db } from '../db';

     

       3
       3
        
       import { parseLimit } from '../util/params';

     

       4
       4
        
       import { logger } from '../util/logger';

     

       5
       5
        
       

     

       6
       6
        
       export async function listShardsHandler(ctx: {

     

       7
       7
       -
         params: xrpc.Params;

     

       7
       7
       +
         params: any;

     

       8
       8
        
       }) {

     

       9
       9
        
         try {

     

       10
       10
        
           const { limit: rawLimit, cursor, author } = ctx.params;

     

       11
       11
        
           const limit = parseLimit(rawLimit);

     

       12
       12
        
       

     

       13
       13
        
           if (!author) {

     

       14
       14
       -
             throw new xrpc.InvalidRequestError('Missing required parameter: author');

     

       14
       14
       +
             throw new InvalidRequestError({ description: 'Missing required parameter: author' });

     

       15
       15
        
           }

     

       16
       16
        
       

     

       17
       17
        
           if (typeof author !== 'string') {

     

       18
       18
       -
             throw new xrpc.InvalidRequestError('Parameter "author" must be a string');

     

       18
       18
       +
             throw new InvalidRequestError({ description: 'Parameter "author" must be a string' });

     

       19
       19
        
           }

     

       20
       20
        
       

     

       21
       21
        
           let query = db

     
···

       34
       34
        
       

     

       35
       35
        
           if (cursor) {

     

       36
       36
        
             if (typeof cursor !== 'string') {

     

       37
       37
       -
               throw new xrpc.InvalidRequestError('Parameter "cursor" must be a string');

     

       37
       37
       +
               throw new InvalidRequestError({ description: 'Parameter "cursor" must be a string' });

     

       38
       38
        
             }

     

       39
       39
        
             query = query.where('indexed_at', '<', new Date(cursor));

     

       40
       40
        
           }

     
···

       55
       55
        
           const lastResult = results.at(-1);

     

       56
       56
        
           const nextCursor = lastResult ? lastResult.indexed_at.toISOString() : undefined;

     

       57
       57
        
       

     

       58
       58
       -
           return {

     

       59
       59
       -
             encoding: 'application/json',

     

       60
       60
       -
             body: {

     

       61
       61
       -
               shards,

     

       62
       62
       -
               cursor: nextCursor,

     

       63
       63
       -
             },

     

       64
       64
       -
           };

     

       58
       58
       +
           return json({

     

       59
       59
       +
             shards,

     

       60
       60
       +
             cursor: nextCursor,

     

       61
       61
       +
           });

     

       65
       62
        
       

     

       66
       63
        
         } catch (error) {

     

       67
       64
        
           logger.error({ err: error }, 'Internal server error in listShardsHandler');

+49 -28

src/services/api.ts

···

       1
       1
       -
       import { db, pool } from 'db';

     

       1
       1
       +
       import { db } from 'db';

     

       2
       2
        
       import { logger } from '../util/logger';

     

       3
       3
       -
       import express from 'express';

     

       4
       4
       -
       import helmet from 'helmet';

     

       5
       5
       -
       import compression from 'compression';

     

       6
       6
       -
       import * as http from 'http';

     

       7
       3
        
       import { createServer } from '../api';

     

       8
       8
       -
       import { createWebSocketServer, closeAllClients } from './websocket';

     

       4
       4
       +
       import { websocketHandler as customWsHandler, closeAllClients } from './websocket';

     

       9
       5
        
       import { setupQueueListener, processQueue, setShuttingDown } from './queue';

     

       10
       6
        
       

     

       11
       11
       -
       const server = createServer();

     

       7
       7
       +
       type WebSocketData = { type: 'custom' } | { controller: any; handler: any };

     

       12
       8
        
       

     

       13
       13
       -
       const app = express();

     

       14
       14
       -
       app.use(helmet());

     

       15
       15
       -
       app.use(compression());

     

       16
       16
       -
       app.use(server.router);

     

       9
       9
       +
       const bunConfig = createServer();

     

       17
       10
        
       

     

       18
       18
       -
       const httpServer = http.createServer(app);

     

       19
       19
       -
       createWebSocketServer(httpServer);

     

       11
       11
       +
       const server = Bun.serve<WebSocketData>({

     

       12
       12
       +
         port: 3000,

     

       13
       13
       +
         fetch(req, server) {

     

       14
       14
       +
           const url = new URL(req.url);

     

       15
       15
       +
           if (!url.pathname.startsWith('/xrpc/')) {

     

       16
       16
       +
              if (server.upgrade(req, { data: { type: 'custom' } })) {

     

       17
       17
       +
                return undefined;

     

       18
       18
       +
              }

     

       19
       19
       +
           }

     

       20
       20
        
       

     

       21
       21
       -
       let queuePoller: ReturnType<typeof setInterval>;

     

       22
       22
       -
       

     

       23
       23
       -
       httpServer.listen(3000, () => {

     

       24
       24
       -
         logger.info('XRPC server running on http://localhost:3000');

     

       25
       25
       -
         logger.info('WebSocket server initialized and listening.');

     

       21
       21
       +
           return bunConfig.fetch(req, server as any);

     

       22
       22
       +
         },

     

       23
       23
       +
         websocket: {

     

       24
       24
       +
           open(ws) {

     

       25
       25
       +
             if (ws.data && (ws.data as any).type === 'custom') {

     

       26
       26
       +
               customWsHandler.open(ws as any);

     

       27
       27
       +
             } else {

     

       28
       28
       +
               bunConfig.websocket.open?.(ws as any);

     

       29
       29
       +
             }

     

       30
       30
       +
           },

     

       31
       31
       +
           close(ws, code, reason) {

     

       32
       32
       +
             if (ws.data && (ws.data as any).type === 'custom') {

     

       33
       33
       +
               customWsHandler.close(ws as any);

     

       34
       34
       +
             } else {

     

       35
       35
       +
               bunConfig.websocket.close?.(ws as any, code, reason);

     

       36
       36
       +
             }

     

       37
       37
       +
           },

     

       38
       38
       +
           message(ws, message) {

     

       39
       39
       +
             if (ws.data && (ws.data as any).type === 'custom') {

     

       40
       40
       +
               customWsHandler.message(ws as any, message);

     

       41
       41
       +
             } else {

     

       42
       42
       +
               bunConfig.websocket.message?.(ws as any, message);

     

       43
       43
       +
             }

     

       44
       44
       +
           },

     

       45
       45
       +
           drain(ws) {

     

       46
       46
       +
              if (bunConfig.websocket.drain) bunConfig.websocket.drain(ws as any);

     

       47
       47
       +
           }

     

       48
       48
       +
         }

     

       49
       49
       +
       });

     

       26
       50
        
       

     

       27
       27
       -
         setupQueueListener();

     

       51
       51
       +
       logger.info('XRPC server running on http://localhost:3000');

     

       52
       52
       +
       logger.info('WebSocket server initialized and listening.');

     

       28
       53
        
       

     

       29
       29
       -
         processQueue();

     

       54
       54
       +
       setupQueueListener();

     

       55
       55
       +
       processQueue();

     

       30
       56
        
       

     

       31
       31
       -
         // Heartbeat / Fallback poller (every 30s)

     

       32
       32
       -
         queuePoller = setInterval(processQueue, 30000);

     

       33
       33
       -
       });

     

       57
       57
       +
       const queuePoller = setInterval(processQueue, 30000);

     

       34
       58
        
       

     

       35
       59
        
       const shutdown = async () => {

     

       36
       60
        
         logger.info('Shutting down server...');

     
···

       38
       62
        
         setShuttingDown(true);

     

       39
       63
        
         clearInterval(queuePoller);

     

       40
       64
        
       

     

       41
       41
       -
         httpServer.close(() => {

     

       42
       42
       -
           logger.info('HTTP server closed');

     

       43
       43
       -
         });

     

       65
       65
       +
         server.stop();

     

       66
       66
       +
         logger.info('HTTP server closed');

     

       44
       67
        
       

     

       45
       68
        
         closeAllClients();

     

       46
       69
        
       

     

       47
       70
        
         try {

     

       48
       48
       -
           await pool.end();

     

       49
       49
       -
           logger.info('Database pool closed');

     

       50
       71
        
           await db.destroy();

     

       51
       72
        
           logger.info('Kysely instance destroyed');

     

       52
       73
        
         } catch (err) {

+18 -29

src/services/websocket.ts

···

       1
       1
       -
       import { WebSocketServer, WebSocket } from 'ws';

     

       1
       1
       +
       import { ServerWebSocket } from 'bun';

     

       2
       2
        
       import { logger } from '../util/logger';

     

       3
       3
       -
       import * as http from 'http';

     

       4
       3
        
       

     

       5
       5
       -
       const clients = new Set<WebSocket>();

     

       6
       6
       -
       

     

       7
       7
       -
       export function createWebSocketServer(server: http.Server) {

     

       8
       8
       -
         const wss = new WebSocketServer({ server });

     

       4
       4
       +
       const clients = new Set<ServerWebSocket<any>>();

     

       9
       5
        
       

     

       10
       10
       -
         wss.on('connection', (ws) => {

     

       6
       6
       +
       export const websocketHandler = {

     

       7
       7
       +
         open(ws: ServerWebSocket<any>) {

     

       11
       8
        
           logger.info('WebSocket client connected');

     

       12
       12
       -
       

     

       13
       9
        
           clients.add(ws);

     

       14
       14
       -
       

     

       15
       15
       -
           ws.on('close', () => {

     

       16
       16
       -
             logger.info('WebSocket client disconnected');

     

       17
       17
       -
             clients.delete(ws);

     

       18
       18
       -
           });

     

       19
       19
       -
       

     

       20
       20
       -
           ws.on('error', (err) => {

     

       21
       21
       -
             logger.error({ err }, 'WebSocket error');

     

       22
       22
       -
             clients.delete(ws);

     

       23
       23
       -
           });

     

       24
       24
       -
         });

     

       25
       25
       -
       

     

       26
       26
       -
         return wss;

     

       27
       27
       -
       }

     

       10
       10
       +
         },

     

       11
       11
       +
         close(ws: ServerWebSocket<any>) {

     

       12
       12
       +
           logger.info('WebSocket client disconnected');

     

       13
       13
       +
           clients.delete(ws);

     

       14
       14
       +
         },

     

       15
       15
       +
         message(_ws: ServerWebSocket<any>, _message: string | Buffer) {

     

       16
       16
       +
           // We don't expect messages from clients for now

     

       17
       17
       +
         },

     

       18
       18
       +
       };

     

       28
       19
        
       

     

       29
       20
        
       export function broadcast(data: any) {

     

       30
       21
        
         const message = JSON.stringify(data);

     

       31
       22
        
         clients.forEach((client) => {

     

       32
       32
       -
           if (client.readyState === WebSocket.OPEN) {

     

       33
       33
       -
             try {

     

       34
       34
       -
               client.send(message);

     

       35
       35
       -
             } catch (e: any) {

     

       36
       36
       -
               logger.error({ err: e }, 'Failed to send message to client');

     

       37
       37
       -
             }

     

       23
       23
       +
           try {

     

       24
       24
       +
             client.send(message);

     

       25
       25
       +
           } catch (e: any) {

     

       26
       26
       +
             logger.error({ err: e }, 'Failed to send message to client');

     

       38
       27
        
           }

     

       39
       28
        
         });

     

       40
       29
        
       }

     

       41
       30
        
       

     

       42
       31
        
       export function closeAllClients() {

     

       43
       32
        
         for (const client of clients) {

     

       44
       44
       -
           client.terminate();

     

       33
       33
       +
           client.close();

     

       45
       34
        
         }

     

       46
       35
        
         clients.clear();

     

       47
       36
        
       }