diff --git a/src/sdk/unthread-webhook/WebhookConsumer.js b/src/sdk/unthread-webhook/WebhookConsumer.js index 8062da3..013e8b1 100644 --- a/src/sdk/unthread-webhook/WebhookConsumer.js +++ b/src/sdk/unthread-webhook/WebhookConsumer.js @@ -2,6 +2,9 @@ import { createClient } from 'redis'; import { EventValidator } from './EventValidator.js'; import { LogEngine } from '@wgtechlabs/log-engine'; +// Helper function for command options (Redis v4 compatibility) +const commandOptions = (options) => options; + /** * WebhookConsumer - Simple Redis queue consumer for Unthread webhook events * @@ -130,7 +133,7 @@ export class WebhookConsumer { try { // Get the next event from the queue (blocking pop with 1 second timeout) - const result = await this.redisClient.blPop({ key: this.queueName, timeout: 1 }); + const result = await this.redisClient.blPop(commandOptions({ isolated: true }), this.queueName, 1); if (result) { const eventData = result.element; diff --git a/yarn.lock b/yarn.lock index ba716e2..db085b9 100644 --- a/yarn.lock +++ b/yarn.lock @@ -7,7 +7,7 @@ resolved "https://registry.npmjs.org/@redis/bloom/-/bloom-5.5.5.tgz" integrity sha512-M0GDmw8k0EOFoSpmMjhFUADk/apoano97fLSpT81opgmkkDtBB9iB6l6husxnzK5t2qNz/o0+OCVG9g6lEEwKw== -"@redis/client@^5.5.5", "@redis/client@5.5.5": +"@redis/client@5.5.5": version "5.5.5" resolved "https://registry.npmjs.org/@redis/client/-/client-5.5.5.tgz" integrity sha512-1Dv/CVdMNLw0mlROSnmpp4MQu+6YIJX0YR0h3g2hnPdLvk6L7TcRcrUj7BQFGSeZD2MxklAUO+rp09ITUqE5Og== @@ -166,6 +166,11 @@ formdata-polyfill@^4.0.10: dependencies: fetch-blob "^3.1.2" +fsevents@~2.3.2: + version "2.3.3" + resolved "https://registry.yarnpkg.com/fsevents/-/fsevents-2.3.3.tgz#cac6407785d03675a2a5e1a5305c697b347d90d6" + integrity sha512-5xoDfX+fL7faATnagmWPpbFtwh/R77WmMMqqHGS65C3vvB0YHrgF+B1YmZ3441tMj5n63k0212XNoJwzlhffQw== + glob-parent@~5.1.2: version "5.1.2" resolved "https://registry.npmjs.org/glob-parent/-/glob-parent-5.1.2.tgz" @@ -307,7 +312,7 @@ pg-types@2.2.0: postgres-date "~1.0.4" postgres-interval "^1.1.0" -pg@^8.16.0, pg@>=8.0: +pg@^8.16.0: version "8.16.0" resolved "https://registry.npmjs.org/pg/-/pg-8.16.0.tgz" integrity sha512-7SKfdvP8CTNXjMUzfcVTaI+TDzBEeaUnVwiVGZQD1Hh33Kpev7liQba9uLd4CfN8r9mCVsD0JIpq03+Unpz+kg==