set.js

const v = require(`../../values`);
const dev = require('../dev');

const generalFuncs = require('../general');
const airtableDev = require('../dev/airtable');

/** Creates records passed inside airtable
 * @async
 * @param {string} tableName - The table name
 * @param {Array} recordsArray - An array of maximum 10 JSON elements that is following that specific airtable base fields naming conventions, if column not needed then simply do not include it in the JSON object of that record
 * @param {string} apiKey - The api key // (Optional - configurable through the config.airtable object) //
 * @param {string} baseURL - The base url // (Optional - Default is 'https://api.airtable.com/v0/' - configurable through the config.airtable object) //
 * @param {string} baseId - The base id // (Optional - configurable through the config.airtable object) //
 * @returns - Return a response following this module's format (Created using func.constructResponse functionality)
 ** The body will have an array with the records created
 ** In case of error (error of execution e.g. no url provided, not url hit error response), it will throw an exception with an object following the same format, for the url hit error responses, they will be returned as success but full body will be in the body value
 */
module.exports.records = async (
  tableName,
  recordsArray,
  apiKey = v.airtable.apiKey,
  baseURL = v.airtable.baseURL,
  baseId = v.airtable.baseId
) => {
  dev.throwErrorIfValueNotPassedAndNotSet(apiKey, 'airtable', 'apiKey');
  dev.throwErrorIfValueNotPassedAndNotSet(baseURL, 'airtable', 'baseURL');
  dev.throwErrorIfValueNotPassedAndNotSet(baseId, 'airtable', 'baseId');

  dev.throwErrorIfValueNotPassed(tableName, 'tableName');

  if (await generalFuncs.isEmptyArray(recordsArray)) {
    return generalFuncs.constructResponse(
      true,
      200,
      `recordsArray is empty`,
      []
    );
  }

  dev.throwErrorIfValueNotPassed(recordsArray, 'recordsArray');

  try {
    let statusCode;
    let recordsCreateddArray = [];

    await generalFuncs.performActionForSubArrays(
      async (chunk, {tableName, apiKey, baseURL, baseId}) => {
        const singleResponse = await airtableDev.createMax10Records(
          tableName,
          chunk,
          apiKey,
          baseURL,
          baseId
        );
        statusCode = singleResponse.code;

        recordsCreateddArray = [
          ...recordsCreateddArray,
          ...singleResponse.body,
        ];
      },
      recordsArray,
      10,
      {tableName, apiKey, baseURL, baseId},
      v.airtable.waitBetweenRequestsInMilliSeconds
    );

    return generalFuncs.constructResponse(
      true,
      statusCode,
      `Successfully updated ${recordsCreateddArray.length} records in table ${tableName}`,
      recordsCreateddArray
    );
  } catch (err) {
    throw dev.formatError(err);
  }
};