chore(deps): complete TypeORM 0.3 -> 1.0 migration

Builds all ~60 libs green locally. Changes:
- Migration files: cast switch discriminants to DatabaseTypeEnum (TypeORM 1.0 dropped 'sqlite' from the driver-type union; type-only, no runtime change).
- relations/select array->object via the official @typeorm/codemod (127 files in core).
- patches/typeorm+1.0.0.patch (patch-package): restore string[] relations/select + the join option in the TYPES — TypeORM 1.0 removed them from types but still honors them at runtime (FindOptionsUtils still does Array.isArray(relations) / options.join). Avoids rewriting 100+ dynamic-relations call sites. Wired into postinstall.manual.
- packages/config: switch driver configs to the public DataSourceOptions union, drop removed connectorPackage, pin better-sqlite type, add invalidWhereValuesBehavior:{null:ignore,undefined:ignore} to restore 0.3 null-where behavior.
- .onConflict(...do nothing) -> .orIgnore() (wakatime); drop deprecated .join spread in crud.service; revert codemod-mangled broadcast findOneById call.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: evereq

package.json

@@ -113,7 +113,7 @@
 		"doc:build": "compodoc -p tsconfig.json -d dist/docs",
 		"doc:serve": "compodoc -s -d dist/docs",
 		"doc:build-serve": "compodoc -p tsconfig.json -d docs -s",
-		"postinstall.manual": "yarn node ./.scripts/postinstall.js",
+		"postinstall.manual": "patch-package && yarn node ./.scripts/postinstall.js",
 		"postinstall.electron": "yarn electron-builder install-app-deps && yarn node tools/electron/postinstall",
 		"postinstall.web": "yarn node ./decorate-angular-cli.js && yarn node tools/web/postinstall",
 		"build:desktop": "cross-env NODE_ENV=production yarn run copy-files-i18n-desktop && yarn run postinstall.electron && yarn run config:prod && yarn run config:desktop:prod && yarn run pack:desktop && yarn run generate:icons:desktop --environment=prod && yarn run build:package:all:prod && yarn ng:prod run gauzy:desktop-ui --base-href ./ && yarn ng:prod run api:desktop-api && yarn ng:prod build desktop-api --configuration=production --output-path=dist/apps/desktop/desktop-api && yarn ng:prod build desktop --configuration=production --base-href ./ && yarn run prepare:desktop && yarn run copy-files-desktop && yarn run copy-assets-gauzy",
@@ -757,6 +757,7 @@
 		"ng-packagr": "^21.0.0",
 		"node-gyp": "^10.2.0",
 		"npm-run-all": "^4.1.5",
+		"patch-package": "^8.0.1",
 		"nx": "^22.5.2",
 		"pkg": "^5.3.0",
 		"png-to-ico": "^2.1.8",

packages/config/src/lib/database.ts

@@ -6,8 +6,6 @@ import { BetterSqliteDriver, Options as MikroOrmBetterSqliteOptions } from '@mik
 import { PostgreSqlDriver, Options as MikroOrmPostgreSqlOptions } from '@mikro-orm/postgresql';
 import { Options as MikroOrmMySqlOptions, MySqlDriver } from '@mikro-orm/mysql';
 import { DataSourceOptions } from 'typeorm';
-import { PostgresConnectionOptions } from 'typeorm/driver/postgres/PostgresConnectionOptions';
-import { MysqlConnectionOptions } from 'typeorm/driver/mysql/MysqlConnectionOptions';
 import { KnexModuleOptions } from 'nest-knexjs';
 import * as path from 'path';
 import * as chalk from 'chalk';
