const ChangeDetector = require("airtable-change-detector");
 
const base = new Airtable({ apiKey: process.env.AIR_KEY }).base(
  process.env.AIR_BASE_ID
);
 
// You can create multiple ChangeDetectors for each table you want to watch.
const myTableDetector = new ChangeDetector(base("MyTableName"), {
  writeDelayMs: 100, // Delay between Airtable writes.
  metaFieldName: "MyMetaField", // Defaults to `Meta`
  lastModifiedFieldName: "My Last Modified", // Defaults to `Last Modified`
  lastProcessedFieldName: "Last Processed", // If not included, detector will not write this field
  sensitiveFields: ["Address", "Birthdate"], // Fields not to include in `Meta`s previous state. Useful for keeping data deletion easy.
  autoUpdateEnabled: true // Defaults to true. If disabled you need to, when ready, pass an array of records to the function myTableDetector.updateRecords() to mark the record(s) as having been processed. It is recommended that you 'await' the return of the function to ensure a successful update.
});
myTableDetector.pollWithInterval(
  "pollingNameForLogging",
  10000, // interval in milliseconds. `pollWithInterval` will wait for both interval and work to complete
  async recordsChanged => {
    const statusFieldName = "Status";
    const colorFieldName = "Color";
    console.info(`Found ${recordsChanged.length} changes in MyTableName`);
    const promises = [];
    const someSetupConfig = await mySetup(recordsChanged.length);
    recordsChanged.forEach(record => {
      // Each `record` is an Airtable record in the node API with extra fields added including:
      // record.didChange(field) returns true if the field changed (or is new) between the last observation and now
      // record.getPrior(field) returns the prior value for `field` or undefined
      // See `enrichRecord` for more added methods
 
      if (record.didChange(colorFieldName)) {
        // Ex: send new color value to webhook
        promises.push(axios.post(myWebhookUrl, { newColor: record.get(colorFieldName) }));
      }
      if (
        record.didChange(statusFieldName) &&
        record.getPrior(statusFieldName) === "New" &&
        record.get(statusFieldName) === "Assigned"
      ) {
        promises.push(doSomeAsyncLogic(someSetupConfig));
      }
    });
    // If doing many Airtable writes, be careful of 5rps rate limit
    return Promise.all(promises);
  },
  // errFunc is optional. If absent, the error will be logged to console and retried after interval.
  // In that case, the recordId will not be logged.
  async (err, recordId) => {
    // recordId will be passed if the error is specific to a record
    // (ex: the Meta field for a record isn't valid JSON because its been edited manually)
    if (recordId) {
      console.log(`Error for record ${recordId}:`);
    }
    console.log(err);
    await sendAlertingWebhook(err);
  }
);