mirror of
https://github.com/awatertrevi/infisical.git
synced 2026-10-14 07:30:20 +00:00
feat: resolved merge issues
This commit is contained in:
@@ -4,7 +4,7 @@ import { ProjectType, TableName } from "../schemas";
|
||||
|
||||
export async function up(knex: Knex): Promise<void> {
|
||||
const hasTypeColumn = await knex.schema.hasColumn(TableName.Project, "type");
|
||||
const hasDefaultTypeColumn = await knex.schema.hasColumn(TableName.Project, "defaultType");
|
||||
const hasDefaultTypeColumn = await knex.schema.hasColumn(TableName.Project, "defaultProduct");
|
||||
if (hasTypeColumn && !hasDefaultTypeColumn) {
|
||||
await knex.schema.alterTable(TableName.Project, (t) => {
|
||||
t.string("type").nullable().alter();
|
||||
|
||||
@@ -182,22 +182,25 @@ export const sshHostServiceFactory = ({
|
||||
return ca.id;
|
||||
};
|
||||
|
||||
const projectSshConfig = await projectSshConfigDAL.transaction(async (tx) => {
|
||||
await tx.raw("SELECT pg_advisory_xact_lock(?)", [PgSqlLock.SshInit(projectId)]);
|
||||
let projectSshConfig = await projectSshConfigDAL.findOne({ projectId });
|
||||
if (!projectSshConfig) {
|
||||
projectSshConfig = await projectSshConfigDAL.transaction(async (tx) => {
|
||||
await tx.raw("SELECT pg_advisory_xact_lock(?)", [PgSqlLock.SshInit(projectId)]);
|
||||
|
||||
let sshConfig = await projectSshConfigDAL.findOne({ projectId });
|
||||
if (sshConfig) return sshConfig;
|
||||
let sshConfig = await projectSshConfigDAL.findOne({ projectId }, tx);
|
||||
if (sshConfig) return sshConfig;
|
||||
|
||||
sshConfig = await bootstrapSshProject({
|
||||
projectId,
|
||||
sshCertificateAuthorityDAL,
|
||||
sshCertificateAuthoritySecretDAL,
|
||||
kmsService,
|
||||
projectSshConfigDAL,
|
||||
tx
|
||||
sshConfig = await bootstrapSshProject({
|
||||
projectId,
|
||||
sshCertificateAuthorityDAL,
|
||||
sshCertificateAuthoritySecretDAL,
|
||||
kmsService,
|
||||
projectSshConfigDAL,
|
||||
tx
|
||||
});
|
||||
return sshConfig;
|
||||
});
|
||||
return sshConfig;
|
||||
});
|
||||
}
|
||||
|
||||
const userSshCaId = await resolveSshCaId({
|
||||
requestedId: requestedUserSshCaId,
|
||||
|
||||
Reference in New Issue
Block a user