chore: move environments firebase things to hoppscotch-web (#2939)

packages/hoppscotch-web/src/environments.ts

@@ -0,0 +1,186 @@
+import { Environment } from "@hoppscotch/data"
+import {
+  collection,
+  doc,
+  getFirestore,
+  onSnapshot,
+  setDoc,
+} from "firebase/firestore"
+import { def as platformAuth } from "./firebase/auth"
+import {
+  environments$,
+  globalEnv$,
+  replaceEnvironments,
+  setGlobalEnvVariables,
+} from "@hoppscotch/common/newstore/environments"
+import {
+  getSettingSubject,
+  settingsStore,
+} from "@hoppscotch/common/newstore/settings"
+import { EnvironmentsPlatformDef } from "@hoppscotch/common/platform/environments"
+
+/**
+ * Used locally to prevent infinite loop when environment sync update
+ * is applied to the store which then fires the store sync listener.
+ * When you want to update environments and not want to fire the update listener,
+ * set this to true and then set it back to false once it is done
+ */
+let loadedEnvironments = false
+
+/**
+ * Used locally to prevent infinite loop when global env sync update
+ * is applied to the store which then fires the store sync listener.
+ * When you want to update global env and not want to fire the update listener,
+ * set this to true and then set it back to false once it is done
+ */
+let loadedGlobals = true
+
+async function writeEnvironments(environment: Environment[]) {
+  const currentUser = platformAuth.getCurrentUser()
+
+  if (currentUser === null)
+    throw new Error("Cannot write environments when signed out")
+
+  const ev = {
+    updatedOn: new Date(),
+    author: currentUser.uid,
+    author_name: currentUser.displayName,
+    author_image: currentUser.photoURL,
+    environment,
+  }
+
+  try {
+    await setDoc(
+      doc(getFirestore(), "users", currentUser.uid, "environments", "sync"),
+      ev
+    )
+  } catch (e) {
+    console.error("error updating", ev, e)
+    throw e
+  }
+}
+
+async function writeGlobalEnvironment(variables: Environment["variables"]) {
+  const currentUser = platformAuth.getCurrentUser()
+
+  if (currentUser === null)
+    throw new Error("Cannot write global environment when signed out")
+
+  const ev = {
+    updatedOn: new Date(),
+    author: currentUser.uid,
+    author_name: currentUser.displayName,
+    author_image: currentUser.photoURL,
+    variables,
+  }
+
+  try {
+    await setDoc(
+      doc(getFirestore(), "users", currentUser.uid, "globalEnv", "sync"),
+      ev
+    )
+  } catch (e) {
+    console.error("error updating", ev, e)
+    throw e
+  }
+}
+
+export function initEnvironmentsSync() {
+  const currentUser$ = platformAuth.getCurrentUserStream()
+
+  const envListenSub = environments$.subscribe((envs) => {
+    const currentUser = platformAuth.getCurrentUser()
+
+    if (
+      currentUser &&
+      settingsStore.value.syncEnvironments &&
+      loadedEnvironments
+    ) {
+      writeEnvironments(envs)
+    }
+  })
+
+  const globalListenSub = globalEnv$.subscribe((vars) => {
+    const currentUser = platformAuth.getCurrentUser()
+
+    if (currentUser && settingsStore.value.syncEnvironments && loadedGlobals) {
+      writeGlobalEnvironment(vars)
+    }
+  })
+
+  let envSnapshotStop: (() => void) | null = null
+  let globalsSnapshotStop: (() => void) | null = null
+
+  const currentUserSub = currentUser$.subscribe((user) => {
+    if (!user) {
+      // User logged out, clean up snapshot listener
+      if (envSnapshotStop) {
+        envSnapshotStop()
+        envSnapshotStop = null
+      }
+
+      if (globalsSnapshotStop) {
+        globalsSnapshotStop()
+        globalsSnapshotStop = null
+      }
+    } else if (user) {
+      envSnapshotStop = onSnapshot(
+        collection(getFirestore(), "users", user.uid, "environments"),
+        (environmentsRef) => {
+          const environments: any[] = []
+
+          environmentsRef.forEach((doc) => {
+            const environment = doc.data()
+            environment.id = doc.id
+            environments.push(environment)
+          })
+
+          loadedEnvironments = false
+          if (environments.length > 0 && settingsStore.value.syncEnvironments) {
+            replaceEnvironments(environments[0].environment)
+          }
+          loadedEnvironments = true
+        }
+      )
+      globalsSnapshotStop = onSnapshot(
+        collection(getFirestore(), "users", user.uid, "globalEnv"),
+        (globalsRef) => {
+          if (globalsRef.docs.length === 0) {
+            loadedGlobals = true
+            return
+          }
+
+          const doc = globalsRef.docs[0].data()
+          loadedGlobals = false
+          if (settingsStore.value.syncEnvironments)
+            setGlobalEnvVariables(doc.variables)
+          loadedGlobals = true
+        }
+      )
+    }
+  })
+
+  let oldSyncStatus = settingsStore.value.syncEnvironments
+
+  const syncStop = getSettingSubject("syncEnvironments").subscribe(
+    (newStatus) => {
+      if (oldSyncStatus === true && newStatus === false) {
+        envSnapshotStop?.()
+        globalsSnapshotStop?.()
+
+        oldSyncStatus = newStatus
+      } else if (oldSyncStatus === false && newStatus === true) {
+        syncStop.unsubscribe()
+        envListenSub.unsubscribe()
+        globalListenSub.unsubscribe()
+        currentUserSub.unsubscribe()
+
+        initEnvironmentsSync()
+      }
+    }
+  )
+}
+
+export const def: EnvironmentsPlatformDef = {
+  initEnvironmentsSync,
+}

packages/hoppscotch-web/src/main.ts

@@ -1,6 +1,10 @@
 import { createHoppApp } from "@hoppscotch/common"
 import { def as authDef } from "./firebase/auth"
+import { def as envDef } from "./environments"
 
 createHoppApp("#app", {
   auth: authDef,
+  sync: {
+    environments: envDef,
+  },
 })