Importar dados de produtos para o Vecta Desk

export const main = async () => {
  const intervalMinutes = 10; // Igual à frequência do seu agendamento
  const cutoffTime = new Date(Date.now() - intervalMinutes * 60 * 1000).toISOString();
 
  // Substitua pela conexão real do seu armazém de dados
  const response = await fetch("https://seu-armazem-api.com/query", {
    method: "POST",
    headers: {
      "Authorization": "Bearer SUA_API_KEY",
      "Content-Type": "application/json"
    },
    body: JSON.stringify({
      query: `
        SELECT id, name, sku, price, stock_quantity, updated_at
        FROM products
        WHERE updated_at >= '${cutoffTime}'
      `
    })
  });
 
  const data = await response.json();
  return { products: data.results };
};

export const main = async (params: { products: any }) => {
  const products = typeof params.products === "string"
    ? JSON.parse(params.products)
    : params.products;
 
  return {
    products: products.map(product => ({
      externalId: product.id,
      name: product.name,
      sku: product.sku,
      price: parseFloat(product.price),        // String → Número
      stockQuantity: parseInt(product.stock_quantity),
      isActive: product.status === "active"    // String → Booleano
    }))
  };
};

export const main = async (params: { deals: any }) => {
  const deals = typeof params.deals === "string"
    ? JSON.parse(params.deals)
    : params.deals;
 
  return {
    deals: deals.map(deal => ({
      ...deal,
      // Converte timestamp Unix em data ISO
      closedAt: deal.closed_timestamp
        ? new Date(deal.closed_timestamp * 1000).toISOString()
        : null,
      // Garante que o valor seja um número (remove símbolos de moeda)
      amount: parseFloat(String(deal.amount).replace(/[^0-9.-]/g, "")),
      // Normaliza nomes de etapa
      stage: deal.stage?.toLowerCase().replace(/_/g, " ")
    }))
  };
};