Skip to content
Build and test

Added generic MessageProcessor abstraction to unify signatures and handling between different exact implementations #962

Sign in to view logs

Added generic MessageProcessor abstraction to unify signatures and handling between different exact implementations

Added generic MessageProcessor abstraction to unify signatures and handling between different exact implementations #962

Triggered via pull request March 3, 2025 17:21
@oskardudyczoskardudycz
synchronize #202
added_message_processor_abstraction
Status Failure
Total duration 56s
Artifacts –

build_and_test.yml

on: pull_request
Build application code
46s
Build application code
Fit to window
Zoom out
Zoom in

Annotations

10 errors
Build application code
Object literal may only specify known properties, and 'globalPosition' does not exist in type '{ lastCheckpoint: bigint; }'.
Build application code
Object literal may only specify known properties, and 'globalPosition' does not exist in type '{ lastCheckpoint: bigint; }'.
Build application code
Argument of type 'PostgreSQLEventStoreMessagesBatch<ConsumerEventType>' is not assignable to parameter of type 'RecordedMessage<ConsumerEventType, ReadEventMetadataWithGlobalPosition>[]'.
Build application code
Argument of type 'PostgreSQLProcessor<EventType>' is not assignable to parameter of type 'PostgreSQLProcessor<ConsumerEventType>'.
Build application code
Argument of type '(CurrentMessageProcessorPosition<bigint> | undefined)[]' is not assignable to parameter of type '(PostgreSQLEventStoreMessageBatchPullerStartFrom | undefined)[]'.
Build application code
Argument of type 'SQLExecutor' is not assignable to parameter of type 'Partial<PostgreSQLProcessorHandlerContext> & { startFrom: MessageProcessorStartFrom<bigint>; }'.
Build application code
Type '(options: { processorId: string; partition?: string | undefined; }, context: PostgreSQLProcessorHandlerContext) => Promise<bigint | null>' is not assignable to type 'ReadProcessorCheckpoint<bigint, PostgreSQLProcessorHandlerContext>'.
Build application code
Type '(options: { message: AnyMessage; processorId: string; version: number | undefined; lastCheckpoint: bigint | null; partition?: string | undefined; }, context: PostgreSQLProcessorHandlerContext) => Promise<...>' is not assignable to type 'StoreProcessorCheckpoint<AnyMessage, bigint, PostgreSQLProcessorHandlerContext>'.
Build application code
No overload matches this call.
Build application code
Type '{}' is missing the following properties from type 'Checkpointer<EventType, ReadEventMetadataWithGlobalPosition, PostgreSQLProcessorHandlerContext, bigint>': read, store