Untitled

if ( !sfdc.credentials.refresh_token ) {
  sdfcConnect().then(async function(){
    var test = await checkComponents();
    console.log(JSON.stringify(test) + " test value");
    JSONTester("testJ.json",test);
    
  });  // no ui available

}

async function JSONTester(filename, jsonData) {
  let jsonString = JSON.stringify(jsonData, null, 2);
  jsonString=jsonString.replace(/\\/g,"").replace(/"{/g, '{').replace(/}"/g, '}').replace(/},]/g, '}]');
  try {
    // Scrivi il JSON su file in modo sincrono
    fs.writeFileSync(filename, jsonString);
    console.log('File JSON salvato con successo!');
  } catch (err) {
    console.error('Errore durante la scrittura del file:', err);
  }
  
}

async function checkComponents() {
  return new Promise(async (resolve, reject) => {
    try {
      console.log("checkComponents started");

      let soql = `SELECT id__c, data__c, type__c FROM component__c`;

      // Esegui la query tramite l'interfaccia Salesforce (sfdc)
      var res = await sfdc.query(soql);
      console.log("query result:", res);

      // Verifica se ci sono record nella risposta
      if (res.records && res.records.length > 0) {
        console.log("Records trovati:", res.records);
        
        // Mappa i risultati per la struttura richiesta
        let objects = res.records.map(record => ({
          id: record.id__c,
          type: record.type__c || "",  
          notes: record.notes__c || "", 
          data: record.data__c
        }));
        
        console.log("  scrivi console log", objects);
        
        // Risolvi la promise con il risultato degli oggetti
        resolve(objects);
      } else {
        // Se non ci sono record, risolvi con un messaggio vuoto
        resolve("vuoto");
      }
    } catch (error) {
      // Se c'è un errore, rigetta la promise
      reject(`Errore nella query: ${error.message}`);
    }
  });
}