Limit Recovery

1'use strict';
2const fs = require('node:fs/promises');
3const path = require('node:path');
4const crypto = require('node:crypto');
5const STORES_PRODUCT_TAGS_MAX = 100;
6const STORES_SKU_MAX = 40;
7function truncate(value, limit, sourceId) { const chars = Array.from(String(value || '')); if (chars.length <= limit) return String(value || ''); const suffix = `-${crypto.createHash('sha256').update(
8function normalizeProduct({ sourceId, sku, tagIds = [] }) { const recoveries = []; const uniqueTags = [...new Set(tagIds)].slice(0, STORES_PRODUCT_TAGS_MAX); if (tagIds.length > uniqueTags.length) recoveries.push({ code: 'stores_product_tag_count', field: 'tags.publicTags.tagIds', action: 'capped'
9async function appendRecoveries(projectDir, adapter, sourceId, recoveries) { if (!recoveries.length) return; const file = path.join(projectDir, 'execution', 'quick-limit-recoveries.ndjson'); await fs.mkdir(path.dirname(file), { recursive: true }); await fs.appendFile(file, recoveries.
10function recordRecoveredRecord(summary, recoveries) { if (!recoveries.length) return; summary.recovered = (summary.recovered || 0) + 1; summary.recoveryCounts ||= {}; for (const item of recoveries) summary.recoveryCounts[item.code] = (summary.recoveryCounts[item.code] || 0) + 1; }
11async function writeFinalReport(projectDir, summary) { const file = path.join(projectDir, 'execution', 'quick-mode-final-report.md'); const rows = Object.entries(summary.recoveryCounts || {}).map(([code, count]) => `- ${code}: ${count}`).join('
12module.exports = { STORES_PRODUCT_TAGS_MAX, STORES_SKU_MAX, truncate, normalizeProduct, appendRecoveries, recordRecoveredRecord, writeFinalReport };