store: Create subServerStore

Author: itsrachelfish

app/src/store/store.ts

@@ -16,6 +16,7 @@ import {
   RouterStore,
   SessionStore,
   SettingsStore,
+  SubServerStore,
   SwapStore,
 } from './stores';
 import {
@@ -49,6 +50,7 @@ export class Store {
   orderStore = new OrderStore(this);
   settingsStore = new SettingsStore(this);
   sessionStore = new SessionStore(this);
+  subServerStore = new SubServerStore(this);
 
   /** the store which synchronizes with the browser history */
   router: RouterStore;
@@ -157,11 +159,18 @@ export class Store {
    * makes the initial API calls to fetch the data we need to display in the app
    */
   async fetchAllData() {
+    await this.subServerStore.fetchStatus();
     await this.nodeStore.fetchInfo();
     await this.channelStore.fetchChannels();
-    await this.swapStore.fetchSwaps();
     await this.nodeStore.fetchBalances();
     await this.sessionStore.fetchSessions();
+
+    if (
+      this.subServerStore.subServers.loop?.running &&
+      !this.subServerStore.subServers.loop?.error
+    ) {
+      await this.swapStore.fetchSwaps();
+    }
   }
 
   /** connects to the LND and Loop websocket streams if not already connected */

app/src/store/stores/batchStore.ts

@@ -313,11 +313,17 @@ export default class BatchStore {
    * initialize the batch store
    */
   init() {
-    // when the pubkey is fetched from the API and set in the nodeStore, fetch
-    // the node's tier
-    when(
-      () => !!this._store.nodeStore.pubkey && !this.nodeTier,
-      () => this.fetchNodeTier(),
-    );
+    // make sure the pool subserver is running before initializing
+    if (
+      this._store.subServerStore.subServers.pool?.running &&
+      !this._store.subServerStore.subServers.pool?.error
+    ) {
+      // when the pubkey is fetched from the API and set in the nodeStore, fetch
+      // the node's tier
+      when(
+        () => !!this._store.nodeStore.pubkey && !this.nodeTier,
+        () => this.fetchNodeTier(),
+      );
+    }
   }
 }

app/src/store/stores/index.ts

@@ -8,3 +8,4 @@ export { default as SettingsStore } from './settingsStore';
 export { default as SwapStore } from './swapStore';
 export { default as RouterStore } from './routerStore';
 export { default as SessionStore } from './sessionStore';
+export { default as SubServerStore } from './subServerStore';

app/src/store/stores/subServerStore.ts

@@ -0,0 +1,58 @@
+import { makeAutoObservable, runInAction } from 'mobx';
+import { Store } from 'store';
+import { SubServerStatus } from 'types/state';
+
+/** processed data for specific subservices we need to display in the UI */
+interface SubServers {
+  loop: SubServerStatus;
+  pool: SubServerStatus;
+}
+
+export default class SubServerStore {
+  private _store: Store;
+
+  loading = false;
+
+  subServers: SubServers = {
+    loop: {
+      disabled: false,
+      running: true,
+      error: '',
+    },
+    pool: {
+      disabled: false,
+      running: true,
+      error: '',
+    },
+  };
+
+  constructor(store: Store) {
+    makeAutoObservable(this, {}, { deep: false, autoBind: true });
+
+    this._store = store;
+  }
+
+  /** fetch subserver statuses from the lit API */
+  async fetchStatus() {
+    try {
+      this.loading = true;
+      const serverStatus = await this._store.api.lit.listSubServerStatus();
+
+      serverStatus.subServersMap.map(([serverName, serverStatus]) => {
+        runInAction(() => {
+          if (serverName === 'pool') {
+            this.subServers.pool = serverStatus;
+          } else if (serverName === 'loop') {
+            this.subServers.loop = serverStatus;
+          }
+        });
+      });
+    } catch (error) {
+      this._store.appView.handleError(error, 'Unable to fetch SubServer Status');
+    } finally {
+      runInAction(() => {
+        this.loading = false;
+      });
+    }
+  }
+}

app/src/types/state.ts

@@ -69,3 +69,9 @@ export enum ChannelStatus {
  * duration is not just a random number.
  */
 export type LeaseDuration = number;
+
+export interface SubServerStatus {
+  disabled: boolean;
+  running: boolean;
+  error: string;
+}