Integrate the Datawaves API with the Airtable API

import { axios } from "@pipedream/platform"
export default defineComponent({
  props: {
    datawaves: {
      type: "app",
      app: "datawaves",
    }
  },
  async run({steps, $}) {
    const data = {
      "id": `123`,
      "product": `iPhone Charger`,
    }
    return await axios($, {
      method: "post",
      url: `https://datawaves.io/api/v1.0/projects/${this.datawaves.$auth.project_id}/events/test`,
      headers: {
        "Authorization": `${this.datawaves.$auth.secret_key}`,
      },
      data,
    })
  },
})

module.exports = defineComponent({
  props: {
    airtable: {
      type: "app",
      app: "airtable",
    },
    baseId: {
      type: "$.airtable.baseId",
      appProp: "airtable",
    },
    tableId: {
      type: "$.airtable.tableId",
      baseIdProp: "baseId",
    },
  },
  async run({steps, $}) {
    const Airtable = require('airtable');
    const base = new Airtable({apiKey: this.airtable.$auth.api_key}).base(this.baseId);

    const data = []
    
    await base(this.tableId).select({
      // pass optional config parameters here
    }).eachPage(function page(records, fetchNextPage) {
        // This function (`page`) will get called for each page of records.
        records.forEach(function(record) {
            data.push(record._rawJson)
        });

        // To fetch the next page of records, call `fetchNextPage`.
        // If there are more records, `page` will get called again.
        // If there are no more records, `done` will get called.
        fetchNextPage();
    })

    return data
  },
})