🪟 🐛 Remove reinitialization of AnalyticsService (#19304)

* Remvoe reinitialization of AnalyticsService

* Change to ref

* Make useCurrentWorkspaceId work globally

* Fix workspace id

airbyte-webapp/.storybook/withProvider.tsx

@@ -12,17 +12,14 @@ import { FeatureService } from "../src/hooks/services/Feature";
 import { ConfigServiceProvider, defaultConfig } from "../src/config";
 import { DocumentationPanelProvider } from "../src/views/Connector/ConnectorDocumentationLayout/DocumentationPanelContext";
 import { ServicesProvider } from "../src/core/servicesProvider";
-import { analyticsServiceContext, AnalyticsServiceProviderValue } from "../src/hooks/services/Analytics";
+import { analyticsServiceContext } from "../src/hooks/services/Analytics";
+import type { AnalyticsService } from "../src/core/analytics";
 
-const AnalyticsContextMock: AnalyticsServiceProviderValue = {
-  analyticsContext: {},
-  setContext: () => {},
-  addContextProps: () => {},
-  removeContextProps: () => {},
-  service: {
+const analyticsContextMock: AnalyticsService = {
     track: () => {},
-  },
-} as unknown as AnalyticsServiceProviderValue;
+    setContext: () => {},
+    removeFromContext: () => {},
+} as unknown as AnalyticsService;
 
 const queryClient = new QueryClient({
   defaultOptions: {
@@ -35,7 +32,7 @@ const queryClient = new QueryClient({
 
 export const withProviders = (getStory) => (
   <React.Suspense fallback={null}>
-    <analyticsServiceContext.Provider value={AnalyticsContextMock}>
+    <analyticsServiceContext.Provider value={analyticsContextMock}>
       <QueryClientProvider client={queryClient}>
         <ServicesProvider>
           <MemoryRouter>

airbyte-webapp/src/core/analytics/AnalyticsService.test.ts

@@ -26,13 +26,13 @@ describe("AnalyticsService", () => {
   });
 
   it("should send events to segment", () => {
-    const service = new AnalyticsService({});
+    const service = new AnalyticsService();
     service.track(Namespace.CONNECTION, Action.CREATE, {});
     expect(window.analytics.track).toHaveBeenCalledWith("Airbyte.UI.Connection.Create", expect.anything());
   });
 
   it("should send version and environment for prod", () => {
-    const service = new AnalyticsService({}, "0.42.13");
+    const service = new AnalyticsService("0.42.13");
     service.track(Namespace.CONNECTION, Action.CREATE, {});
     expect(window.analytics.track).toHaveBeenCalledWith(
       expect.anything(),
@@ -41,7 +41,7 @@ describe("AnalyticsService", () => {
   });
 
   it("should send version and environment for dev", () => {
-    const service = new AnalyticsService({}, "dev");
+    const service = new AnalyticsService("dev");
     service.track(Namespace.CONNECTION, Action.CREATE, {});
     expect(window.analytics.track).toHaveBeenCalledWith(
       expect.anything(),
@@ -50,7 +50,7 @@ describe("AnalyticsService", () => {
   });
 
   it("should pass parameters to segment event", () => {
-    const service = new AnalyticsService({});
+    const service = new AnalyticsService();
     service.track(Namespace.CONNECTION, Action.CREATE, { actionDescription: "Created new connection" });
     expect(window.analytics.track).toHaveBeenCalledWith(
       expect.anything(),
@@ -59,7 +59,8 @@ describe("AnalyticsService", () => {
   });
 
   it("should pass context parameters to segment event", () => {
-    const service = new AnalyticsService({ context: 42 });
+    const service = new AnalyticsService();
+    service.setContext({ context: 42 });
     service.track(Namespace.CONNECTION, Action.CREATE, { actionDescription: "Created new connection" });
     expect(window.analytics.track).toHaveBeenCalledWith(
       expect.anything(),

airbyte-webapp/src/core/analytics/AnalyticsService.ts

@@ -1,10 +1,25 @@
 import { Action, EventParams, Namespace } from "./types";
 
+type Context = Record<string, unknown>;
+
 export class AnalyticsService {
-  constructor(private context: Record<string, unknown>, private version?: string) {}
+  private context: Context = {};
+
+  constructor(private version?: string) {}
 
   private getSegmentAnalytics = (): SegmentAnalytics.AnalyticsJS | undefined => window.analytics;
 
+  public setContext(context: Context) {
+    this.context = {
+      ...this.context,
+      ...context,
+    };
+  }
+
+  public removeFromContext(...keys: string[]) {
+    keys.forEach((key) => delete this.context[key]);
+  }
+
   alias = (newId: string): void => this.getSegmentAnalytics()?.alias?.(newId);
 
   page = (name: string): void => this.getSegmentAnalytics()?.page?.(name, { ...this.context });

airbyte-webapp/src/hooks/services/Analytics/__mocks__/useAnalyticsService.tsx

@@ -8,5 +8,7 @@ export const useAnalyticsService = (): AnalyticsService => {
     track: jest.fn(),
     identify: jest.fn(),
     group: jest.fn(),
+    setContext: jest.fn(),
+    removeFromContext: jest.fn(),
   } as unknown as AnalyticsService;
 };

airbyte-webapp/src/hooks/services/Analytics/useAnalyticsService.tsx

@@ -1,62 +1,26 @@
-import React, { useContext, useEffect, useMemo } from "react";
-import { useMap } from "react-use";
+import React, { useContext, useEffect, useRef } from "react";
 
+import { useConfig } from "config";
 import { AnalyticsService } from "core/analytics/AnalyticsService";
 
 type AnalyticsContext = Record<string, unknown>;
 
-export interface AnalyticsServiceProviderValue {
-  analyticsContext: AnalyticsContext;
-  setContext: (ctx: AnalyticsContext) => void;
-  addContextProps: (props: AnalyticsContext) => void;
-  removeContextProps: (props: string[]) => void;
-  service: AnalyticsService;
-}
-
-export const analyticsServiceContext = React.createContext<AnalyticsServiceProviderValue | null>(null);
-
-const AnalyticsServiceProvider = ({
-  children,
-  version,
-  initialContext = {},
-}: {
-  children: React.ReactNode;
-  version?: string;
-  initialContext?: AnalyticsContext;
-}) => {
-  const [analyticsContext, { set, setAll, remove }] = useMap(initialContext);
-
-  const analyticsService: AnalyticsService = useMemo(
-    () => new AnalyticsService(analyticsContext, version),
-    [version, analyticsContext]
-  );
+export const analyticsServiceContext = React.createContext<AnalyticsService | null>(null);
 
-  const handleAddContextProps = (props: AnalyticsContext) => {
-    Object.entries(props).forEach((value) => set(...value));
-  };
+const AnalyticsServiceProvider: React.FC<React.PropsWithChildren<unknown>> = ({ children }) => {
+  const { version } = useConfig();
+  const analyticsService = useRef<AnalyticsService>();
 
-  const handleRemoveContextProps = (props: string[]) => props.forEach(remove);
+  if (!analyticsService.current) {
+    analyticsService.current = new AnalyticsService(version);
+  }
 
   return (
-    <analyticsServiceContext.Provider
-      value={{
-        analyticsContext,
-        setContext: setAll,
-        addContextProps: handleAddContextProps,
-        removeContextProps: handleRemoveContextProps,
-        service: analyticsService,
-      }}
-    >
-      {children}
-    </analyticsServiceContext.Provider>
+    <analyticsServiceContext.Provider value={analyticsService.current}>{children}</analyticsServiceContext.Provider>
   );
 };
 
 export const useAnalyticsService = (): AnalyticsService => {
-  return useAnalytics().service;
-};
-
-export const useAnalytics = (): AnalyticsServiceProviderValue => {
   const analyticsContext = useContext(analyticsServiceContext);
 
   if (!analyticsContext) {
@@ -86,15 +50,15 @@ export const useTrackPage = (page: string): void => {
 };
 
 export const useAnalyticsRegisterValues = (props?: AnalyticsContext | null): void => {
-  const { addContextProps, removeContextProps } = useAnalytics();
+  const service = useAnalyticsService();
 
   useEffect(() => {
     if (!props) {
       return;
     }
 
-    addContextProps(props);
-    return () => removeContextProps(Object.keys(props));
+    service.setContext(props);
+    return () => service.removeFromContext(...Object.keys(props));
 
     // eslint-disable-next-line react-hooks/exhaustive-deps
   }, [props]);

airbyte-webapp/src/packages/cloud/cloudRoutes.tsx

@@ -13,7 +13,6 @@ import { OnboardingServiceProvider } from "hooks/services/Onboarding";
 import { useQuery } from "hooks/useQuery";
 import { useExperimentSpeedyConnection } from "packages/cloud/components/experiments/SpeedyConnection/hooks/useExperimentSpeedyConnection";
 import { useAuthService } from "packages/cloud/services/auth/AuthService";
-import { useIntercom } from "packages/cloud/services/thirdParty/intercom/useIntercom";
 import { Auth } from "packages/cloud/views/auth";
 import { CreditsPage } from "packages/cloud/views/credits";
 import MainView from "packages/cloud/views/layout/MainView";
@@ -114,7 +113,6 @@ const MainRoutes: React.FC = () => {
 
 const MainViewRoutes = () => {
   useApiHealthPoll();
-  useIntercom();
   const query = useQuery<{ from: string }>();
 
   return (

airbyte-webapp/src/packages/cloud/services/thirdParty/intercom/useIntercom.ts

@@ -1,14 +1,14 @@
 import { useEffect } from "react";
 import { useIntercom as useIntercomProvider, IntercomContextValues } from "react-use-intercom";
 
-import { useAnalytics } from "hooks/services/Analytics";
 import { useCurrentUser } from "packages/cloud/services/auth/AuthService";
+import { useCurrentWorkspaceId } from "services/workspaces/WorkspacesService";
 
 export const useIntercom = (): IntercomContextValues => {
   const intercomContextValues = useIntercomProvider();
 
   const user = useCurrentUser();
-  const { analyticsContext } = useAnalytics();
+  const workspaceId = useCurrentWorkspaceId();
 
   useEffect(() => {
     intercomContextValues.boot({
@@ -18,7 +18,7 @@ export const useIntercom = (): IntercomContextValues => {
       userHash: user.intercomHash,
 
       customAttributes: {
-        workspace_id: analyticsContext.workspaceId,
+        workspace_id: workspaceId,
       },
     });
 
@@ -29,11 +29,11 @@ export const useIntercom = (): IntercomContextValues => {
   useEffect(() => {
     intercomContextValues.update({
       customAttributes: {
-        workspace_id: analyticsContext.workspace_id,
+        workspace_id: workspaceId,
       },
     });
     // eslint-disable-next-line react-hooks/exhaustive-deps
-  }, [analyticsContext.workspace_id]);
+  }, [workspaceId]);
 
   return intercomContextValues;
 };

airbyte-webapp/src/packages/cloud/services/thirdParty/launchdarkly/LDExperimentService.tsx

@@ -8,7 +8,7 @@ import { LoadingPage } from "components";
 
 import { useConfig } from "config";
 import { useI18nContext } from "core/i18n";
-import { useAnalytics } from "hooks/services/Analytics";
+import { useAnalyticsService } from "hooks/services/Analytics";
 import { ExperimentProvider, ExperimentService } from "hooks/services/Experiment";
 import type { Experiments } from "hooks/services/Experiment/experiments";
 import { FeatureSet, useFeatureService } from "hooks/services/Feature";
@@ -46,7 +46,7 @@ const LDInitializationWrapper: React.FC<React.PropsWithChildren<{ apiKey: string
   const ldClient = useRef<LDClient.LDClient>();
   const [state, setState] = useState<LDInitState>("initializing");
   const { user } = useAuthService();
-  const { addContextProps: addAnalyticsContext } = useAnalytics();
+  const analyticsService = useAnalyticsService();
   const { locale } = useIntl();
   const { setMessageOverwrite } = useI18nContext();
 
@@ -93,7 +93,7 @@ const LDInitializationWrapper: React.FC<React.PropsWithChildren<{ apiKey: string
         // The LaunchDarkly promise resolved before the timeout, so we're good to use LD.
         setState("initialized");
         // Make sure enabled experiments are added to each analytics event
-        addAnalyticsContext({ experiments: JSON.stringify(ldClient.current?.allFlags()) });
+        analyticsService.setContext({ experiments: JSON.stringify(ldClient.current?.allFlags()) });
         // Check for overwritten i18n messages
         updateI18nMessages();
         updateFeatureOverwrites(ldClient.current?.variation(FEATURE_FLAG_EXPERIMENT, ""));
@@ -118,7 +118,7 @@ const LDInitializationWrapper: React.FC<React.PropsWithChildren<{ apiKey: string
   useEffectOnce(() => {
     const onFeatureFlagsChanged = () => {
       // Update analytics context whenever a flag changes
-      addAnalyticsContext({ experiments: JSON.stringify(ldClient.current?.allFlags()) });
+      analyticsService.setContext({ experiments: JSON.stringify(ldClient.current?.allFlags()) });
       // Check for overwritten i18n messages
       updateI18nMessages();
     };

airbyte-webapp/src/packages/cloud/views/layout/MainView/MainView.tsx

@@ -10,6 +10,7 @@ import { CloudRoutes } from "packages/cloud/cloudRoutes";
 import { useExperimentSpeedyConnection } from "packages/cloud/components/experiments/SpeedyConnection/hooks/useExperimentSpeedyConnection";
 import { SpeedyConnectionBanner } from "packages/cloud/components/experiments/SpeedyConnection/SpeedyConnectionBanner";
 import { CreditStatus } from "packages/cloud/lib/domain/cloudWorkspaces/types";
+import { useIntercom } from "packages/cloud/services/thirdParty/intercom";
 import { useGetCloudWorkspace } from "packages/cloud/services/workspaces/CloudWorkspacesService";
 import SideBar from "packages/cloud/views/layout/SideBar";
 import { useCurrentWorkspace } from "services/workspaces/WorkspacesService";
@@ -21,6 +22,7 @@ import styles from "./MainView.module.scss";
 
 const MainView: React.FC<React.PropsWithChildren<unknown>> = (props) => {
   const { formatMessage } = useIntl();
+  useIntercom();
   const workspace = useCurrentWorkspace();
   const cloudWorkspace = useGetCloudWorkspace(workspace.workspaceId);
   const showCreditsBanner =

airbyte-webapp/src/packages/cloud/views/workspaces/WorkspacesPage/WorkspacesPage.tsx

@@ -5,12 +5,14 @@ import { Heading } from "components/ui/Heading";
 import { Text } from "components/ui/Text";
 
 import { useTrackPage, PageTrackingCodes } from "hooks/services/Analytics";
+import { useIntercom } from "packages/cloud/services/thirdParty/intercom";
 
 import WorkspacesList from "./components/WorkspacesList";
 import styles from "./WorkspacesPage.module.scss";
 
 const WorkspacesPage: React.FC = () => {
   useTrackPage(PageTrackingCodes.WORKSPACES);
+  useIntercom();
 
   return (
     <div className={styles.container}>

airbyte-webapp/src/views/common/AnalyticsProvider.tsx

@@ -4,11 +4,9 @@ import { useConfig } from "config";
 import AnalyticsServiceProvider from "hooks/services/Analytics/useAnalyticsService";
 import useSegment from "hooks/useSegment";
 
-const AnalyticsProvider: React.FC<React.PropsWithChildren<unknown>> = ({ children }) => {
+export const AnalyticsProvider: React.FC<React.PropsWithChildren<unknown>> = ({ children }) => {
   const config = useConfig();
   useSegment(config.segment.enabled ? config.segment.token : "");
 
-  return <AnalyticsServiceProvider version={config.version}>{children}</AnalyticsServiceProvider>;
+  return <AnalyticsServiceProvider>{children}</AnalyticsServiceProvider>;
 };
-
-export { AnalyticsProvider };