S12-010-read-info-for-user

jbergant · Nov 19, 2019 · f3033af · f3033af
1 parent 0404788
commit f3033af
Show file tree

Hide file tree

Showing 2 changed files with 84 additions and 0 deletions.
diff --git a/app.js b/app.js
@@ -12,6 +12,7 @@ const pg = require('pg');
 pg.defaults.ssl = true;
 
 const userService = require('./user');
+const colors = require('./colors');
 
 // Messenger API parameters
 if (!config.FB_PAGE_TOKEN) {
@@ -228,6 +229,13 @@ function handleEcho(messageId, appId, metadata) {
 
 function handleDialogFlowAction(sender, action, messages, contexts, parameters) {
 	switch (action) {
+        case "iphone_colors":
+            colors.readAllColors(function (allColors) {
+                let allColorsString = allColors.join(', ');
+                let reply = `IPhone xxx is available in ${allColorsString}. What is your favourite color?`;
+                sendTextMessage(sender, reply);
+            });
+            break;
         case "get-current-weather":
         	if ( parameters.fields.hasOwnProperty('geo-city') && parameters.fields['geo-city'].stringValue!='') {
             	request({

diff --git a/colors.js b/colors.js
@@ -0,0 +1,76 @@
+'use strict';
+const request = require('request');
+const config = require('./config');
+const pg = require('pg');
+pg.defaults.ssl = true;
+
+module.exports = {
+
+    readAllColors: function(callback) {
+        var pool = new pg.Pool(config.PG_CONFIG);
+        pool.connect(function(err, client, done) {
+            if (err) {
+                return console.error('Error acquiring client', err.stack);
+            }
+            client
+                .query(
+                    'SELECT color FROM public.iphone_colors',
+                    function(err, result) {
+                        if (err) {
+                            console.log(err);
+                            callback([]);
+                        } else {
+                            let colors = [];
+                            for (let i = 0; i < result.rows.length; i++) {
+                                colors.push(result.rows[i]['color']);
+                            }
+                            callback(colors);
+                        };
+                    });
+        });
+        pool.end();
+    },
+
+
+    readUserColor: function(callback, userId) {
+        var pool = new pg.Pool(config.PG_CONFIG);
+        pool.connect(function(err, client, done) {
+            if (err) {
+                return console.error('Error acquiring client', err.stack);
+            }
+            client
+                .query(
+                    'SELECT color FROM public.users WHERE fb_id=$1',
+                    [userId],
+                    function(err, result) {
+                        if (err) {
+                            console.log(err);
+                            callback('');
+                        } else {
+                            callback(result.rows[0]['color']);
+                        };
+                    });
+
+        });
+        pool.end();
+    },
+
+    updateUserColor: function(color, userId) {
+        var pool = new pg.Pool(config.PG_CONFIG);
+        pool.connect(function(err, client, done) {
+            if (err) {
+                return console.error('Error acquiring client', err.stack);
+            }
+            let sql = 'UPDATE public.users SET color=$1 WHERE fb_id=$2';
+            client.query(sql,
+                [
+                    color,
+                    userId
+                ]);
+
+        });
+        pool.end();
+    }
+
+
+}