Advanced I/O Functionの設定

'use strict';
var express = require('express');
var app = express();
var catalyst = require('zcatalyst-sdk-node');
app.use(express.json());
//必要なテーブルからニュースを取得するGET API
app.get('/fetchData', (req, res) => {
	var tablename = req.query.tablename;
	console.log("Table Name "+tablename);
	//Catalyst SDKの初期化
	var catalystApp = catalyst.initialize(req);
	//Catalyst Data Storeテーブルをクエリして必要なニュースを取得
	getDataFromCatalystDataStore(catalystApp, tablename).then(newsDetails => {
			res.send({
				"content": newsDetails
			})
	}).catch(err => {
		console.log(err);
		sendErrorResponse(res);
	})
});
/**
 * クエリを実行してテーブルからニュースを取得します
 * @param {*} catalystApp 
 * @param {*} tablename 
 */
function getDataFromCatalystDataStore(catalystApp, tablename) {
	return new Promise((resolve, reject) => {
		//Catalyst Data Storeテーブルをクエリ
		catalystApp.zcql().executeZCQLQuery("Select title,url from " + tablename).then(queryResponse => {
			resolve(queryResponse);
		}).catch(err => {
			reject(err);
		})
	});
}
/**
 * エラーレスポンスを送信します
 * @param {*} res 
 */
function sendErrorResponse(res) {
	res.status(500);
	res.send({
		"error": "Internal server error occurred. Please try again in some time."
	});
}
module.exports = app;