Advanced I/O Functionの設定

'use strict';
var express = require('express');
var app = express();
var catalyst = require('zcatalyst-sdk-node');
app.use(express.json());
const tableName = 'AlienCity'; // Data Storeに作成したテーブル
const columnName = 'CityName'; // テーブルに作成したカラム
// 特定の都市のエイリアン遭遇を報告するPOST API
app.post('/alien', (req, res) => {
    var cityJson = req.body;
    console.log(cityJson);
    // Catalyst SDKの初期化
    var catalystApp = catalyst.initialize(req);
    // Catalyst Data Storeテーブルにクエリを実行し、指定された都市の行が存在するかどうかを確認します
    getDataFromCatalystDataStore(catalystApp, cityJson.city_name).then(cityDetails => {
        if (cityDetails.length == 0) { // 行が存在しない場合、新しい行を挿入します
            console.log("Alien alert!"); // ログに記録されます。コンソールのMonitorセクションにあるLogsからこのログを確認できます
            var rowData = {}
            rowData[columnName] = cityJson.city_name;
            var rowArr = [];
            rowArr.push(rowData);
            // Catalyst Data Storeテーブルに都市名を行として挿入します
            catalystApp.datastore().table(tableName).insertRows(rowArr).then(cityInsertResp => {
                res.send({
                    "message": "Thanks for reporting!"
                });
            }).catch(err => {
                console.log(err);
                sendErrorResponse(res);
            })
        } else { // 行が存在する場合、重複を示すメッセージを送信します
            res.send({
                "message": "Looks like you are not the first person to encounter aliens in this city! Someone has already reported an alien encounter here!"
            });
        }
    }).catch(err => {
        console.log(err);
        sendErrorResponse(res);
    })
});
// テーブルで該当都市のエイリアン遭遇を確認するGET API
app.get('/alien', (req, res) => {
    var city = req.query.city_name;
    // Catalyst SDKの初期化
    var catalystApp = catalyst.initialize(req);
    // Catalyst Data Storeテーブルにクエリを実行し、指定された都市の行が存在するかどうかを確認します
    getDataFromCatalystDataStore(catalystApp, city).then(cityDetails => {
        if (cityDetails.length == 0) {
            res.send({
                "message": "Hurray! No alien encounters in this city yet!",
                "signal": "negative"
            });
        } else {
            res.send({
                "message": "Uh oh! Looks like there are aliens in this city!",
                "signal": "positive"
            });
        }
    }).catch(err => {
        console.log(err);
        sendErrorResponse(res);
    })
});
/**
 * 指定された都市のエイリアン遭遇が既に報告されているかどうかをData Storeテーブルにクエリを実行して確認します
 * @param {*} catalystApp 
 * @param {*} cityName 
 */
function getDataFromCatalystDataStore(catalystApp, cityName) {
    return new Promise((resolve, reject) => {
        // Catalyst Data Storeテーブルにクエリを実行します
        catalystApp.zcql().executeZCQLQuery("SELECT * FROM AlienCity WHERE CityName = '" + cityName + "'").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;