chore(generative-ai): move ai sign in modal to gen ai package from atlas-service COMPASS-8459 (#6448)

Author: Anemy

package-lock.json

@@ -88,7 +88,6 @@
     "hadron-ipc": "^3.2.25",
     "lodash": "^4.17.21",
     "react": "^17.0.2",
-    "react-redux": "^8.1.3",
     "redux": "^4.2.1",
     "redux-thunk": "^2.4.2"
   }

packages/atlas-service/package.json

@@ -4,7 +4,7 @@ import type { AtlasUserInfo } from './util';
 export type ArgsWithSignal<T = Record<string, unknown>> = T & {
   signal?: AbortSignal;
 };
-export type SignInPrompt = 'none' | 'ai-promo-modal';
+export type SignInPrompt = 'none';
 
 type AtlasAuthServiceEvents = {
   'signed-in': [];

packages/atlas-service/src/atlas-auth-service.ts

@@ -1,9 +1,6 @@
 import { ipcRenderer } from 'hadron-ipc';
 import type { CompassAuthService as AtlasServiceMain } from './main';
-import {
-  signInWithModalPrompt,
-  signInWithoutPrompt,
-} from './store/atlas-signin-reducer';
+import { signInWithoutPrompt } from './store/atlas-signin-reducer';
 import { getStore } from './store/atlas-signin-store';
 import { AtlasAuthService } from './atlas-auth-service';
 import type { ArgsWithSignal, SignInPrompt } from './atlas-auth-service';
@@ -46,8 +43,6 @@ export class CompassAtlasAuthService extends AtlasAuthService {
     switch (promptType) {
       case 'none':
         return getStore().dispatch(signInWithoutPrompt({ signal }));
-      case 'ai-promo-modal':
-        return getStore().dispatch(signInWithModalPrompt({ signal }));
       default:
         return this.ipc.signIn({ signal });
     }

packages/atlas-service/src/compass-atlas-auth-service.ts

@@ -1,12 +1,11 @@
 import { registerHadronPlugin } from 'hadron-app-registry';
 import { activatePlugin } from './store/atlas-signin-store';
 import { atlasAuthServiceLocator } from './provider';
-import { AtlasSignIn } from './components';
 
 export const AtlasAuthPlugin = registerHadronPlugin(
   {
     name: 'AtlasAuth',
-    component: AtlasSignIn,
+    component: () => null,
     activate: activatePlugin,
   },
   {

packages/atlas-service/src/renderer.ts

@@ -5,8 +5,6 @@ import {
   cancelSignIn,
   attemptId,
   AttemptStateMap,
-  signInWithModalPrompt,
-  closeSignInModal,
   signInWithoutPrompt,
 } from './atlas-signin-reducer';
 import { expect } from 'chai';
@@ -176,7 +174,7 @@ describe('atlasSignInReducer', function () {
         atlasAuthService: mockAtlasService as any,
       });
 
-      void store.dispatch(signInWithModalPrompt()).catch(() => {});
+      void store.dispatch(signInWithoutPrompt()).catch(() => {});
 
       await Promise.all([
         store.dispatch(signIn()),
@@ -186,101 +184,6 @@ describe('atlasSignInReducer', function () {
     });
   });
 
-  describe('signInWithModalPrompt', function () {
-    it('should resolve when user finishes sign in with prompt flow', async function () {
-      const mockAtlasService = {
-        isAuthenticated: sandbox.stub().resolves(false),
-        signIn: sandbox.stub().resolves({ sub: '1234' }),
-        getUserInfo: sandbox.stub().resolves({ sub: '1234' }),
-        emit: sandbox.stub(),
-      };
-      const store = configureStore({
-        atlasAuthService: mockAtlasService as any,
-      });
-
-      const signInPromise = store.dispatch(signInWithModalPrompt());
-      await store.dispatch(signIn());
-      await signInPromise;
-
-      expect(store.getState()).to.have.property('state', 'success');
-    });
-
-    it('should reject if sign in flow fails', async function () {
-      const mockAtlasService = {
-        isAuthenticated: sandbox.stub().resolves(false),
-        signIn: sandbox.stub().rejects(new Error('Whoops!')),
-        getUserInfo: sandbox.stub().resolves({ sub: '1234' }),
-        emit: sandbox.stub(),
-      };
-      const store = configureStore({
-        atlasAuthService: mockAtlasService as any,
-      });
-
-      const signInPromise = store.dispatch(signInWithModalPrompt());
-      await store.dispatch(signIn());
-
-      try {
-        await signInPromise;
-        throw new Error('Expected signInPromise to throw');
-      } catch (err) {
-        expect(err).to.have.property('message', 'Whoops!');
-      }
-
-      expect(store.getState()).to.have.property('state', 'error');
-    });
-
-    it('should reject if user dismissed the modal', async function () {
-      const mockAtlasService = {
-        isAuthenticated: sandbox.stub().resolves(false),
-        signIn: sandbox.stub().resolves({ sub: '1234' }),
-        getUserInfo: sandbox.stub().resolves({ sub: '1234' }),
-        emit: sandbox.stub(),
-      };
-      const store = configureStore({
-        atlasAuthService: mockAtlasService as any,
-      });
-
-      const signInPromise = store.dispatch(signInWithModalPrompt());
-      store.dispatch(closeSignInModal());
-
-      try {
-        await signInPromise;
-        throw new Error('Expected signInPromise to throw');
-      } catch (err) {
-        expect(err).to.have.property('message', 'This operation was aborted');
-      }
-
-      expect(store.getState()).to.have.property('state', 'canceled');
-    });
-
-    it('should reject if provided signal was aborted', async function () {
-      const mockAtlasService = {
-        isAuthenticated: sandbox.stub().resolves(false),
-        signIn: sandbox.stub().resolves({ sub: '1234' }),
-        getUserInfo: sandbox.stub().resolves({ sub: '1234' }),
-        emit: sandbox.stub(),
-      };
-      const store = configureStore({
-        atlasAuthService: mockAtlasService as any,
-      });
-
-      const c = new AbortController();
-      const signInPromise = store.dispatch(
-        signInWithModalPrompt({ signal: c.signal })
-      );
-      c.abort(new Error('Aborted from outside'));
-
-      try {
-        await signInPromise;
-        throw new Error('Expected signInPromise to throw');
-      } catch (err) {
-        expect(err).to.have.property('message', 'Aborted from outside');
-      }
-
-      expect(store.getState()).to.have.property('state', 'canceled');
-    });
-  });
-
   describe('signInWithoutPrompt', function () {
     it('should resolve when sign in flow finishes', async function () {
       const mockAtlasService = {

packages/atlas-service/src/store/atlas-signin-reducer.spec.ts

@@ -14,7 +14,6 @@ export function isAction<A extends AnyAction>(
 
 export type AtlasSignInState = {
   error: string | null;
-  isModalOpen: boolean;
   // For managing attempt state that doesn't belong in the store
   currentAttemptId: number | null;
 } & (
@@ -37,8 +36,6 @@ export type AtlasSignInThunkAction<
 > = ThunkAction<R, AtlasSignInState, { atlasAuthService: AtlasAuthService }, A>;
 
 export const enum AtlasSignInActions {
-  OpenSignInModal = 'atlas-service/atlas-signin/OpenSignInModal',
-  CloseSignInModal = 'atlas-service/atlas-signin/CloseSignInModal',
   RestoringStart = 'atlas-service/atlas-signin/StartRestoring',
   RestoringFailed = 'atlas-service/atlas-signin/RestoringFailed',
   RestoringSuccess = 'atlas-service/atlas-signin/RestoringSuccess',
@@ -52,14 +49,6 @@ export const enum AtlasSignInActions {
   SignedOut = 'atlas-service/atlas-signin/SignedOut',
 }
 
-export type AtlasSignInOpenModalAction = {
-  type: AtlasSignInActions.OpenSignInModal;
-};
-
-export type AtlasSignInCloseModalAction = {
-  type: AtlasSignInActions.CloseSignInModal;
-};
-
 export type AtlasSignInRestoringStartAction = {
   type: AtlasSignInActions.RestoringStart;
 };
@@ -250,24 +239,6 @@ const reducer: Reducer<AtlasSignInState, Action> = (
     return { ...INITIAL_STATE, state: 'canceled' };
   }
 
-  if (
-    isAction<AtlasSignInOpenModalAction>(
-      action,
-      AtlasSignInActions.OpenSignInModal
-    )
-  ) {
-    return { ...state, isModalOpen: true };
-  }
-
-  if (
-    isAction<AtlasSignInCloseModalAction>(
-      action,
-      AtlasSignInActions.CloseSignInModal
-    )
-  ) {
-    return { ...state, isModalOpen: false };
-  }
-
   if (
     isAction<AtlasSignInTokenRefreshFailedAction>(
       action,
@@ -337,29 +308,6 @@ const startAttempt = (fn: () => void): AtlasSignInThunkAction<AttemptState> => {
   };
 };
 
-export const signInWithModalPrompt = ({
-  signal,
-}: { signal?: AbortSignal } = {}): AtlasSignInThunkAction<
-  Promise<AtlasUserInfo>
-> => {
-  return async (dispatch, getState) => {
-    // Nothing to do if we already signed in
-    const { state, userInfo } = getState();
-    if (state === 'success') {
-      return userInfo;
-    }
-    const attempt = dispatch(
-      startAttempt(() => {
-        dispatch(openSignInModal());
-      })
-    );
-    signal?.addEventListener('abort', () => {
-      dispatch(closeSignInModal(signal.reason));
-    });
-    return attempt.promise;
-  };
-};
-
 export const signInWithoutPrompt = ({
   signal,
 }: { signal?: AbortSignal } = {}): AtlasSignInThunkAction<
@@ -383,12 +331,8 @@ export const signInWithoutPrompt = ({
   };
 };
 
-export const openSignInModal = () => {
-  return { type: AtlasSignInActions.OpenSignInModal };
-};
-
 /**
- * Sign in from the opt in window
+ * Sign into Atlas. To be called when the user isn't signed in yet.
  */
 export const signIn = (): AtlasSignInThunkAction<Promise<void>> => {
   return async (dispatch, getState, { atlasAuthService }) => {
@@ -434,15 +378,6 @@ export const signIn = (): AtlasSignInThunkAction<Promise<void>> => {
   };
 };
 
-export const closeSignInModal = (
-  reason?: any
-): AtlasSignInThunkAction<void> => {
-  return (dispatch) => {
-    dispatch(cancelSignIn(reason));
-    dispatch({ type: AtlasSignInActions.CloseSignInModal });
-  };
-};
-
 export const cancelSignIn = (reason?: any): AtlasSignInThunkAction<void> => {
   return (dispatch, getState) => {
     // Can't cancel sign in after the flow was finished indicated by current

packages/atlas-service/src/store/atlas-signin-reducer.ts

@@ -25,7 +25,6 @@ import {
 } from '@mongodb-js/compass-app-stores/provider';
 import { workspacesServiceLocator } from '@mongodb-js/compass-workspaces/provider';
 import { preferencesLocator } from 'compass-preferences-model/provider';
-import { atlasAuthServiceLocator } from '@mongodb-js/atlas-service/provider';
 import { atlasAiServiceLocator } from '@mongodb-js/compass-generative-ai/provider';
 import { pipelineStorageLocator } from '@mongodb-js/my-queries-storage/provider';
 import { connectionRepositoryAccessLocator } from '@mongodb-js/compass-connections/provider';
@@ -49,7 +48,6 @@ const CompassAggregationsHadronPlugin = registerHadronPlugin(
     preferences: preferencesLocator,
     logger: createLoggerLocator('COMPASS-AGGREGATIONS-UI'),
     track: telemetryLocator,
-    atlasAuthService: atlasAuthServiceLocator,
     atlasAiService: atlasAiServiceLocator,
     pipelineStorage: pipelineStorageLocator,
     connectionInfoRef: connectionInfoRefLocator,

packages/compass-aggregations/src/index.ts

@@ -42,7 +42,6 @@ import type { PreferencesAccess } from 'compass-preferences-model';
 import type { Logger } from '@mongodb-js/compass-logging/provider';
 import type AppRegistry from 'hadron-app-registry';
 import type { AtlasAiService } from '@mongodb-js/compass-generative-ai/provider';
-import type { AtlasAuthService } from '@mongodb-js/atlas-service/provider';
 import type { MongoDBInstance } from 'mongodb-instance-model';
 import type { DataService } from '../modules/data-service';
 import type {
@@ -100,7 +99,6 @@ export type PipelineBuilderExtraArgs = {
   localAppRegistry: AppRegistry;
   pipelineBuilder: PipelineBuilder;
   pipelineStorage: PipelineStorage;
-  atlasAuthService: AtlasAuthService;
   workspaces: WorkspacesService;
   preferences: PreferencesAccess;
   logger: Logger;

packages/compass-aggregations/src/modules/index.ts

@@ -447,10 +447,10 @@ export const resetIsAggregationGeneratedFromQuery =
   };
 
 export const showInput = (): PipelineBuilderThunkAction<Promise<void>> => {
-  return async (dispatch, _getState, { atlasAuthService }) => {
+  return async (dispatch, _getState, { atlasAiService }) => {
     try {
       if (process.env.COMPASS_E2E_SKIP_ATLAS_SIGNIN !== 'true') {
-        await atlasAuthService.signIn({ promptType: 'ai-promo-modal' });
+        await atlasAiService.ensureAiFeatureAccess();
       }
       dispatch({
         type: AIPipelineActionTypes.ShowInput,