Merge pull request #2 from hcengineering/compress-kafka-messages

Compress kafka messages and fix exception in findAll

Author: ArtyomSavchenko

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"
+}

common/changes/@hcengineering/middleware/fix-formatting_2025-11-12-14-59.json renamed to 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"

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",

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

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",

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<any> {
             workspace,
             meta: JSON.stringify(ctx.extractMeta())
           }
-        }))
+        })),
+        compression: CompressionTypes.GZIP
       })
     )
   }

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",

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

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",

packages/middleware/src/findSecurity.ts

@@ -46,7 +46,7 @@ export class FindSecurityMiddleware extends BaseMiddleware implements Middleware
     query: DocumentQuery<T>,
     options?: FindOptions<T>
   ): Promise<FindResult<T>> {
-    if (options !== undefined) {
+    if (options != null) {
       const { limit, sort, lookup, projection, associations, total, showArchived } = options
       return this.provideFindAll(ctx, _class, query, {
         limit,