Connect DALL-E (OpenAI) images and Elasticsearch in our serverless environment

class OpenaiSourceGenerateImages {
    async init() {
        // More info at https://www.npmjs.com/package/openai
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.openai = new OpenAI({
            apiKey: yepcode.env.OPENAI_API_KEY,
        });
    }

    async fetch(publish, done) {
        // TODO: Configure your prompt
        const prompts = [
            "A cute baby sea otter",
            "A happy little cloud",
            "A grumpy potato",
            "A sleepy owl",
            "A mischievous kitten",
            "A nerdy giraffe",
            "A hipster penguin",
            "A jolly llama",
            "A clumsy elephant",
            "A sassy flamingo",
            "A quirky squirrel",
        ];

        for (const prompt of prompts) {
            // More info at: https://platform.openai.com/docs/api-reference/images
            const response = await this.openai.images.generate({
                prompt: prompt,
                n: 1,
                size: "1024x1024",
            });

            await publish(response.data);
        }
        done();
    }

    async close() {}
}

class ElasticsearchTargetInsert {
    async init() {
        // More info at https://www.npmjs.com/package/@elastic/elasticsearch
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.elasticsearch = new Client({
            cloud: {
                id: yepcode.env.ELASTICSEARCH_CLOUD_ID,
            },
            auth: {
                apiKey: yepcode.env.ELASTICSEARCH_API_KEY,
            },
        });
    }

    async consume(item) {
        // TODO: Map your item to row
        await this.elasticsearch.index({
            index: "your_table_name",
            document: item,
        });
    }

    async close() {}
}