Merge pull request #23 from funktechno/f/updates

F/updates 0.0.8

Author: lastlink

conversations/index.php

@@ -38,9 +38,17 @@
     case 'submit':
         $threadId = $input['threadId'];
         $message = $input['message'];
-        if (empty($threadId) || empty($message)) {
+        if (empty($message)) {
             $errorStatus->response(400, "threadId, message field(s) are required");
         }
+        if (empty($threadId)) {
+            $regOutcome = startThread();
+            if ($regOutcome['rowsChanged'] === 1) {
+                $threadId = $regOutcome['lastId'];
+            } else {
+                $errorStatus->response(500, "Error starting thread");
+            }
+        }
         $regOutcome = sendMessage($threadId, $message);
         if ($regOutcome['rowsChanged'] === 1) {
             $result = getMessage($regOutcome['lastId']);

examples/js/vue.js

@@ -26,6 +26,7 @@ var app = new Vue({
         example: "comments",
         status: null,
         form: {},
+        threadId: null,
         conversations: [],
         loading: {
             general: false,
@@ -88,12 +89,16 @@ var app = new Vue({
             if (this.loading.chat)
                 return;
             // retrieve from cookie
-            let threadId = "effba2487ece11eb8e3a0242ac110002"
+            // will start from
+
+            // let threadId = "effba2487ece11eb8e3a0242ac110002"
+            let threadId = this.threadId;
             let config = {}
             let request = {
-                threadId: threadId,
+                threadId: threadId || null,
                 message: this.chat.message
             }
+            console.log(request);
             this.loading.chat = true;
 
             this.$http.post("/conversations/?action=submit", request, config).then((response) => {
@@ -103,6 +108,8 @@ var app = new Vue({
                 if (response.status == 201) {
                     this.chat.message = "";
                     console.log(response.data);
+                    this.threadId = response.data.threadId;
+                    Cookies.set('thread', this.threadId, { expires: 7, path: '' })
                     this.conversations.push(response.data);
                     // this.$set()
                     // this.comments = response.data;
@@ -192,7 +199,8 @@ var app = new Vue({
         },
         getConversation() {
             // check from cookie for conversation id
-            let threadId = "effba2487ece11eb8e3a0242ac110002"
+            let threadId = this.threadId;
+            // "effba2487ece11eb8e3a0242ac110002"
             this.loading.chat = true;
             this.errors = null;
             this.$http.post("/conversations/?action=get", { "threadId": threadId }).then((response) => {
@@ -236,6 +244,8 @@ var app = new Vue({
     },
     mounted() {
         this.getComments();
-        this.getConversation();
+        this.threadId = Cookies.get('thread');
+        if (this.threadId)
+            this.getConversation();
     }
 })

examples/vue.html

@@ -24,6 +24,7 @@
 
     <script src="https://cdn.jsdelivr.net/npm/vue/dist/vue.js"></script>
     <script src="https://cdn.jsdelivr.net/npm/[email protected]"></script>
+    <script src="https://cdn.jsdelivr.net/npm/js-cookie@rc/dist/js.cookie.min.js"></script>
 
 </head>
 

library/Core.php

@@ -1,6 +1,6 @@
 <?php
 //should contain app meta data such as version
-define('APP_VERSION', '0.0.7');
+define('APP_VERSION', '0.0.8');
 
 define('APP_Name','CommentsPress');
 // comment out this line if you don't want this meta response header

model/conversations-model.php

@@ -25,6 +25,31 @@ function getMessage($id)
     return $prodInfo;
 }
 
+function startThread(){
+    $id = generateUuid();
+    // Create a connection object using the acme connection function
+    $db = acmeConnect();
+    // The SQL statement
+    $sql = 'INSERT INTO threads(id)
+    values(:id);';
+    // echo $sql;
+    $stmt = $db->prepare($sql);
+
+    // $stmt->bindValue(':id', $id, PDO::PARAM_STR);
+    $stmt->bindValue(':id', $id, PDO::PARAM_STR);
+
+    // // Create the prepared statement using the acme connection
+
+    // Insert the data
+    $stmt->execute();
+    // Ask how many rows changed as a result of our insert
+    $rowsChanged = $stmt->rowCount();
+    // Close the database interaction
+    $stmt->closeCursor();
+    // Return the indication of success (rows changed)
+    $result = array('rowsChanged' => $rowsChanged, 'lastId' => $id);
+    return $result;
+}
 function sendMessage($conversationId, $message)
 {
     // $id = generateUuid();

rest/conversations.rest

@@ -7,12 +7,12 @@ Accept: application/json
     "threadId": "effba2487ece11eb8e3a0242ac110002"
 }
 
-### send charset
+### sendmessage, pass null threadId to start a new conversation
 POST http://127.0.0.1:8000/conversations/?action=submit HTTP/1.1
 content-type: application/json
 Accept: application/json
 
 {
-    "threadId": "effba2487ece11eb8e3a0242ac110002",
+    "threadId": null,
     "message": "test comment"
 }