NeoAnd/evolution-api
1
0
Fork 0
mirror of https://github.com/EvolutionAPI/evolution-api.git synced 2026-03-21 20:18:40 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #2441 from rafaelberrocalj/feature/sqs-endpoint

Browse Source 
feat(sqs): add support for custom base_url
This commit is contained in:
Davidson Gomes
2026-02-24 12:17:42 -03:00
committed by GitHub
parent 6bb1637699 0419e82d8f
commit 138ff23cf8
3 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
env.example
+1
View File
@@ -166,6 +166,7 @@ SQS_ACCESS_KEY_ID=
SQS_SECRET_ACCESS_KEY= SQS_SECRET_ACCESS_KEY=
SQS_ACCOUNT_ID= SQS_ACCOUNT_ID=
SQS_REGION= SQS_REGION=
SQS_BASE_URL=
SQS_MAX_PAYLOAD_SIZE=1048576 SQS_MAX_PAYLOAD_SIZE=1048576
# =========================================== # ===========================================
src/api/integrations/event/sqs/sqs.controller.ts
+3 -1
View File
@@ -126,7 +126,9 @@ export class SqsController extends EventController implements EventControllerInt
? 'singlequeue' ? 'singlequeue'
: `${event.replace('.', '_').toLowerCase()}`; : `${event.replace('.', '_').toLowerCase()}`;
const queueName = `${prefixName}_${eventFormatted}.fifo`; const queueName = `${prefixName}_${eventFormatted}.fifo`;
const sqsUrl = `https://sqs.${sqsConfig.REGION}.amazonaws.com/${sqsConfig.ACCOUNT_ID}/${queueName}`; const rawBaseUrl = sqsConfig.BASE_URL || `https://sqs.${sqsConfig.REGION}.amazonaws.com`;
const baseUrl = rawBaseUrl.replace(/\/+$/, '');
const sqsUrl = `${baseUrl}/${sqsConfig.ACCOUNT_ID}/${queueName}`;
const message = { const message = {
...(extra ?? {}), ...(extra ?? {}),
src/config/env.config.ts
+2
View File
@@ -122,6 +122,7 @@ export type Sqs = {
SECRET_ACCESS_KEY: string; SECRET_ACCESS_KEY: string;
ACCOUNT_ID: string; ACCOUNT_ID: string;
REGION: string; REGION: string;
BASE_URL: string;
MAX_PAYLOAD_SIZE: number; MAX_PAYLOAD_SIZE: number;
EVENTS: { EVENTS: {
APPLICATION_STARTUP: boolean; APPLICATION_STARTUP: boolean;
@@ -593,6 +594,7 @@ export class ConfigService {
SECRET_ACCESS_KEY: process.env.SQS_SECRET_ACCESS_KEY || '', SECRET_ACCESS_KEY: process.env.SQS_SECRET_ACCESS_KEY || '',
ACCOUNT_ID: process.env.SQS_ACCOUNT_ID || '', ACCOUNT_ID: process.env.SQS_ACCOUNT_ID || '',
REGION: process.env.SQS_REGION || '', REGION: process.env.SQS_REGION || '',
BASE_URL: process.env.SQS_BASE_URL || '',
MAX_PAYLOAD_SIZE: Number.parseInt(process.env.SQS_MAX_PAYLOAD_SIZE ?? '1048576'), MAX_PAYLOAD_SIZE: Number.parseInt(process.env.SQS_MAX_PAYLOAD_SIZE ?? '1048576'),
EVENTS: { EVENTS: {
APPLICATION_STARTUP: process.env?.SQS_GLOBAL_APPLICATION_STARTUP === 'true', APPLICATION_STARTUP: process.env?.SQS_GLOBAL_APPLICATION_STARTUP === 'true',