feat: Improve subscription workflow #76
Annotations
4 errors
|
test
Process completed with exit code 1.
|
|
src/domain/services/imports/publish-import-to-queue.spec.ts > publishToQueue > should publish movies and series to their queues:
apps/backend/src/domain/services/imports/publish-import-to-queue.spec.ts#L32
AssertionError: expected "vi.fn()" to be called 2 times, but got 0 times
❯ src/domain/services/imports/publish-import-to-queue.spec.ts:32:27
|
|
Unhandled error:
apps/backend/src/infra/adapters/sqs.ts#L72
QueueDoesNotExist: The specified queue does not exist.
❯ AwsJson1_0Protocol.handleError ../../node_modules/.pnpm/@aws-sdk+core@3.973.5/node_modules/@aws-sdk/core/dist-cjs/submodules/protocols/index.js:773:27
❯ AwsJson1_0Protocol.deserializeResponse ../../node_modules/.pnpm/@smithy+core@3.22.0/node_modules/@smithy/core/dist-cjs/submodules/protocols/index.js:481:13
❯ ../../node_modules/.pnpm/@smithy+core@3.22.0/node_modules/@smithy/core/dist-cjs/submodules/schema/index.js:26:24
❯ ../../node_modules/.pnpm/@smithy+core@3.22.0/node_modules/@smithy/core/dist-cjs/index.js:121:20
❯ ../../node_modules/.pnpm/@smithy+middleware-retry@4.4.29/node_modules/@smithy/middleware-retry/dist-cjs/index.js:254:46
❯ ../../node_modules/.pnpm/@aws-sdk+middleware-sdk-sqs@3.972.5/node_modules/@aws-sdk/middleware-sdk-sqs/dist-cjs/index.js:113:18
❯ ../../node_modules/.pnpm/@aws-sdk+middleware-logger@3.972.3/node_modules/@aws-sdk/middleware-logger/dist-cjs/index.js:5:26
❯ publish src/infra/adapters/sqs.ts:72:48
❯ processAndPublish src/domain/services/imports/publish-import-to-queue.ts:40:3
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { '$fault': 'client', '$response': { statusCode: 400, reason: 'BAD REQUEST', headers: { server: 'TwistedWeb/25.5.0', date: 'Tue, 24 Feb 2026 02:44:53 GMT', 'content-type': 'application/json', 'x-amzn-errortype': 'QueueDoesNotExist', 'content-length': '81', 'x-amzn-query-error': 'AWS.SimpleQueueService.NonExistentQueue;Sender', 'x-amzn-requestid': '552948e5-7127-4299-9031-4d89798a308b', 'x-localstack': 'true' }, body: { _events: { close: undefined, error: 'Function<anonymous>', data: undefined, end: 'Function<responseOnEnd>', readable: undefined }, _readableState: { highWaterMark: 65536, buffer: [], bufferIndex: +0, length: +0, pipes: [], awaitDrainWriters: null, constructor: 'Function<ReadableState>', objectMode: false, ended: true, endEmitted: true, reading: false, constructed: true, sync: true, needReadable: false, emittedReadable: false, readableListening: false, resumeScheduled: false, errorEmitted: false, emitClose: true, autoDestroy: true, destroyed: true, closed: true, closeEmitted: true, multiAwaitDrain: false, readingMore: true, dataEmitted: true, errored: null, defaultEncoding: 'utf8', decoder: null, encoding: null, flowing: false, pipesCount: +0, paused: true }, _maxListeners: undefined, socket: null, httpVersionMajor: 1, httpVersionMinor: 1, httpVersion: '1.1', complete: true, rawHeaders: [ 'Server', 'TwistedWeb/25.5.0', 'Date', 'Tue, 24 Feb 2026 02:44:53 GMT', 'Content-Type', 'application/json', 'X-Amzn-Errortype', 'QueueDoesNotExist', 'Content-Length', '81', 'x-amzn-query-error', 'AWS.SimpleQueueService.NonExistentQueue;Sender', 'x-amzn-RequestId', '552948e5-7127-4299-9031-4d89798a308b', 'x-localstack', 'true' ], rawTrailers: [], joinDuplicateHeaders: undefined, aborted: false, upgrade: false, url: '', method: null, statusCode: 400, statusMessage: 'BAD REQUEST', client: { connecting: false, _hadError: false, _parent: null, _host: 'localhost', _closeAfterHandlingError: false, _events: { close: 'Function<onClose>', error: 'Function<bound onceWrapper>', prefinish: undefined, finish: undefined, drain: undefined, data: undefined, end: 'Function<onReadableStreamEnd>', readable: undefined, connect: undefined, free: 'Function<onFree>', timeout: 'Function<onTimeout>', agentRemove: 'Function<onRemove>' }, _readableState: { highWaterMark: 65536, buffer: [], bufferIndex: +0, length: +0, pipes: [], awaitDrainWriters: null, constructor: 'Function<ReadableState>', objectMode: false, ended: false, endEmitted: false, reading: true, constructed: true, sync: false, needReadable: true, emittedReadable: false, readableListening: false, resumeScheduled: false, errorEmitted: false, emitClose: false, autoDestroy: true, destroyed: false, closed: false, closeEmitted: false, multiAwaitDrain: false, readingMore: false, dataEmitted: true, errored: null, defaultEncoding: 'utf8', decoder: null, encoding: null, flowing: true, pipesCount: +0, paused
|
|
Unhandled error:
apps/backend/src/infra/adapters/sqs.ts#L72
QueueDoesNotExist: The specified queue does not exist.
❯ AwsJson1_0Protocol.handleError ../../node_modules/.pnpm/@aws-sdk+core@3.973.5/node_modules/@aws-sdk/core/dist-cjs/submodules/protocols/index.js:773:27
❯ AwsJson1_0Protocol.deserializeResponse ../../node_modules/.pnpm/@smithy+core@3.22.0/node_modules/@smithy/core/dist-cjs/submodules/protocols/index.js:481:13
❯ ../../node_modules/.pnpm/@smithy+core@3.22.0/node_modules/@smithy/core/dist-cjs/submodules/schema/index.js:26:24
❯ ../../node_modules/.pnpm/@smithy+core@3.22.0/node_modules/@smithy/core/dist-cjs/index.js:121:20
❯ ../../node_modules/.pnpm/@smithy+middleware-retry@4.4.29/node_modules/@smithy/middleware-retry/dist-cjs/index.js:254:46
❯ ../../node_modules/.pnpm/@aws-sdk+middleware-sdk-sqs@3.972.5/node_modules/@aws-sdk/middleware-sdk-sqs/dist-cjs/index.js:113:18
❯ ../../node_modules/.pnpm/@aws-sdk+middleware-logger@3.972.3/node_modules/@aws-sdk/middleware-logger/dist-cjs/index.js:5:26
❯ publish src/infra/adapters/sqs.ts:72:48
❯ processAndPublish src/domain/services/imports/publish-import-to-queue.ts:40:3
⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯⎯
Serialized Error: { '$fault': 'client', '$response': { statusCode: 400, reason: 'BAD REQUEST', headers: { server: 'TwistedWeb/25.5.0', date: 'Tue, 24 Feb 2026 02:44:53 GMT', 'content-type': 'application/json', 'x-amzn-errortype': 'QueueDoesNotExist', 'content-length': '81', 'x-amzn-query-error': 'AWS.SimpleQueueService.NonExistentQueue;Sender', 'x-amzn-requestid': 'e79318ad-9c3f-453e-b24b-a2e62cb4ae61', 'x-localstack': 'true' }, body: { _events: { close: undefined, error: 'Function<anonymous>', data: undefined, end: 'Function<responseOnEnd>', readable: undefined }, _readableState: { highWaterMark: 65536, buffer: [], bufferIndex: +0, length: +0, pipes: [], awaitDrainWriters: null, constructor: 'Function<ReadableState>', objectMode: false, ended: true, endEmitted: true, reading: false, constructed: true, sync: true, needReadable: false, emittedReadable: false, readableListening: false, resumeScheduled: false, errorEmitted: false, emitClose: true, autoDestroy: true, destroyed: true, closed: true, closeEmitted: true, multiAwaitDrain: false, readingMore: true, dataEmitted: true, errored: null, defaultEncoding: 'utf8', decoder: null, encoding: null, flowing: false, pipesCount: +0, paused: true }, _maxListeners: undefined, socket: null, httpVersionMajor: 1, httpVersionMinor: 1, httpVersion: '1.1', complete: true, rawHeaders: [ 'Server', 'TwistedWeb/25.5.0', 'Date', 'Tue, 24 Feb 2026 02:44:53 GMT', 'Content-Type', 'application/json', 'X-Amzn-Errortype', 'QueueDoesNotExist', 'Content-Length', '81', 'x-amzn-query-error', 'AWS.SimpleQueueService.NonExistentQueue;Sender', 'x-amzn-RequestId', 'e79318ad-9c3f-453e-b24b-a2e62cb4ae61', 'x-localstack', 'true' ], rawTrailers: [], joinDuplicateHeaders: undefined, aborted: false, upgrade: false, url: '', method: null, statusCode: 400, statusMessage: 'BAD REQUEST', client: { connecting: false, _hadError: false, _parent: null, _host: 'localhost', _closeAfterHandlingError: false, _events: { close: 'Function<onClose>', error: 'Function<bound onceWrapper>', prefinish: undefined, finish: undefined, drain: undefined, data: undefined, end: 'Function<onReadableStreamEnd>', readable: undefined, connect: undefined, free: 'Function<onFree>', timeout: 'Function<onTimeout>', agentRemove: 'Function<onRemove>' }, _readableState: { highWaterMark: 65536, buffer: [], bufferIndex: +0, length: +0, pipes: [], awaitDrainWriters: null, constructor: 'Function<ReadableState>', objectMode: false, ended: false, endEmitted: false, reading: true, constructed: true, sync: false, needReadable: true, emittedReadable: false, readableListening: false, resumeScheduled: false, errorEmitted: false, emitClose: false, autoDestroy: true, destroyed: false, closed: false, closeEmitted: false, multiAwaitDrain: false, readingMore: false, dataEmitted: true, errored: null, defaultEncoding: 'utf8', decoder: null, encoding: null, flowing: true, pipesCount: +0, paused
|