Integrate the Dux Soup API with the Snowflake API

// To use any npm package on Pipedream, just import it
import axios from "axios";
import jsSHA from "jssha";

export default defineComponent({
    props: {
    dux_soup: {
      type: "app",
      app: "dux_soup",
    }
  },
  async run({ steps, $ }) {
    const targeturl = `${this.dux_soup.$auth.target_url}/queue`;
    const userid = `${this.dux_soup.$auth.user_id}`;
    const auth_key = `${this.dux_soup.$auth.auth_key}`;

    var shaObj = new jsSHA("SHA-1", "TEXT");
    const timestamp = +new Date();
    let commandrequestjsonbody = {
      command: "visit",
      targeturl,
      userid: userid,
      timestamp: timestamp,
      params: { 
        profile: "",
      }
    }
    commandrequestjsonbody = JSON.stringify(commandrequestjsonbody);
    shaObj.setHMACKey(auth_key, "TEXT");
    shaObj.update(commandrequestjsonbody); 
    var hmac = shaObj.getHMAC("B64");
    const config = {
      url: targeturl,
      method: "POST",
      headers: {
        "X-Dux-Signature": hmac,
        "Content-Type": "application/json"
      },
      data: commandrequestjsonbody
    };
    return (await axios(config)).data;
  },
})

import { promisify } from 'util'
import snowflake from 'snowflake-sdk'

export default defineComponent({
  props: {
    snowflake: {
      type: "app",
      app: "snowflake",
    }
  },
  async run({steps, $}) {
    const connection = snowflake.createConnection({
      ...this.snowflake.$auth,
      application: "PIPEDREAM_PIPEDREAM",
    })
    const connectAsync = promisify(connection.connect)
    await connectAsync()
    
    async function connExecuteAsync(options) {
      return new Promise((resolve, reject) => {
        connection.execute({
          ...options,
          complete: function(err, stmt, rows) {
            if (err) {
              reject(err)
            } else {
              resolve({stmt, rows})
            }
          }
        })
      })
    }
    
    // See https://docs.snowflake.com/en/user-guide/nodejs-driver-use.html#executing-statements
    const { rows } = await connExecuteAsync({
      sqlText: `SELECT CURRENT_TIMESTAMP()`,
    })
    return rows
  },
})