Chore: use SDK for health metrics and add error handling to homestar …

…client getter

package.json

@@ -57,7 +57,7 @@
     ]
   },
   "dependencies": {
-    "@fission-codes/homestar": "^0.6.0",
+    "@fission-codes/homestar": "^0.6.1",
     "@oddjs/odd": "0.37.0",
     "@open-rpc/client-js": "^1.8.1",
     "@types/three": "^0.156.0",

src/components/settings/NodeInfo.svelte

@@ -2,8 +2,8 @@
   import clipboardCopy from 'clipboard-copy'
   import { onDestroy, onMount } from 'svelte'
 
-  import { requestHealth } from '$lib/health'
   import { addNotification } from '$lib/notifications'
+  import { getHomestarClient } from '$lib/rpc'
   import ClipboardIcon from '$components/icons/ClipboardIcon.svelte'
 
   export let compressedView = false
@@ -17,12 +17,13 @@
   }
 
   onMount(async () => {
-    health = await requestHealth()
+    const homestar = getHomestarClient()
+    health = (await homestar.health()).result
 
     // Poll until listener addresses are returned
     if (!health?.nodeInfo?.dynamic?.listeners?.length) {
       interval = setInterval(async () => {
-        health = await requestHealth()
+        health = (await homestar.health()).result
         if (health?.nodeInfo?.dynamic?.listeners?.length) {
           clearInterval(interval)
         }

src/lib/metrics.ts

@@ -1,6 +1,6 @@
 // import type { InferError } from '@fission-codes/homestar/types'
 
-import { homestar } from '$lib/rpc'
+import { getHomestarClient } from '$lib/rpc'
 
 type Metric = {
   data: Data[]
@@ -17,6 +17,7 @@ type Data = {
 
 export const requestMetrics = async (): Promise<Metric> => {
   try {
+    const homestar = getHomestarClient()
     const { error, result } = await homestar.metrics()
     if (error) {
       throw new Error(error)

src/lib/network.ts

@@ -3,7 +3,7 @@
 // import { WebSocket } from 'unws'
 
 import { networkStore } from '$lib/stores'
-import { homestar } from '$lib/rpc'
+import { getHomestarClient } from '$lib/rpc'
 
 export type NetworkStore = {
   loading: boolean
@@ -34,6 +34,8 @@ const RECEIPT_SENT = 'network:publishedReceiptPubsub'
 // })
 
 export const subscribNetworkEvents = async (): Promise<void> => {
+  const homestar = getHomestarClient()
+
   await homestar.networkEvents(res => {
     // console.log('node1 res', res)
     if (res.error) {

src/lib/rpc.ts

@@ -7,22 +7,35 @@ import {
   Client,
   WebSocketTransport as OpenRPCWebSocketTransport
 } from '@open-rpc/client-js'
+import { addNotification } from './notifications'
 
 const openRPCTransport = new OpenRPCWebSocketTransport(
   import.meta.env.VITE_WEBSOCKET_ENDPOINT
 )
 const requestManager = new RequestManager([openRPCTransport])
 export const rpcClient = new Client(requestManager)
 
-const transport = new WebsocketTransport(
-  import.meta.env.VITE_WEBSOCKET_ENDPOINT,
-  {
-    ws: WebSocket
+let homestar
+export const getHomestarClient = () => {
+  try {
+    if (!homestar) {
+      const transport = new WebsocketTransport(
+        import.meta.env.VITE_WEBSOCKET_ENDPOINT,
+        {
+          ws: WebSocket
+        }
+      ) // WS
+      homestar = new Homestar({
+        transport
+      })
+    }
+
+    return homestar
+  } catch (error) {
+    console.error(error)
+    addNotification(error, 'error')
   }
-) // WS
-export const homestar = new Homestar({
-  transport,
-})
+}
 
 /**
  * Subscribe to WS messages and pass the data to the appropriate handler

src/lib/workflows/index.ts

@@ -5,7 +5,7 @@ import { get as getStore } from 'svelte/store'
 
 import type { Receipt, FunctionOperation, Meta } from '$lib/functions'
 import { addNotification } from '$lib/notifications'
-import { homestar } from '$lib/rpc'
+import { getHomestarClient } from '$lib/rpc'
 import { workflowsStore } from '$lib/stores'
 
 export type WorkflowsStore = {
@@ -213,6 +213,8 @@ export const runWorkflow = async (
       }
     })
 
+    const homestar = getHomestarClient()
+
     await homestar.runWorkflow(
       { ...payloadToRun, name: runName },
       async data => {