N21-1324-migration-page-buttons-fix

apps/server/src/modules/oauth/controller/api-test/oauth-sso.api.spec.ts

@@ -242,8 +242,100 @@ describe('OAuth SSO Controller (API)', () => {
 			});
 		});
 
+		describe('when school is in migration during the login process', () => {
+			const setupMigration = async () => {
+				const externalUserId = 'externalUserId';
+				const system: SystemEntity = systemFactory
+					.withOauthConfig()
+					.buildWithId({ provisioningStrategy: SystemProvisioningStrategy.SANIS });
+				const userLoginMigration: UserLoginMigrationEntity = userLoginMigrationFactory.buildWithId({
+					sourceSystem: system,
+					targetSystem: system,
+					startedAt: new Date('2022-12-17T03:24:00'),
+				});
+				const school: SchoolEntity = schoolFactory.buildWithId({
+					systems: [system],
+					userLoginMigration,
+					officialSchoolNumber: 'officialSchoolNumber',
+				});
+				const user: User = userFactory.buildWithId({ school });
+				const account: Account = accountFactory.buildWithId({ systemId: system.id, userId: user.id });
+				await em.persistAndFlush([system, user, school, account, userLoginMigration]);
+				em.clear();
+
+				const query: AuthorizationParams = new AuthorizationParams();
+				query.code = 'code';
+				query.state = 'state';
+
+				return {
+					system,
+					user,
+					externalUserId,
+					school,
+					query,
+					userLoginMigration,
+				};
+			};
+			it('should redirect to login page with migration error', async () => {
+				const { system, externalUserId, query } = await setupMigration();
+				const { state, cookies } = await setupSessionState(system.id, false);
+				const baseUrl: string = Configuration.get('HOST') as string;
+				query.code = 'code';
+				query.state = state;
+
+				const idToken: string = JwtTestFactory.createJwt({
+					sub: 'testUser',
+					iss: system.oauthConfig?.issuer,
+					aud: system.oauthConfig?.clientId,
+					// For OIDC provisioning strategy
+					external_sub: externalUserId,
+				});
+
+				axiosMock
+					.onPost(system.oauthConfig?.tokenEndpoint)
+					.reply<OauthTokenResponse>(200, {
+						id_token: idToken,
+						refresh_token: 'refreshToken',
+						access_token: 'accessToken',
+					})
+					.onGet(system.provisioningUrl)
+					.replyOnce<SanisResponse>(200, {
+						pid: externalUserId,
+						person: {
+							name: {
+								familienname: 'familienName',
+								vorname: 'vorname',
+							},
+							geschlecht: 'weiblich',
+							lokalisierung: 'not necessary',
+							vertrauensstufe: 'not necessary',
+						},
+						personenkontexte: [
+							{
+								id: new UUID('aef1f4fd-c323-466e-962b-a84354c0e713').toString(),
+								rolle: SanisRole.LEHR,
+								organisation: {
+									id: new UUID('aef1f4fd-c323-466e-962b-a84354c0e713').toString(),
+									kennung: 'officialSchoolNumber',
+									name: 'schulName',
+									typ: 'not necessary',
+								},
+								personenstatus: 'not necessary',
+							},
+						],
+					});
+
+				await request(app.getHttpServer())
+					.get(`/sso/oauth`)
+					.set('Cookie', cookies)
+					.query(query)
+					.expect(302)
+					.expect('Location', `${baseUrl}/login?error=SCHOOL_IN_MIGRATION&provider=mock_type`);
+			});
+		});
+
 		describe('when a faulty query is passed', () => {
-			it('should redirect to the login page with an error', async () => {
+			it('should redirect to the login page with an sso error', async () => {
 				const { system, query } = await setup();
 				const { state, cookies } = await setupSessionState(system.id, false);
 				const clientUrl: string = Configuration.get('HOST') as string;

apps/server/src/modules/oauth/controller/oauth-sso.controller.ts

@@ -30,6 +30,7 @@ import { OauthUc } from '../uc';
 import { OauthLoginStateDto } from '../uc/dto/oauth-login-state.dto';
 import { AuthorizationParams, SSOLoginQuery, SystemIdParams } from './dto';
 import { StatelessAuthorizationParams } from './dto/stateless-authorization.params';
+import { SchoolInMigrationError } from '../../authentication/errors/school-in-migration.error';
 
 @ApiTags('SSO')
 @Controller('sso')
@@ -47,7 +48,16 @@ export class OauthSSOController {
 
 	private errorHandler(error: unknown, session: ISession, res: Response, provider?: string) {
 		this.logger.error(error);
-		const ssoError: OAuthSSOError = error instanceof OAuthSSOError ? error : new OAuthSSOError();
+
+		let ssoError: OAuthSSOError;
+
+		if (error instanceof SchoolInMigrationError) {
+			ssoError = new OAuthSSOError(error.message, error.type);
+		} else if (error instanceof OAuthSSOError) {
+			ssoError = error;
+		} else {
+			ssoError = new OAuthSSOError();
+		}
 
 		session.destroy((err) => {
 			this.logger.log(err);

apps/server/src/modules/user-login-migration/service/migration-check.service.spec.ts

@@ -6,6 +6,7 @@ import { legacySchoolDoFactory, userDoFactory } from '@shared/testing';
 import { LegacySchoolService } from '@src/modules/legacy-school';
 import { UserService } from '@src/modules/user';
 import { MigrationCheckService } from './migration-check.service';
+import { SchoolInMigrationError } from '../../authentication/errors/school-in-migration.error';
 
 describe('MigrationCheckService', () => {
 	let module: TestingModule;
@@ -95,9 +96,9 @@ describe('MigrationCheckService', () => {
 			it('should return true', async () => {
 				setup();
 
-				const result: boolean = await service.shouldUserMigrate('externalId', 'systemId', 'officialSchoolNumber');
-
-				expect(result).toEqual(true);
+				await expect(service.shouldUserMigrate('externalId', 'systemId', 'officialSchoolNumber')).rejects.toThrowError(
+					new SchoolInMigrationError()
+				);
 			});
 		});
 

apps/server/src/modules/user-login-migration/service/migration-check.service.ts

@@ -3,6 +3,7 @@ import { EntityId, LegacySchoolDo, UserDO, UserLoginMigrationDO } from '@shared/
 import { UserLoginMigrationRepo } from '@shared/repo';
 import { LegacySchoolService } from '@src/modules/legacy-school';
 import { UserService } from '@src/modules/user';
+import { SchoolInMigrationError } from '../../authentication/errors/school-in-migration.error';
 
 @Injectable()
 export class MigrationCheckService {
@@ -22,11 +23,14 @@ export class MigrationCheckService {
 
 			const user: UserDO | null = await this.userService.findByExternalId(externalUserId, systemId);
 
-			if (user?.lastLoginSystemChange && userLoginMigration && !userLoginMigration.closedAt) {
+			if (!user) {
+				throw new SchoolInMigrationError();
+			} else if (user && user.lastLoginSystemChange && userLoginMigration && !userLoginMigration.closedAt) {
 				const hasMigrated: boolean = user.lastLoginSystemChange > userLoginMigration.startedAt;
 				return !hasMigrated;
+			} else {
+				return !!userLoginMigration && !userLoginMigration.closedAt;
 			}
-			return !!userLoginMigration && !userLoginMigration.closedAt;
 		}
 		return false;
 	}

backup/setup/user_login_migrations.json

@@ -0,0 +1 @@
+[]