* Get SQS queue URL for a task type
(type: LambdaTaskType)
| 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 |
no test coverage detected