Connect Monday and Pinecone 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 PineconeTargetUpsertVectors {
    async init() {
        // TODO: Create your pinecone credential
        // More info at https://yepcode.io/docs/integrations/pinecone/#credential-configuration
        this.pineconeClient = yepcode.integration.pinecone(
            "your-pinecone-credential-name"
        );
        // TODO: Select the index name you want to recover.
        // More info at https://docs.pinecone.io/docs/node-client#index
        this.index = await this.pineconeClient.Index("your-index-name");
        this.vectors = [];
    }

    async consume(item) {
        // TODO: Save vectors you want to upsert into a namespace.
        this.vectors.push({
            id: item.id,
            values: item.values,
            metadata: item.metadata,
        });
    }

    async close() {
        // TODO: Write vectors into a namespace.
        // More info at https://docs.pinecone.io/docs/node-client#indexupsert
        await this.index.upsert({
            upsertRequest: {
                vectors: this.vectors,
                namespace: "your-namespace",
            },
        });
    }
}