:sparkles: grabbing chat history | SIIMEE-T-82

frontend/src/components/ProfileCardList.vue

@@ -12,7 +12,6 @@ section.profile-card-list.xs12.w-flex.column
 
 <script setup>
 import { ref } from 'vue'
-import { currentProfile } from '../services'
 import { cardAspects } from '../entities'
 import ProfileCard from './ProfileCard.vue'
 
@@ -33,15 +32,6 @@ const props = defineProps({
         ],
     },
 })
-
-/**
- * publish a new message to the chatter with the channel and the message & title is optional
- */
-const subscribeToChannel = async channelName => {
-    // You MUST send chatter channels as an array in an object
-    const channels = [channelName]
-    currentProfile.chatter.subscribe({ channels })
-}
 </script>
 
 <style lang="sass">

frontend/src/services/chat.service.js

@@ -101,6 +101,31 @@ class Chatter {
         this.subscribe({ channels: this._subscriptions })
         return this.subscriptions
     }
+    async getHistory(channel, count = 10) {
+        console.warn('[chatter] grabbing history for channel:', channel)
+        let pastMessages = null
+        try {
+            pastMessages = await this.provider.fetchMessages({
+                channels: [channel],
+                count: count,
+                includeMessageType: true,
+                includeUUID: true,
+                includeMeta: true,
+                includeMessageActions: false,
+            })
+        } catch (error) {
+            console.error('[chatter]', error)
+        }
+        const channelHistory = pastMessages.channels[channel]
+        console.log('channelHistory :>> ', channelHistory)
+        return channelHistory
+            ? channelHistory.map(msg => ({
+                  publisher: msg.uuid,
+                  message: new ChatMessage(msg.message.description),
+                  timetoken: msg.timetoken,
+              }))
+            : []
+    }
     /**
      * Send a message to a channel
      * example = new ChatMessage({ title: 'example', description: 'ni' })
@@ -118,7 +143,7 @@ class Chatter {
     /**
      * Subscribe to a channels
      * Facade so we can hide provider specific methods
-     * @param {array} channels
+     * @param {array} channels grouping name
      */
     subscribe({ channels }) {
         _providerMethods.subscribe({ channels })
@@ -130,8 +155,10 @@ 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
+    /**
+     * Get all groupings for this profile and
+     * then store them as subscriptions
+     */
     async _setupAllChannels(groupings) {
         groupings.forEach(grouping => {
             this._subscriptions.push(grouping.grouping_name)

frontend/src/utils/db.js

@@ -21,13 +21,23 @@ const headerTemplate = {
 class Connector {
     constructor() {
         this.apiPrefix = prefix
+        this._verbs = {
+            get: 'GET',
+            post: 'POST',
+            patch: 'PATCH',
+        }
     }
-    async get(endpoint) {
+    _makeHeader({ method, payload }) {
         const header = { ...headerTemplate }
-        header.method = 'GET'
+        header.method = method
+        if (payload) {
+            header.body = JSON.stringify(payload)
+        }
+        return header
+    }
+    async _tryFetch({ endpoint, header }) {
         try {
-            // console.log(`${remote}${endpoint}`)
-            let res = await fetch(`${remote}${endpoint}`, header)
+            const res = await fetch(`${remote}${endpoint}`, header)
             if (!res.ok) {
                 throw Error(res.statusText)
             }
@@ -37,35 +47,23 @@ class Connector {
             console.error(`[API Util]: ${error}\nroute:`, endpoint)
         }
     }
+    async get(endpoint) {
+        return await this._tryFetch({
+            endpoint,
+            header: this._makeHeader(this._verbs.get),
+        })
+    }
     async post(endpoint, payload = {}) {
-        const header = { ...headerTemplate }
-        header.method = 'POST'
-        header.body = JSON.stringify(payload)
-        try {
-            let res = await fetch(`${remote}${endpoint}`, header)
-            if (!res.ok) {
-                throw Error(res.statusText)
-            }
-            const jsonRes = await res.json()
-            return jsonRes.data
-        } catch (error) {
-            console.error(error)
-        }
+        return await this._tryFetch({
+            endpoint,
+            header: this._makeHeader(this._verbs.post, payload),
+        })
     }
     async patch(endpoint, payload = {}) {
-        const header = { ...headerTemplate }
-        header.method = 'PATCH'
-        header.body = JSON.stringify(payload)
-        try {
-            let res = await fetch(`${remote}${endpoint}`, header)
-            if (!res.ok) {
-                throw Error(res.statusText)
-            }
-            const jsonRes = await res.json()
-            return jsonRes.data
-        } catch (error) {
-            console.error(error)
-        }
+        return await this._tryFetch({
+            endpoint,
+            header: this._makeHeader(this._verbs.patch, payload),
+        })
     }
 
     /** !: DEV ONLY */

frontend/src/utils/index.js

@@ -1,5 +1,4 @@
 import Joi from 'joi'
-import { Connector } from './db.js'
 import { SurveyFactory } from './survey.js'
 import { possible } from './lang.js'
 import { pidMixin, profileMixin } from './mixins.js'
@@ -31,8 +30,6 @@ const possibleZipcodes = [
     '97075',
 ]
 
-const api = new Connector('kittens')
-
 const validatorMapping = {
     'input-string': Joi.string(),
     'tag-cloud': Joi.string(),
@@ -133,7 +130,6 @@ const randomSurveyResponses = count => {
 }
 
 export {
-    api,
     validatorMapping,
     surveyFactory,
     makeKebob,

frontend/src/utils/lang.js

@@ -17,7 +17,7 @@ const allSteps = {
         distance: 'distance',
         blurb: 'blurb',
         image: 'image',
-    }
+    },
 }
 
 const aspectResponses = {
@@ -29,7 +29,7 @@ const aspectResponses = {
         mostly: 'mostly',
         often: 'often',
         everytime: 'everytime',
-    }
+    },
 }
 
 const possible = {}
@@ -55,27 +55,11 @@ possible.usa = {
         'casually_browsing',
     ],
     // key 11
-    presence: [
-        'remote',
-        'in_person',
-        'hybrid',
-        'flexible'
-    ],
+    presence: ['remote', 'in_person', 'hybrid', 'flexible'],
     // key 10
-    duration: [
-        'full-time',
-        'part-time',
-        'contract',
-        'flexible',
-    ],
+    duration: ['full-time', 'part-time', 'contract', 'flexible'],
     // Experience and roles concat, key: 14
-    experience: [
-        'associate',
-        'junior',
-        'mid-level',
-        'senior',
-        'staff',
-    ],
+    experience: ['associate', 'junior', 'mid-level', 'senior', 'staff'],
     roles: {
         type: [
             'back-end',
@@ -96,21 +80,12 @@ possible.usa = {
             'manager',
             'technician',
         ],
-        candidate: [
-            'hiring_manager',
-            'recruiter',
-        ]
+        candidate: ['hiring_manager', 'recruiter'],
     },
-    pronouns: [
-        'she/her',
-        'she/they',
-        'he/him',
-        'he/they',
-        'they/them',
-    ],
+    pronouns: ['she/her', 'she/they', 'he/him', 'he/they', 'they/them'],
     image: [],
     zipcode: [],
-    blurb: []
+    blurb: [],
 }
 
-export { allSteps, aspectResponses, possible }
+export { allSteps, aspectResponses, possible, DELIMITER }

frontend/src/views/ChatView.vue

@@ -1,17 +1,20 @@
 <template lang="pug">
 main.view--chat
     header.mb6(v-if='profile && grouping')
-        h3 chatting with: {{ target.profile_id }}
-        p {{ grouping.profile.user_name }}
-        p {{ grouping.profile.user_email }}
-        p(v-if='!grouping._loading') {{ grouping.revealed }}
+        h3 chatting with:
+        p {{ target.profile_id }} | {{ grouping.profile.user_name }} | {{ grouping.profile.user_email }}
+
+        h3 logged in as:
+        p {{ profile.id }} | {{ profile._profile.user_name }} | {{ profile._profile.user_email }}
         //- p subscriptions: {{ profile.chatter.subscriptions }}
+        hr
 
-        .w-flex.column
-            p reveal: {{ grouping.revealed }}
+        .w-flex.column(v-if='!grouping._loading')
+            p you revealed: {{ grouping.revealed[profile.id.value].map(tag => tag.description) }}
             .w-flex.row
-                button(@click='reveal(7)') my name
-                button(@click='reveal(8)') my email
+                button(@click='reveal(7)') reveal my name
+                button(@click='reveal(8)') reveal my email
+            p they revealed: {{ grouping.revealed[target.profile_id].map(tag => tag.description) }}
 
     article
         template(v-if='isLoading')
@@ -22,7 +25,7 @@ main.view--chat
                 template(v-for='chatmessage in messages')
                     li(
                         :class='[{ me: chatmessage.publisher == profile.id.value }, chatmessage.publisher]'
-                        v-if='chatmessage.message.description'
+                        v-if='chatmessage.message && chatmessage.message.description'
                     )
                         ChatBubble(
                             :message='chatmessage.message.description'
@@ -41,7 +44,7 @@ main.view--chat
     MainNav
 </template>
 
-<script>
+<script lang="js">
 import ChatBubble from '../components/ChatBubble.vue'
 import { currentProfile } from '../services'
 import { mixins } from '../utils'
@@ -54,19 +57,25 @@ export default {
         target: null,
         toSend: '',
         messages: [],
-        openDrawer: null,
         grouping: null,
     }),
     watch: {
-        profile() {
+        async profile() {
             this.loadTargetProfile()
+            currentProfile._loading.value = true
+            this.messages = await currentProfile.chatter.getHistory(this.grouping.grouping_name)
             currentProfile.chatter.setOnMessage(this._onMessage)
+            currentProfile._loading.value = false
         },
     },
-    created() {
+    async created() {
         this.loadTargetProfile()
-        currentProfile.chatter.setOnMessage(this._onMessage)
+        currentProfile._loading.value = true
         this.grouping = this.getGrouping()
+        this.messages = await currentProfile.chatter.getHistory(this.grouping.grouping_name)
+        console.log('this.messages :>> ', this.messages)
+        currentProfile.chatter.setOnMessage(this._onMessage)
+        currentProfile._loading.value = false
     },
     methods: {
         async reveal(tagId) {