Revert "fix: no more watches"

This reverts commit cba783a.

Author: izadoesdev

apps/api/src/agent/handlers/chart-handler.ts

@@ -60,7 +60,11 @@ export async function* handleChartResponse(
 			},
 			debugInfo: context.user.role === 'ADMIN' ? context.debugInfo : undefined,
 		};
-	} catch (_queryError: unknown) {
+	} catch (queryError: unknown) {
+		console.error('❌ SQL execution error', {
+			error: queryError instanceof Error ? queryError.message : 'Unknown error',
+			sql: parsedAiJson.sql,
+		});
 		yield {
 			type: 'error',
 			content: 'Database query failed. The data might not be available.',

apps/api/src/agent/handlers/metric-handler.ts

@@ -32,7 +32,12 @@ export async function* handleMetricResponse(
 				parsedAiJson.metric_value
 			);
 			yield* sendMetricResponse(parsedAiJson, metricValue, context);
-		} catch (_queryError: unknown) {
+		} catch (queryError: unknown) {
+			console.error('❌ Metric SQL execution error', {
+				error:
+					queryError instanceof Error ? queryError.message : 'Unknown error',
+				sql: parsedAiJson.sql,
+			});
 			yield* sendMetricResponse(
 				parsedAiJson,
 				parsedAiJson.metric_value,
@@ -48,9 +53,7 @@ function extractMetricValue(
 	queryData: unknown[],
 	defaultValue: unknown
 ): unknown {
-	if (!(queryData.length && queryData[0])) {
-		return defaultValue;
-	}
+	if (!(queryData.length && queryData[0])) return defaultValue;
 
 	const firstRow = queryData[0] as Record<string, unknown>;
 	const valueKey =

apps/api/src/agent/processor.ts

@@ -32,6 +32,12 @@ export async function* processAssistantRequest(
 	const startTime = Date.now();
 
 	try {
+		console.info('✅ [Assistant Processor] Input validated', {
+			message: request.message,
+			website_id: request.website_id,
+			website_hostname: request.website_hostname,
+		});
+
 		if (context.user.role === 'ADMIN') {
 			context.debugInfo.validatedInput = {
 				message: request.message,
@@ -54,6 +60,11 @@ export async function* processAssistantRequest(
 		const aiResponse = await getAICompletion({ prompt: fullPrompt });
 		const aiTime = Date.now() - aiStart;
 
+		console.info('📝 [Assistant Processor] Raw AI response received', {
+			timeTaken: `${aiTime}ms`,
+			contentLength: aiResponse.content.length,
+		});
+
 		const parsedResponse = parseAIResponse(aiResponse.content);
 
 		if (!parsedResponse.success) {
@@ -82,6 +93,11 @@ export async function* processAssistantRequest(
 			};
 			return;
 		}
+		console.info('✅ [Assistant Processor] AI response parsed', {
+			responseType: aiJson.response_type,
+			hasSQL: !!aiJson.sql,
+			thinkingSteps: aiJson.thinking_steps?.length || 0,
+		});
 
 		// Process thinking steps
 		if (aiJson.thinking_steps?.length) {
@@ -133,6 +149,9 @@ export async function* processAssistantRequest(
 	} catch (error: unknown) {
 		const errorMessage =
 			error instanceof Error ? error.message : 'Unknown error';
+		console.error('💥 [Assistant Processor] Processing error', {
+			error: errorMessage,
+		});
 
 		yield {
 			type: 'error',

apps/api/src/agent/prompts/agent.ts

@@ -40,7 +40,7 @@ export const comprehensiveUnifiedPrompt = (
 	mode: 'analysis_only' | 'execute_chat' | 'execute_agent_step',
 	previousMessages?: any[],
 	agentToolResult?: any,
-	_model?: 'chat' | 'agent' | 'agent-max'
+	model?: 'chat' | 'agent' | 'agent-max'
 ) => `
 <persona>
 You are Nova, a world-class, specialized AI analytics assistant for the website ${websiteHostname}. You are precise, analytical, and secure. Your sole purpose is to help users understand their website's analytics data by providing insights, generating SQL queries, and creating visualizations.

apps/api/src/agent/utils/ai-client.ts

@@ -27,18 +27,33 @@ export async function getAICompletion(
 	request: AICompletionRequest
 ): Promise<AICompletionResponse> {
 	const startTime = Date.now();
-	const completion = await openai.chat.completions.create({
-		model: AI_MODEL,
-		messages: [{ role: 'system', content: request.prompt }],
-		temperature: request.temperature ?? 0.1,
-		response_format: { type: 'json_object' },
-	});
-
-	const content = completion.choices[0]?.message?.content || '';
-	const _aiTime = Date.now() - startTime;
-
-	return {
-		content,
-		usage: completion.usage,
-	};
+
+	try {
+		const completion = await openai.chat.completions.create({
+			model: AI_MODEL,
+			messages: [{ role: 'system', content: request.prompt }],
+			temperature: request.temperature ?? 0.1,
+			response_format: { type: 'json_object' },
+		});
+
+		const content = completion.choices[0]?.message?.content || '';
+		const aiTime = Date.now() - startTime;
+
+		console.info('🤖 [AI Client] Completion completed', {
+			timeTaken: `${aiTime}ms`,
+			contentLength: content.length,
+			usage: completion.usage,
+		});
+
+		return {
+			content,
+			usage: completion.usage,
+		};
+	} catch (error) {
+		console.error('❌ [AI Client] Completion failed', {
+			error: error instanceof Error ? error.message : 'Unknown error',
+			timeTaken: Date.now() - startTime,
+		});
+		throw error;
+	}
 }

apps/api/src/agent/utils/query-executor.ts

@@ -11,6 +11,12 @@ export async function executeQuery(sql: string): Promise<QueryResult> {
 	const result = await chQuery(sql);
 	const queryTime = Date.now() - queryStart;
 
+	console.info('🔍 [Query Executor] Query completed', {
+		timeTaken: `${queryTime}ms`,
+		resultCount: result.length,
+		sql: sql.substring(0, 100) + (sql.length > 100 ? '...' : ''),
+	});
+
 	return {
 		data: result,
 		executionTime: queryTime,

apps/api/src/agent/utils/response-parser.ts

@@ -17,11 +17,22 @@ export function parseAIResponse(rawResponse: string): ParsedAIResponse {
 
 		const parsedData = AIResponseJsonSchema.parse(JSON.parse(cleanedResponse));
 
+		console.info('✅ [Response Parser] AI response parsed successfully', {
+			responseType: parsedData.response_type,
+			hasSQL: !!parsedData.sql,
+			thinkingSteps: parsedData.thinking_steps?.length || 0,
+		});
+
 		return {
 			success: true,
 			data: parsedData,
 		};
 	} catch (parseError) {
+		console.error('❌ [Response Parser] AI response parsing failed', {
+			error: parseError instanceof Error ? parseError.message : 'Unknown error',
+			rawResponseLength: rawResponse.length,
+		});
+
 		return {
 			success: false,
 			error:

apps/api/src/agent/utils/sql-validator.ts

@@ -22,9 +22,7 @@ export function validateSQL(sql: string): boolean {
 
 	// Check for dangerous keyword patterns
 	for (const keyword of FORBIDDEN_SQL_KEYWORDS) {
-		if (upperSQL.includes(keyword)) {
-			return false;
-		}
+		if (upperSQL.includes(keyword)) return false;
 	}
 
 	// Must start with SELECT or WITH (for CTEs)

apps/api/src/middleware/logging.ts

@@ -0,0 +1 @@
+ 

apps/api/src/middleware/rate-limit.ts

@@ -22,7 +22,9 @@ export function createRateLimitMiddleware(options: RateLimitOptions) {
 					headers: request.headers,
 				});
 				userId = session?.user?.id;
-			} catch (_error) {}
+			} catch (error) {
+				console.error('[Rate Limit] Auth error:', error);
+			}
 		}
 
 		const identifier = getRateLimitIdentifier(userId, request.headers);