{"_id":"@dafaz/change-stream-broker","_rev":"30-5feda0cea4eff87c5b6f4fb8a266d2c3","name":"@dafaz/change-stream-broker","dist-tags":{"latest":"1.4.2"},"versions":{"1.0.0":{"name":"@dafaz/change-stream-broker","version":"1.0.0","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.0","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"9cc8556aaafcadd3fd254465d76e5d11d597954c","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.0.tgz","fileCount":73,"integrity":"sha512-7ogLtq+/stDVne81+s9qaAC6McbhlT1YWPqc81FJY6H72nnIJ+E8lkZVTxez/LvCs9oGg1QrTkGENxQs3hJ0HA==","signatures":[{"sig":"MEUCIGz2r53223BJIu411UgB9zTFrP8nRcTGzJIgXBuLpU2AAiEA0jNCh1tZBzZtJvDchEKoI/RBrM8IYAjAh6Qhm2LSSOg=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":263177},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","gitHead":"e0d3db84ba802489f297a3cccd8aefed5aafbd10","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.0_1757197554659_0.05395146353116087","host":"s3://npm-registry-packages-npm-production"}},"1.0.1":{"name":"@dafaz/change-stream-broker","version":"1.0.1","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.1","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"995287373a9268de03bd166f7f476a5c588ad14b","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.1.tgz","fileCount":73,"integrity":"sha512-kwigohZLKEz/BBWCoEP2XfAM+2kG01qfkGzhdI2Zsj4HPS6J6/e0e79mrf1nleYfA/MjHTXQsVB+4aDtHwp/wQ==","signatures":[{"sig":"MEYCIQChb+LW9TuuDlxuhY/bCtYgEPykwKUvoOfvmrvpulEyoAIhAInYyYlmqFUpQgkbHFs9fDD6RrrIP8rM19eh/5VXDO40","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":263069},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","gitHead":"971d6fb6e0eaa3bd6a18b83f31dd1517f32514f5","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.1_1757198487938_0.35250854951838817","host":"s3://npm-registry-packages-npm-production"}},"1.0.2":{"name":"@dafaz/change-stream-broker","version":"1.0.2","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.2","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"9b0f28c5ea04e7f86bb2f2c5e67d160565ee7eff","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.2.tgz","fileCount":73,"integrity":"sha512-kWPTTDATOT1fPBR86EsMGo07UIcieA7J9behfLGm5QkDp7lQzdMCkyIaQjKbiXpl8zMj1KBibokNsTtPbPjtqQ==","signatures":[{"sig":"MEQCICW0perm0AJFMjT883n3C8b9BYISK1kTwYJbhZThauhFAiBBXiDAjIsarnxtLJobzPYhmfXOg9JBq36Wo8CIV7iVGg==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":263542},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","gitHead":"21e0e95c0609de784be8fe98c11cbcbbb91917ee","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.2_1757419434340_0.2695314631972143","host":"s3://npm-registry-packages-npm-production"}},"1.0.3":{"name":"@dafaz/change-stream-broker","version":"1.0.3","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.3","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"b6d8e4dea4662b187e134a9095ca7fd6a5c1820d","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.3.tgz","fileCount":73,"integrity":"sha512-scyMf6VtnSMayD+UzvzXkG4xQBFGb9Blwwobhv4vrtW5ZsUJfs+5t7/xpucXceptRZkNghG/upGPCTCMGdvg/A==","signatures":[{"sig":"MEQCIC3J7IXexipBbP4y0GpjkPyP6IKANtVMwkmKo62c2jrdAiAhmBQZsmh+42aXnRNYd9ZmbEonjTHITCLYJbKmkR6V0w==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":263526},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","gitHead":"d01a3ae9528278526c2512d06dd731247c7f044c","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.3_1757420091135_0.9720203840181867","host":"s3://npm-registry-packages-npm-production"}},"1.0.6":{"name":"@dafaz/change-stream-broker","version":"1.0.6","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.6","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"661cf7b46de3bae960e6914d99f6d54747f1e01f","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.6.tgz","fileCount":73,"integrity":"sha512-XAw4hv58hpn4tTzFIjL7WtxQj9ezkGRL6uUf9AycGIarI4OFQ7VDSww9Mym5cbnyLzOsoqgcORAMRR2RnUFgng==","signatures":[{"sig":"MEUCIQDBrzTq0Lo2TKbJL2+0bTilslFNzRPOjgnmZhRnlK2WBgIgGiUZ1ysQOjoOI3Fd0mLoe2oNxm8TcZxLVN3gRpiQDVM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":251733},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","gitHead":"b49458424e3b1b6175958767f8b711c43cab3329","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.6_1757508178454_0.391563219261738","host":"s3://npm-registry-packages-npm-production"}},"1.0.7":{"name":"@dafaz/change-stream-broker","version":"1.0.7","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.7","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"88c7465104dab3fb601aa4bf82697205aa3f6afb","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.7.tgz","fileCount":73,"integrity":"sha512-NGbSakTleJoVO2Td11ttWJhfBXhuPpilQ65Q1WYNCT4HhUWhX6wyt5Z/kGwHnzEfYKZeF5PkbzjIJJoLJvQJ/Q==","signatures":[{"sig":"MEQCIF7hfHXdUgE15ngUw7UnuE65YOsRvznwNRlwuiPpE1HsAiAZF9KwGWpDVwduRDKxflkHA1seJcSapiVnakn08/fzTQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":252404},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./dist/client/index.js"},"gitHead":"54379fabb8cf6e69a4572944f54e01f4a01e9382","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.7_1757514631056_0.1574244353087917","host":"s3://npm-registry-packages-npm-production"}},"1.0.9":{"name":"@dafaz/change-stream-broker","version":"1.0.9","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.0.9","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"22d8f68df0abded22e1b7ffdf57bd9eab1eec2d8","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.0.9.tgz","fileCount":73,"integrity":"sha512-TR92JsPcqMCnnMdUb8KtgQcDdm0MMidXMrV4kWC3HbkHry9V8azD8coKxqBXILU9aP+ORMpPIGbYdElttXM/9A==","signatures":[{"sig":"MEUCIQDyzJhddhyOH4Ykm8SnXXbfmJyQgiDGrgwrPGf9mVC5UAIgS/f8o+uvWseEegm0WNYNsrE+4s5PIZhITsrQz0bzObM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":252388},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./dist/client/index.js"},"gitHead":"a618a1c989fbf7a9aa94388f6b26b2eaf1289df0","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.0.9_1757515972976_0.2031473924620235","host":"s3://npm-registry-packages-npm-production"}},"1.1.0":{"name":"@dafaz/change-stream-broker","version":"1.1.0","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.0","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"c431c521596fbd712f5667ec99aadf3bbb7e069a","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.0.tgz","fileCount":73,"integrity":"sha512-2gRsnD75Dcjx0IPTfuemKzf2JUd6C9CduATsFQGPRJFwUuYfPhSLXXeJzerGDSXObyOH8dazto67vT0cRgPydg==","signatures":[{"sig":"MEUCIQDIOQ//hpoASghXCWPjUNOuHwUvqy/96ovNiLSRz6zRMwIgXy4ctfrWZv1iAWqF51mdKee3NOJiJBkLwJnFwKq3ND8=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":252483},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":{"types":"./client/index.d.ts","import":"./client/index.js","require":"./client/index.js"}},"gitHead":"6a62144355f216dee8a205898badf9207be5071f","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.0_1757517680993_0.26326539404073035","host":"s3://npm-registry-packages-npm-production"}},"1.1.1":{"name":"@dafaz/change-stream-broker","version":"1.1.1","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.1","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"8afbc61f76f6f95a6af71bafc06c566608355df9","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.1.tgz","fileCount":73,"integrity":"sha512-yjdfweyBpT6RFidXO01w6S8k/Fp7qBB45eR9gvjIS0jrsmEiQRLa4haCfqCXXiYD3SmNSPwBL+OCeGnFMQhajw==","signatures":[{"sig":"MEYCIQD52uz3f/cyL1cRPo7zRtE9BoeeJhjSuEimykp3tuPjgwIhAP7mfVzei7y7olz3f9RsIuZK0Ka86fmCbJXgchMZIsBz","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":263996},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"06b72590cc00c6e9bee259bbfc5e1df6e9fdc4e7","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.1_1757530331465_0.8428007438659","host":"s3://npm-registry-packages-npm-production"}},"1.1.2":{"name":"@dafaz/change-stream-broker","version":"1.1.2","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.2","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"12be2cd3aa8707a66d20302489d3f22a1f0e4b4b","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.2.tgz","fileCount":72,"integrity":"sha512-gXdHLom1h5pq7RvrkpbZvGrd5WW+F/PrDdKdb1fM1O5oPN65xH+G7iUlZIrxgztjhFE7vpWqxbYhl53g2D5TFw==","signatures":[{"sig":"MEUCIQDy4ed3F41Vq2cflAw199olyCP6d2N9pmxM8NsR6v4fDAIgNldx6ziwO+PrmKx4h3vfwU+L6V5x/1RUGZSmHMKL7NM=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":262301},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"091ac7c2aea5e3f88e565a06eb9ae15728e2c739","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.2_1757533889687_0.9643139315176465","host":"s3://npm-registry-packages-npm-production"}},"1.1.3":{"name":"@dafaz/change-stream-broker","version":"1.1.3","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.3","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"6aac58361fe1011cb9d0f6f7a61eefdca8abd03a","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.3.tgz","fileCount":72,"integrity":"sha512-Bx6Sd3NDTZXD9z+yrrtbLN89wo//LbH/6SROaVjSAweqqLBRq85z77Wu7vj732azOqmlvJkggkCu/p2OQWL+XA==","signatures":[{"sig":"MEQCIEDzCo256fobfJSH6Vx8uOv3N1FWhvCD59rrNeFPS0EtAiAI6Bwbezz+CwGIXbHwSS2NMO56BPdBmQJ3v2DoBfs6nQ==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":262567},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"e97ee5c4501676937d7ef8601d1a8dc78a05a281","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.3_1757536441860_0.44562487136258366","host":"s3://npm-registry-packages-npm-production"}},"1.1.4":{"name":"@dafaz/change-stream-broker","version":"1.1.4","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.4","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"7f832ee3f285b35634cdc9bd1bf6fda20ebd91dc","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.4.tgz","fileCount":72,"integrity":"sha512-3hnRjWPV1bWOsnIO6vFoqvXDhTlPLCcVl8OpT5fNwVGqLjzdqvOCCZSyn01G+xA5PWsInPgRTr835aGaxqyNBw==","signatures":[{"sig":"MEUCICIUTHEKrZFRLDnFlPyOEnuD2t6MjkapBiDDtwDXKUugAiEA00sTsow3VXbtYPvtyOhtnWqUyhwr7DXY9wk2+nj/dM4=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":263235},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"33dd95696279c1ea38870d37e97bcddb0df04bc1","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.4_1757537210719_0.12930576509662584","host":"s3://npm-registry-packages-npm-production"}},"1.1.5":{"name":"@dafaz/change-stream-broker","version":"1.1.5","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.5","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"8aa151530754e6f65c2a3642c47dc480a5aa7cb0","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.5.tgz","fileCount":72,"integrity":"sha512-WgaVRbw06wWYCHYdx0ChxRu+1vfPzFK1eYqVzYHWL07mBOcxenm+8ZqMfQ+B95qOUFN3ISDI2J1p1+MeggmiSg==","signatures":[{"sig":"MEYCIQCqRAXu0MXH4v+YlB/RxWTT+HfKBjaxKjN/nJNMZzzslwIhAM3IJin2FAaK+P6Llm9ppb/2QjkYLiLXi9L/T+QwO+65","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":267002},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"5631ce9ca1b2d0e7e1e7ad322785480071f71cd3","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.5_1757604036473_0.7830305704560738","host":"s3://npm-registry-packages-npm-production"}},"1.1.6":{"name":"@dafaz/change-stream-broker","version":"1.1.6","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.6","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"5512194213bd630d98306275adeb25c83a3a3d63","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.6.tgz","fileCount":72,"integrity":"sha512-BY/BDbKqPfPDbfWeUYEeeNxVqL4wpLeVxgzDybwZECbV8/uCL1xmlAx7ck4nGuKVrXocvamTp8Sm3ZcDdHhK0g==","signatures":[{"sig":"MEUCICE3CwnpqC9YGy1zAYPf+7+Sfi+eQHFUw5+OruUZrwNXAiEAhhAo2whXYD/1YBozCYtU0IOK2xPgy3QBBKh6E1ZvFEc=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":267040},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"5ea510c8fe7e5ffe3cfe64ba5eee338b6752da10","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.6_1757604972019_0.08191112559461922","host":"s3://npm-registry-packages-npm-production"}},"1.1.7":{"name":"@dafaz/change-stream-broker","version":"1.1.7","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.7","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"19519ad5ee4c3235cd7b412896b2182d8267158c","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.7.tgz","fileCount":72,"integrity":"sha512-dQbj+nKi3WOCVrxG7kpKXxJNpTCiJt2UY5bNJ7wDtgOs3zEGY5cYtTVOsr9a8OVTKt3Iz37paDkAT3lrNGN87g==","signatures":[{"sig":"MEUCICkrAIePhUjgRyTOqZb8FtRy+MBR6PyUCHYM4spNaxH2AiEA5PsDvork/2pfFAZSDBmj+1I9TAMuWgdKeYBiPMmV/k0=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":272052},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"e13e935a80df9b12e7014cb89b2e85e78e072336","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.7_1757610576905_0.971856832097058","host":"s3://npm-registry-packages-npm-production"}},"1.1.8":{"name":"@dafaz/change-stream-broker","version":"1.1.8","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.1.8","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"5122c869d1709598b7c006bb5726ae0446baef67","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.1.8.tgz","fileCount":72,"integrity":"sha512-4UitA4zDomKfGc44qz5kd/TUBOVlhsiApG2c76t1CW6In3i1ETgcrZlG6IMmgFGR2MwRAK3dluJc1PdmZCiFyg==","signatures":[{"sig":"MEQCICKeoHYYnn550ctXL8ZjdVX2NpicZAdKmo91+2rSmz9hAiBsTSopo0PCLjFGtmb1vb/5QbYm6ShSwiD/NuS+kXV4CA==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":272730},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"10494ace5bd4a0d5f6b128868098dfef2a5bf333","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.1.8_1757613249687_0.45908674135365146","host":"s3://npm-registry-packages-npm-production"}},"1.2.0":{"name":"@dafaz/change-stream-broker","version":"1.2.0","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.2.0","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"74d1e550bf800af9c396098f2377ae88230121c0","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.2.0.tgz","fileCount":72,"integrity":"sha512-l11Cx839cqt+rCrH0B89JQ6KFRc+v7OKcmDO8q+obURtJx1iR4dyfltk2HVNAZEVyxZqiiPgrCm1OHOeRHr1lg==","signatures":[{"sig":"MEUCIFmpivZLvyxEJqCckVgPXO2gjrvjOXMmX4gaLbGHgkn5AiEAw7HdOp5deApSq6A7r1Eak3F0RYodeKTRQqMn7J2Uh78=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":319447},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"bce06926e0eee2674ba57dfaebe20aab12e69a5a","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.2.0_1757631354132_0.8240174664579512","host":"s3://npm-registry-packages-npm-production"}},"1.2.1":{"name":"@dafaz/change-stream-broker","version":"1.2.1","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.2.1","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"17f15e60e65293f462c1bdc8c89d91e8e8e8ca1b","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.2.1.tgz","fileCount":72,"integrity":"sha512-lNsWmP20CwRNkukIHc7I6blMbctmnVqo9GFJwg5lw1Yc9//zO+O0FhPnOuOkZQRtoHafrwv2gqpDd6qb4ly9fg==","signatures":[{"sig":"MEUCIQC6HW3oeM37MxdRbrYcGhgUvpg3tf6wDbSMaJ72OTX+ywIgXwhsPL1FxSpkX8AFzDmZNTOMuM0Bka8Zqpo7kHTRa5s=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":320279},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"b9bfb38fbd4b9010822a818c0618ad80344966fc","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.2.1_1757693652204_0.109988111981415","host":"s3://npm-registry-packages-npm-production"}},"1.2.2":{"name":"@dafaz/change-stream-broker","version":"1.2.2","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.2.2","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"cdde802a26524f5c02010ad22e78ffb50ad88b7c","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.2.2.tgz","fileCount":96,"integrity":"sha512-U1U+DwajGZYWCCmfzgiT/eZktBAO7cS48cNyEBG/DDvVuclHemwfyQBCy42AzvE/JNoI4k0cxse6eoBvHLxtoA==","signatures":[{"sig":"MEYCIQDMArg3zL3LOa8/EsDIeLB05wGFoOBsYRVglMkry9zlZwIhALT0iK9VYIeb6M3tyyWaW2uUBjjCCQy/sMbF+iPw51Aw","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":367177},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"477059b00a86b79cfea253cd8110f9cb9951b659","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.2.2_1757698667022_0.8296590554279601","host":"s3://npm-registry-packages-npm-production"}},"1.2.3":{"name":"@dafaz/change-stream-broker","version":"1.2.3","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.2.3","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"6754871c695d45b7defb1c734528df5a724e467a","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.2.3.tgz","fileCount":121,"integrity":"sha512-bPHDmzluc5wPTQt+Rl/w0EmFUudFTYQSRZtfTBjsHsisplVjKOfjIbxbTHVgKeGpLfgZtcvvN9hnu0NA5lK4KA==","signatures":[{"sig":"MEUCIQCkv69r6vNF97ZyQXJMFAQOXGOCauXrzrL03yvh//JnuQIgW0W0u85KpnRVPVGc3VICJNirb2SX1zoRC6Ckhf++Tdc=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":389815},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"b2a1ec02bbb23d5f0766588f9a504ec75760f410","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.2.3_1757766118764_0.9324493401446114","host":"s3://npm-registry-packages-npm-production"}},"1.2.4":{"name":"@dafaz/change-stream-broker","version":"1.2.4","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.2.4","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"268a10f5f980709a2498b186e9fc33fd1c03f7c5","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.2.4.tgz","fileCount":112,"integrity":"sha512-5ixSVS5lPZo87n5T2mDbQ5uhYMJ4H4/xeZSP0m936ltZCTVO9h2/gUKyMRNyvQ/NL9Bcon09OXcOZKSceEuViA==","signatures":[{"sig":"MEUCICDFt4kbmBym+VCCdXrwSjxSr+E78bXMp2akIO/25A0fAiEAgjg9ozIBeGEpcfBA5ujDzkkHCQbLKSRo8Fn+6DDJW5A=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":346368},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"1378f39b971eac0be0829a0bcd0e6e79c417f3f1","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.2.4_1758297883102_0.1577653348271819","host":"s3://npm-registry-packages-npm-production"}},"1.2.5":{"name":"@dafaz/change-stream-broker","version":"1.2.5","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.2.5","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"dec2b492f50904204e869800235cf4367cd1e6f5","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.2.5.tgz","fileCount":112,"integrity":"sha512-ICKuDNBDmLQJExAU0HFY4NkrWgmp9u8sRbOCWg7x4mk518LJhqy4ctqImvReEPLPFGaXy3nqfD0Frlz/hRKOHw==","signatures":[{"sig":"MEUCIQDkQv6y0kz1/3TtgP/21L+XUSaTwLW3NRxRgtKVm7kpNwIgCGEcYR1z49oORh4s+irXSfscV2nDL8ftGgP/Epp7Vq8=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":346224},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"4eda6d2dd5bce2049d782fccc5beda71946e9fab","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.2.5_1758709345929_0.8197251663424108","host":"s3://npm-registry-packages-npm-production"}},"1.3.2":{"name":"@dafaz/change-stream-broker","version":"1.3.2","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.3.2","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"1911041731556d0c5cbc40ae9ea8b57cf44e50ca","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.3.2.tgz","fileCount":72,"integrity":"sha512-VDwjVRyzOp+3tl0s1jwE0WZaGpiKRaIB1+Jiw4/crl6gJZTDMF5Ua9c7hvfoCrbDzrZAEAUVBuIG+it43FMikA==","signatures":[{"sig":"MEYCIQDSHve5juWrgxbFPOI73duZwPn09Jfy9w4wkQi0H9RK2QIhAJFW9L0I5RHo8hzGOs6wCAjqZcr08TUDhTDace5o1vdC","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":308033},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"b4e7dc0045a6867aed7ffc69a73c0ae5806b340b","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.3.2_1761696223793_0.6866318458683145","host":"s3://npm-registry-packages-npm-production"}},"1.3.3":{"name":"@dafaz/change-stream-broker","version":"1.3.3","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.3.3","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"32adaa919ea16dbc100b5c6630a62d479ded94fd","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.3.3.tgz","fileCount":88,"integrity":"sha512-IdGt3bxTdu6k9mcK/ANyZXSj3f/cohurfOYjdBGfHgskwtjCDOJJOgqCs0U+u8BNGv25prBAhl7Jpor9nU48hA==","signatures":[{"sig":"MEYCIQDZ2BtMEmJiB6ykBAn6LFIR8CewnEK8EGmiNMVqeKtF0gIhAJzztpFPXG2CtRnoJ9K0adukrAImQ9v+8H+fGPulZy90","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":329667},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"bb9588f3856b44ee1ee4578b8a9802023159bbd0","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.3.3_1761702087102_0.24279636240408586","host":"s3://npm-registry-packages-npm-production"}},"1.3.5":{"name":"@dafaz/change-stream-broker","version":"1.3.5","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.3.5","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"18b07cbd6fe8d925174ebe8e1d67d1a8668dba23","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.3.5.tgz","fileCount":112,"integrity":"sha512-KvWMuM65bx6+jpGs24hThZTo60pVcYZORYellSY35RXEaaSJVS8urFdkcVFDMDktOyKh9HMALpNQgbDWlq+9QA==","signatures":[{"sig":"MEQCIF1G/eKmH5bTuGBuuyZ4n7bklggfB8dRL4GvGPsGW6iOAiB6xQr0ZZAR/N/T3FW4Pw9U7e5m8+VMD6za1G8acqI/zw==","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":354839},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"e79ef2215cf741d6dedaa5c17e4ce3f17ad2e78c","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.3.5_1761768093288_0.5591783344671213","host":"s3://npm-registry-packages-npm-production"}},"1.4.0":{"name":"@dafaz/change-stream-broker","version":"1.4.0","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.4.0","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"a3ef21123709ec642556aec2b8d38de7d1d60498","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.4.0.tgz","fileCount":72,"integrity":"sha512-1kMwugW/75JHrlvGv8VyeDWqlXQoAgCaVkArDlbE1kUe7H0BGT1oMrD/nIoz3g18BlMZPe4eGnr+BO3c3lcbfQ==","signatures":[{"sig":"MEUCIHJYWul7FzeVfjdcmDtc/a7V5HbNHMbcbB4IXkfX9772AiEAhg9ASeawQeBnfWc4StNEVM4l72eGRUNoOysIkoBZMIo=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":312373},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"98a0bcafdd94336f7c68b3bcae8ee22fa5dcc6d3","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.4.0_1764798860854_0.050843862943638074","host":"s3://npm-registry-packages-npm-production"}},"1.4.1":{"name":"@dafaz/change-stream-broker","version":"1.4.1","keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","_id":"@dafaz/change-stream-broker@1.4.1","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"bin":{"csbroker":"dist/cli/index.js"},"dist":{"shasum":"a74d73ca639c01780ae4082ffc8e91ef4023f6c0","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.4.1.tgz","fileCount":80,"integrity":"sha512-SeZhtNIdG0btrX+PhGGr+8HXHGASTGZlIMu9Y7PkyH0xJNjRNttCLb0ydPhY1u5BbbW2e/axsf/7qrCM2I1bWQ==","signatures":[{"sig":"MEUCIE7wwDKj8dLSqAxl02zVHUFT02rRYG9iyHepTy/aU68vAiEA2T6BW7QmMkT2G5P/z0ByvKD/EHFWhdmKHMAqA8wblsA=","keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U"}],"unpackedSize":322722},"main":"dist/index.js","type":"commonjs","types":"dist/index.d.ts","exports":{".":"./dist/index.js","./client":"./client/index.js"},"gitHead":"b3b39bb7a9d1da2c6937285c7824aaa25556b549","private":false,"scripts":{"lint":"npx @biomejs/biome check --write","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","clean":"rm -rf dist","prepack":"npm run build","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/"},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"_npmVersion":"10.9.0","description":"A reusable MongoDB Change Stream manager","directories":{},"_nodeVersion":"23.2.0","dependencies":{"chalk":"^5.6.0","dotenv":"^17.2.2","mongodb":"^6.19.0","chokidar":"^4.0.3","date-fns":"^4.1.0","fs-extra":"^11.3.1","inquirer":"^12.9.4","commander":"^14.0.0"},"_hasShrinkwrap":false,"devDependencies":{"copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2","@types/node":"^24.3.0","@types/dotenv":"^6.1.1","@biomejs/biome":"2.2.2","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9"},"peerDependencies":{"mongodb":"^6.19.0"},"_npmOperationalInternal":{"tmp":"tmp/change-stream-broker_1.4.1_1764799786598_0.8994715650900638","host":"s3://npm-registry-packages-npm-production"}},"1.4.2":{"name":"@dafaz/change-stream-broker","version":"1.4.2","description":"A reusable MongoDB Change Stream manager","main":"dist/index.js","types":"dist/index.d.ts","bin":{"csbroker":"dist/cli/index.js"},"type":"commonjs","exports":{".":"./dist/index.js","./client":"./client/index.js"},"private":false,"scripts":{"clean":"rm -rf dist","prepack":"npm run build","test":"echo \"Error: no test specified\" && exit 1","build":"tsc && tsc-alias && npm run copy:templates","copy:templates":"copyfiles -f src/cli/templates/**/*.template dist/cli/templates/","lint":"npx @biomejs/biome check --write"},"keywords":["mongodb","change-stream","microservices"],"author":{"name":"asammarco"},"license":"MIT","devDependencies":{"@biomejs/biome":"2.2.2","@types/dotenv":"^6.1.1","@types/fs-extra":"^11.0.4","@types/inquirer":"^9.0.9","@types/node":"^24.3.0","copyfiles":"^2.4.1","tsc-alias":"^1.8.16","typescript":"^5.9.2"},"dependencies":{"chalk":"^5.6.0","chokidar":"^4.0.3","commander":"^14.0.0","date-fns":"^4.1.0","dotenv":"^17.2.2","fs-extra":"^11.3.1","inquirer":"^12.9.4","mongodb":"^6.19.0"},"peerDependencies":{"mongodb":"^6.19.0"},"_id":"@dafaz/change-stream-broker@1.4.2","gitHead":"f628747d82c898c49a908bcf0722285e3e639314","_nodeVersion":"23.2.0","_npmVersion":"10.9.0","dist":{"integrity":"sha512-LlMB832BdZH4c2aQY7ynIY/svYfNHh1ff+nyXVGxUHJpS+D0Dc8JQFlL73KYfgleeTltAuxypzkql0hKZsKZQQ==","shasum":"688aecae64623b83fd3260c52f4218d090bbb99c","tarball":"https://registry.npmjs.org/@dafaz/change-stream-broker/-/change-stream-broker-1.4.2.tgz","fileCount":80,"unpackedSize":322884,"signatures":[{"keyid":"SHA256:DhQ8wR5APBvFHLF/+Tc+AYvPOdTpcIDqOhxsBHRwC7U","sig":"MEUCIDG1dOG6nwry0Mxb94QNBQQUtwt+C9fpE6l/J/ON0KemAiEAlA3kn9482rhA2Sc1kcTbew6c9LBpEHXAonJowXl0YxI="}]},"_npmUser":{"name":"asammarco","email":"asammarco@hotmail.com"},"directories":{},"maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"_npmOperationalInternal":{"host":"s3://npm-registry-packages-npm-production","tmp":"tmp/change-stream-broker_1.4.2_1765123503723_0.20698063819868362"},"_hasShrinkwrap":false}},"time":{"created":"2025-09-06T22:25:54.462Z","modified":"2025-12-07T16:05:04.136Z","1.0.0":"2025-09-06T22:25:54.860Z","1.0.1":"2025-09-06T22:41:28.141Z","1.0.2":"2025-09-09T12:03:54.536Z","1.0.3":"2025-09-09T12:14:51.393Z","1.0.6":"2025-09-10T12:42:58.638Z","1.0.7":"2025-09-10T14:30:31.303Z","1.0.9":"2025-09-10T14:52:53.170Z","1.1.0":"2025-09-10T15:21:21.185Z","1.1.1":"2025-09-10T18:52:11.641Z","1.1.2":"2025-09-10T19:51:29.897Z","1.1.3":"2025-09-10T20:34:02.083Z","1.1.4":"2025-09-10T20:46:50.894Z","1.1.5":"2025-09-11T15:20:36.673Z","1.1.6":"2025-09-11T15:36:12.199Z","1.1.7":"2025-09-11T17:09:37.114Z","1.1.8":"2025-09-11T17:54:09.895Z","1.2.0":"2025-09-11T22:55:54.317Z","1.2.1":"2025-09-12T16:14:12.418Z","1.2.2":"2025-09-12T17:37:47.220Z","1.2.3":"2025-09-13T12:21:58.955Z","1.2.4":"2025-09-19T16:04:43.336Z","1.2.5":"2025-09-24T10:22:26.138Z","1.3.0":"2025-10-28T23:54:27.149Z","1.3.2":"2025-10-29T00:03:44.036Z","1.3.3":"2025-10-29T01:41:27.315Z","1.3.5":"2025-10-29T20:01:33.491Z","1.4.0":"2025-12-03T21:54:21.070Z","1.4.1":"2025-12-03T22:09:46.819Z","1.4.2":"2025-12-07T16:05:03.907Z"},"author":{"name":"asammarco"},"license":"MIT","keywords":["mongodb","change-stream","microservices"],"description":"A reusable MongoDB Change Stream manager","maintainers":[{"name":"asammarco","email":"asammarco@hotmail.com"}],"readme":"# Change Stream Broker\r\n\r\nWelcome 👋\r\n\r\n**Change Stream Broker** é um pacote Node.js que transforma o MongoDB Change Streams em um sistema completo de message broker para arquiteturas de microsserviços. Ele fornece uma API similar ao Kafka/RabbitMQ, mas utilizando apenas MongoDB como backbone, reduzindo drasticamente a complexidade de implementação e administração, bem como os custos de infraestrutura e processamento.\r\n\r\n**Development CLI** torna a experiência de desenvolmento intuitiva, mantém a configuração do message broker e o schema do payload das mensagens no mesmo local do código. As alterações feitas são publicadas via linha de comando.\r\n\r\n## Instalação\r\n\r\n```bash\r\nnpm install @dafaz/change-stream-broker\r\n```\r\n\r\n## Inicialização\r\n\r\n### 1. Crie os arquivos de Configuração e de Schema do broker:\r\n\r\n```bash\r\nnpx csbroker init\r\n```\r\n\r\n### 2. Edite os arquivos:\r\n\r\nEncontre a pasta (change-stream) na raíz do seu projeto:\r\n\r\n```text\r\n[root]/\r\n└── change-stream/\r\n        ├── config.ts\r\n        └── message-payload.schema.ts/\r\n```\r\n\r\nNo arquivo de configurações você terá um serviço de message broker pré-configurado, para você customizar\r\nconforme sua necessidade, e ainda, um exemplo de configuração de um producer e de um consumer.\r\n\r\nNo arquivo de schema de mensagens, você terá um exemplo de payload de messagem pré-configurado. Edite o arquivo conforme a necessidade do seu microsserviço. \r\n\r\nÉ importante observar que tanto o arquivo de configuração quanto o de schema, devem permanecer na pasta change-stream gerada na raíz de seu projeto.\r\n\r\n\r\n### 3. Após a edição, gere os arquivos internos a serem utilizados pelo broker:\r\n\r\n```bash\r\nnpx csbroker generate\r\n```\r\n\r\nObservação: Sempre que editar os arquivos de configuração e de schema, chame o generate para enviar as alterações para o broker.\r\n\r\n### 4. Variáveis de ambiente:\r\n\r\nNo arquivo .env da sua aplicação, crie as seguintes variáveis de conexão com sua instância do MongoDB:\r\n\r\n```text\r\n\r\n# MongoDB\r\nMONGODB_BROKER_URI=\"mongodb://root:docker@127.0.0.1:27017/?replicaSet=rs0&authSource=admin\"\r\nMONGODB_BROKER_DATABASE=\"purchase-events\"\r\n\r\n```\r\n\r\n### Demais comandos da CLI\r\n\r\n#### Modo Watch:\r\n\r\nUtilize o modo watch, em desenvolvimento, para auto-gerar os arquivos do broker, sempre que for realizada uma alteração nos arquivos de configuração ou schema:\r\n\r\n```bash\r\nnox csbroker watch\r\n```\r\n\r\n\r\n#### Backups:\r\n\r\nA cada generate, os arquivos antigos são colocados em um backup, e caso seja necessário, podem ser recuperados. Para visualizar a lista de backups, utilize o comando:\r\n\r\n```bash\r\nnpx csbroker backups\r\n```\r\n\r\n#### Restore:\r\n\r\nPara recuperar um backup, utilize o comando:\r\n\r\n```bash\r\nnpx csbroker restore [backup_name]\r\n```\r\n\r\n**Atenção** \r\nSempre que fizer um restore, você precisa verificar os arquivos de configuração e schema específicos desse restore. Esses arquivos ficam guardados em um Stage. Os comandos à seguir, podem ser utilizados para você comparar os seus arquivos de configuração e schema atuais, com os arquivos em stage. Faça a atualização dos seus arquivos de configuração e schema conforme houver necessidade.\r\n\r\n#### Stage:\r\n\r\nOs arquivos de geração utilizados pelo broker, ficam em stage, e podem ser verificados através do comando abaixo:\r\n\r\n```bash\r\nnpx csbroker stage\r\n```\r\n\r\n#### Apply Stage:\r\n\r\nApós o restore, e a verificação dos arquivos em stage, utilize o comando a seguir para atualizar seus arquivos de configuração e schema em desenvolvimento:\r\n\r\n```bash\r\nnpx csbroker apply-stage\r\n```\r\n\r\n\r\n#### Diferenças entre Stages:\r\n\r\nCaso você queira uma forma mais eficiente de verificar as diferenças entre o estágio atual do broker e seus arquivos de configuração e schema, utilize o comando:\r\n\r\n```bash\r\nnpx csbroker diff\r\n```\r\n  \r\n\r\n## Principais Características\r\n\r\n- 🎯 **API Familiar**: Interface similar a brokers populares (Kafka-like).\r\n- 📦 **Zero Dependências Extras**: Usa apenas o driver oficial do MongoDB.\r\n- 🔄 **Resume Tokens**: Garante delivery exactly-once com mecanismo de offsets.\r\n- 👥 **Consumer Groups**: Suporte a grupos de consumidores com balanceamento automático.\r\n- 🛡️ **Type Safety**: Completo suporte a TypeScript com generics.\r\n- ⚡ **Alta Disponibilidade**: Reconexão automática e lógica de retries integrada.\r\n- 🔧 **Extensível**: Arquitetura modular para customizações.\r\n\r\n## Casos de Uso Ideais\r\n\r\n- Microsserviços que já utilizam MongoDB.\r\n- Sistemas que precisam de comunicação assíncrona entre serviços.\r\n- Migração de sistemas legados para arquitetura orientada a eventos.\r\n- Ambientes onde Kafka ou RabbitMQ seriam excessivos (overkill).\r\n\r\n\r\n## Pré-requisitos\r\n\r\n- Node.js 16+  \r\n- MongoDB 5.0+ com replica set habilitado\r\n- TypeScript **(recomendado)**\r\n\r\n\r\n### Configuração do MongoDB\r\n\r\n- Para usar **Change Stream Broker** no seu projeto, é necessário configurar o MongoDB em replica set.\r\n- Ou ainda, utilize o **MongoDB Atlas Online**, que já vem com replica set por padrão habilitado.\r\n\r\n#### Exemplo de Configuração do MongoDB replica set em um container Docker\r\n\r\nO Change Stream exige que a sua instância do MongoDB esteja em um cluster.\r\nEm desenvolvimento, você pode simular esse cluster. Para isso, será necessário criar o docker-compose e o Dockerfile da seguinte forma:\r\n\r\n**[root] / docker-compose.yml**\r\n\r\n```yml\r\nversion: '3.8'\r\n \r\nservices:\r\n  mongo:\r\n    build:\r\n      context: .\r\n      dockerfile: Dockerfile\r\n    container_name: mongo-server\r\n    restart: always\r\n    environment:\r\n      MONGO_INITDB_ROOT_USERNAME: root\r\n      MONGO_INITDB_ROOT_PASSWORD: docker\r\n    ports:\r\n      - \"0.0.0.0:27017:27017\"\r\n    expose:\r\n      - 27017\r\n    command: --replSet rs0 --keyFile /etc/mongo-keyfile --bind_ip_all --port 27017 --auth\r\n    healthcheck:\r\n      test: echo \"try { rs.status() } catch (err) { rs.initiate({_id:'rs0',members:[{_id:0,host:'127.0.0.1:27017'}]}) }\" | mongosh --port 27017 -u root -p docker --authenticationDatabase admin\r\n      interval: 5s\r\n      timeout: 15s\r\n      start_period: 15s\r\n      retries: 10\r\n    volumes:\r\n      - \"./data:/data/db\"\r\n      - \"./data/config:/etc/mongod.conf\"\r\n    networks:\r\n      - mongo-net\r\n  \r\nnetworks:\r\n  mongo-net:\r\n    driver: bridge\r\n```\r\n\r\n**[root-path] / Dockerfile**\r\n\r\n```text\r\nFROM mongo\r\nRUN openssl rand -base64 756 > /etc/mongo-keyfile \r\nRUN chmod 400 /etc/mongo-keyfile \r\nRUN chown mongodb:mongodb /etc/mongo-keyfile \r\n```\r\n\r\n**Inicialize o container docker:**\r\n\r\n```bash\r\ndocker compose up -d\r\n```\r\n\r\n\r\n## Exemplo de Desenvolvimento de um Producer em NestJS:\r\n\r\n### Purchases\r\n\r\nInstale o broker \r\n\r\n```bash\r\nnpm install @dafaz/change-stream-broker\r\n```\r\n\r\n#### Edite o arquivo .env da aplicação:\r\n\r\n```\r\nMONGODB_BROKER_URI=\"mongodb://root:docker@127.0.0.1:27017/?replicaSet=rs0&authSource=admin\"\r\nMONGODB_BROKER_DATABASE=\"purchase-events\"\r\n```\r\n\r\n#### Crie os arquivos de configuração e schema do broker\r\n\r\n```bash\r\nnpx csbroker init\r\n```\r\n\r\n#### [root] / change-stream / config\r\n\r\n```text\r\n// ==============================================\r\n// EXAMPLE - BROKER CONFIGURATION\r\n// ==============================================\r\nexport const brokerConfig = defineBroker({\r\n\tmongoUri: process.env.MONGODB_BROKER_URI,\r\n\tdatabase: process.env.MONGODB_BROKER_DATABASE,\r\n\tautoCreateTopics: true,\r\n\tlogLevel: 'INFO',\r\n\tlogContext: 'Purchase Service Broker',\r\n})\r\n\r\n// ==============================================\r\n// EXAMPLE - CREATE PRODUCERS\r\n// ==============================================\r\n\r\nexport const purchasesProducerConfig = defineProducer({\r\n\ttopic: 'purchases.new-purchase',\r\n\tpartitions: 1,\r\n\tretentionMs: 7 * 24 * 60 * 60 * 1000,\r\n\tpartitionStrategy: 'hash',\r\n})\r\n```\r\n\r\n\r\n#### [root] / change-stream / message-payload.schema.ts\r\n\r\n```text\r\n// ==============================================\r\n// EXAMPLE - MESSAGE PAYLOAD SCHEMAS\r\n// ==============================================\r\n\r\nexport interface PurchaseCreatedPayload {\r\n\tcustomer: {\r\n\t\tid: string\r\n\t\tauthUserId: string\r\n\t}\r\n\tproduct: {\r\n\t\tid: string\r\n\t\ttitle: string\r\n\t\tslug: string\r\n\t}\r\n}\r\n```\r\n\r\n#### Geração dos arquivos para o broker:\r\n\r\n```bash\r\nnpx csbroker generate\r\n```\r\n\r\n### Desenvolvimento\r\n\r\n#### src / messaging / change-stream.service.ts\r\n\r\n```javascript\r\nimport { ChangeStreamBroker } from '@dafaz/change-stream-broker'\r\nimport { brokerConfig } from '@dafaz/change-stream-broker/client'\r\nimport { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common'\r\n\r\n@Injectable()\r\nexport class ChangeStreamBrokerService\r\n\textends ChangeStreamBroker\r\n\timplements OnModuleInit, OnModuleDestroy\r\n{\r\n\tconstructor() {\r\n\t\tsuper(brokerConfig)\r\n\t}\r\n\r\n\tasync onModuleInit() {\r\n\t\tawait this.connect()\r\n\t}\r\n\tasync onModuleDestroy() {\r\n\t\tawait this.disconnect()\r\n\t}\r\n}\r\n```\r\n\r\n#### src / messaging / messaging.module.ts\r\n\r\n```javascript\r\nimport { Module } from '@nestjs/common'\r\nimport { ChangeStreamBrokerService } from './change-stream.service'\r\n\r\n@Module({\r\n\tproviders: [ChangeStreamBrokerService],\r\n\texports: [ChangeStreamBrokerService],\r\n})\r\nexport class MessagingModule {}\r\n```\r\n\r\nImporte MessagingModule no módulo principal, ou no módulo cuja as classes dependem de ChangeStreamBrokerService.\r\n\r\n\r\n#### src / services / purchases.service.ts\r\n\r\n```javascript\r\n[...]\r\n\r\n  const docToSend: PurchaseCreatedPayload = {\r\n        customer: {\r\n          id: customer.id,\r\n          authUserId: customer.authUserId,\r\n        },\r\n        product: {\r\n          id: product.id,\r\n          title: product.title,\r\n          slug: product.slug,\r\n        },\r\n      }\r\n\r\n  const producer = await this.changeStreamBroker.createProducer(\r\n    purchasesProducerConfig,\r\n  )\r\n\r\n  await producer.send({\r\n    key: purchase.id,\r\n    value: docToSend, // message-payload\r\n    timestamp: new Date(),\r\n    headers: {\r\n      eventType: 'purchase.created',\r\n      source: 'purchases-service',\r\n    },\r\n  })\r\n\r\n[...]\r\n```\r\n\r\n## Exemplo de desenvolvimento do Consumer em NestJS:\r\n\r\nInstale o broker \r\n\r\n```bash\r\nnpm install @dafaz/change-stream-broker\r\n```\r\n\r\n#### Edite o arquivo .env da aplicação:\r\n\r\n```\r\nMONGODB_BROKER_URI=\"mongodb://root:docker@127.0.0.1:27017/?replicaSet=rs0&authSource=admin\"\r\nMONGODB_BROKER_DATABASE=\"purchase-events\"\r\n```\r\n\r\n#### Crie os arquivos de configuração e schema do broker\r\n\r\n```bash\r\nnpx csbroker init\r\n```\r\n\r\n#### [root] / change-stream / config\r\n\r\n```text\r\n// ==============================================\r\n// EXAMPLE - BROKER CONFIGURATION\r\n// ==============================================\r\nexport const brokerConfig = defineBroker({\r\n\tmongoUri: process.env.MONGODB_BROKER_URI,\r\n\tdatabase: process.env.MONGODB_BROKER_DATABASE,\r\n\tautoCreateTopics: true,\r\n\tlogLevel: 'INFO',\r\n\tlogContext: 'Purchase Service Broker',\r\n})\r\n\r\n// ==============================================\r\n// EXAMPLE - CREATE CONSUMERS\r\n// ==============================================\r\n\r\nexport const purchasesConsumerConfig = defineConsumer({\r\n\tgroupId: 'classroom-service',\r\n\ttopic: 'purchases.new-purchase',\r\n\tpartitions: [0],\r\n\tautoCommit: true,\r\n\tautoCommitIntervalMs: 15000,\r\n\tfromBeginning: false,\r\n\tmaxRetries: 3,\r\n\tretryDelayMs: 1000,\r\n\tenableOffsetMonitoring: false,\r\n\toptions: {\r\n\t\tbatchSize: 100,\r\n\t\tmaxAwaitTimeMS: 1000,\r\n\t\tfullDocument: 'updateLookup',\r\n\t},\r\n})\r\n```\r\n\r\n\r\n#### [root] / change-stream / message-payload.schema.ts\r\n\r\n```text\r\n// ==============================================\r\n// EXAMPLE - MESSAGE PAYLOAD SCHEMAS\r\n// ==============================================\r\n\r\nexport interface PurchaseCreatedPayload {\r\n\tcustomer: {\r\n\t\tid: string\r\n\t\tauthUserId: string\r\n\t}\r\n\tproduct: {\r\n\t\tid: string\r\n\t\ttitle: string\r\n\t\tslug: string\r\n\t}\r\n}\r\n```\r\n\r\n#### Geração dos arquivos para o broker:\r\n\r\n```bash\r\nnpx csbroker generate\r\n```\r\n\r\n### Desenvolvimento\r\n\r\n#### src / messaging / change-stream.service.ts\r\n\r\n\r\n```javascript\r\nimport {\r\n\tChangeStreamBroker,\r\n\tChangeStreamConsumer,\r\n\tConsumerRecord,\r\n\tMessageHandlerConfig,\r\n} from '@dafaz/change-stream-broker'\r\nimport {\r\n\tbrokerConfig,\r\n\tPurchaseCreatedPayload,\r\n\tpurchasesConsumerConfig,\r\n} from '@dafaz/change-stream-broker/client'\r\nimport { Injectable, OnModuleDestroy, OnModuleInit } from '@nestjs/common'\r\nimport { EnrollmentsService } from '../http/services/enrollments.service'\r\n\r\n@Injectable()\r\nexport class ChangeStreamBrokerService\r\n\textends ChangeStreamBroker\r\n\timplements OnModuleInit, OnModuleDestroy\r\n{\r\n\tprivate consumer: ChangeStreamConsumer\r\n\r\n\tconstructor(private readonly enrollmentsService: EnrollmentsService) {\r\n\t\tsuper(brokerConfig)\r\n\t}\r\n\r\n\tasync onModuleInit() {\r\n\t\tawait this.connect()\r\n\r\n\t\tconst handlerConfig: MessageHandlerConfig<PurchaseCreatedPayload> = {\r\n\t\t\thandler: this.handlePurchaseEvent.bind(this),\r\n\t\t\terrorHandler: this.handleError.bind(this),\r\n\t\t\tmaxRetries: 3,\r\n\t\t\tretryDelay: 1000,\r\n\t\t\tautoCommit: true,\r\n\t\t}\r\n\r\n\t\tthis.consumer = await this.createConsumer(purchasesConsumerConfig)\r\n\t\tawait this.consumer.subscribe(handlerConfig)\r\n\r\n\t\tconsole.log('Enrollment consumer started listening for purchase events...')\r\n\t}\r\n\tasync onModuleDestroy() {\r\n\t\tif (this.consumer) {\r\n\t\t\tawait this.consumer.unsubscribe()\r\n\t\t}\r\n\r\n\t\tawait this.disconnect()\r\n\t}\r\n\r\n\tasync handlePurchaseEvent(payload: ConsumerRecord<PurchaseCreatedPayload>) {\r\n\t\tconst purchase = payload.message.value\r\n\r\n\t\ttry {\r\n\t\t\tawait this.enrollmentsService.createEnrollment(purchase)\r\n\t\t} catch (error) {\r\n\t\t\tconsole.error(`Error creating enrollment: ${error.message}`)\r\n\t\t\tthrow error\r\n\t\t}\r\n\t}\r\n\r\n\tprivate async handleError(error: Error, record?: any) {\r\n\t\tconsole.error('Error processing purchase event:', error)\r\n\r\n\t\tif (record) {\r\n\t\t\tconsole.error('Failed record:', record.message.value)\r\n\t\t}\r\n\t}\r\n}\r\n```\r\n\r\n#### src / messaging / messaging.module.ts\r\n\r\n```javascript\r\nimport { Module } from '@nestjs/common'\r\nimport { DatabaseModule } from '../database/database.module'\r\nimport { EnrollmentsService } from '../http/services/enrollments.service'\r\nimport { ChangeStreamBrokerService } from './change-stream.service'\r\n\r\n@Module({\r\n  imports: [DatabaseModule]\r\n\tproviders: [ChangeStreamBrokerService, EnrollmentsService,],\r\n\texports: [ChangeStreamBrokerService, EnrollmentsService,],\r\n})\r\nexport class MessagingModule {}\r\n```\r\n\r\nImporte o MessagingModule no módulo principal, ou no módulo cuja as classes dependem de ChangeStreamBrokerService.","readmeFilename":"README.md"}