Connect Github issues and MySQL in our serverless environment

class GithubSourceRepositoryIssues {
    async init() {
        // More info at https://www.npmjs.com/package/octokit
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.github = new Octokit({
            auth: yepcode.env.GITHUB_TOKEN,
        });
    }

    async fetch(publish, done) {
        // TODO: Customize your request params
        // See all available params at: https://docs.github.com/en/rest/issues/issues#list-repository-issues
        const response = await this.github.rest.issues.listForRepo({
            owner: "repository-owner",
            repo: "repository-name",
            per_page: 100,
            page: 0,
            state: "open",
        });

        const issues = response.data;
        for (const issue of issues) {
            // TODO: Customize the object to publish for each issue
            // Here you can see the issue object:
            // https://docs.github.com/en/rest/issues/issues#list-repository-issues
            await publish(issue);
        }
        done();
    }

    async close() {}
}

class MysqlTargetInsert {
    async init() {
        // More info at https://www.npmjs.com/package/mysql2
        // TODO: Create team variables. More info at https://yepcode.io/docs/processes/team-variables
        this.mysql = mysql.createConnection({
            host: yepcode.env.MYSQL_HOST,
            user: yepcode.env.MYSQL_USER,
            password: yepcode.env.MYSQL_PASSWORD,
            database: yepcode.env.MYSQL_DATABASE,
        });
    }

    async consume(item) {
        // TODO: Map your item to row and customize INSERT statement
        return await this.mysql
            .promise()
            .query(`INSERT INTO your_table_name SET ?`, {
                id: item.id,
                name: item.name,
            });
    }

    async close() {
        await this.mysql.end();
    }
}