Connect OpenAI prompt and Microsoft SQL Server in our serverless environment

class OpenaiSourceGetPromptResponse {
    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 funnyPrompts = [
            "What do you think of humans?",
            "Do you prefer tabs or spaces?",
            "What's the meaning of life, the universe, and everything?",
            "What's your favorite programming joke?",
            "What's the worst code you've ever seen?",
        ];
        // More info at: https://platform.openai.com/docs/api-reference/completions/create
        const completion = await this.openai.completions.create({
            model: "gpt-3.5-turbo",
            prompt: funnyPrompts,
            max_tokens: 7,
            temperature: 0,
        });

        for (const choice of completion.choices) {
            await publish(choice);
        }
        done();
    }

    async close() {}
}

class MssqlTargetInsert {
    async init() {
        // More info at https://www.npmjs.com/package/mssql
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        const mssqlConnectionPool = new sql.ConnectionPool({
            user: yepcode.env.MSSQL_USER,
            password: yepcode.env.MSSQL_PASSWORD,
            server: yepcode.env.MSSQL_SERVER,
            database: yepcode.env.MSSQL_DATABASE,
        });
        this.pool = await mssqlConnectionPool.connect();
    }

    async consume(item) {
        // TODO: Customize input params and INSERT statement
        await this.pool
            .request()
            .input("name", sql.VarChar(50), item.name)
            .input("price", sql.Int, item.price)
            .input("stock", sql.Int, item.stock)
            .query(
                "INSERT INTO products(name, price, stock, created_at) VALUES(@name, @price, @stock, CURRENT_TIMESTAMP)"
            );
    }

    async close() {
        await this.pool.close();
    }
}