Allow the application to run without analytics

.env.template

@@ -53,6 +53,7 @@ OPS_TABLES_TOKEN_LIFETIME_MINUTES=60
 OPS_MAX_CONCURRENT_TABLES_REQUESTS=100
 
 # OPENOPS ANALYTICS
+OPS_ANALYTICS_ENABLED=true
 OPS_ANALYTICS_PUBLIC_URL=http://localhost:8088
 OPS_ANALYTICS_PRIVATE_URL=http://localhost:8088
 OPS_ANALYTICS_ADMIN_PASSWORD=admin

deploy/docker-compose/.env.defaults

@@ -83,6 +83,7 @@ OPS_MAX_CONCURRENT_TABLES_REQUESTS=100
 # Analytics
 # ---------------------------------------------------------
 
+OPS_ANALYTICS_ENABLED=true
 OPS_ANALYTICS_PUBLIC_URL=${OPS_PUBLIC_URL}
 OPS_ANALYTICS_PRIVATE_URL=http://openops-analytics:8088
 OPS_ANALYTICS_ADMIN_PASSWORD=please-change-this-password-1

deploy/helm/openops/values.overrides-example.yaml

@@ -10,4 +10,5 @@ openopsEnv:
   OPS_JWT_SECRET: M72yCOp9riLjIDws
   OPS_POSTGRES_PASSWORD: WZKUM0tSvFC6VWai
   OPS_ANALYTICS_ADMIN_PASSWORD: 7YO7YEVRaECPQimI
+  OPS_ANALYTICS_ENABLED: "true"
   ANALYTICS_POWERUSER_PASSWORD: v5vIvwhdBDWwx4el

deploy/helm/openops/values.yaml

@@ -57,6 +57,7 @@ openopsEnv:
   OPS_OPENOPS_TABLES_DB_HOST: '{{ include "openops.postgresHost" . }}'
 
   # Analytics
+  OPS_ANALYTICS_ENABLED: "true"
   OPS_ANALYTICS_PUBLIC_URL: "{{ .Values.openopsEnv.OPS_PUBLIC_URL }}"
   OPS_ANALYTICS_PRIVATE_URL: '{{ include "openops.analyticsServiceUrl" . }}'
   OPS_ANALYTICS_ADMIN_PASSWORD: please-change-this-password-1

packages/react-ui/src/app/common/hooks/analytics-hooks.ts

@@ -0,0 +1,18 @@
+import { authenticationSession } from '@/app/lib/authentication-session';
+import { FlagId } from '@openops/shared';
+import { useMemo } from 'react';
+import { flagsHooks } from './flags-hooks';
+
+export const useHasAnalyticsAccess = (): boolean => {
+  const { data: isAnalyticsEnabled } = flagsHooks.useFlag<boolean | undefined>(
+    FlagId.ANALYTICS_ENABLED,
+  );
+
+  const hasAnalyticsPrivileges =
+    authenticationSession.getUserHasAnalyticsPrivileges();
+
+  return useMemo(
+    () => Boolean(isAnalyticsEnabled && hasAnalyticsPrivileges),
+    [isAnalyticsEnabled, hasAnalyticsPrivileges],
+  );
+};

packages/react-ui/src/app/features/navigation/lib/menu-links-hook.ts

