function writeProcessedData()

in app/nodejs/process.js [135:157]


function writeProcessedData(aggregate) {
  logger.info('writeProcessedData: start writing');

  let counter = 0;

  const processedBucket = storage.bucket(process.env.PROCESSED_DATA_BUCKET);

  const writeData = new Promise((resolve) => {
    Object.keys(aggregate).forEach(async function(rowKey) {
      const facetData = aggregate[rowKey];
      processedBucket
          .file(`${rowKey}/data.json`)
          .save(JSON.stringify(facetData));
      counter += 1;
    });

    resolve(counter);
  });

  writeData.then(function(counter) {
    logger.info(`writeProcessedData: wrote ${counter} files`);
  });
}