Connect Monday and Oracle NetSuite journal entries in our serverless environment

class GraphqlSourceMondaySelectItems {
    async init() {
        // TODO: Create your GraphQL credential with monday information and base url: https://api.monday.com/v2/
        // More info at https://yepcode.io/docs/integrations/http/#credential-configuration
        // Official docs: https://developer.monday.com/api-reference/docs/authentication
        this.monday = yepcode.integration.graphql("your-monday-credential-name");
    }

    async fetch(publish, done) {
        const ids = ["<your-board-id>"];
        const queryParams = {
            rules: [{
                column_id: "your-column-id",
                compare_value: ["your-filter-criteria"],
            }, ],
        };
        const variables = {
            ids,
            queryParams
        };

        try {
            const {
                boards
            } = await this.getBoards(variables);
            const page = boards[0].items_page;
            page.items.forEach((item) => publish(item));
            variables.cursor = page.cursor;
            // It's not allowed to send cursor and query_params in the same request
            // Subsequent cursor calls will return the elements on the next page with the criteria defined in the initial queryParams.
            variables.queryParams = undefined;

            while (variables.cursor) {
                const {
                    boards
                } = await this.getBoards(variables);
                const page = boards[0].items_page;
                page.items.forEach((item) => publish(item));
                variables.cursor = page.cursor;
            }
        } catch (error) {
            console.log(`Something wrong has happened: ${error.message}`);
        }

        done();
    }

    getBoards(variables) {
        // TODO: Customize your GraphQL query
        // The max page size is 100.
        // IMPORTANT: This example uses the api version "2023-10" recommended by Monday. Some fields could change between versions, so check the official docs for more info.
        // Official docs: https://developer.monday.com/api-reference/docs/items_page
        return this.monday.request(
            gql`
        query getBoards(
          $limit: Int!
          $queryParams: ItemsQuery
          $ids: [ID!]
          $cursor: String
        ) {
          boards(ids: $ids) {
            items_page(
              limit: $limit
              query_params: $queryParams
              cursor: $cursor
            ) {
              cursor
              items {
                id
                name
              }
            }
          }
        }
      `,
            variables
        );
    }

    async close() {}
}

class AxiosOauth10ATargetOracleNetsuiteCreateJournalEntries {
    async init() {
        // TODO: Create your axios oauth10a credential with netsuite information:
        // More info at https://yepcode.io/docs/integrations/axios-oauth-10-a#credential-configuration

        // To get your Netsuite credentials, see the help topic Getting Started with Token-based Authentication (https://system.netsuite.com/app/help/helpcenter.nl?fid=section_4247337262.html)
        // More info at: https://docs.oracle.com/en/cloud/saas/netsuite/ns-online-help/section_161942084079.html
        // You should get this parameters: consumer_key, consumer_secret_key, token, token_secret and realm

        // Check this documentation to build the base url (https://docs.oracle.com/en/cloud/saas/netsuite/ns-online-help/section_1546938065.html)
        // It should be something like: https://demo123.suitetalk.api.netsuite.com/services/rest/record/v1/
        this.httpClient = yepcode.integration.axiosOauth10a(
            "your-axios-oauth-10-a-oracle-netsuite-credential-name"
        );
    }

    async consume(item) {
        // TODO: Customize your request checking the API documentation:
        // https://system.netsuite.com/help/helpcenter/en_US/APIs/REST_API_Browser/record/v1/2021.2/index.html#tag-journalEntry
        // https://docs.oracle.com/en/cloud/saas/netsuite/ns-online-help/section_159886587653.html
        await this.httpClient.post(`/journalEntry`, {
            // TODO: Map item attributes to journal entry fields
            // https://system.netsuite.com/help/helpcenter/en_US/APIs/REST_API_Browser/record/v1/2021.2/index.html#/definitions/journalEntry
            accountingBook: item.accountingBook,
            accountingBookDetail: item.accountingBookDetail,
            approvalStatus: {
                id: item.id,
                refName: item.refName,
            },
            // complete your fields
        });
    }

    async close() {}
}