Add piconnection state

Author: bierdok

extension.js

@@ -13,7 +13,6 @@ import pkg from './package.json' with { type: 'json' }
 export default class Extension {
   #bootstrap = null
   #category = null
-  #debug = false
   #demo = false
   #features = []
   #functions = []
@@ -39,7 +38,6 @@ export default class Extension {
       this.#publisher = new Publisher(
         () => {
           return {
-            debug: this.#debug,
             mercure,
           }
         },
@@ -63,7 +61,6 @@ export default class Extension {
       )
       new Subscriber(() => {
         return {
-          debug: this.#debug,
           extension: this,
           functions: this.#functions,
           mercure,
@@ -111,11 +108,6 @@ export default class Extension {
     return this
   }
 
-  enableDebug() {
-    this.#debug = true
-    return this
-  }
-
   /**
    * @param {Boolean} demo - If the extension is a demonstration.
    * @returns {Extension} The updated extension instance.

package.json

@@ -1,7 +1,7 @@
 {
   "name": "talkops",
   "description": "TalkOps SDK",
-  "version": "2.8.0",
+  "version": "2.9.0",
   "author": "bierdok",
   "license": "MIT",
   "main": "index.mjs",

publisher.js

@@ -4,6 +4,7 @@ export default class Publisher {
   #useConfig = null
   #useState = null
   #lastEventState = null
+  #lastPingAt = null
 
   constructor(useConfig, useState) {
     this.#useConfig = useConfig
@@ -32,9 +33,14 @@ export default class Publisher {
     this.publishEvent({ type: 'state', state: this.#useState() })
   }
 
+  onPing() {
+    this.#lastPingAt = new Date().getTime()
+    this.publishEvent({ type: 'pong' })
+  }
+
   async publishEvent(event) {
+    if (this.#lastPingAt && this.#lastPingAt < new Date().getTime() - 6000) return
     const config = this.#useConfig()
-    config.debug && console.log('pub', event.type)
     await axios.post(
       config.mercure.url,
       new URLSearchParams({

subscriber.js

@@ -27,7 +27,9 @@ export default class Subscriber {
 
   async #onEvent(event) {
     const config = this.#useConfig()
-    config.debug && console.log('sub', event.type)
+    if (event.type === 'ping') {
+      config.publisher.onPing()
+    }
     if (event.type === 'boot') {
       for (const name of Object.keys(event.parameters)) {
         for (const parameter of config.parameters) {