'use strict';
const AWS = require('aws-sdk');
const dynamoDb = new AWS.DynamoDB.DocumentClient();
const tableName = 'IPTable'; // DynamoDBのテーブル名
const http = require('http');
// --------------- Helpers that build all of the responses -----------------------
function buildSpeechletResponse(title, output, repromptText, shouldEndSession) {
return {
outputSpeech: {
type: 'PlainText',
text: output,
},
card: {
type: 'Simple',
title: `SessionSpeechlet - ${title}`,
content: `SessionSpeechlet - ${output}`,
},
reprompt: {
outputSpeech: {
type: 'PlainText',
text: repromptText,
},
},
shouldEndSession,
};
}
function buildResponse(sessionAttributes, speechletResponse) {
return {
version: '1.0',
sessionAttributes,
response: speechletResponse,
};
}
// --------------- Functions that control the skill's behavior -----------------------
function getWelcomeResponse(callback) {
const sessionAttributes = {};
const cardTitle = 'Welcome';
const speechOutput = "二階の温度を教えてなどと問いかけると、それを答えます。";
const repromptText = "私はこの部屋を見てるわよっ！何が知りたいのっ！ ってかっ";
const shouldEndSession = false;
callback(sessionAttributes,
buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
}
function handleSessionEndRequest(callback) {
const cardTitle = 'Session Ended';
const speechOutput = 'Thank you for trying the Alexa Skills Kit sample. Have a nice day!';
const shouldEndSession = true;
callback({}, buildSpeechletResponse(cardTitle, speechOutput, null, shouldEndSession));
}
function createLocationAttributes(location) {
return { location };
}
async function readTemperatureInSession(intent, session, callback) {
const cardTitle = intent.name;
const LocationSlot = intent.slots.Location;
const MeasurementSlot = intent.slots.Measurement;
let repromptText = '';
let sessionAttributes = session.attributes || {};
const shouldEndSession = false;
let speechOutput = '';
let body = '';
const blynkport = '8080';
let blynkAuthToken;
let blynkPin;
let location = LocationSlot.value || sessionAttributes.location || '二階';
sessionAttributes.location = location;
let ip;
try {
// DynamoDBからIPアドレスを取得
const params = {
TableName: tableName,
Key: {
id: 'globalIP' // パーティションキーは固定値
}
};
const data = await dynamoDb.get(params).promise();
const item = data.Item;
if (!item || !item.ipAddress) {
console.error('IPアドレスがDynamoDBに存在しません。');
speechOutput = 'IPアドレスが取得できませんでした。';
repromptText = 'もう一度お試しください。';
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
return;
}
ip = item.ipAddress; // DynamoDBから取得したIPアドレス
} catch (error) {
console.error(`DynamoDBからIPアドレスを取得中にエラーが発生しました: ${error}`);
speechOutput = 'IPアドレスの取得中にエラーが発生しました。';
repromptText = 'もう一度お試しください。';
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
return; // エラー発生時は処理を中断
}
switch (location) {
case '二階':
blynkAuthToken = encodeURIComponent('********************************');
break;
case '仏間':
blynkAuthToken = encodeURIComponent('********************************');
break;
case '屋根裏':
blynkAuthToken = encodeURIComponent('********************************');
break;
default:
speechOutput = '指定された場所が見つかりませんでした。';
repromptText = '他の場所を指定してください。';
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
return;
}
let measurement = MeasurementSlot.value || '温度';
switch (measurement) {
case '何度':
case '気温':
case '室温':
case '温度':
blynkPin = 'V0';
break;
case '湿気':
case '湿度':
blynkPin = 'V1';
break;
case '大気圧':
case '気圧':
blynkPin = 'V2';
break;
case '熱中度指数':
case '熱中度':
case '暑さ指数':
case '暑さ度':
case '暑さ':
blynkPin = 'V4';
break;
default:
speechOutput = '指定された測定項目が見つかりませんでした。';
repromptText = '他の測定項目を指定してください。';
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
return;
}
try {
console.log(`Sending request to Blynk server with Auth Token: ${blynkAuthToken}, Pin: ${blynkPin}, IP: ${ip}`);
const httpPromise = new Promise((resolve, reject) => {
http.get({
host: ip,
path: `/${encodeURIComponent(blynkAuthToken)}/get/${blynkPin}`,
port: blynkport,
}, (response) => {
response.on('data', (d) => {
body += d;
});
response.on('end', () => {
resolve('Done Sending');
});
}).on('error', (e) => {
reject(e); // エラーをreject
console.error(`Blynkサーバーへのリクエストエラー: ${e}`); // エラーログ
});
});
await httpPromise;
console.log(`Received response from Blynk server: ${body}`);
let info;
try {
info = parseFloat(JSON.parse(body)); // パースを試みる
} catch (parseError) {
console.error(`JSONパースエラー: ${parseError}, body: ${body}`);
info = NaN; // パースに失敗したらNaNを設定
}
if (isNaN(info)) {
speechOutput = '温度の取得に失敗しました。';
repromptText = 'もう一度お試しください。';
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
} else {
// ... (温度表示処理)
speechOutput = location + 'の ' + measurement + 'は ';
repromptText = speechOutput;
switch (measurement) {
default:
case '何度':
case '気温':
case '室温':
case '温度':
speechOutput += `${info.toFixed(1)}度 です。`;
repromptText += `${info.toFixed(1)}℃です。`;
break;
case '湿気':
case '湿度':
speechOutput += `${info.toFixed(1)}パーセント です。`;
repromptText += `${info.toFixed(1)}%です。`;
break;
case '大気圧':
case '気圧':
speechOutput += `${info.toFixed(0)}ヘクトパスカル です。`;
repromptText += `${info.toFixed(0)}hPaです。`;
break;
case '熱中度指数':
case '熱中度':
case '暑さ指数':
case '暑さ度':
case '暑さ':
let annotation = '';
if (info >= 31) {
annotation = '危険！ ブラックです。';
} else if (info >= 28) {
annotation = '厳重警戒！ レッドです。';
} else if (info >= 25) {
annotation = '警戒！ オレンジです。';
} else if (info >= 21) {
annotation = '注意です。';
}
speechOutput += `${info.toFixed(0)}度 です。${annotation}`;
repromptText += `${info.toFixed(0)}℃です。${annotation}`;
break;
}
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
}
} catch (error) {
console.error(`温度取得処理全体のエラー: ${error}`);
speechOutput = '温度の取得中にエラーが発生しました。';
repromptText = 'もう一度お試しください。';
callback(sessionAttributes, buildSpeechletResponse(cardTitle, speechOutput, repromptText, shouldEndSession));
}
}
// ... (onSessionStarted, onLaunch, onIntent, onSessionEnded関数は変更なし)
function onSessionStarted(sessionStartedRequest, session) {
console.log(`onSessionStarted requestId=${sessionStartedRequest.requestId}, sessionId=${session.sessionId}`);
}
function onLaunch(launchRequest, session, callback) {
console.log(`onLaunch requestId=${launchRequest.requestId}, sessionId=${session.sessionId}`);
getWelcomeResponse((sessionAttributes, speechletResponse) => {
callback(sessionAttributes, speechletResponse);
});
}
function onIntent(intentRequest, session, callback) {
console.log(`onIntent requestId=${intentRequest.requestId}, sessionId=${session.sessionId}`);
const intent = intentRequest.intent;
const intentName = intentRequest.intent.name;
if (intentName === 'GetMeasurement') {
readTemperatureInSession(intent, session, callback);
} else if (intentName === 'AMAZON.HelpIntent') {
getWelcomeResponse((sessionAttributes, speechletResponse) => {
callback(sessionAttributes, speechletResponse);
});
} else if (intentName === 'AMAZON.StopIntent' || intentName === 'AMAZON.CancelIntent') {
handleSessionEndRequest((sessionAttributes, speechletResponse) => {
callback(sessionAttributes, speechletResponse);
});
} else {
throw new Error('Invalid intent');
}
}
function onSessionEnded(sessionEndedRequest, session) {
console.log(`onSessionEnded requestId=${sessionEndedRequest.requestId}, sessionId=${session.sessionId}`);
// callbackを呼び出す必要はありません。
// context.succeed()も不要です。
}
exports.handler = (event, context) => {
try {
console.log('Event:', JSON.stringify(event));
let globalIP;
if (event.session && event.session.attributes && event.session.attributes.globalIP) {
globalIP = event.session.attributes.globalIP;
console.log(`Using globalIP from session attributes: ${globalIP}`);
continueProcessing(event, context); // IPアドレス取得後に実行したい処理
} else {
console.log("globalIP not found in session attributes. Retrieving from DynamoDB or IP");
// IPアドレスの取得処理 (DynamoDB or event.ip)
if (event.body && JSON.parse(event.body).ip) { // Lambda関数URLからのIPアドレス取得
globalIP = JSON.parse(event.body).ip;
if (!event.session) {
event.session = {};
}
if (!event.session.attributes) {
event.session.attributes = {};
}
event.session.attributes.globalIP = globalIP; // セッション属性に保存
console.log(`IP from event body: ${globalIP}`);
updateIPAddress(event, context); // IPアドレス更新処理
} else {
getIPAddressFromDynamoDB(event, context);
}
}
} catch (e) {
console.error(`Exception: ${e}`);
context.fail(`Exception: ${e}`);
}
};
function updateIPAddress(event, context) {
const params = {
TableName: tableName,
Item: {
id: 'globalIP',
ipAddress: JSON.parse(event.body).ip // event.bodyからIPアドレスを取得
}
};
dynamoDb.put(params).promise()
.then(() => {
console.log(`Successfully updated IP address in DynamoDB: ${JSON.parse(event.body).ip}`);
if (!event.session) {
event.session = {};
}
if (!event.session.attributes) {
event.session.attributes = {};
}
event.session.attributes.globalIP = JSON.parse(event.body).ip;
console.log(`Updated globalIP to: ${JSON.parse(event.body).ip}`);
continueProcessing(event, context);
})
.catch(err => {
console.error(`Error updating IP address in DynamoDB: ${err}`);
context.fail(`Error updating IP address: ${err}`);
});
}
function getIPAddressFromDynamoDB(event, context) {
const params = {
TableName: tableName,
Key: {
id: 'globalIP'
}
};
dynamoDb.get(params).promise()
.then(data => {
if (data.Item) {
const ipAddress = data.Item.ipAddress;
if (!event.session) {
event.session = {};
}
if (!event.session.attributes) {
event.session.attributes = {};
}
event.session.attributes.globalIP = ipAddress;
console.log(`Retrieved IP address from DynamoDB: ${ipAddress}`);
continueProcessing(event, context);
} else {
console.error('IP address not found in DynamoDB.');
context.fail('IP address not found.');
}
})
.catch(err => {
console.error(`Error retrieving IP address from DynamoDB: ${err}`);
context.fail(`Error retrieving IP address: ${err}`);
});
}
function continueProcessing(event, context) {
if (event.request && event.request.type) { // event.requestの存在チェックを追加
// Alexaからのリクエストの場合の処理
if (event.session && event.session.new) {
onSessionStarted({ requestId: event.request.requestId }, event.session);
}
if (event.request.type === 'LaunchRequest') {
onLaunch(event.request, event.session, (sessionAttributes, speechletResponse) => {
context.succeed(buildResponse(sessionAttributes, speechletResponse));
console.log('LaunchRequest succeeded');
});
} else if (event.request.type === 'IntentRequest') {
onIntent(event.request, event.session, (sessionAttributes, speechletResponse) => {
context.succeed(buildResponse(sessionAttributes, speechletResponse));
console.log('IntentRequest succeeded');
});
} else if (event.request.type === 'SessionEndedRequest') {
onSessionEnded(event.request, event.session);
context.succeed();
console.log('SessionEndedRequest succeeded');
}
} else {
// Lambda URLからのリクエストの場合
context.succeed(); // Lambda関数を正常終了
console.log('Lambda URL request completed.');
}
}
// ... (buildResponse, buildSpeechletResponseなどの関数は省略)
に聞いて作ります。
