diff --git a/communication b/communication index 069fa40d8a..f36ea74c26 160000 --- a/communication +++ b/communication @@ -1 +1 @@ -Subproject commit 069fa40d8ad411bbf30ebef5001890e3d9a9a554 +Subproject commit f36ea74c26f05d0d5c98fc6072839f63666822b0 diff --git a/services/msg2file/src/config.ts b/services/msg2file/src/config.ts index e04ec0abb3..3de2f64592 100644 --- a/services/msg2file/src/config.ts +++ b/services/msg2file/src/config.ts @@ -32,7 +32,7 @@ const config: Config = (() => { DbUrl: process.env.DB_URL, MaxSyncAttempts: parseNumber(process.env.MAX_SYNC_ATTEMPTS) ?? 3, MessagesPerFile: parseNumber(process.env.MESSAGES_PER_FILE) ?? 500, - MinSyncMessagesCount: parseNumber(process.env.MIN_SYNC_MESSAGES_COUNT) ?? 1, + MinSyncMessagesCount: parseNumber(process.env.MIN_SYNC_MESSAGES_COUNT) ?? 60, Port: parseNumber(process.env.PORT), Secret: process.env.SECRET ?? 'secret', ServiceID: process.env.SERVICE_ID ?? 'msg2file-service' diff --git a/services/msg2file/src/db.ts b/services/msg2file/src/db.ts index c68b00cb5f..090b0e47d4 100644 --- a/services/msg2file/src/db.ts +++ b/services/msg2file/src/db.ts @@ -117,7 +117,7 @@ export class PostgresDB { FROM ${this.messagesTable} WHERE workspace_id = $1::uuid AND card_id = $2::varchar - AND id = ANY ($3::bigint[]);` + AND id = ANY ($3::varchar[]);` await this.client.unsafe(sql, [workspace, card, ids]) } @@ -129,7 +129,7 @@ export class PostgresDB { FROM ${this.patchesTable} WHERE workspace_id = $1::uuid AND card_id = $2::varchar - AND message_id = ANY ($3::bigint[]);` + AND message_id = ANY ($3::varchar[]);` await this.client.unsafe(sql, [workspace, card, ids]) }