fix5.js

const fs = require('fs');
let c = fs.readFileSync('C:/Users/ADMIN/SYNCRO/backend/src/services/risk-detection/risk-detection-service.ts', 'utf8');

// 1. Move pLimit import to top if not already there
if (!c.startsWith('import pLimit')) {
  c = 'import pLimit from "p-limit";\nconst RISK_CALC_CONCURRENCY = parseInt(process.env.RISK_CALC_CONCURRENCY ?? "10", 10);\n' + c;
}

// 2. Cut everything from the class closing brace onward (line 342 area)
const cutMarker = '  }\r\n}\r\n\r\nexport const riskDetectionService = new RiskDetectionService();\r\nimport pLimit from "p-limit";';
const cutIdx = c.indexOf(cutMarker);
if (cutIdx === -1) { console.log('marker not found'); process.exit(1); }

const goodTail = `  }

  async recalculateAllRiskScores() {
    const result = { total: 0, successful: 0, failed: 0, errors: [] };
    const startTime = Date.now();
    const limit = pLimit(RISK_CALC_CONCURRENCY);
    try {
      logger.info("Starting risk recalculation for all active subscriptions", { concurrency: RISK_CALC_CONCURRENCY });
      let page = 0;
      const pageSize = 100;
      while (true) {
        const { data: subscriptions, error } = await supabase
          .from("subscriptions")
          .select("id, user_id")
          .eq("status", "active")
          .range(page * pageSize, (page + 1) * pageSize - 1);
        if (error) throw error;
        if (!subscriptions || subscriptions.length === 0) break;
        result.total += subscriptions.length;
        await Promise.all(
          subscriptions.map((subscription) =>
            limit(async () => {
              try {
                const assessment = await this.computeRiskLevel(subscription.id);
                await this.saveRiskScore(assessment, subscription.user_id);
                result.successful++;
              } catch (err) {
                result.failed++;
                result.errors.push({ subscription_id: subscription.id, error: err instanceof Error ? err.message : String(err) });
                logger.error(\`Failed to recalculate risk for subscription \${subscription.id}:\`, err);
              }
            }),
          ),
        );
        logger.info("Risk recalculation progress", { processed: result.total, successful: result.successful, failed: result.failed, elapsed_ms: Date.now() - startTime });
        if (subscriptions.length < pageSize) break;
        page++;
      }
      return result;
    } catch (error) {
      logger.error("Error during risk recalculation:", error);
      throw error;
    }
  }
}

export const riskDetectionService = new RiskDetectionService();
`;

// The cutMarker starts with '  }' which is the closing of recordRenewalAttempt - keep up to but not including that last '  }'
c = c.slice(0, cutIdx) + goodTail;
fs.writeFileSync('C:/Users/ADMIN/SYNCRO/backend/src/services/risk-detection/risk-detection-service.ts', c, 'utf8');
console.log('done, lines:', c.split('\n').length);