awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-10-14 07:30:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: lint errors fix

Browse Source
This commit is contained in:
=
2025-07-02 23:04:36 +05:30
parent 566a243520
commit 5709afe0d3
5 changed files with 55 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/auto-start-migrations.ts
+28 -28
View File
@@ -44,17 +44,17 @@ export const runMigrations = async ({ applicationDb, auditLogDb, logger }: TArgs
});
}
}
// if (auditLogDb) {
// const hasMigrationTableInAuditLog = await auditLogDb.schema.hasTable(migrationTable);
// if (hasMigrationTableInAuditLog) {
// const firstFile = (await auditLogDb(migrationTable).where({}).first()) as { name: string };
// if (firstFile?.name?.includes(".ts")) {
// await auditLogDb(migrationTable).update({
// name: auditLogDb.raw("REPLACE(name, '.ts', '.mjs')")
// });
// }
// }
// }
if (auditLogDb) {
const hasMigrationTableInAuditLog = await auditLogDb.schema.hasTable(migrationTable);
if (hasMigrationTableInAuditLog) {
const firstFile = (await auditLogDb(migrationTable).where({}).first()) as { name: string };
if (firstFile?.name?.includes(".ts")) {
await auditLogDb(migrationTable).update({
name: auditLogDb.raw("REPLACE(name, '.ts', '.mjs')")
});
}
}
}
}
const shouldRunMigration = Boolean(
@@ -65,23 +65,23 @@ export const runMigrations = async ({ applicationDb, auditLogDb, logger }: TArgs
return;
}
// if (auditLogDb) {
// await auditLogDb.transaction(async (tx) => {
// await tx.raw("SELECT pg_advisory_xact_lock(?)", [PgSqlLock.BootUpMigration]);
// logger.info("Running audit log migrations.");
//
// const didPreviousInstanceRunMigration = !(await auditLogDb.migrate
// .status(migrationConfig)
// .catch(migrationStatusCheckErrorHandler));
// if (didPreviousInstanceRunMigration) {
// logger.info("No audit log migrations pending: Applied by previous instance. Skipping migration process.");
// return;
// }
//
// await auditLogDb.migrate.latest(migrationConfig);
// logger.info("Finished audit log migrations.");
// });
// }
if (auditLogDb) {
await auditLogDb.transaction(async (tx) => {
await tx.raw("SELECT pg_advisory_xact_lock(?)", [PgSqlLock.BootUpMigration]);
logger.info("Running audit log migrations.");
const didPreviousInstanceRunMigration = !(await auditLogDb.migrate
.status(migrationConfig)
.catch(migrationStatusCheckErrorHandler));
if (didPreviousInstanceRunMigration) {
logger.info("No audit log migrations pending: Applied by previous instance. Skipping migration process.");
return;
}
await auditLogDb.migrate.latest(migrationConfig);
logger.info("Finished audit log migrations.");
});
}
await applicationDb.transaction(async (tx) => {
await tx.raw("SELECT pg_advisory_xact_lock(?)", [PgSqlLock.BootUpMigration]);
backend/src/ee/services/audit-log/audit-log-dal.ts
-1
View File
@@ -61,7 +61,6 @@ export const auditLogDALFactory = (db: TDbClient) => {
},
tx
) => {
try {
// Find statements
const sqlQuery = (tx || db.replicaNode())(TableName.AuditLog)