Merge branch 'pub-sub' of fyindr/siimee into dev

frontend/src/App.vue

@@ -72,6 +72,9 @@ export default {
                 currentProfile.setupToaster(this.$waveui.notify)
             }
             console.log('---')
+            //  step 3: subscribe to the this.subscriptions array
+            // view current subscriptions on the currentProfile.chatter.subscriptions
+            console.log('subscriptions', currentProfile.chatter.subscriptions)
         },
     },
 }

frontend/src/components/ProfileCardList.vue

@@ -112,13 +112,11 @@ const chat = async pid => {
     const chatter = currentProfile.chatter
     // console.log('mock sender:', pid)
     
-    /**  publish a new message to the chatter with the channel and the message
-     *  
-     *  title is optional
+    /**  publish a new message to the chatter with the channel and the message & title is optional
      */
     const res = await chatter.publish(chatter.subscriptions[1], {
         title: 'New Message',
-        description: 'This is the start of a chat conversation!',
+        description: 'This is the checking to see if we are subscribed to a channel!',
     })
     // PubNub response will be a timecode of when the message was published
     console.log('res:', res)

frontend/src/services/chat.service.js

@@ -1,5 +1,8 @@
 import PubNub from 'pubnub'
 
+// custom services 
+import {fetchMembershipsByProfileId} from '../services/grouping.service'
+
 /**
  * Provider method holder
  * We always reference this object so
@@ -20,7 +23,6 @@ const providerMethods = {
 const setupPubnub = async uuid => {
     const publishKey = 'pub-c-73f35484-396f-47ff-b4b6-45bed079fd3b'
     const subscribeKey = 'sub-c-6cb7f5d0-94e2-11ec-b249-a68c05a281ab'
-    // console.log('publishKey: ' , publishKey)
     if (!uuid) return console.error('no pubnub uuid set')
 
     const pubnubClient = await new PubNub({
@@ -57,6 +59,7 @@ class Chatter {
      */
     constructor() {
         // Map of each active chat
+        // * this is where we will store all of our groupings on from the backend on user login...
         this.groupings = {}
 
         // Our pubnub instance
@@ -66,10 +69,11 @@ class Chatter {
         this.uuid = null
 
         // Setup the main channel
+        //  subscriptions array will be built dynamically from the "this.groupings" object
         this.subscriptions = [MAIN_CHANNEL, 'Channel-LosAngeles']
         this.listeners = {
             status: async e => {
-                await this.publish(this.subscriptions[0], testMessage)
+                await this.publish(this.subscriptions[2], testMessage)
                 if (e.category !== 'PNConnectedCategory') return
             },
             message: this._onMessage,
@@ -94,9 +98,16 @@ class Chatter {
     async setup(uuid) {
         this.uuid = `${uuid}`
         this.provider = await setupPubnub(this.uuid)
-
-        this._listenFor({ listeners: this.listeners })
-        this._subscribe(this.subscriptions)
+            
+        //  step 1: build the this.groupings object from the backend
+        // ? .then() to wait for the groupings to be fetched before subscribing to channels
+        this.getGroupingsByProfileId(this.uuid).then(() => {
+            this._listenFor({ listeners: this.listeners })
+            this._subscribe(this.subscriptions)
+        })
+        
+        console.log('this.subscriptions', this.subscriptions)
+       
     }
     /**
      * Send a message to a channel
@@ -107,6 +118,7 @@ class Chatter {
      * @return {object} timestamp
      */
     async publish(channel, message) {
+        console.log('publishing message to channel:', channel)
         return await providerMethods['publish']({ channel, message })
     }
     /**
@@ -124,6 +136,23 @@ class Chatter {
     _listenFor({ listeners }) {
         providerMethods['listen'](listeners)
     }
+    
+    //  step 2: build the this.subscriptions array from the this.groupings object
+    // fetch all groupings for this profile and then store them in the chatter groupings object for reference
+    async getGroupingsByProfileId(profileId) {
+        console.log('fetching groupings for profileId:', profileId)
+        const groupings = await fetchMembershipsByProfileId(profileId)
+        this.groupings = groupings
+        this.createChannelNamesByGroupings(this.groupings)
+    }
+    // building a list of channel names from the groupings object.grouping_name
+    createChannelNamesByGroupings(groupings) {
+        groupings.forEach(item => {
+            this.subscriptions.push(item.grouping_name)
+        });
+        
+        
+    }
 }
 
 export { Chatter }

frontend/src/services/login.service.js

@@ -2,6 +2,7 @@ import { ref } from 'vue'
 import { fetchResponsesByProfileId, Chatter, StonkAlert } from '../services'
 import { surveyFactory } from '../utils'
 
+
 /**
  * Logged in profile state manager
  * Sort of a util and service hybrid
@@ -106,6 +107,8 @@ class Login {
         const testAccountUUID = this.id.value
         this.chatter.setup(testAccountUUID)
     }
+
+    
 }
 
 const currentProfile = new Login()