Event Functionの設定

const axios = require('axios');
const catalyst = require('zcatalyst-sdk-node');
const ZBOOKSDOMAIN = "{{YOUR_ZBOOKS_DOMAIN}}"; //リージョンに基づいたZoho Booksドメインを入力してください
const ZBOOKSORG = "{{YOUR_ZBOOKS_ORGANIZATION_ID}}" //Zoho BooksのOrganization IDを入力してください
const ZCLIQDOMAIN = "{{YOUR_ZCLIQ_DOMAIN}}"; //リージョンに基づいたZoho Cliqドメインを入力してください
const ZCLIQ_CHANNEL_UNIQUE_NAME = "{{YOUR_CHANNEL_UNIQUE_NAME}}" //更新を投稿するチャンネルのユニーク名を入力してください
const ZCLIQ_BOT_UNIQUE_NAME = "{{YOUR_BOT_UNIQUE_NAME}}" //メッセージを投稿するボットのユニーク名を入力してください
const ZACCOUNTSDOMAIN = "{{YOUR_ZACCOUNTS_DOMAIN}}" //リージョンに基づいたZoho Accountsドメインを入力してください
module.exports = async (event, context) => {
    try {
        const rows = transformEventData(event.getRawData());
        const requestBody = buildCliqRequestBody(rows);
        const accessToken = await getAccessToken(context);
        await sendToCliq(requestBody, accessToken);
        console.log("Message pushed to channel successfully");
        context.closeWithSuccess();
    } catch (error) {
        console.error('Error occurred:', error);
        context.closeWithFailure();
    }
};
function transformEventData(rawData) {
    let rows = rawData.data.flat();
    for (let row of rows) {
        const invoiceId = row["Invoice Id"];
        delete row["Invoice Id"];
        row["Link"] = `https://${ZBOOKSDOMAIN}/app/${ZBOOKSORG}#/invoices/${invoiceId}`;
    }
    return rows;
}
function buildCliqRequestBody(rows) {
    return {
        slides: [{
            type: "table",
            data: {
                headers: ["Customer", "Invoice Number", "Amount", "Paid On", "Link"],
                rows: rows
            }
        }],
        text: "Here are the invoices marked as Paid in the last hour:"
    };
}
async function getAccessToken(context) {
    const app = catalyst.initialize(context);
    var connector = app.connection({
            CliqConnector: {
                client_id: "{{YOUR_CLIENT_ID}}", //Client IDを入力してください
                client_secret: "{{YOUR_CLIENT_SECRET}}", //Client Secretを入力してください
                auth_url: `https://${ZACCOUNTSDOMAIN}/oauth/v2/auth`,
                refresh_url: `https://${ZACCOUNTSDOMAIN}/oauth/v2/token`,
                refresh_token: "{{YOUR_REFRESH_TOKEN}}" //Refresh Tokenを入力してください
            }
        })
        .getConnector('CliqConnector'); 
    return await connector.getAccessToken();
}
async function sendToCliq(body, accessToken) {
    const cliqChannelURL = `https://${ZCLIQDOMAIN}/api/v2/channelsbyname/${ZCLIQ_CHANNEL_UNIQUE_NAME}/message?bot_unique_name=${ZCLIQ_BOT_UNIQUE_NAME}`;
    const headers = {
        'Content-Type': 'application/json',
        'Authorization': 'Zoho-oauthtoken ' + accessToken
    };
    const response = await axios.post(cliqChannelURL, body, { headers });
}