Add option to add deepgram tags. (#67)

Author: bgrozev

env.example

@@ -102,6 +102,12 @@ OPENAI_TRANSCRIPTION_PROMPT="You will hear audio coming from one participant in
 # Default: false
 # DEEPGRAM_DIARIZE=false
 
+# Custom tags for Deepgram requests (comma-separated list)
+# Tags can be used to categorize and filter requests in Deepgram analytics
+# Default: none
+# Example: DEEPGRAM_TAGS=production,voice-assistant,customer-support
+# DEEPGRAM_TAGS=
+
 # ============================================
 # Server Configuration
 # ============================================

src/backends/DeepgramBackend.ts

@@ -92,6 +92,13 @@ export class DeepgramBackend implements TranscriptionBackend {
 					params.set('diarize', config.deepgram.diarize.toString());
 				}
 
+				// Add tags if configured
+				if (config.deepgram.tags && config.deepgram.tags.length > 0) {
+					config.deepgram.tags.forEach((tag) => {
+						params.append('tag', tag);
+					});
+				}
+
 				const deepgramUrl = `${DEEPGRAM_WS_BASE}?${params.toString()}`;
 
 				// Create WebSocket with Sec-WebSocket-Protocol for authentication

src/config.ts

@@ -57,6 +57,7 @@ export const config = {
 		punctuate: process.env.DEEPGRAM_PUNCTUATE === 'true',
 		diarize: process.env.DEEPGRAM_DIARIZE === 'true',
 		includeLanguage: process.env.DEEPGRAM_INCLUDE_LANGUAGE === 'true', // Default false
+		tags: process.env.DEEPGRAM_TAGS ? process.env.DEEPGRAM_TAGS.split(',').map((t) => t.trim()).filter((t) => t) : [],
 	},
 
 	server: {

test/unit/backends/DeepgramBackend.test.ts

@@ -34,6 +34,7 @@ vi.mock('../../../src/config', () => ({
 			punctuate: true,
 			diarize: false,
 			includeLanguage: false,
+			tags: ['test-tag-1', 'test-tag-2'],
 		},
 	},
 }));
@@ -144,6 +145,22 @@ describe('DeepgramBackend', () => {
 			expect(mockWsManager.mockWs.url).toContain('diarize=false');
 		});
 
+		it('should include tags in URL if configured', async () => {
+			const backend = new DeepgramBackend('test-tag', { id: 'participant-1' });
+			const config: BackendConfig = {
+				model: 'nova-2',
+				language: null,
+				prompt: undefined,
+			};
+
+			const connectPromise = backend.connect(config);
+			mockWsManager.mockWs.simulateOpen();
+			await connectPromise;
+
+			expect(mockWsManager.mockWs.url).toContain('tag=test-tag-1');
+			expect(mockWsManager.mockWs.url).toContain('tag=test-tag-2');
+		});
+
 		it('should start KeepAlive timer on connection', async () => {
 			const backend = new DeepgramBackend('test-tag', { id: 'participant-1' });
 			const config: BackendConfig = {

worker/env.d.ts

@@ -30,6 +30,7 @@ export interface Env {
 	DEEPGRAM_INCLUDE_LANGUAGE?: string;
 	DEEPGRAM_PUNCTUATE?: string;
 	DEEPGRAM_ENCODING?: string;
+	DEEPGRAM_TAGS?: string;
 	PROVIDERS_PRIORITY?: string;
 	FORCE_COMMIT_TIMEOUT?: string;
 	DEBUG?: string;

worker/index.ts

@@ -64,6 +64,7 @@ export class TranscriberContainer extends Container<Env> {
 		DEEPGRAM_INCLUDE_LANGUAGE: this.env.DEEPGRAM_INCLUDE_LANGUAGE || 'false',
 		DEEPGRAM_PUNCTUATE: this.env.DEEPGRAM_PUNCTUATE || 'true',
 		DEEPGRAM_ENCODING: this.env.DEEPGRAM_ENCODING || 'opus',
+		DEEPGRAM_TAGS: this.env.DEEPGRAM_TAGS || '',
 		PROVIDERS_PRIORITY: this.env.PROVIDERS_PRIORITY || 'openai',
 		FORCE_COMMIT_TIMEOUT: this.env.FORCE_COMMIT_TIMEOUT || '2',
 		DEBUG: this.env.DEBUG || 'true',