Skip to content

Trigger CI #401

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
CarlosGamero merged 10 commits into from
Feb 19, 2026
Merged

Trigger CI #401

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
12a7f09
Trigger CI
CarlosGamero Feb 19, 2026
31c73a9
Fixing tests
CarlosGamero Feb 19, 2026
8d9df0b
version bump
CarlosGamero Feb 19, 2026
16919d0
Merge branch 'main' into chore/kafka_ci_fix
CarlosGamero Feb 19, 2026
b56a512
test concurrency
CarlosGamero Feb 19, 2026
7fa8841
Merge branch 'chore/kafka_ci_fix' of https://github.com/kibertoad/mes…
CarlosGamero Feb 19, 2026
812d706
Revert concurrency
CarlosGamero Feb 19, 2026
4b269ea
Fix tests
CarlosGamero Feb 19, 2026
8ced196
Coverage fix
CarlosGamero Feb 19, 2026
c4b5dbe
Revert wrong change
CarlosGamero Feb 19, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,9 @@ Useful utilities, interfaces and base classes for message queue handling.

## Overview

`message-queue-toolkit ` is an abstraction over several different queue systems, which implements common deserialization, validation and error handling logic. The library provides utilities, interfaces and base classes to build the support for any queue system you may need in your service.
`message-queue-toolkit ` is an abstraction over several different queue systems, which implements common deserialization,
validation and error handling logic. The library provides utilities, interfaces and base classes to build the support for
any queue system you may need in your service.

It consists of the following submodules:

Expand Down
2 changes: 1 addition & 1 deletion packages/kafka/package.json
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@
"dependencies": {
"@lokalise/node-core": "^14.2.0",
"@lokalise/universal-ts-utils": "^4.5.1",
"@platformatic/kafka": "^1.24.0"
"@platformatic/kafka": "^1.26.0"
},
"peerDependencies": {
"@message-queue-toolkit/core": ">=23.0.0",
Expand Down
1 change: 1 addition & 0 deletions packages/kafka/test/consumer/PermissionConsumer.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -75,6 +75,7 @@ export class PermissionConsumer extends AbstractKafkaConsumer<
handlerSpy: options.handlerSpy ?? true,
headerRequestIdField: options.headerRequestIdField,
messageIdField: options.messageIdField,
maxWaitTime: 5,
},
{
incrementAmount: 0,
Expand Down
6 changes: 3 additions & 3 deletions packages/kafka/test/utils/testContext.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import {
type TransactionObservabilityManager,
} from '@lokalise/node-core'
import type { MessageMetricsManager } from '@message-queue-toolkit/core'
import { adminClient } from '@platformatic/kafka'
import { Admin } from '@platformatic/kafka'
import {
type AwilixContainer,
asFunction,
Expand All @@ -26,7 +26,7 @@ export type TestContext = AwilixContainer<Dependencies>
type Dependencies = {
awilixManager: AwilixManager
kafkaConfig: KafkaConfig
kafkaAdmin: adminClient.Admin
kafkaAdmin: Admin
errorReporter: ErrorReporter
logger: CommonLogger
transactionObservabilityManager: TransactionObservabilityManager
Expand Down Expand Up @@ -60,7 +60,7 @@ const resolveDIConfig = (awilixManager: AwilixManager): DiConfig => ({
kafkaConfig: asFunction(getKafkaConfig, SINGLETON_CONFIG),
kafkaAdmin: asFunction(
({ kafkaConfig }) =>
new adminClient.Admin({
new Admin({
clientId: randomUUID(),
bootstrapBrokers: kafkaConfig.bootstrapBrokers,
}),
Expand Down
2 changes: 1 addition & 1 deletion packages/kafka/vitest.config.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ export default defineConfig({
lines: 93,
functions: 91,
branches: 85,
statements: 93,
statements: 92,
},
},
},
Expand Down
Loading