awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-09-22 13:39:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

updated locks

Browse Source
This commit is contained in:
Daniel Hougaard
2024-10-03 22:50:47 +04:00
parent 9a27873af5
commit 787f8318fe
2 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
backend/src/keystore/keystore.ts
View File

@@ -16,13 +16,9 @@ export const KeyStorePrefixes = {
WaitUntilReadyKmsOrgKeyCreation: "wait-until-ready-kms-org-key-creation-",
WaitUntilReadyKmsOrgDataKeyCreation: "wait-until-ready-kms-org-data-key-creation-",
ProjectEnvironmentCreate: "project-environment-creation-lock",
ProjectEnvironmentUpdate: "project-environment-update-lock",
ProjectEnvironmentDelete: "project-environment-delete-lock",
WaitUntilReadyProjectEnvironmentOperation: (projectId: string) =>
`wait-until-ready-project-environments-operation-${projectId}`,
ProjectEnvironmentLock: (projectId: string) => `project-environment-lock-${projectId}` as const,
SyncSecretIntegrationLock: (projectId: string, environmentSlug: string, secretPath: string) =>
`sync-integration-mutex-${projectId}-${environmentSlug}-${secretPath}` as const,
SyncSecretIntegrationLastRunTimestamp: (projectId: string, environmentSlug: string, secretPath: string) =>

6
backend/src/services/project-env/project-env-service.ts
View File

@@ -50,7 +50,7 @@ export const projectEnvServiceFactory = ({
ForbiddenError.from(permission).throwUnlessCan(ProjectPermissionActions.Create, ProjectPermissionSub.Environments);
const lock = await keyStore
.acquireLock([KeyStorePrefixes.ProjectEnvironmentCreate, projectId], 5000)
.acquireLock([KeyStorePrefixes.ProjectEnvironmentLock(projectId)], 5000)
.catch(() => null);
try {
@@ -122,7 +122,7 @@ export const projectEnvServiceFactory = ({
ForbiddenError.from(permission).throwUnlessCan(ProjectPermissionActions.Edit, ProjectPermissionSub.Environments);
const lock = await keyStore
.acquireLock([KeyStorePrefixes.ProjectEnvironmentUpdate, projectId], 5000)
.acquireLock([KeyStorePrefixes.ProjectEnvironmentLock(projectId)], 5000)
.catch(() => null);
try {
@@ -178,7 +178,7 @@ export const projectEnvServiceFactory = ({
ForbiddenError.from(permission).throwUnlessCan(ProjectPermissionActions.Delete, ProjectPermissionSub.Environments);
const lock = await keyStore
.acquireLock([KeyStorePrefixes.ProjectEnvironmentDelete, projectId], 5000)
.acquireLock([KeyStorePrefixes.ProjectEnvironmentLock(projectId)], 5000)
.catch(() => null);
try {