EW-1011 Add migration to TspSyncStrategy

apps/server/src/infra/sync/sync.module.ts

@@ -2,9 +2,11 @@ import { Configuration } from '@hpi-schul-cloud/commons/lib';
 import { ConsoleWriterModule } from '@infra/console';
 import { RabbitMQWrapperModule } from '@infra/rabbitmq';
 import { TspClientModule } from '@infra/tsp-client/tsp-client.module';
+import { AccountModule } from '@modules/account';
 import { LegacySchoolModule } from '@modules/legacy-school';
 import { SchoolModule } from '@modules/school';
 import { SystemModule } from '@modules/system';
+import { UserModule } from '@modules/user';
 import { Module } from '@nestjs/common';
 import { LoggerModule } from '@src/core/logger';
 import { ProvisioningModule } from '@src/modules/provisioning';
@@ -20,7 +22,16 @@ import { SyncUc } from './uc/sync.uc';
 		LoggerModule,
 		ConsoleWriterModule,
 		...((Configuration.get('FEATURE_TSP_SYNC_ENABLED') as boolean)
-			? [TspClientModule, SystemModule, SchoolModule, LegacySchoolModule, RabbitMQWrapperModule, ProvisioningModule]
+			? [
+					TspClientModule,
+					SystemModule,
+					SchoolModule,
+					LegacySchoolModule,
+					RabbitMQWrapperModule,
+					ProvisioningModule,
+					UserModule,
+					AccountModule,
+			  ]
 			: []),
 	],
 	providers: [

apps/server/src/infra/sync/tsp/loggable/tsp-students-fetched.loggable.spec.ts

@@ -0,0 +1,26 @@
+import { TspStudentsFetchedLoggable } from './tsp-students-fetched.loggable';
+
+describe(TspStudentsFetchedLoggable.name, () => {
+	let loggable: TspStudentsFetchedLoggable;
+
+	beforeAll(() => {
+		loggable = new TspStudentsFetchedLoggable(10);
+	});
+
+	describe('when loggable is initialized', () => {
+		it('should be defined', () => {
+			expect(loggable).toBeDefined();
+		});
+	});
+
+	describe('getLogMessage', () => {
+		it('should return a log message', () => {
+			expect(loggable.getLogMessage()).toEqual({
+				message: `Fetched 10 students for migration from TSP`,
+				data: {
+					tspStudentCount: 10,
+				},
+			});
+		});
+	});
+});

apps/server/src/infra/sync/tsp/loggable/tsp-students-fetched.loggable.ts

@@ -0,0 +1,16 @@
+import { Loggable, LogMessage } from '@src/core/logger';
+
+export class TspStudentsFetchedLoggable implements Loggable {
+	constructor(private readonly tspStudentCount: number) {}
+
+	getLogMessage(): LogMessage {
+		const message: LogMessage = {
+			message: `Fetched ${this.tspStudentCount} students for migration from TSP`,
+			data: {
+				tspStudentCount: this.tspStudentCount,
+			},
+		};
+
+		return message;
+	}
+}

apps/server/src/infra/sync/tsp/loggable/tsp-students-migrated.loggable.spec.ts

@@ -0,0 +1,26 @@
+import { TspStudentsMigratedLoggable } from './tsp-students-migrated.loggable';
+
+describe(TspStudentsMigratedLoggable.name, () => {
+	let loggable: TspStudentsMigratedLoggable;
+
+	beforeAll(() => {
+		loggable = new TspStudentsMigratedLoggable(10);
+	});
+
+	describe('when loggable is initialized', () => {
+		it('should be defined', () => {
+			expect(loggable).toBeDefined();
+		});
+	});
+
+	describe('getLogMessage', () => {
+		it('should return a log message', () => {
+			expect(loggable.getLogMessage()).toEqual({
+				message: `Migrated students: 10 students migrated`,
+				data: {
+					migratedStudents: 10,
+				},
+			});
+		});
+	});
+});

apps/server/src/infra/sync/tsp/loggable/tsp-students-migrated.loggable.ts

@@ -0,0 +1,16 @@
+import { Loggable, LogMessage } from '@src/core/logger';
+
+export class TspStudentsMigratedLoggable implements Loggable {
+	constructor(private readonly migratedStudents: number) {}
+
+	getLogMessage(): LogMessage {
+		const message: LogMessage = {
+			message: `Migrated students: ${this.migratedStudents} students migrated`,
+			data: {
+				migratedStudents: this.migratedStudents,
+			},
+		};
+
+		return message;
+	}
+}

apps/server/src/infra/sync/tsp/loggable/tsp-teachers-fetched.loggable.spec.ts

@@ -0,0 +1,26 @@
+import { TspTeachersFetchedLoggable } from './tsp-teachers-fetched.loggable';
+
+describe(TspTeachersFetchedLoggable.name, () => {
+	let loggable: TspTeachersFetchedLoggable;
+
+	beforeAll(() => {
+		loggable = new TspTeachersFetchedLoggable(10);
+	});
+
+	describe('when loggable is initialized', () => {
+		it('should be defined', () => {
+			expect(loggable).toBeDefined();
+		});
+	});
+
+	describe('getLogMessage', () => {
+		it('should return a log message', () => {
+			expect(loggable.getLogMessage()).toEqual({
+				message: `Fetched 10 teachers for migration from TSP`,
+				data: {
+					tspTeacherCount: 10,
+				},
+			});
+		});
+	});
+});

apps/server/src/infra/sync/tsp/loggable/tsp-teachers-fetched.loggable.ts

@@ -0,0 +1,16 @@
+import { Loggable, LogMessage } from '@src/core/logger';
+
+export class TspTeachersFetchedLoggable implements Loggable {
+	constructor(private readonly tspTeacherCount: number) {}
+
+	getLogMessage(): LogMessage {
+		const message: LogMessage = {
+			message: `Fetched ${this.tspTeacherCount} teachers for migration from TSP`,
+			data: {
+				tspTeacherCount: this.tspTeacherCount,
+			},
+		};
+
+		return message;
+	}
+}

apps/server/src/infra/sync/tsp/loggable/tsp-teachers-migrated.loggable.spec.ts

@@ -0,0 +1,26 @@
+import { TspTeachersMigratedLoggable } from './tsp-teachers-migrated.loggable';
+
+describe(TspTeachersMigratedLoggable.name, () => {
+	let loggable: TspTeachersMigratedLoggable;
+
+	beforeAll(() => {
+		loggable = new TspTeachersMigratedLoggable(10);
+	});
+
+	describe('when loggable is initialized', () => {
+		it('should be defined', () => {
+			expect(loggable).toBeDefined();
+		});
+	});
+
+	describe('getLogMessage', () => {
+		it('should return a log message', () => {
+			expect(loggable.getLogMessage()).toEqual({
+				message: `Migrated teachers: 10 teachers migrated`,
+				data: {
+					migratedTeachers: 10,
+				},
+			});
+		});
+	});
+});

apps/server/src/infra/sync/tsp/loggable/tsp-teachers-migrated.loggable.ts

@@ -0,0 +1,16 @@
+import { Loggable, LogMessage } from '@src/core/logger';
+
+export class TspTeachersMigratedLoggable implements Loggable {
+	constructor(private readonly migratedTeachers: number) {}
+
+	getLogMessage(): LogMessage {
+		const message: LogMessage = {
+			message: `Migrated teachers: ${this.migratedTeachers} teachers migrated`,
+			data: {
+				migratedTeachers: this.migratedTeachers,
+			},
+		};
+
+		return message;
+	}
+}

apps/server/src/infra/sync/tsp/loggable/tsp-users-migrated.loggable.spec.ts

@@ -0,0 +1,26 @@
+import { TspUsersMigratedLoggable } from './tsp-users-migrated.loggable';
+
+describe(TspUsersMigratedLoggable.name, () => {
+	let loggable: TspUsersMigratedLoggable;
+
+	beforeAll(() => {
+		loggable = new TspUsersMigratedLoggable(10);
+	});
+
+	describe('when loggable is initialized', () => {
+		it('should be defined', () => {
+			expect(loggable).toBeDefined();
+		});
+	});
+
+	describe('getLogMessage', () => {
+		it('should return a log message', () => {
+			expect(loggable.getLogMessage()).toEqual({
+				message: `Migrated users: 10 users migrated`,
+				data: {
+					migratedUsers: 10,
+				},
+			});
+		});
+	});
+});

apps/server/src/infra/sync/tsp/loggable/tsp-users-migrated.loggable.ts

@@ -0,0 +1,16 @@
+import { Loggable, LogMessage } from '@src/core/logger';
+
+export class TspUsersMigratedLoggable implements Loggable {
+	constructor(private readonly migratedUsers: number) {}
+
+	getLogMessage(): LogMessage {
+		const message: LogMessage = {
+			message: `Migrated users: ${this.migratedUsers} users migrated`,
+			data: {
+				migratedUsers: this.migratedUsers,
+			},
+		};
+
+		return message;
+	}
+}

apps/server/src/infra/sync/tsp/tsp-sync.config.ts

@@ -3,4 +3,6 @@ export interface TspSyncConfig {
 	TSP_SYNC_SCHOOL_DAYS_TO_FETCH: number;
 	TSP_SYNC_DATA_LIMIT: number;
 	TSP_SYNC_DATA_DAYS_TO_FETCH: number;
+	TSP_SYNC_MIGRATION_LIMIT: number;
+	FEATURE_TSP_MIGRATION_ENABLED: boolean;
 }