@@ -1,4 +1,4 @@
-import { authenticationSession } from '@/app/lib/authentication-session';
+import { useHasAnalyticsAccess } from '@/app/common/hooks/analytics-hooks';
 import { MenuLink, RunsIcon } from '@openops/components/ui';
 import { t } from 'i18next';
 import {
@@ -18,11 +18,10 @@ import { useMemo } from 'react';
  *
  */
 export const useMenuLinks = () => {
-  const hasAnalyticsPrivileges =
-    authenticationSession.getUserHasAnalyticsPrivileges();
+  const hasAnalyticsAccess = useHasAnalyticsAccess();
 
-  const menuLinks: MenuLink[] = useMemo(
-    () => [
+  const menuLinks: MenuLink[] = useMemo(() => {
+    const links: MenuLink[] = [
       {
         to: '/',
         label: t('Overview'),
@@ -48,7 +47,7 @@ export const useMenuLinks = () => {
         label: t('Tables'),
         icon: TableProperties,
       },
-      ...(hasAnalyticsPrivileges
+      ...(hasAnalyticsAccess
         ? [
             {
               to: '/analytics',
@@ -57,9 +56,10 @@ export const useMenuLinks = () => {
             },
           ]
         : []),
-    ],
-    [hasAnalyticsPrivileges],
-  );
+    ];
+
+    return links;
+  }, [hasAnalyticsAccess]);
 
   return menuLinks;
 };

packages/react-ui/src/app/router.tsx

@@ -17,6 +17,7 @@ import { FlowsPage } from '../app/routes/flows';
 import { PageHeader } from '@openops/components/ui';
 import { t } from 'i18next';
 
+import { useHasAnalyticsAccess } from '@/app/common/hooks/analytics-hooks';
 import { flagsHooks } from '@/app/common/hooks/flags-hooks';
 import { FlowsPageHeader } from '@/app/features/flows/components/flows-page-header';
 import { HomeHelpDropdown } from '@/app/features/home/components/home-help-dropdown';
@@ -31,7 +32,6 @@ import { ConnectionsHeader } from './features/connections/components/connection-
 import { ConnectionsProvider } from './features/connections/components/connections-context';
 import { GlobalLayout } from './features/navigation/layout/global-layout';
 import { RouteWrapper } from './features/navigation/layout/route-wrapper';
-import { authenticationSession } from './lib/authentication-session';
 import NotFoundPage from './routes/404-page';
 import { ChangePasswordPage } from './routes/change-password';
 import AppConnectionsPage from './routes/connections';
@@ -57,22 +57,19 @@ const SettingsRerouter = () => {
   );
 };
 
-const createRoutes = () => {
-  const { data: isCloudConnectionPageEnabled } = flagsHooks.useFlag<any>(
-    FlagId.CLOUD_CONNECTION_PAGE_ENABLED,
-  );
-
-  const { data: isDemoHomePage } = flagsHooks.useFlag<any>(
-    FlagId.SHOW_DEMO_HOME_PAGE,
-  );
-
-  const { data: isFederatedLogin } = flagsHooks.useFlag<boolean | undefined>(
-    FlagId.FEDERATED_LOGIN_ENABLED,
-  );
-
-  const hasAnalyticsPrivileges =
-    authenticationSession.getUserHasAnalyticsPrivileges();
+interface CreateRoutesParams {
+  isCloudConnectionPageEnabled: any;
+  isDemoHomePage: any;
+  isFederatedLogin: boolean | null | undefined;
+  hasAnalyticsAccess: boolean;
+}
 
+const createRoutes = ({
+  isCloudConnectionPageEnabled,
+  isDemoHomePage,
+  isFederatedLogin,
+  hasAnalyticsAccess,
+}: CreateRoutesParams) => {
   const routes = [
     {
       path: 'flows',
@@ -207,7 +204,7 @@ const createRoutes = () => {
       ),
       errorElement: <RouteErrorBoundary />,
     },
-    ...(hasAnalyticsPrivileges
+    ...(hasAnalyticsAccess
       ? [
           {
             path: 'analytics',
@@ -411,11 +408,30 @@ const createRoutes = () => {
 };
 
 const ApplicationRouter = () => {
+  const { data: isCloudConnectionPageEnabled } = flagsHooks.useFlag<any>(
+    FlagId.CLOUD_CONNECTION_PAGE_ENABLED,
+  );
+
+  const { data: isDemoHomePage } = flagsHooks.useFlag<any>(
+    FlagId.SHOW_DEMO_HOME_PAGE,
+  );
+
+  const { data: isFederatedLogin } = flagsHooks.useFlag<boolean | undefined>(
+    FlagId.FEDERATED_LOGIN_ENABLED,
+  );
+
+  const hasAnalyticsAccess = useHasAnalyticsAccess();
+
   const router = createBrowserRouter([
     {
       path: '/',
       element: <GlobalLayout />,
-      children: createRoutes(),
+      children: createRoutes({
+        isCloudConnectionPageEnabled,
+        isDemoHomePage,
+        isFederatedLogin,
+        hasAnalyticsAccess,
+      }),
     },
   ]);
   return <RouterProvider router={router}></RouterProvider>;

packages/server/api/.env.tests

@@ -25,3 +25,4 @@ OPS_ENGINE_URL=http://localhost:3005/execute
 OPS_OPENOPS_ADMIN_EMAIL=local-admin@openops.com
 OPS_OPENOPS_ADMIN_PASSWORD=12345678
 OPS_OPENOPS_TABLES_PUBLIC_URL=http://localhost:3001
+OPS_ANALYTICS_ENABLED=true

packages/server/api/src/app/ai/mcp/superset-tools.ts

@@ -5,6 +5,13 @@ import path from 'path';
 import { MCPTool } from './types';
 
 export async function getSupersetTools(): Promise<MCPTool> {
+  if (!system.isAnalyticsEnabled()) {
+    return {
+      client: undefined,
+      toolSet: {},
+    };
+  }
+
   const basePath = system.get<string>(AppSystemProp.SUPERSET_MCP_SERVER_PATH);
 
   if (!basePath) {

packages/server/api/src/app/ai/mcp/tools-initializer.ts

@@ -43,13 +43,14 @@ export const startMCPTools = async (
   const loadExperimentalTools = system.getBoolean(
     AppSystemProp.LOAD_EXPERIMENTAL_MCP_TOOLS,
   );
+  const analyticsEnabled = system.isAnalyticsEnabled();
 
   let supersetTools: Partial<MCPTool> = {
     client: undefined,
     toolSet: {},
   };
 
-  if (loadExperimentalTools) {
+  if (loadExperimentalTools && analyticsEnabled) {
     supersetTools = await safeGetTools('superset', getSupersetTools);
   }
 

packages/server/api/src/app/authentication/authentication.controller.ts

@@ -44,6 +44,8 @@ const AnalyticsGuestTokenRequestOptions = {
 export const authenticationController: FastifyPluginAsyncTypebox = async (
   app,
 ) => {
+  const analyticsEnabled = system.isAnalyticsEnabled();
+
   app.post('/sign-up', SignUpRequestOptions, signUpRoute);
   app.post('/sign-in', SignInRequestOptions, signInRoute);
 
@@ -60,37 +62,40 @@ export const authenticationController: FastifyPluginAsyncTypebox = async (
     },
   );
 
-  app.get('/analytics-embed-id', async (request, reply) => {
-    const { access_token } =
-      await analyticsAuthenticationService.authenticateAnalyticsRequest(
-        request.principal.id,
-      );
-
-    const embedId = await analyticsDashboardService.fetchFinopsDashboardEmbedId(
-      access_token,
-    );
-
-    return reply.send(embedId);
-  });
-
-  app.get(
-    '/analytics-guest-token',
-    AnalyticsGuestTokenRequestOptions,
-    async (request, reply) => {
+  if (analyticsEnabled) {
+    app.get('/analytics-embed-id', async (request, reply) => {
       const { access_token } =
         await analyticsAuthenticationService.authenticateAnalyticsRequest(
           request.principal.id,
         );
 
-      const guestToken =
-        await analyticsDashboardService.fetchDashboardGuestToken(
+      const embedId =
+        await analyticsDashboardService.fetchFinopsDashboardEmbedId(
           access_token,
-          request.query.dashboardEmbedUuid,
         );
 
-      return reply.send(guestToken);
-    },
-  );
+      return reply.send(embedId);
+    });
+
+    app.get(
+      '/analytics-guest-token',
+      AnalyticsGuestTokenRequestOptions,
+      async (request, reply) => {
+        const { access_token } =
+          await analyticsAuthenticationService.authenticateAnalyticsRequest(
+            request.principal.id,
+          );
+
+        const guestToken =
+          await analyticsDashboardService.fetchDashboardGuestToken(
+            access_token,
+            request.query.dashboardEmbedUuid,
+          );
+
+        return reply.send(guestToken);
+      },
+    );
+  }
 };
 
 // eslint-disable-next-line @typescript-eslint/no-explicit-any

packages/server/api/src/app/database/seeds/openops-analytics-seed.ts

@@ -23,6 +23,11 @@ const setAnalyticsDataSeededFlag = async (): Promise<void> => {
 };
 
 export const seedAnalytics = async (): Promise<void> => {
+  if (!system.isAnalyticsEnabled()) {
+    logger.info('Skipping analytics seeding, analytics disabled');
+    return;
+  }
+
   if (!system.get(AppSystemProp.ANALYTICS_PRIVATE_URL)) {
     logger.info('Skipping analytics seeding, no configured private URL');
     return;

packages/server/api/src/app/flags/flag.service.ts

@@ -229,7 +229,15 @@ export const flagService = {
       },
       {
         id: FlagId.ANALYTICS_PUBLIC_URL,
-        value: system.get(AppSystemProp.ANALYTICS_PUBLIC_URL),
+        value: system.isAnalyticsEnabled()
+          ? system.get(AppSystemProp.ANALYTICS_PUBLIC_URL)
+          : undefined,
+        created,
+        updated,
+      },
+      {
+        id: FlagId.ANALYTICS_ENABLED,
+        value: system.isAnalyticsEnabled(),
         created,
         updated,
       },

packages/server/api/src/main.ts

@@ -99,7 +99,12 @@ const main = async (): Promise<void> => {
     await seedFocusDataAggregationTemplateTable();
     await seedKnownCostTypesByApplicationTable();
     await seedAutoInstancesShutdownTable();
-    await analytics.seedAnalytics();
+
+    if (system.isAnalyticsEnabled()) {
+      await analytics.seedAnalytics();
+    } else {
+      logger.info('Skipping analytics seed run, analytics disabled');
+    }
   }
 
   const environmentId = await seedEnvironmentId();