db version of Functions

expert-db/expert-add → expert-db/expert-add.js

@@ -28,14 +28,19 @@ exports.handler = function(context, event, callback) {
  client.sync.services(sync_id)
            .syncMaps('experts')
            .syncMapItems
-           .create({key: expert.number , data: expert_json })
+           .create({key: expert.number, data: expert_json })
            .then(sync_map_item => {
                console.log(sync_map_item.key)
-               callback(sync_map_item.key);
+               callback(null,sync_map_item.key);
                })
            .catch(e => { 
                console.log(e); 
-               callback(false);
+
+               if(e.code==54208)
+                 callback(null,expert.number);
+               else
+                 callback(e);
+
                });
  //callback(null, response);
-};
+};

expert-db/expert-fetch → expert-db/expert-fetch.js

@@ -31,12 +31,12 @@ exports.handler = function(context, event, callback) {
            .fetch()
            .then(sync_map_item => {
                console.log(sync_map_item.key)
-               callback(JSON.stringify(sync_map_item.data));
+               callback(null,JSON.stringify(sync_map_item.data));
                })
            .catch(e => { 
                console.log(e); 
-               callback(false);
+               callback(null,false);
                });
 
  //callback(null, response);
-};
+};

expert-db/expert-list → expert-db/expert-list.js

@@ -30,12 +30,12 @@ exports.handler = function(context, event, callback) {
               console.log(s.key);
               array.push(s.data);
               })
-          callback(JSON.stringify(array));
+          callback(null,JSON.stringify(array));
 
       })
       .catch(e => { 
                console.log(e); 
-               callback(false);
+               callback(null,false);
                });
 
-};
+};

expert-db/expert-table-create.js

@@ -0,0 +1,60 @@
+exports.handler = function(context, event, callback) {
+
+    // take the sync_id
+    //create map with name "experts""
+    //what do we return???
+
+    const sync_id = event['service'];
+
+    console.log('CONTEXT:');
+     for(var property in context) {
+     console.log(property + "=" + context[property]);
+     }
+
+     console.log('EVENT:');
+     for(var proper in event) {
+     console.log(proper + "=" + event[proper]);
+     }
+     let response = "{}";
+
+    /* fetch service hosting our DB */
+    const client = context.getTwilioClient();
+
+
+    client.sync.services(sync_id)
+              .syncMaps
+              .create({ uniqueName: 'experts'})
+              .then(sync_map => {
+                  //happy path
+                  console.log(sync_map.sid);
+                  response = "{experts_id: '"+ sync_map.sid +"'}";
+                  callback(null,response);
+                  })
+              .catch(e => { 
+                  //manage unhapy path
+                  console.log(e); 
+                  if(e=="Error: Unique name already exists")
+                  {
+                      client.sync.services(sync_id)
+                       .syncMaps
+                       .list({limit: 20})
+                       .then(syncMaps => {
+                           syncMaps.forEach(s => {
+                               console.log(s.sid)
+                               if(s.uniqueName == "experts")
+                                   callback(null,"{experts_id: '"+ s.sid +"'}");
+                               });
+                               callback(null,JSON.stringify(syncMaps)); //it should not get here
+                           }
+
+                           )
+                       .catch(e => { 
+                           //manage unhapy path
+                            console.log(e); 
+                               callback(e);
+                       });
+                  }
+                  else
+                   callback(e);
+                  });
+   };

expert-db/expert-update.js

@@ -0,0 +1,42 @@
+exports.handler = function(context, event, callback) {
+
+    // take the sync_id
+    //create map with name "experts""
+    //what do we return???
+
+    const sync_id = event['service'];
+    const expert_json = event['expert'];
+    const expert = JSON.parse(expert_json);
+
+    //HAPPY PATH
+
+    console.log('CONTEXT:');
+     for(var property in context) {
+     console.log(property + "=" + context[property]);
+     }
+
+     console.log('EVENT:');
+     for(var proper in event) {
+     console.log(proper + "=" + event[proper]);
+     }
+     let response = "{}";
+
+    /* fetch service hosting our DB */
+    const client = context.getTwilioClient();
+
+
+    client.sync.services(sync_id)
+              .syncMaps('experts')
+              .syncMapItems(expert.number)
+              .update({data: expert_json })
+              .then(sync_map_item => {
+                  console.log(sync_map_item.key)
+                  callback(null,sync_map_item.key);
+                  })
+              .catch(e => { 
+                  console.log(e); 
+                  callback(null,false);
+                  });
+
+    //callback(null, response);
+   };