Connect Stripe products and Pinecone in our serverless environment

class StripeSourceListProducts {
    async init() {
        // TODO: Create your stripe credential
        // More info at https://yepcode.io/docs/integrations/stripe/#credential-configuration
        this.stripe = yepcode.integration.stripe("your-stripe-credential-name");
    }

    async fetch(publish, done) {
        // See product object structure at: https://stripe.com/docs/api/products/list?lang=node
        const {
            data: products
        } = await this.stripe.products.list();

        for (const product of products) {
            await publish(product);
        }
        done();
    }

    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",
            },
        });
    }
}