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

Merge pull request #2586 from Infisical/daniel/envkey-fix

Browse Source 
fix: envkey migration failing due to not using batches
This commit is contained in:
Maidul Islam
2024-10-14 22:29:54 -07:00
committed by GitHub
parent 114f42fc14 87cd3ea727
commit f3bcdf74df
1 changed files with 13 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
backend/src/services/external-migration/external-migration-fns.ts
View File

@@ -214,22 +214,21 @@ export const importDataIntoInfisicalFn = async ({
name: "Create secret" name: "Create secret"
}); });
const secretsByKeys = await secretDAL.findBySecretKeys(
folder.id,
secrets.map((el) => ({
key: el.secretKey,
type: SecretType.Shared
})),
tx
);
if (secretsByKeys.length) {
throw new BadRequestError({
message: `Secret already exist: ${secretsByKeys.map((el) => el.key).join(",")}`
});
}
const secretBatches = chunkArray(secrets, 2500); const secretBatches = chunkArray(secrets, 2500);
for await (const secretBatch of secretBatches) { for await (const secretBatch of secretBatches) {
const secretsByKeys = await secretDAL.findBySecretKeys(
folder.id,
secretBatch.map((el) => ({
key: el.secretKey,
type: SecretType.Shared
})),
tx
);
if (secretsByKeys.length) {
throw new BadRequestError({
message: `Secret already exist: ${secretsByKeys.map((el) => el.key).join(",")}`
});
}
await fnSecretBulkInsert({ await fnSecretBulkInsert({
inputSecrets: secretBatch.map((el) => { inputSecrets: secretBatch.map((el) => {
const references = getAllNestedSecretReferences(el.secretValue); const references = getAllNestedSecretReferences(el.secretValue);