t1c.dev / rocksky
forked from rocksky.app/rocksky
A decentralized music tracking and discovery platform built on AT Protocol 🎵
fork atom

Reject JetStream subscription promise on error

tsiry-sandratraina.com dc51ba8c 660ae75f

+3 -1
+3 -1
apps/cli/src/cmd/sync.ts
··· 537 537 debug: true, 538 538 }); 539 539 540 - return new Promise((resolve) => { 540 + return new Promise((resolve, reject) => { 541 541 client.on("open", () => { 542 542 logger.info`✅ Connected to JetStream!`; 543 543 cleanUpJetstreamLockOnExit(user.did); ··· 568 568 569 569 client.on("error", (error) => { 570 570 logger.error`❌ Error: ${error}`; 571 + cleanUpJetstreamLockOnExit(user.did); 572 + reject(error); 571 573 }); 572 574 573 575 client.on("reconnect", (data) => {