@@ -116,16 +114,17 @@ switch (dbType) {
 		mikroOrmConnectionConfig = mikroOrmMySqlOptions;
 
 		// TypeORM DB Config (MySQL)
-		const typeOrmMySqlOptions: MysqlConnectionOptions = {
+		const typeOrmMySqlOptions: DataSourceOptions = {
 			type: dbType,
+			// TypeORM 1.0 throws on null/undefined in where by default; restore 0.3 'ignore' behavior.
+			invalidWhereValuesBehavior: { null: 'ignore', undefined: 'ignore' },
 			ssl: getTlsOptions(dbSslMode),
 			host: process.env.DB_HOST || 'localhost',
 			port: process.env.DB_PORT ? Number.parseInt(process.env.DB_PORT, 10) : 3306,
 			database: process.env.DB_NAME || 'mysql',
 			username: process.env.DB_USER || 'root',
 			password: process.env.DB_PASS || 'root',
 			// forcing typeorm to use (mysql2) if both (mysql/mysql2) packages found, it prioritize to load (mysql)
-			connectorPackage: 'mysql2',
 			logging: getLoggingOptions(process.env.DB_LOGGING), // by default set to error only
 			logger: 'advanced-console',
 			// log queries that take more than 10 sec as warnings
@@ -212,8 +211,10 @@ switch (dbType) {
 		mikroOrmConnectionConfig = mikroOrmPostgresOptions;
 
 		// TypeORM DB Config (PostgreSQL)
-		const typeOrmPostgresOptions: PostgresConnectionOptions = {
+		const typeOrmPostgresOptions: DataSourceOptions = {
 			type: dbType,
+			// TypeORM 1.0 throws on null/undefined in where by default; restore 0.3 'ignore' behavior.
+			invalidWhereValuesBehavior: { null: 'ignore', undefined: 'ignore' },
 			ssl: getTlsOptions(dbSslMode),
 			host: process.env.DB_HOST || 'localhost',
 			port: process.env.DB_PORT ? Number.parseInt(process.env.DB_PORT, 10) : 5432,
@@ -310,7 +311,9 @@ switch (dbType) {
 
 		// TypeORM DB Config (Better-SQLite3)
 		const typeOrmBetterSqliteConfig: DataSourceOptions = {
-			type: dbType,
+			type: DatabaseTypeEnum.betterSqlite3,
+			// TypeORM 1.0 throws on null/undefined in where by default; restore 0.3 'ignore' behavior.
+			invalidWhereValuesBehavior: { null: 'ignore', undefined: 'ignore' },
 			database: sqlitePath,
 			logging: 'all',
 			logger: 'file', // Removes console logging, instead logs all queries in a file ormlogs.log

packages/core/src/lib/auth/auth.service.ts

@@ -1691,7 +1691,9 @@ export class AuthService extends SocialAuthService {
 				case MultiORMEnum.TypeORM: {
 					const users = await this.typeOrmUserRepository.find({
 						where: { email },
-						select: ['id']
+						select: {
+                            id: true
+                        }
 					});
 					for (const user of users) {
 						await this.typeOrmUserRepository.update(user.id, { code: magicCode, codeExpireAt });
@@ -2248,7 +2250,8 @@ export class AuthService extends SocialAuthService {
 					break;
 				}
 				case MultiORMEnum.TypeORM: {
-					user = await this.typeOrmUserRepository.findOne({ where, relations });
+					// TODO(typeorm-v1): `relations` no longer accepts a string array. This value references a variable whose shape can't be determined statically — if it holds `string[]`, wrap it: `Object.fromEntries(<expr>?.map(r => [r, true]) ?? [])` (dot-paths need extra nesting handling). If it already holds the v1 object shape, no change needed.
+                    user = await this.typeOrmUserRepository.findOne({ where, relations });
 					break;
 				}
 				default:
@@ -2274,7 +2277,8 @@ export class AuthService extends SocialAuthService {
 					break;
 				}
 				case MultiORMEnum.TypeORM: {
-					employee = await this.typeOrmEmployeeRepository.findOne({ where: employeeWhere, relations: employeeRelations });
+					// TODO(typeorm-v1): `relations` no longer accepts a string array. This value references a variable whose shape can't be determined statically — if it holds `string[]`, wrap it: `Object.fromEntries(<expr>?.map(r => [r, true]) ?? [])` (dot-paths need extra nesting handling). If it already holds the v1 object shape, no change needed.
+                    employee = await this.typeOrmEmployeeRepository.findOne({ where: employeeWhere, relations: employeeRelations });
 					break;
 				}
 				default:
@@ -2385,7 +2389,8 @@ export class AuthService extends SocialAuthService {
 					break;
 				}
 				case MultiORMEnum.TypeORM: {
-					user = await this.typeOrmUserRepository.findOne({ where, relations });
+					// TODO(typeorm-v1): `relations` no longer accepts a string array. This value references a variable whose shape can't be determined statically — if it holds `string[]`, wrap it: `Object.fromEntries(<expr>?.map(r => [r, true]) ?? [])` (dot-paths need extra nesting handling). If it already holds the v1 object shape, no change needed.
+                    user = await this.typeOrmUserRepository.findOne({ where, relations });
 					break;
 				}
 				default:

packages/core/src/lib/availability-slots/commands/handlers/get-conflict-availability-slots.handler.ts

@@ -33,7 +33,7 @@ export class GetConflictAvailabilitySlotsHandler implements ICommandHandler<GetC
 			employeeId
 		});
 
-		switch (this.configService.dbConnectionOptions.type) {
+		switch (this.configService.dbConnectionOptions.type as DatabaseTypeEnum) {
 			case DatabaseTypeEnum.sqlite:
 			case DatabaseTypeEnum.betterSqlite3:
 				query.andWhere(

packages/core/src/lib/core/crud/crud.service.ts

@@ -199,7 +199,6 @@ export abstract class CrudService<T extends BaseEntity> implements ICrudService<
 						 *
 						 * @deprecated
 						 */
-						...(options && options.join ? { join: options.join } : {}),
 						...(options && options.select ? { select: options.select } : {}),
 						...(options && options.relations ? { relations: options.relations } : {}),
 						...(options && options.where ? { where: options.where } : {}),

packages/core/src/lib/core/utils.ts

@@ -68,7 +68,7 @@ export function unixTimestampToDate(timestamps, format = 'YYYY-MM-DD HH:mm:ss')
  */
 export function convertToDatetime(datetime): Date | string | null {
 	if (moment(new Date(datetime)).isValid()) {
-		switch (getConfig().dbConnectionOptions.type) {
+		switch (getConfig().dbConnectionOptions.type as DatabaseTypeEnum) {
 			case DatabaseTypeEnum.sqlite:
 			case DatabaseTypeEnum.betterSqlite3:
 				return moment(new Date(datetime)).format('YYYY-MM-DD HH:mm:ss');
@@ -122,7 +122,7 @@ export function getDateRange(
 		throw 'End date must be greater than start date.';
 	}
 
-	switch (getConfig().dbConnectionOptions.type) {
+	switch (getConfig().dbConnectionOptions.type as DatabaseTypeEnum) {
 		case DatabaseTypeEnum.sqlite:
 		case DatabaseTypeEnum.betterSqlite3:
 			start = start.format('YYYY-MM-DD HH:mm:ss');
@@ -216,7 +216,7 @@ export function getDateRangeFormat(startDate: moment.Moment, endDate: moment.Mom
 		throw 'End date must be greater than start date.';
 	}
 
-	switch (getConfig().dbConnectionOptions.type) {
+	switch (getConfig().dbConnectionOptions.type as DatabaseTypeEnum) {
 		case DatabaseTypeEnum.sqlite:
 		case DatabaseTypeEnum.betterSqlite3:
 			return {

packages/core/src/lib/database/connection-entity-manager.ts

@@ -21,7 +21,7 @@ export class ConnectionEntityManager {
 	 * @returns The raw connection from the EntityManager.
 	 */
 	get rawConnection(): DataSource {
-		return this.entityManager.connection;
+		return this.entityManager.dataSource;
 	}
 
 	/**

packages/core/src/lib/database/migration-executor.ts

@@ -293,7 +293,7 @@ export class ${camelCase(name, true)}${timestamp} implements MigrationInterface
     public async up(queryRunner: QueryRunner): Promise<void> {
         console.log(chalk.yellow(this.name + ' start running!'));
 
-        switch (queryRunner.connection.options.type) {
+        switch (queryRunner.connection.options.type as DatabaseTypeEnum) {
             case DatabaseTypeEnum.sqlite:
             case DatabaseTypeEnum.betterSqlite3:
                 await this.sqliteUpQueryRunner(queryRunner);
@@ -317,7 +317,7 @@ export class ${camelCase(name, true)}${timestamp} implements MigrationInterface
     public async down(queryRunner: QueryRunner): Promise<void> {
 		console.log(chalk.yellow(this.name + ' reverting changes!'));
 
-        switch (queryRunner.connection.options.type) {
+        switch (queryRunner.connection.options.type as DatabaseTypeEnum) {
             case DatabaseTypeEnum.sqlite:
             case DatabaseTypeEnum.betterSqlite3:
                 await this.sqliteDownQueryRunner(queryRunner);

packages/core/src/lib/database/migrations/1638541848595-SwitchToMigration.ts

@@ -13,7 +13,7 @@ export class SwitchToMigration1638541848595 implements MigrationInterface {
     public async up(queryRunner: QueryRunner): Promise<void> {
         console.log(chalk.yellow(this.name + ' start running!'));
 
-        switch (queryRunner.connection.options.type) {
+        switch (queryRunner.connection.options.type as DatabaseTypeEnum) {
             case DatabaseTypeEnum.sqlite:
             case DatabaseTypeEnum.betterSqlite3:
                 await this.sqliteUpQueryRunner(queryRunner);
@@ -34,7 +34,7 @@ export class SwitchToMigration1638541848595 implements MigrationInterface {
      * @param queryRunner
      */
     public async down(queryRunner: QueryRunner): Promise<void> {
-        switch (queryRunner.connection.options.type) {
+        switch (queryRunner.connection.options.type as DatabaseTypeEnum) {
             case DatabaseTypeEnum.sqlite:
             case DatabaseTypeEnum.betterSqlite3:
                 await this.sqliteDownQueryRunner(queryRunner);

packages/core/src/lib/database/migrations/1638793919144-KnowledgeBasePlugin.ts

@@ -13,7 +13,7 @@ export class KnowledgeBasePlugin1638793919144 implements MigrationInterface {
     public async up(queryRunner: QueryRunner): Promise<void> {
         console.log(chalk.yellow(this.name + ' start running!'));
 
-        switch (queryRunner.connection.options.type) {
+        switch (queryRunner.connection.options.type as DatabaseTypeEnum) {
             case DatabaseTypeEnum.sqlite:
             case DatabaseTypeEnum.betterSqlite3:
                 await this.sqliteUpQueryRunner(queryRunner);
@@ -34,7 +34,7 @@ export class KnowledgeBasePlugin1638793919144 implements MigrationInterface {
      * @param queryRunner
      */
     public async down(queryRunner: QueryRunner): Promise<void> {
-        switch (queryRunner.connection.options.type) {
+        switch (queryRunner.connection.options.type as DatabaseTypeEnum) {
             case DatabaseTypeEnum.sqlite:
             case DatabaseTypeEnum.betterSqlite3:
                 await this.sqliteDownQueryRunner(queryRunner);