Event関数の設定

const catalyst = require('zcatalyst-sdk-node');
const axios = require('axios').default;
const FormData = require('form-data');
const fs = require('fs');
const credentials = {
WorkDriveConnector: {
client_id: ‘{{YOUR_CLIENT_ID}}’, // Client IDを入力してください
client_secret: ‘{{YOUR_CLIENT_SECRET}}’, // Client Secretを入力してください
auth_url: ‘https://accounts.zoho.com/oauth/v2/token',
refresh_url: ‘https://accounts.zoho.com/oauth/v2/token',
refresh_token: ‘{{YOUR_REFRESH_TOKEN}}’ // Refresh Tokenを入力してください
}
}
const FOLDERID = ‘5m0kq28f2efdbc2464a37866cec7d6580cb47’; // WorkDriveフォルダIDを入力してください
module.exports = async (event, context) => {
try {

	const eventData = event.getRawData().events[0];
	const eventType = eventData.event_config.api_name;
	const fileName = eventData.data.object_details[0].key;

	const app = catalyst.initialize(context);
	const query = `SELECT ROWID, WorkDriveFileID FROM FileVault where FileName='${fileName}'`;
	const queryResult = await app.zcql().executeZCQLQuery(query);
	console.log(queryResult);
	const ROWID = queryResult[0].FileVault.ROWID;

	const accessToken = await app.connection(credentials).getConnector('WorkDriveConnector').getAccessToken();

	if (eventType === "stratus_object_uploaded") {

		const stratus = app.stratus();
		const bucket = stratus.bucket("file-vault-demo"); // バケット名に置き換えてください

		let fileStream = await bucket.getObject(fileName);
		const chunks = [];
		for await (const chunk of fileStream) {
			chunks.push(chunk);
		}
		const buffer = Buffer.concat(chunks);

		fs.writeFileSync(__dirname + '/' + fileName, buffer);
		var data = new FormData();
		data.append('content', fs.createReadStream(__dirname + '/' + fileName));

		const config = {
			method: 'POST',
			url: `https://workdrive.zoho.com/api/v1/upload?filename=${fileName}&override-name-exist=true&parent_id=${FOLDERID}`, headers: { 'Authorization': `Zoho-oauthtoken ${accessToken}`, ...data.getHeaders() }, data: data
		};

		const response = await axios(config);
		console.log(response);

		const WorkDriveSync = 'Uploaded';
		const body = response.data;
		const WorkDriveFileID = body.data[0].attributes.resource_id;
		const catalystTable = app.datastore().table('FileVault');
		await catalystTable.updateRow({
			WorkDriveFileID,
			WorkDriveSync,
			ROWID
		});

	} else if (eventType === "stratus_object_deleted") {
		const WorkDriveFileID = queryResult[0].FileVault.WorkDriveFileID;

		const config = {
			method: "PATCH",
			url: `https://workdrive.zoho.com/api/v1/files/${WorkDriveFileID}`, headers: { Authorization: `Zoho-oauthtoken ${accessToken}`, Accept: "application/vnd.api+json", }, data: JSON.stringify({
				data: {
					attributes: {
						status: "51",
					},
					type: "files",
				},
			}),
		};

		console.log(config);

		await axios(config);

		const table = app.datastore().table("FileVault");
		await table.deleteRow(ROWID);
	}

	context.closeWithSuccess();

} catch (err) {
	console.log(err);
	context.closeWithFailure();
}

};