MCPcopy Create free account
hub / github.com/refly-ai/refly / getQueueUrl

Method getQueueUrl

apps/api/src/modules/lambda/lambda.service.ts:168–181  ·  view source on GitHub ↗

* Get SQS queue URL for a task type

(type: LambdaTaskType)

Source from the content-addressed store, hash-verified

166 * Get SQS queue URL for a task type
167 */
168 private getQueueUrl(type: LambdaTaskType): string {
169 const urlMap: Record<LambdaTaskType, string> = {
170 'document-ingest': this.config.get<string>('lambda.sqs.docIngestQueueUrl') || '',
171 'image-transform': this.config.get<string>('lambda.sqs.imageTransformQueueUrl') || '',
172 'document-render': this.config.get<string>('lambda.sqs.documentRenderQueueUrl') || '',
173 'video-analyze': this.config.get<string>('lambda.sqs.videoAnalyzeQueueUrl') || '',
174 };
175
176 const url = urlMap[type];
177 if (!url) {
178 throw new Error(`SQS queue URL not configured for type: ${type}`);
179 }
180 return url;
181 }
182
183 /**
184 * Dispatch a document ingest task

Callers 4

dispatchVideoAnalyzeMethod · 0.95

Calls 1

getMethod · 0.45

Tested by

no test coverage detected