From adb49143eec3912528efeb3c107a424ba9f4ea8d Mon Sep 17 00:00:00 2001
From: Immanuel Onyeka <immanuel@debian-BULLSEYE-live-builder-AMD64>
Date: Mon, 22 Jan 2024 19:00:02 -0500
Subject: [PATCH] Setup subscription endpoint

---
 .../user/js/registration/registration.vue     | 55 ++++++++++++++++++-
 migrations/0_29092022_setup_tables.sql        |  1 +
 skouter.go                                    |  8 ++-
 3 files changed, 59 insertions(+), 5 deletions(-)

diff --git a/grav-admin/user/js/registration/registration.vue b/grav-admin/user/js/registration/registration.vue
index 7ec08ac..4a12fca 100644
--- a/grav-admin/user/js/registration/registration.vue
+++ b/grav-admin/user/js/registration/registration.vue
@@ -7,12 +7,36 @@
 </template>
 
 <script setup>
-import { ref } from "vue"
+import { ref, onMounted } from "vue"
 import Account from "./account.vue"
 import Billing from "./billing.vue"
 
 let err = ref("")
 const step = ref(0)
+const token = ref("")
+
+function getCookie(name) {
+	var re = new RegExp(name + "=([^;]+)")
+	var value = re.exec(document.cookie)
+
+	return (value != null) ? unescape(value[1]) : null
+}
+
+function getUser() {
+	token.value = getCookie("skouter")
+
+	return fetch(`/api/user`,
+		{method: 'GET',
+		headers: {
+			"Accept": "application/json",
+			"Authorization": `Bearer ${token.value}`,
+    		},
+	}).then(response => {
+		if (response.ok) {
+			return response.json()
+		}
+	})
+}
 
 function create(user) {
   console.log(user)
@@ -24,14 +48,39 @@ function create(user) {
         	"Accept": "application/json",
     		},
         }).then(resp => {
-            console.log(resp)
+            if (resp.ok) {
+              return resp.json().then(u => { err.value = "" }).
+              then( () => intent(user) )
+            } else {
+              resp.text().then( e => err.value = e)
+            }
+        })
+}
+
+function intent(user) {
+  console.log(user)
+  
+  return fetch(`/api/user/subscribe`,
+	    {method: 'POST',
+	        body: JSON.stringify(user),
+    		headers: {
+        	"Accept": "application/json",
+        	"Authorization": `Bearer ${token.value}`,
+    		},
+        }).then(resp => {
             if (resp.ok) {
               return resp.json().then(u => { err.value = "" })
             } else {
               resp.text().then( e => err.value = e)
             }
-        }).then(u => console.log(u))
+        })
 }
+
+onMounted(() => {
+  getUser().then( u => {
+    intent(u)
+  })
+})
 </script>
 
 <style scoped>
diff --git a/migrations/0_29092022_setup_tables.sql b/migrations/0_29092022_setup_tables.sql
index 0eb2d23..7252f7f 100644
--- a/migrations/0_29092022_setup_tables.sql
+++ b/migrations/0_29092022_setup_tables.sql
@@ -28,6 +28,7 @@ CREATE TABLE user (
 	email 			VARCHAR(40) UNIQUE NOT NULL,
 	first_name 		VARCHAR(30) NOT NULL,
 	last_name 		VARCHAR(30) NOT NULL,
+	customer_id 		VARCHAR(255) NOT NULL DEFAULT '',
 	phone	VARCHAR(20) NOT NULL DEFAULT '',
 	address	INT NOT NULL,
 	password 		CHAR(64) NOT NULL,
diff --git a/skouter.go b/skouter.go
index 74a848c..4cef825 100644
--- a/skouter.go
+++ b/skouter.go
@@ -1123,12 +1123,12 @@ func queryUser(db *sql.DB, id int) (User, error) {
 	u.country,
 	u.title,
 	coalesce(u.status, ''),
-	coalesce(u.customer_id, '')
+	coalesce(u.customer_id, ''),
 	u.verified,
 	u.role,
 	u.address,
 	u.phone
-	FROM user u WHERE u.id = CASE @e := ? WHEN 0 THEN u.id ELSE @e END
+	FROM user u WHERE u.id = ?
 	`
 	row := db.QueryRow(query, id)
 
@@ -2988,6 +2988,10 @@ func api(w http.ResponseWriter, r *http.Request) {
 		r.Method == http.MethodPost &&
 		guard(r, 1):
 		changePassword(w, db, r)
+	case match(p, "/api/user/subscribe", &args) &&
+		r.Method == http.MethodPost &&
+		guard(r, 1):
+		createSubscription(w, db, r)
 	case match(p, "/api/fees", &args) &&
 		r.Method == http.MethodGet &&
 		guard(r, 1):