Skip to content
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.

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

chore(deps): update dependency @sebbo2002/semantic-release-jsr to v2 #540

Merged

chore(deps): update dependency @sebbo2002/semantic-release-jsr to v2

4789042
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Merged

chore(deps): update dependency @sebbo2002/semantic-release-jsr to v2 #540

chore(deps): update dependency @sebbo2002/semantic-release-jsr to v2
4789042
Select commit
Loading
Failed to load commit list.
GitHub Actions / Test Results (20.x succeeded Dec 16, 2024 in 0s

91 passed, 0 failed and 0 skipped

Tests passed successfully

βœ…Β test-results.json

91 tests were completed in 234ms with 91 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
test/tests/consumer.test.ts 91βœ… 91ms

βœ…Β test/tests/consumer.test.ts

Consumer .create
  βœ… creates a new instance of a Consumer object
Consumer .start
  βœ… ack all messages if handleMessageBatch returns void
  βœ… ack only returned messages if handleMessagesBatch returns an array
  βœ… ack the message if handleMessage returns a message with the same ID
  βœ… ack the message if handleMessage returns void
  βœ… calls deleteMessageBatch if alwaysAcknowledge is `true` and handleMessagesBatch returns an empty array
  βœ… calls the handleMessage function when a message is received
  βœ… calls the handleMessagesBatch function when a batch of messages is received
  βœ… calls the preReceiveMessageCallback and postReceiveMessageCallback function before receiving a message
  βœ… changes message visibility timeout on processing error
  βœ… consumes another message once one is processed
  βœ… consumes messages with message attribute 'ApproximateReceiveCount'
  βœ… consumes multiple messages when the batchSize is greater than 1
  βœ… deletes the message if alwaysAcknowledge is `true` and handleMessage returns an empty object
  βœ… deletes the message when the handleMessage function is called
  βœ… does not ack the message if handleMessage returns a different ID
  βœ… does not ack the message if handleMessage returns an empty object
  βœ… does not call deleteMessageBatch if handleMessagesBatch returns an empty array
  βœ… does not delete the message if shouldDeleteMessages is false
  βœ… does not include the response and metadata in the error when extendedAWSErrors is false
  βœ… does not terminate visibility timeout when `terminateVisibilityTimeout` option is false
  βœ… doesn't consume more messages when called multiple times
  βœ… doesn't consume more messages when called multiple times after stopped
  βœ… doesn't delete the message when a processing error is reported
  βœ… emit error when changing visibility timeout fails
  βœ… emit error when changing visibility timeout fails for batch handler functions
  βœ… fires a `processing_error` event when a non-`SQSError` error occurs processing a message
  βœ… fires a message_processed event when a message is successfully deleted
  βœ… fires a message_received event when a message is received
  βœ… fires a timeout event if handler function takes too long
  βœ… fires an `error` event when an `SQSError` occurs processing a message
  βœ… fires an emptyQueue event when all messages have been consumed
  βœ… fires an error event when an error occurs deleting a message
  βœ… fires an error event when an error occurs receiving a message
  βœ… fires an event when the consumer is started
  βœ… fires error event when failed to terminate visibility timeout on processing error
  βœ… fires response_processed event for each batch
  βœ… handles non-standard exceptions thrown by the handler batch function
  βœ… handles non-standard exceptions thrown by the handler function
  βœ… handles non-standard objects thrown by the handler batch function
  βœ… handles non-standard objects thrown by the handler function
  βœ… handles unexpected exceptions thrown by the handler batch function
  βœ… handles unexpected exceptions thrown by the handler function
  βœ… includes the response and metadata in the error when "extendedAWSErrors" is true
  βœ… passes in the correct visibility timeout for long running batch handler functions
  βœ… prefers handleMessagesBatch over handleMessage when both are set
  βœ… retains sqs error information
  βœ… terminate message visibility timeout on processing error
  βœ… uses the correct abort signal
  βœ… uses the correct visibility timeout for long running handler functions
  βœ… waits before repolling when a 403 error occurs
  βœ… waits before repolling when a credentials error occurs
  βœ… waits before repolling when a CredentialsProviderError error occurs
  βœ… waits before repolling when a InvalidAddress error occurs
  βœ… waits before repolling when a InvalidSecurity error occurs
  βœ… waits before repolling when a NonExistentQueue error occurs
  βœ… waits before repolling when a polling timeout is set
  βœ… waits before repolling when a QueueDoesNotExist error occurs
  βœ… waits before repolling when a RequestThrottled error occurs
  βœ… waits before repolling when a RequestThrottled error occurs
  βœ… waits before repolling when a UnknownEndpoint error occurs
Consumer .stop
  βœ… aborts requests when the abort param is true
  βœ… clears the polling timeout when stopped
  βœ… fires a stopped event a second time if started and stopped twice
  βœ… fires a stopped event only once when stopped multiple times
  βœ… stops the consumer polling for messages
  βœ… waits for in-flight messages before emitting stopped (timeout reached)
  βœ… waits for in-flight messages before emitting stopped (within timeout)
Consumer event listeners
  βœ… fires the event multiple times
  βœ… fires the events only once
Consumer logger
  βœ… logs a debug event when an event is emitted
Consumer options validation
  βœ… requires a handleMessage or handleMessagesBatch function to be set
  βœ… requires heartbeatInterval to be less than visibilityTimeout
  βœ… requires the batchSize option to be greater than 0
  βœ… requires the batchSize option to be no greater than 10
  βœ… requires visibilityTimeout to be set with heartbeatInterval
Consumer status
  βœ… returns false for `isRunning` if the consumer has been stopped
  βœ… returns the defaults before the consumer is started
  βœ… returns true for `isPolling` if the consumer is polling for messages
  βœ… returns true for `isRunning` if the consumer has not been stopped
Consumer updateOption
  βœ… does not update the batchSize if the value is less than 0
  βœ… does not update the batchSize if the value is less than 1
  βœ… does not update the batchSize if the value is more than 10
  βœ… does not update the batchSize if the value is more than 20
  βœ… does not update the pollingWaitTimeMs if the value is less than 0
  βœ… does not update the visibilityTimeout if the value is less than the heartbeatInterval
  βœ… throws an error for an unknown option
  βœ… updates the batchSize option and emits an event
  βœ… updates the pollingWaitTimeMs option and emits an event
  βœ… updates the visibilityTimeout option and emits an event
  βœ… updates the waitTimeSeconds option and emits an event