yujunjun/context7
1
0
Fork 0
mirror of https://github.com/upstash/context7.git synced 2025-12-05 03:19:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: log sse usage counter

Browse Source
This commit is contained in:
enesgules 2025-10-30 11:46:03 +03:00
parent 5888ae1b12
commit 7f86335cfa
1 changed files with 22 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/index.ts
View File

@ -69,6 +69,18 @@ const CLI_PORT = (() => {
// Store SSE transports by session ID // Store SSE transports by session ID
const sseTransports: Record<string, SSEServerTransport> = {}; const sseTransports: Record<string, SSEServerTransport> = {};
// Counter for SSE deprecation notice usage
let sseDeprecationCounter = 0;
/**
* Tracks SSE deprecation notice usage and logs every 10th occurrence
*/
function trackSseDeprecation(): void {
sseDeprecationCounter++;
if (sseDeprecationCounter % 10 === 0) {
console.error(`SSE deprecated usage count: ${sseDeprecationCounter}`);
}
}
function getClientIp(req: IncomingMessage): string | undefined { function getClientIp(req: IncomingMessage): string | undefined {
// Check both possible header casings // Check both possible header casings
@ -166,6 +178,11 @@ For ambiguous queries, request clarification before proceeding with a best-guess
const resultsText = formatSearchResults(searchResponse); const resultsText = formatSearchResults(searchResponse);
// Track SSE deprecation usage
if (transportType === "sse") {
trackSseDeprecation();
}
const responseText = `${transportType === "sse" ? sseDeprecationNotice + "\n\n" : ""}Available Libraries (top matches): const responseText = `${transportType === "sse" ? sseDeprecationNotice + "\n\n" : ""}Available Libraries (top matches):
Each result includes: Each result includes:
@ -240,6 +257,11 @@ ${resultsText}`;
}; };
} }
// Track SSE deprecation usage
if (transportType === "sse") {
trackSseDeprecation();
}
const responseText = const responseText =
(transportType === "sse" ? sseDeprecationNotice + "\n\n" : "") + fetchDocsResponse; (transportType === "sse" ? sseDeprecationNotice + "\n\n" : "") + fetchDocsResponse;