awatertrevi/infisical
1
0
Fork 0
mirror of https://github.com/awatertrevi/infisical.git synced 2026-10-03 21:26:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: updated v1 engine sync to be on shared secret mutation

Browse Source
This commit is contained in:
=
2024-10-11 16:37:08 +05:30
parent 96eab464c7
commit 02fd484632
1 changed files with 31 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/services/secret/secret-service.ts
+31 -25
View File
@@ -264,14 +264,16 @@ export const secretServiceFactory = ({
}) })
); );
await snapshotService.performSnapshot(folderId); if (inputSecret.type === SecretType.Shared) {
await secretQueueService.syncSecrets({ await snapshotService.performSnapshot(folderId);
secretPath: path, await secretQueueService.syncSecrets({
actorId, secretPath: path,
actor, actorId,
projectId, actor,
environmentSlug: folder.environment.slug projectId,
}); environmentSlug: folder.environment.slug
});
}
return { ...secret[0], environment, workspace: projectId, tags, secretPath: path }; return { ...secret[0], environment, workspace: projectId, tags, secretPath: path };
}; };
@@ -399,14 +401,16 @@ export const secretServiceFactory = ({
}) })
); );
await snapshotService.performSnapshot(folderId); if (inputSecret.type === SecretType.Shared) {
await secretQueueService.syncSecrets({ await snapshotService.performSnapshot(folderId);
actor, await secretQueueService.syncSecrets({
actorId, secretPath: path,
secretPath: path, actorId,
projectId, actor,
environmentSlug: folder.environment.slug projectId,
}); environmentSlug: folder.environment.slug
});
}
return { ...updatedSecret[0], workspace: projectId, environment, secretPath: path }; return { ...updatedSecret[0], workspace: projectId, environment, secretPath: path };
}; };
@@ -474,15 +478,17 @@ export const secretServiceFactory = ({
}) })
); );
await snapshotService.performSnapshot(folderId); if (inputSecret.type === SecretType.Shared) {
await secretQueueService.syncSecrets({ await snapshotService.performSnapshot(folderId);
actor, await secretQueueService.syncSecrets({
actorId, secretPath: path,
secretPath: path, actorId,
projectId, actor,
environmentSlug: folder.environment.slug projectId,
}); environmentSlug: folder.environment.slug
// TODO(akhilmhdh-pg): license check, posthog service and snapshot });
}
return { ...deletedSecret[0], _id: deletedSecret[0].id, workspace: projectId, environment, secretPath: path }; return { ...deletedSecret[0], _id: deletedSecret[0].id, workspace: projectId, environment, secretPath: path };
}; };