diff --git a/common/changes/@hcengineering/kafka/compress-kafka-messages_2025-11-19-07-02.json b/common/changes/@hcengineering/kafka/compress-kafka-messages_2025-11-19-07-02.json new file mode 100644 index 0000000..835a0e2 --- /dev/null +++ b/common/changes/@hcengineering/kafka/compress-kafka-messages_2025-11-19-07-02.json @@ -0,0 +1,10 @@ +{ + "changes": [ + { + "packageName": "@hcengineering/kafka", + "comment": "Compress Kafka messages", + "type": "patch" + } + ], + "packageName": "@hcengineering/kafka" +} \ No newline at end of file diff --git a/common/changes/@hcengineering/middleware/fix-formatting_2025-11-12-14-59.json b/common/changes/@hcengineering/middleware/compress-kafka-messages_2025-11-19-07-02.json similarity index 65% rename from common/changes/@hcengineering/middleware/fix-formatting_2025-11-12-14-59.json rename to common/changes/@hcengineering/middleware/compress-kafka-messages_2025-11-19-07-02.json index b78e3e8..c9dbf3e 100644 --- a/common/changes/@hcengineering/middleware/fix-formatting_2025-11-12-14-59.json +++ b/common/changes/@hcengineering/middleware/compress-kafka-messages_2025-11-19-07-02.json @@ -2,8 +2,8 @@ "changes": [ { "packageName": "@hcengineering/middleware", - "comment": "Fix formatting", - "type": "none" + "comment": "Fix exception in findAll", + "type": "patch" } ], "packageName": "@hcengineering/middleware" diff --git a/packages/kafka/CHANGELOG.json b/packages/kafka/CHANGELOG.json index dce8d9c..62bd682 100644 --- a/packages/kafka/CHANGELOG.json +++ b/packages/kafka/CHANGELOG.json @@ -1,6 +1,18 @@ { "name": "@hcengineering/kafka", "entries": [ + { + "version": "0.7.17", + "tag": "@hcengineering/kafka_v0.7.17", + "date": "Wed, 19 Nov 2025 06:47:45 GMT", + "comments": { + "patch": [ + { + "comment": "Compress Kafka messages" + } + ] + } + }, { "version": "0.7.16", "tag": "@hcengineering/kafka_v0.7.16", diff --git a/packages/kafka/CHANGELOG.md b/packages/kafka/CHANGELOG.md index 46ad7e1..be0e49e 100644 --- a/packages/kafka/CHANGELOG.md +++ b/packages/kafka/CHANGELOG.md @@ -1,6 +1,13 @@ # Change Log - @hcengineering/kafka -This log was last generated on Thu, 06 Nov 2025 10:21:28 GMT and should not be manually modified. +This log was last generated on Wed, 19 Nov 2025 06:47:45 GMT and should not be manually modified. + +## 0.7.17 +Wed, 19 Nov 2025 06:47:45 GMT + +### Patches + +- Compress Kafka messages ## 0.7.16 Thu, 06 Nov 2025 10:21:28 GMT diff --git a/packages/kafka/package.json b/packages/kafka/package.json index fdae751..f3efadf 100644 --- a/packages/kafka/package.json +++ b/packages/kafka/package.json @@ -1,6 +1,6 @@ { "name": "@hcengineering/kafka", - "version": "0.7.16", + "version": "0.7.17", "main": "lib/index.js", "svelte": "src/index.ts", "types": "types/index.d.ts", diff --git a/packages/kafka/src/index.ts b/packages/kafka/src/index.ts index 76475f1..5a88767 100644 --- a/packages/kafka/src/index.ts +++ b/packages/kafka/src/index.ts @@ -22,7 +22,7 @@ import { type PlatformQueue, type PlatformQueueProducer } from '@hcengineering/server-core' -import { Kafka, Partitioners, type Consumer, type Producer } from 'kafkajs' +import { Kafka, Partitioners, type Consumer, type Producer, CompressionTypes } from 'kafkajs' import type * as tls from 'tls' export interface QueueConfig { @@ -223,7 +223,8 @@ class PlatformQueueProducerImpl implements PlatformQueueProducer { workspace, meta: JSON.stringify(ctx.extractMeta()) } - })) + })), + compression: CompressionTypes.GZIP }) ) } diff --git a/packages/middleware/CHANGELOG.json b/packages/middleware/CHANGELOG.json index 824358c..5327adf 100644 --- a/packages/middleware/CHANGELOG.json +++ b/packages/middleware/CHANGELOG.json @@ -1,6 +1,23 @@ { "name": "@hcengineering/middleware", "entries": [ + { + "version": "0.7.20", + "tag": "@hcengineering/middleware_v0.7.20", + "date": "Wed, 19 Nov 2025 06:47:45 GMT", + "comments": { + "patch": [ + { + "comment": "Fix exception in findAll" + } + ], + "none": [ + { + "comment": "Fix formatting" + } + ] + } + }, { "version": "0.7.19", "tag": "@hcengineering/middleware_v0.7.19", diff --git a/packages/middleware/CHANGELOG.md b/packages/middleware/CHANGELOG.md index 429015f..3ba6293 100644 --- a/packages/middleware/CHANGELOG.md +++ b/packages/middleware/CHANGELOG.md @@ -1,6 +1,13 @@ # Change Log - @hcengineering/middleware -This log was last generated on Fri, 07 Nov 2025 16:12:16 GMT and should not be manually modified. +This log was last generated on Wed, 19 Nov 2025 06:47:45 GMT and should not be manually modified. + +## 0.7.20 +Wed, 19 Nov 2025 06:47:45 GMT + +### Patches + +- Fix exception in findAll ## 0.7.19 Fri, 07 Nov 2025 16:12:16 GMT diff --git a/packages/middleware/package.json b/packages/middleware/package.json index 7b5eb00..05f0546 100644 --- a/packages/middleware/package.json +++ b/packages/middleware/package.json @@ -1,6 +1,6 @@ { "name": "@hcengineering/middleware", - "version": "0.7.19", + "version": "0.7.20", "main": "lib/index.js", "svelte": "src/index.ts", "types": "types/index.d.ts", diff --git a/packages/middleware/src/findSecurity.ts b/packages/middleware/src/findSecurity.ts index c8fce0c..b4f4732 100644 --- a/packages/middleware/src/findSecurity.ts +++ b/packages/middleware/src/findSecurity.ts @@ -46,7 +46,7 @@ export class FindSecurityMiddleware extends BaseMiddleware implements Middleware query: DocumentQuery, options?: FindOptions ): Promise> { - if (options !== undefined) { + if (options != null) { const { limit, sort, lookup, projection, associations, total, showArchived } = options return this.provideFindAll(ctx, _class, query, { limit,