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

requested changes

Browse Source
This commit is contained in:
Daniel Hougaard
2024-10-03 21:47:37 +04:00
parent 0abab57d83
commit 9a27873af5
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -19,9 +19,9 @@ export const KeyStorePrefixes = {
ProjectEnvironmentCreate: "project-environment-creation-lock",
ProjectEnvironmentUpdate: "project-environment-update-lock",
ProjectEnvironmentDelete: "project-environment-delete-lock",
WaitUntilReadyCreateProjectEnvironment: "wait-until-ready-create-project-environments-",
WaitUntilReadyUpdateProjectEnvironment: "wait-until-ready-update-project-environments-",
WaitUntilReadyDeleteProjectEnvironment: "wait-until-ready-delete-project-environments-",
WaitUntilReadyProjectEnvironmentOperation: (projectId: string) =>
`wait-until-ready-project-environments-operation-${projectId}`,
SyncSecretIntegrationLock: (projectId: string, environmentSlug: string, secretPath: string) =>
`sync-integration-mutex-${projectId}-${environmentSlug}-${secretPath}` as const,

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

@@ -56,7 +56,7 @@ export const projectEnvServiceFactory = ({
try {
if (!lock) {
await keyStore.waitTillReady({
key: `${KeyStorePrefixes.WaitUntilReadyCreateProjectEnvironment}${projectId}`,
key: KeyStorePrefixes.WaitUntilReadyProjectEnvironmentOperation(projectId),
keyCheckCb: (val) => val === "true",
waitingCb: () => logger.debug("Create project environment. Waiting for "),
delay: 500
@@ -90,7 +90,7 @@ export const projectEnvServiceFactory = ({
});
await keyStore.setItemWithExpiry(
`${KeyStorePrefixes.WaitUntilReadyCreateProjectEnvironment}${projectId}`,
KeyStorePrefixes.WaitUntilReadyProjectEnvironmentOperation(projectId),
10,
"true"
);
@@ -128,7 +128,7 @@ export const projectEnvServiceFactory = ({
try {
if (!lock) {
await keyStore.waitTillReady({
key: `${KeyStorePrefixes.WaitUntilReadyUpdateProjectEnvironment}${projectId}`,
key: KeyStorePrefixes.WaitUntilReadyProjectEnvironmentOperation(projectId),
keyCheckCb: (val) => val === "true",
waitingCb: () => logger.debug("Update project environment. Waiting for project environment update"),
delay: 500
@@ -156,7 +156,7 @@ export const projectEnvServiceFactory = ({
});
await keyStore.setItemWithExpiry(
`${KeyStorePrefixes.WaitUntilReadyUpdateProjectEnvironment}${projectId}`,
KeyStorePrefixes.WaitUntilReadyProjectEnvironmentOperation(projectId),
10,
"true"
);
@@ -184,7 +184,7 @@ export const projectEnvServiceFactory = ({
try {
if (!lock) {
await keyStore.waitTillReady({
key: `${KeyStorePrefixes.WaitUntilReadyDeleteProjectEnvironment}${projectId}`,
key: KeyStorePrefixes.WaitUntilReadyProjectEnvironmentOperation(projectId),
keyCheckCb: (val) => val === "true",
waitingCb: () => logger.debug("Delete project environment. Waiting for "),
delay: 500
@@ -204,7 +204,7 @@ export const projectEnvServiceFactory = ({
});
await keyStore.setItemWithExpiry(
`${KeyStorePrefixes.WaitUntilReadyDeleteProjectEnvironment}${projectId}`,
KeyStorePrefixes.WaitUntilReadyProjectEnvironmentOperation(projectId),
10,
"true"
);