Carga inicial de 100k produtos

import { createWriteStream } from 'fs';
import { db } from './seu-db.js';

const stream = createWriteStream('voop-import.jsonl');

for await (const p of db.iterateProducts()) {
  const line = {
    externalSystem: 'meu-erp',
    externalId: p.id,
    sku: p.sku,
    name: p.name,
    description: p.descriptionHtml,
    price: p.price,
    cost: p.cost,
    weight: p.weightKg,
    gtin13: p.ean,
    ncm: p.ncm,
    category: { name: p.categoryName },
    brand:    p.brandName ? { name: p.brandName } : undefined,
    tags: p.tags,
    metadata: { supplierId: p.supplierId },
    media: p.images.map((img, i) => ({
      url: img.publicUrl,
      role: i === 0 ? 'primary' : 'gallery',
      sortOrder: i,
    })),
  };
  stream.write(JSON.stringify(line) + '\n');
}
stream.end();
console.log('Done — voop-import.jsonl');

JOB=$(curl -sX POST https://api.voop.work/api/v1/catalog/imports \
  -H "Authorization: Bearer $VOOP_KEY" \
  -H "Content-Type: application/json" \
  -d "{ \"fileSizeBytes\": $(stat -c%s voop-import.jsonl) }")

JOB_ID=$(echo $JOB | jq -r .data.jobId)
UPLOAD_URL=$(echo $JOB | jq -r .data.uploadUrl)

echo "Job: $JOB_ID"

curl -X PUT "$UPLOAD_URL" \
  -H "Content-Type: application/x-ndjson" \
  --data-binary @voop-import.jsonl

curl -X POST https://api.voop.work/api/v1/catalog/imports/$JOB_ID/start \
  -H "Authorization: Bearer $VOOP_KEY"

while true; do
  STATUS=$(curl -s https://api.voop.work/api/v1/catalog/imports/$JOB_ID \
    -H "Authorization: Bearer $VOOP_KEY" | jq -r .data.status)
  PROGRESS=$(curl -s https://api.voop.work/api/v1/catalog/imports/$JOB_ID \
    -H "Authorization: Bearer $VOOP_KEY" | jq -r .data.progress)
  echo "[$STATUS] $PROGRESS%"
  case $STATUS in
    completed|completed_with_errors|failed|cancelled) break ;;
  esac
  sleep 10
done

curl https://api.voop.work/api/v1/catalog/imports/$JOB_ID/errors \
  -H "Authorization: Bearer $VOOP_KEY" | jq

# crontab
0 3 * * *  /opt/voop-sync/run-import.sh