{"_id":"@atcute/jetstream","_rev":"12-acb6fa9d287b0c5be27888c47ef1fb9b","name":"@atcute/jetstream","dist-tags":{"latest":"2.2.0"},"versions":{"1.0.0":{"name":"@atcute/jetstream","version":"1.0.0","license":"MIT","_id":"@atcute/jetstream@1.0.0","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"homepage":"https://github.com/mary-ext/atcute#readme","bugs":{"url":"https://github.com/mary-ext/atcute/issues"},"dist":{"shasum":"5a40a1433ebdff7ae58135af03c5911b2b7f5994","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.0.0.tgz","fileCount":15,"integrity":"sha512-wd0+5gFubmSYFpQGWa5rUhxEMb8gHADalcTtr3QkRKtdBcXNKKlOXPutHcjKWkHa8GLuOEnZXm7sub3f0xz1yQ==","signatures":[{"sig":"MEUCIEN6k6tZc06GP2JB3Cl1FSrpd/nRwMAw0lOLCY0EQGCtAiEAvRhS5w89N0W/fcjjLqmYXqlhVXH64Rvz3f2QDW0drSQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":43314},"type":"module","_from":"file:atcute-jetstream-1.0.0.tgz","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run --coverage","build":"tsc --project tsconfig.build.json","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"_resolved":"/tmp/f8c52db70248c6dd9a6c24120537afdb/atcute-jetstream-1.0.0.tgz","_integrity":"sha512-wd0+5gFubmSYFpQGWa5rUhxEMb8gHADalcTtr3QkRKtdBcXNKKlOXPutHcjKWkHa8GLuOEnZXm7sub3f0xz1yQ==","repository":{"url":"git+https://github.com/mary-ext/atcute.git","directory":"packages/core/jetstream"},"_npmVersion":"11.3.0","description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"24.0.1","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.4","yocto-queue":"^1.2.1","@badrap/valita":"^0.4.2","@atcute/lexicons":"^1.0.0","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.0"},"_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.0.4","@vitest/coverage-v8":"^3.0.4"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.0.0_1747186945136_0.9281543671268826","host":"s3://npm-registry-packages-npm-production"}},"1.0.1":{"name":"@atcute/jetstream","version":"1.0.1","license":"MIT","_id":"@atcute/jetstream@1.0.1","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"homepage":"https://github.com/mary-ext/atcute#readme","bugs":{"url":"https://github.com/mary-ext/atcute/issues"},"dist":{"shasum":"606c32425849f7d2014fe4245ceb3728000fc177","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.0.1.tgz","fileCount":15,"integrity":"sha512-zF6OjI/a/RX/b6DMJ4lG4kYg9fvW+fhmsIssnh9CUNpR00hYpNE6YMb3YYjGeaasaZXgAUdzm8+VRoHkZmWBkQ==","signatures":[{"sig":"MEUCIQD3H77SgeHvo76WEykfId1BgEKJe/9WqkHjffCoHiDdTwIgQczxh9G4f22CRgfJu8N3HpMFUW4Cdl+HI9tAewpOsog=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":43317},"type":"module","_from":"file:atcute-jetstream-1.0.1.tgz","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run --coverage","build":"tsc --project tsconfig.build.json","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"_resolved":"/tmp/a4caecd167b719481d0c438cb20a73f2/atcute-jetstream-1.0.1.tgz","_integrity":"sha512-zF6OjI/a/RX/b6DMJ4lG4kYg9fvW+fhmsIssnh9CUNpR00hYpNE6YMb3YYjGeaasaZXgAUdzm8+VRoHkZmWBkQ==","repository":{"url":"git+https://github.com/mary-ext/atcute.git","directory":"packages/clients/jetstream"},"_npmVersion":"11.3.0","description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"24.0.1","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.4","yocto-queue":"^1.2.1","@badrap/valita":"^0.4.2","@atcute/lexicons":"^1.0.1","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.0"},"_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.0.4","@vitest/coverage-v8":"^3.0.4"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.0.1_1747444078588_0.8729948804694789","host":"s3://npm-registry-packages-npm-production"}},"1.0.2":{"name":"@atcute/jetstream","version":"1.0.2","license":"MIT","_id":"@atcute/jetstream@1.0.2","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"homepage":"https://github.com/mary-ext/atcute#readme","bugs":{"url":"https://github.com/mary-ext/atcute/issues"},"dist":{"shasum":"3f06881da40a23383a3a08b9d0cd9772469ecf74","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.0.2.tgz","fileCount":15,"integrity":"sha512-ZtdNNxl4zq9cgUpXSL9F+AsXUZt0Zuyj0V7974D7LxdMxfTItPnMZ9dRG8GoFkkGz3+pszdsG888Ix8C0F2+mA==","signatures":[{"sig":"MEYCIQCS2xkIPup+BaEu9C91SAZVOIP+ZFzh7IxmO4oTmd62UAIhANpKpYsTFQCZzD0xStnoq6LO3Li6y/32WDtff3QLwORR","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":43317},"type":"module","_from":"file:atcute-jetstream-1.0.2.tgz","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run --coverage","build":"tsc --project tsconfig.build.json","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"_resolved":"/tmp/6f65f850d944776d84f9b68d07ce5a1a/atcute-jetstream-1.0.2.tgz","_integrity":"sha512-ZtdNNxl4zq9cgUpXSL9F+AsXUZt0Zuyj0V7974D7LxdMxfTItPnMZ9dRG8GoFkkGz3+pszdsG888Ix8C0F2+mA==","repository":{"url":"git+https://github.com/mary-ext/atcute.git","directory":"packages/clients/jetstream"},"_npmVersion":"11.3.0","description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"24.0.1","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.4","yocto-queue":"^1.2.1","@badrap/valita":"^0.4.2","@atcute/lexicons":"^1.0.2","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.0"},"_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.0.4","@vitest/coverage-v8":"^3.0.4"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.0.2_1747714979290_0.36317711139029685","host":"s3://npm-registry-packages-npm-production"}},"1.1.0":{"name":"@atcute/jetstream","version":"1.1.0","license":"0BSD","_id":"@atcute/jetstream@1.1.0","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"homepage":"https://github.com/mary-ext/atcute#readme","bugs":{"url":"https://github.com/mary-ext/atcute/issues"},"dist":{"shasum":"e3e7b96e41f8f69664c95f603dae452e050dd797","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.1.0.tgz","fileCount":15,"integrity":"sha512-XrSeEHLt2FnVNm3KBDQYY7+rWM0IQKBjLQUjdoCj4mnkMCdm3/dC09qs5ubQQGrHieUWeKHHEko/D6EB891hPg==","signatures":[{"sig":"MEQCIEIG324MriSV5oAgJEsH/8heQnYcfv7GPEG+Ro9V8P9uAiBNdAub23ei7aklnXHMhigqlQHsI4ac5t0Mv46dwS+01g==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":45863},"type":"module","_from":"file:atcute-jetstream-1.1.0.tgz","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run --coverage","build":"tsc --project tsconfig.build.json","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"_resolved":"/tmp/b0bb95ff071e8db3d8cc7bea25e3ede5/atcute-jetstream-1.1.0.tgz","_integrity":"sha512-XrSeEHLt2FnVNm3KBDQYY7+rWM0IQKBjLQUjdoCj4mnkMCdm3/dC09qs5ubQQGrHieUWeKHHEko/D6EB891hPg==","repository":{"url":"git+https://github.com/mary-ext/atcute.git","directory":"packages/clients/jetstream"},"_npmVersion":"10.9.2","description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"22.17.1","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.5","yocto-queue":"^1.2.1","@badrap/valita":"^0.4.6","@atcute/lexicons":"^1.1.1","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.0"},"_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.2.4","@vitest/coverage-v8":"^3.2.4"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.1.0_1757168618597_0.998355451769684","host":"s3://npm-registry-packages-npm-production"}},"1.1.1":{"name":"@atcute/jetstream","version":"1.1.1","license":"0BSD","_id":"@atcute/jetstream@1.1.1","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"homepage":"https://github.com/mary-ext/atcute#readme","bugs":{"url":"https://github.com/mary-ext/atcute/issues"},"dist":{"shasum":"d91b5331a0f5007e924904d29c9fb13179b355ae","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.1.1.tgz","fileCount":18,"integrity":"sha512-kRfB1AyCnp4pX61u+9PlKe8vBHLLYnZ/YZHOavUsFLtlkCDauFCY7ObCG5JXvZMsTQ9t6vh1ocOjKS5jVuJ2Rw==","signatures":[{"sig":"MEUCIQCCz+bdz2cL2ZHc8kkWFQKHzNA4nO7fwcd40cV0/EkPvgIgNUamnxJTWV6abzPymbFqSNhw1gf+6tI4rNU7wPrFTk8=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":52766},"type":"module","_from":"file:atcute-jetstream-1.1.1.tgz","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run --coverage","build":"tsc --project tsconfig.build.json","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"_resolved":"/tmp/6ab4e2196e28dd3fa09bc88043d949ff/atcute-jetstream-1.1.1.tgz","_integrity":"sha512-kRfB1AyCnp4pX61u+9PlKe8vBHLLYnZ/YZHOavUsFLtlkCDauFCY7ObCG5JXvZMsTQ9t6vh1ocOjKS5jVuJ2Rw==","repository":{"url":"git+https://github.com/mary-ext/atcute.git","directory":"packages/clients/jetstream"},"_npmVersion":"10.9.2","description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"22.17.1","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.5","yocto-queue":"^1.2.1","@badrap/valita":"^0.4.6","@atcute/lexicons":"^1.2.2","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.0"},"_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.2.4","@vitest/coverage-v8":"^3.2.4"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.1.1_1760012833906_0.8554135349233245","host":"s3://npm-registry-packages-npm-production"}},"1.1.2":{"name":"@atcute/jetstream","version":"1.1.2","license":"0BSD","_id":"@atcute/jetstream@1.1.2","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"homepage":"https://github.com/mary-ext/atcute#readme","bugs":{"url":"https://github.com/mary-ext/atcute/issues"},"dist":{"shasum":"a358c3d1085fe19436daf5c158fa808167c65b9e","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.1.2.tgz","fileCount":23,"integrity":"sha512-u6p/h2xppp7LE6W/9xErAJ6frfN60s8adZuCKtfAaaBBiiYbb1CfpzN8Uc+2qtJZNorqGvuuDb5572Jmh7yHBQ==","signatures":[{"sig":"MEUCIHKvJVJXerZjWG++Vbide0OrOSLph80gGWYkms0Kgg5NAiEAn6DE7C593rm+tcJ5PYnquMAmiCbUYdccT1X0lu70OmI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":35476},"type":"module","_from":"file:atcute-jetstream-1.1.2.tgz","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run --coverage","build":"tsc --project tsconfig.build.json","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"_resolved":"/tmp/faa4a7dbe28215972425eebc346a6694/atcute-jetstream-1.1.2.tgz","_integrity":"sha512-u6p/h2xppp7LE6W/9xErAJ6frfN60s8adZuCKtfAaaBBiiYbb1CfpzN8Uc+2qtJZNorqGvuuDb5572Jmh7yHBQ==","repository":{"url":"git+https://github.com/mary-ext/atcute.git","directory":"packages/clients/jetstream"},"_npmVersion":"10.9.3","description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"22.20.0","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.5","yocto-queue":"^1.2.1","@badrap/valita":"^0.4.6","@atcute/lexicons":"^1.2.2","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.0"},"_hasShrinkwrap":false,"devDependencies":{"vitest":"^3.2.4","@vitest/coverage-v8":"^3.2.4"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.1.2_1761365020884_0.30029129893236606","host":"s3://npm-registry-packages-npm-production"}},"1.1.3":{"name":"@atcute/jetstream","version":"1.1.3","license":"0BSD","_id":"@atcute/jetstream@1.1.3","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"dist":{"shasum":"649aa95dfc6132f2e2c6f766582ee956825185ff","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-1.1.3.tgz","fileCount":23,"integrity":"sha512-IlivviByHDKEC+qsfBL2DSHx9MkJxH0vsoYKc0ouZ8HKwXzR/GSwyjZ8TKb2KyVzbVfh1UPifLW9E3lCoGqaOw==","signatures":[{"sig":"MEUCIAefamQCJf5OTziLTyybwa9c6MQB55sGvFIM+zqflOQTAiEAhw9WUhnMGsV+jr4lGAyANmlZgc1daz5U3ujuXJhlhuI=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":40812},"type":"module","exports":{".":"./dist/index.js"},"scripts":{"build":"tsgo","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"repository":{"url":"https://github.com/mary-ext/atcute","directory":"packages/clients/jetstream"},"description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"26.0.0","dependencies":{"type-fest":"^4.41.0","partysocket":"^1.1.18","@badrap/valita":"^0.4.6","@atcute/lexicons":"^1.3.1","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"@atcute/lexicons":"^1.0.0"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_1.1.3_1778205565738_0.40767302755295565","host":"s3://npm-registry-packages-npm-production"}},"2.0.0":{"name":"@atcute/jetstream","version":"2.0.0","license":"0BSD","_id":"@atcute/jetstream@2.0.0","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"dist":{"shasum":"b44bc9dfd4e6ad7c453d1bfa3a5243b08060b0dc","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-2.0.0.tgz","fileCount":18,"integrity":"sha512-mlFxoQSi5PwF/8NfIdML7C/tH3sN2vZWUP1y4/oBlivVFD93hERaJWKnb3L7NII0iksbqvfs3FW0ylFw6VuAXg==","signatures":[{"sig":"MEUCIC8poxkxXhdavUYh9Z8PXnHGT9rPaY0QPIk5MG4JIxWWAiEAxarVwV6NPIWFEiQaTUGTcjMjCKKkfPZw2RoSnGxwMYQ=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":54334},"type":"module","exports":{".":"./dist/index.js"},"scripts":{"build":"tsgo","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"repository":{"url":"https://github.com/mary-ext/atcute","directory":"packages/clients/jetstream"},"description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"26.0.0","dependencies":{"valibot":"^1.4.0","type-fest":"^4.41.0","partysocket":"^1.1.18","@atcute/lexicons":"^2.0.0","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.1"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"@atcute/lexicons":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_2.0.0_1778312757538_0.18609757704115815","host":"s3://npm-registry-packages-npm-production"}},"2.0.1":{"name":"@atcute/jetstream","version":"2.0.1","license":"0BSD","_id":"@atcute/jetstream@2.0.1","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"dist":{"shasum":"d0a17990256a8fb73cb729fa5265cc9aa9d98a08","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-2.0.1.tgz","fileCount":9,"integrity":"sha512-F+rzT+UsGt/l/Km89G0BJNYWBW4PyA4rOhJH4jw1XyCKhp/qjhajQxPWTaRIyoCdBbipdzPJm1jenrlUH0kyDQ==","signatures":[{"sig":"MEUCIQDDGkoL5Egb31P4vG3olZaOyBqTCRvt43YSlZ50a5ZmqQIgGDaE3aAfkM1os2m/75M5Gy8fsFP5xaj47SzoYTvoe7w=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":33719},"type":"module","exports":{".":"./dist/index.js"},"scripts":{"build":"tsgo","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"repository":{"url":"https://github.com/mary-ext/atcute","directory":"packages/clients/jetstream"},"description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"26.0.0","dependencies":{"valibot":"^1.4.1","type-fest":"^4.41.0","partysocket":"^1.3.0","@atcute/lexicons":"^2.0.2","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.2"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"peerDependencies":{"@atcute/lexicons":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_2.0.1_1782736414057_0.35000736099084717","host":"s3://npm-registry-packages-npm-production"}},"2.0.2":{"name":"@atcute/jetstream","version":"2.0.2","license":"0BSD","_id":"@atcute/jetstream@2.0.2","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"dist":{"shasum":"3be12e769f41b6c659743ab89acd6d36758c56a1","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-2.0.2.tgz","fileCount":9,"integrity":"sha512-gKykCWhSkTM6liv/zcpArCIb7s2iGKZupXqspHXmkNoZWCC42/eipXtaos6y2BBRucxV6HNSbK4MU9yv9zesEw==","signatures":[{"sig":"MEQCICCbO0xvnNrlCxsNSXWpmiYXLblpjGIq+fa3EA6RZS/VAiBOpd/KscJiBjhfHGc/OMFqS+nesf7zE6iYqrcgiE5dYw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":34051},"type":"module","exports":{".":"./dist/index.js"},"scripts":{"test":"vitest run","build":"tsc","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"repository":{"url":"https://github.com/mary-ext/atcute","directory":"packages/clients/jetstream"},"description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"_nodeVersion":"26.0.0","dependencies":{"valibot":"^1.4.2","type-fest":"^4.41.0","partysocket":"^1.3.0","@atcute/lexicons":"^2.0.3","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.2"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"devDependencies":{"ws":"^8.21.0","vitest":"^4.1.10","@types/ws":"^8.18.1"},"peerDependencies":{"@atcute/lexicons":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_2.0.2_1784160604938_0.6623880526220614","host":"s3://npm-registry-packages-npm-production"}},"2.1.0":{"name":"@atcute/jetstream","version":"2.1.0","license":"0BSD","_id":"@atcute/jetstream@2.1.0","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"dist":{"shasum":"c706e492ef93631fdc049d984acb2119117ac281","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-2.1.0.tgz","fileCount":27,"integrity":"sha512-tuqic15rttzhFNsjBHJVASjVq6RekZccEaXdr/X/qdJbhBF2Plfmabw+lx4bDiT4g7D4sRopbwrcHxRLC9iDNg==","signatures":[{"sig":"MEYCIQDD4KyUjpf1ANnsu+DLL7BGYrqcurNHIsXIkrqtksGrkAIhAIXsAxDLcSfsyO8BjF4NXvqE81YeHEQR7/C945Khxxbm","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":78985},"type":"module","exports":{".":"./dist/index.js","./types/*":"./dist/lexicons/types/network/bsky/jetstream/*.js"},"scripts":{"pull":"lex-cli pull","test":"vitest run","build":"tsc","generate":"lex-cli generate","prepublish":"rm -rf dist; pnpm run build"},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"repository":{"url":"https://tangled.org/did:plc:pljn5qch4tgadongtc7i6qij","directory":"packages/clients/jetstream"},"description":"lightweight and cute Jetstream subscriber for AT Protocol","directories":{},"sideEffects":false,"_nodeVersion":"26.0.0","dependencies":{"valibot":"^1.4.2","type-fest":"^4.41.0","partysocket":"^1.3.0","@atcute/atproto":"^4.0.4","@atcute/lexicons":"^2.1.0","@mary-ext/event-iterator":"^1.0.0","@mary-ext/simple-event-emitter":"^1.0.2"},"publishConfig":{"access":"public"},"_hasShrinkwrap":false,"atcute:lexicons":{"mappings":{"network.bsky.jetstream.*":{"path":"./types/{{nsid_remainder}}","type":"namespace"}}},"devDependencies":{"ws":"^8.21.3","vitest":"^4.1.10","@types/ws":"^8.18.1","@atcute/lex-cli":"^3.3.0"},"peerDependencies":{"@atcute/lexicons":"^2.0.0"},"_npmOperationalInternal":{"tmp":"tmp/jetstream_2.1.0_1787124903531_0.2594242344703037","host":"s3://npm-registry-packages-npm-production"}},"2.2.0":{"name":"@atcute/jetstream","version":"2.2.0","description":"lightweight and cute Jetstream subscriber for AT Protocol","license":"0BSD","repository":{"url":"https://tangled.org/did:plc:pljn5qch4tgadongtc7i6qij","directory":"packages/clients/jetstream"},"type":"module","sideEffects":false,"exports":{".":"./dist/index.js","./types/*":"./dist/lexicons/types/network/bsky/jetstream/*.js"},"publishConfig":{"access":"public"},"dependencies":{"@atcute/atproto":"^4.0.4","@atcute/firehose":"^1.2.0","@atcute/lexicons":"^2.1.0","@mary-ext/event-iterator":"^1.1.0","@mary-ext/simple-event-emitter":"^1.0.2","partysocket":"^1.3.0","valibot":"^1.4.2"},"devDependencies":{"@atcute/lex-cli":"^3.3.0","@types/ws":"^8.18.1","vitest":"^4.1.11","ws":"^8.21.3"},"peerDependencies":{"@atcute/lexicons":"^2.0.0"},"atcute:lexicons":{"mappings":{"network.bsky.jetstream.*":{"type":"namespace","path":"./types/{{nsid_remainder}}"}}},"scripts":{"build":"tsc","generate":"lex-cli generate","pull":"lex-cli pull","test":"vitest run","prepublish":"rm -rf dist; pnpm run build"},"_id":"@atcute/jetstream@2.2.0","dist":{"integrity":"sha512-2Aux4AxUj+mRLNyI1L7kycZM/q9UuAF4pGcyuWVfGLrK95OgAe4BSyCn33HbuKidBYZPwQjDn+j6B8fz5cOUYg==","shasum":"b9bfc6bc7c5563d3475c49344d0f9c3a57566dae","tarball":"https://registry.npmjs.org/@atcute/jetstream/-/jetstream-2.2.0.tgz","fileCount":33,"unpackedSize":86351,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIQCMP7DzcaRwOi5MzKGh7nUaHqHN+nA37dZtPCk6Kav3aAIgfsBCqx7ipy1XMUPMipqBAlh+p90cAn1r789D6hqPInY="}]},"_npmUser":{"name":"externdefs","email":"hi@mary.my.id"},"directories":{},"maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/jetstream_2.2.0_1789047712869_0.9259277406170372"},"_hasShrinkwrap":false}},"time":{"created":"2025-05-14T01:42:25.024Z","modified":"2026-09-10T13:41:53.280Z","1.0.0":"2025-05-14T01:42:25.306Z","1.0.1":"2025-05-17T01:07:58.783Z","1.0.2":"2025-05-20T04:22:59.517Z","1.1.0":"2025-09-06T14:23:38.794Z","1.1.1":"2025-10-09T12:27:14.089Z","1.1.2":"2025-10-25T04:03:41.069Z","1.1.3":"2026-05-08T01:59:25.899Z","2.0.0":"2026-05-09T07:45:57.677Z","2.0.1":"2026-06-29T12:33:34.197Z","2.0.2":"2026-07-16T00:10:05.072Z","2.1.0":"2026-08-19T07:35:03.701Z","2.2.0":"2026-09-10T13:41:53.059Z"},"license":"0BSD","repository":{"url":"https://tangled.org/did:plc:pljn5qch4tgadongtc7i6qij","directory":"packages/clients/jetstream"},"description":"lightweight and cute Jetstream subscriber for AT Protocol","maintainers":[{"name":"externdefs","email":"hi@mary.my.id"}],"readme":"# @atcute/jetstream\n\nlightweight Jetstream subscriber for AT Protocol.\n\n```sh\nnpm install @atcute/jetstream\n```\n\n[Jetstream](https://docs.bsky.app/blog/jetstream) is a streaming service that delivers a filtered\nfirehose of AT Protocol events as JSON over WebSocket. this package provides a client to subscribe\nto those events.\n\n## usage\n\n### subscribing to events\n\n```ts\nimport { subscribeEvents } from '@atcute/jetstream';\n\nconst events = subscribeEvents({\n\tservice: 'wss://jetstream.us-east.bsky.network',\n});\n\nfor await (const message of events) {\n\tconsole.log(message.$type, message.seq, message.did);\n}\n```\n\nthe connection opens when iteration starts, reconnects automatically, and closes when iteration\nends. `service` accepts one host because v2 sequence cursors are specific to a Jetstream instance.\n\n### filtering\n\nfilters are combined and match everything when omitted or empty:\n\n```ts\nconst postEvents = subscribeEvents({\n\tservice: 'wss://jetstream.us-east.bsky.network',\n\tcollections: ['app.bsky.feed.post', 'app.bsky.graph.*'],\n\tdids: ['did:plc:z72i7hdynmk6r22z27h6tvur'],\n\tkinds: ['commit'],\n});\n```\n\n`collections` only filters commit events. combine it with `kinds: ['commit']` to exclude identity,\naccount, and sync events.\n\n### handling event types\n\nuse `$type` to narrow an event before accessing its fields:\n\n```ts\nfor await (const message of events) {\n\tswitch (message.$type) {\n\t\tcase 'network.bsky.jetstream.subscribeEvents#commit': {\n\t\t\tconsole.log(message.operation, message.collection, message.rkey, message.record);\n\t\t\tbreak;\n\t\t}\n\n\t\tcase 'network.bsky.jetstream.subscribeEvents#identity': {\n\t\t\tconsole.log(message.identity.handle);\n\t\t\tbreak;\n\t\t}\n\n\t\tcase 'network.bsky.jetstream.subscribeEvents#account': {\n\t\t\tconsole.log(message.account.active, message.account.status);\n\t\t\tbreak;\n\t\t}\n\n\t\tcase 'network.bsky.jetstream.subscribeEvents#sync': {\n\t\t\tconsole.log(message.sync.rev);\n\t\t\tbreak;\n\t\t}\n\t}\n}\n```\n\ncommit fields are placed directly on the message. identity, account, and sync messages wrap the\ncorresponding upstream relay event. event types unknown to this version of the package are skipped\nwithout advancing the cursor.\n\n### validating records\n\nevent envelopes are validated by default, but commit `record` values remain unvalidated JSON. narrow\nthem with `is()` from `@atcute/lexicons`:\n\n```ts\nimport { AppBskyFeedPost } from '@atcute/bluesky';\nimport { is } from '@atcute/lexicons';\n\nfor await (const message of events) {\n\tif (message.$type !== 'network.bsky.jetstream.subscribeEvents#commit') {\n\t\tcontinue;\n\t}\n\n\tif (is(AppBskyFeedPost.mainSchema, message.record)) {\n\t\tconsole.log(`@${message.did}: ${message.record.text}`);\n\t}\n}\n```\n\nset `validateEvents: false` to skip envelope validation. records must still be validated separately.\n\n### resuming from a cursor\n\npass a sequence number to start from, or a `CursorStore` to load and save the position:\n\n```ts\nimport { readFile, writeFile } from 'node:fs/promises';\n\nconst events = subscribeEvents({\n\tservice: 'wss://jetstream.us-east.bsky.network',\n\tcursor: {\n\t\tasync load() {\n\t\t\tconst saved = await readFile('cursor', 'utf8').catch(() => undefined);\n\t\t\treturn saved !== undefined ? Number(saved) : undefined;\n\t\t},\n\t\tasync save(seq) {\n\t\t\tawait writeFile('cursor', String(seq));\n\t\t},\n\t},\n});\n```\n\n`load` decides where the subscription starts, and it is consulted again on every reconnection rather\nthan only on the first connection, so a store written elsewhere takes effect on the next connection\nattempt. returning `undefined` starts from the live tip. a sequence number is treated as a store\nthat only lasts for the subscription.\n\nthe stored cursor advances when the consumer asks for the next event. writes are limited by\n`cursorSaveInterval`, which defaults to 5 seconds; a pending write is flushed before reconnecting\nand when iteration ends. set the interval to `0` to save every event.\n\na store failure while connecting is reported to `onConnectionError` and the connection attempt is\nretried. a `save` failure during iteration is thrown, except for the final flush, which goes to\n`onError` so it does not mask why iteration ended.\n\ndelivery is at least once. reconnect duplicates are removed while the same iterator is running, but\na new iterator may replay its saved cursor event. event handlers should therefore be idempotent.\n\n### cancelling the subscription\n\nan `AbortSignal` stops the stream. iteration rejects with `signal.reason` after flushing any pending\ncursor:\n\n```ts\nconst events = subscribeEvents({\n\tservice: 'wss://jetstream.us-east.bsky.network',\n\tsignal: AbortSignal.timeout(10_000),\n});\n```\n\n### handling errors\n\n`onError` receives malformed frames, validation failures, and server error frames. server errors use\n`FirehoseError`:\n\n```ts\nimport { FirehoseError, subscribeEvents } from '@atcute/jetstream';\n\nconst events = subscribeEvents({\n\tservice: 'wss://jetstream.us-east.bsky.network',\n\tonError: (err) => {\n\t\tif (err instanceof FirehoseError) {\n\t\t\tconsole.error('jetstream sent', err.error);\n\t\t} else {\n\t\t\tconsole.error('jetstream error:', err);\n\t\t}\n\t},\n});\n```\n\nerrors returned before the WebSocket upgrade, including `CursorTooOld` and `InvalidRequest`, are not\nvisible to WebSocket clients and look like connection failures. they are retried by default; use\n`ws.maxRetries` to set a limit. reaching the limit stops reconnection but leaves the iterator open.\n\n### connection options\n\n`onConnectionOpen`, `onConnectionClose`, and `onConnectionError` report the socket lifecycle, and\n`ws` passes options to the underlying\n[partysocket](https://github.com/partykit/partykit/tree/main/packages/partysocket) WebSocket:\n\n```ts\nconst events = subscribeEvents({\n\tservice: 'wss://jetstream.us-east.bsky.network',\n\tonConnectionClose: (event) => console.log('disconnected', event.code, event.reason),\n\tws: {\n\t\tminReconnectionDelay: 1_000,\n\t\tmaxReconnectionDelay: 30_000,\n\t},\n});\n```\n","readmeFilename":""}