Function processLogLine

server/index.js:250–361

(line)

}

function processLogLine(line) {
    enqueueLogLine(line);
    // Detect LLM usage: service=llm providerID=... modelID=...
    // Example: service=llm providerID=openai modelID=gpt-5.2-codex sessionID=...
    const isUsage = line.includes('service=llm') && line.includes('stream');
    const isError = line.includes('service=llm') && (line.includes('error=') || line.includes('status=429'));
    
    if (!isUsage && !isError) return;

    const providerMatch = line.match(/providerID=([^\s]+)/);
    const modelMatch = line.match(/modelID=([^\s]+)/);
    
    if (providerMatch) {
        let provider = providerMatch[1];
        const model = modelMatch ? modelMatch[1] : 'unknown';
        
        // Normalize providers
        if (provider === 'codex') provider = 'openai';
        if (provider === 'claude') provider = 'anthropic';
        
        // Map provider to pool namespace
        let namespace = provider;
        if (provider === 'google') {
            const activePlugin = getActiveGooglePlugin();
            namespace = 'google.antigravity';
        }

        const metadata = loadPoolMetadata();
        if (!metadata._quota) metadata._quota = {};
        if (!metadata._quota[namespace]) metadata._quota[namespace] = {};
        
        const today = new Date().toISOString().split('T')[0];

        if (isUsage) {
            // Increment usage
            metadata._quota[namespace][today] = (metadata._quota[namespace][today] || 0) + 1;
            
            // Also update active account usage if possible
            const studio = loadStudioConfig();
            const activeProfile = studio.activeProfiles?.[provider];
            if (activeProfile && metadata[namespace]?.[activeProfile]) {
                metadata[namespace][activeProfile].usageCount = (metadata[namespace][activeProfile].usageCount || 0) + 1;
                metadata[namespace][activeProfile].lastUsed = Date.now();
            }
        } else if (isError) {
            // Check for quota exhaustion patterns
            const errorMsg = line.match(/error=(.+)/)?.[1] || '';
            const isQuotaError = line.includes('status=429') || 
                               errorMsg.toLowerCase().includes('quota') || 
                               errorMsg.toLowerCase().includes('rate limit');
                               
            if (isQuotaError) {
                console.log(`[LogWatcher] Detected quota exhaustion for ${namespace}`);
                
                // Reload metadata to ensure freshness
                const currentMeta = loadPoolMetadata();
                if (!currentMeta._quota) currentMeta._quota = {};
                if (!currentMeta._quota[namespace]) currentMeta._quota[namespace] = {};