Integrate the Reform API with the Snowflake API

import { axios } from "@pipedream/platform"
export default defineComponent({
  props: {
    reform: {
      type: "app",
      app: "reform",
    }
  },
  async run({steps, $}) {
    const fields_to_extract = [
      {
        "name": "Nouns",
        "description": "Please extract all nouns.",
        "type": "String"
      },
      {
        "name": "Verbs",
        "description": "Please extract all verbs.",
        "type": "String"
      }
    ]
    const data = {
      text_content: "There are usually about 200 words in a paragraph, but this can vary widely. Most paragraphs focus on a single idea that's expressed with an introductory sentence, then followed by two or more supporting sentences about the idea. A short paragraph may not reach even 50 words while long paragraphs can be over 400 words long, but generally speaking they tend to be approximately 200 words in length.",
      fields_to_extract: fields_to_extract
    }
    return await axios($, {
      method: "post",
      url: `https://api.reformhq.com/v1/api/extract-text `,
      headers: {
        Authorization: `Bearer ${this.reform.$auth.api_key}`,
        "Content-Type": `application/json`,
      },
      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
  },
})