| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
Sorry, something went wrong.
Reviewer's GuideThis PR enhances SqsController by adding a global SQS mode with unified queue provisioning, refactoring event routing and queue management to use a common prefix, enforcing payload size validation with S3 fallback for oversized messages, updating FIFO queue deduplication, and extending environment configuration to support new SQS global flags and server metadata. Sequence diagram for SQS message publishing with S3 fallback for large payloadssequenceDiagram
participant SqsController
participant SQS
participant S3Service
actor Logger
SqsController->SQS: sendMessage(message)
alt Payload size <= MAX_PAYLOAD_SIZE
SQS->SqsController: Message accepted
SqsController->Logger: Log success
else Payload size > MAX_PAYLOAD_SIZE & S3 enabled
SqsController->S3Service: uploadFile(message)
S3Service->SqsController: fileUrl
SqsController->SQS: sendMessage({dataType: 's3', data: {fileUrl}})
SQS->SqsController: Message accepted
SqsController->Logger: Log success
else Payload size > MAX_PAYLOAD_SIZE & S3 disabled
SqsController->Logger: Log error (payload too large)
end
Class diagram for updated SqsController queue management and event routingclassDiagram
class SqsController {
+init(): Promise<void>
+set(instanceName: string, data: EventDto): Promise<any>
+sendData(instanceName: string, event: string, data: any, ...): void
+saveQueues(prefixName: string, events: string[], enable: boolean)
+listQueues(prefixName: string)
+removeQueuesByInstance(prefixName: string)
-sqs: SQS
-logger
-monitor
-prisma
-configService
}
SqsController <|-- EventController
SqsController --> SQS
SqsController --> S3Service
SqsController --> ConfigService
SqsController --> Logger
File-Level Changes
Tips and commands Interacting with Sourcery
Customizing Your ExperienceAccess your dashboard to:
Getting Help
|
Sorry, something went wrong.
|
Please fix the lint with npm run lint |
Sorry, something went wrong.
| Back | FazBrowse Home | New Git URL |
Introduce a global SQS configuration mode with unified queue provisioning and event routing, add large-payload handling via S3 fallback, and enhance queue management abstractions in SqsController.
New Features:
Enhancements:
Build:
Summary by Sourcery
Implement a global SQS configuration mode with unified queue management and add large-payload handling via S3 fallback, while refactoring SqsController to simplify dynamic queue routing and message handling.
New Features:
Enhancements:
Build: