Первичная синхронизация

1. Подготовка        → Проверка API ключа
2. Агенты (опционально) → Приглашение и привязка агентов
3. Синхронизация     → Bulk-загрузка объявлений с фото и статусом

const API_KEY = 'YOUR_API_KEY';
const BASE_URL = 'https://crm.rentix.md/api/v1';

async function checkConnection() {
  const response = await fetch(`${BASE_URL}/agency`, {
    headers: { 'Authorization': `ApiKey ${API_KEY}` }
  });

  if (!response.ok) {
    throw new Error('Ошибка подключения. Проверьте API ключ.');
  }

  const agency = await response.json();
  console.log(`Подключено: ${agency.name}`);
  console.log(`Лимит объявлений: ${agency.limits.monthlyListings.limit}`);

  return agency;
}

async function linkAgents(crmAgents) {
  // Получить агентов из Rentix
  const response = await fetch(`${BASE_URL}/users`, {
    headers: { 'Authorization': `ApiKey ${API_KEY}` }
  });
  const { items: rentixAgents } = await response.json();

  // Подготовить операции привязки
  const operations = [];

  for (const crmAgent of crmAgents) {
    const match = rentixAgents.find(r => r.phone === crmAgent.phone);
    if (match && !match.externalId) {
      operations.push({
        op: 'link',
        id: match.id,
        externalId: crmAgent.id
      });
    }
  }

  if (operations.length === 0) return;

  // Bulk-привязка
  await fetch(`${BASE_URL}/users/bulk`, {
    method: 'POST',
    headers: {
      'Authorization': `ApiKey ${API_KEY}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({ operations })
  });

  console.log(`Привязано агентов: ${operations.length}`);
}

function transformListing(crmListing) {
  return {
    op: 'upsert',
    externalId: crmListing.id,

    // Тип
    announcementType: crmListing.type === 'sale' ? 'sale' : 'rent',
    propertyType: 'residential',
    propertySecondaryType: mapPropertyType(crmListing.category),

    // Цена
    announcementValue: crmListing.price,
    announcementCurrency: crmListing.currency || 'EUR',
    announcementPayPeriod: crmListing.type === 'rent' ? 'monthly' : undefined,

    // Характеристики
    propertyArea: crmListing.area,
    propertyFloorNumber: crmListing.floor,
    propertyFloorsTotal: crmListing.totalFloors,

    // Описание
    announcementDescription: crmListing.description,

    // Фото — передайте URL и externalFileId для отслеживания
    files: crmListing.photos.map((photo, index) => ({
      url: photo.url,
      externalFileId: photo.id,
    })),

    // Агент (если привязан)
    user: { externalUserId: crmListing.agentId },

    // Сразу публикуем
    announcementStatus: 'active'
  };
}

function mapPropertyType(category) {
  const map = {
    'квартира': 'apartment',
    'дом': 'house',
    'комната': 'room',
  };
  return map[category];
}

function chunkArray(array, size) {
  const chunks = [];
  for (let i = 0; i < array.length; i += size) {
    chunks.push(array.slice(i, i + size));
  }
  return chunks;
}

async function syncListings(crmListings) {
  const operations = crmListings.map(transformListing);
  const chunks = chunkArray(operations, 100);

  let total = 0;

  // Отправляйте пакеты последовательно
  for (const chunk of chunks) {
    const response = await fetch(`${BASE_URL}/listings/bulk`, {
      method: 'POST',
      headers: {
        'Authorization': `ApiKey ${API_KEY}`,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify({ operations: chunk })
    });

    const result = await response.json();
    total += result.summary.succeeded;

    console.log(`Обработано: ${total}/${crmListings.length}`);

    // Логировать ошибки
    const failed = result.results.filter(r => !r.success);
    for (const f of failed) {
      console.error(`Ошибка ${f.externalId}: ${f.error?.message}`);
    }
  }

  return total;
}

async function fullSync() {
  console.log('=== Первичная синхронизация ===');

  // 1. Проверка подключения
  console.log('\n1. Проверка подключения...');
  await checkConnection();

  // 2. Получить данные из CRM
  console.log('\n2. Получение данных из CRM...');
  const crmListings = await getListingsFromCRM(); // ваша функция
  console.log(`Найдено: ${crmListings.length} объявлений`);

  // 3. Синхронизация объявлений
  console.log('\n3. Синхронизация объявлений...');
  const synced = await syncListings(crmListings);

  console.log('\n=== Синхронизация завершена ===');
  console.log(`Отправлено: ${synced} объявлений`);
  console.log('Объявления появятся на сайте после обработки.');
}

fullSync().catch(console.error);