Connect Tweets from user and Databricks in our serverless environment

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

    async fetch(publish, done) {
        const {
            data: tweets
        } = await this.twitter.tweets.usersIdTweets(
            // TODO: You need to provide the twitter user-id (it's a number, and as a sample, the value for yepcode_io username is "1391856062924533762")
            // You may get the user-id from twitter username with https://tweeterid.com/ (and use it here with quotes)
            "the-twitter-user-id", {
                "tweet.fields": ["author_id", "text"],
                // You can customize which fields to retrieve
                // More info at: https://developer.twitter.com/en/docs/twitter-api/data-dictionary/using-fields-and-expansions
            }
        );

        // See tweet object structure at: https://developer.twitter.com/en/docs/twitter-api/data-dictionary/object-model/tweet
        for (const tweet of tweets) {
            await publish(tweet);
        }
        done();
    }

    async close() {}
}

class DatabricksTargetInsert {
    async init() {
        // TODO: Create your databricks credential
        // More info at https://yepcode.io/docs/integrations/databricks/#credential-configuration
        this.databricks = yepcode.integration.databricks(
            'your-databricks-credential-name'
        );
        this.session = await this.databricks.openSession();
    }

    async consume(item) {
        // TODO: Customize your sql query
        // More info at: https://github.com/databricks/databricks-sql-nodejs/blob/main/tests/e2e/data_types.test.js#L151
        const operation = await this.session.executeStatement(
            `INSERT INTO yourTable VALUES(${item.id}, ${item.name})`
        );
        const result = await operation.fetchAll();
        await operation.close();
        return result
    }

    async close() {
        await this.session.close();
        await this.databricks.close();
    }
}