adjustment: removed artificial limiting of pit versions

This commit is contained in:
Sheen Capadngan
2024-06-04 23:46:02 +08:00
parent 68a30f4212
commit f21a13f388
5 changed files with 11 additions and 31 deletions
@@ -4,7 +4,6 @@ import { TableName, TSecretTagJunctionInsert } from "@app/db/schemas";
import { BadRequestError, InternalServerError } from "@app/lib/errors"; import { BadRequestError, InternalServerError } from "@app/lib/errors";
import { groupBy } from "@app/lib/fn"; import { groupBy } from "@app/lib/fn";
import { logger } from "@app/lib/logger"; import { logger } from "@app/lib/logger";
import { TProjectDALFactory } from "@app/services/project/project-dal";
import { TSecretDALFactory } from "@app/services/secret/secret-dal"; import { TSecretDALFactory } from "@app/services/secret/secret-dal";
import { TSecretVersionDALFactory } from "@app/services/secret/secret-version-dal"; import { TSecretVersionDALFactory } from "@app/services/secret/secret-version-dal";
import { TSecretVersionTagDALFactory } from "@app/services/secret/secret-version-tag-dal"; import { TSecretVersionTagDALFactory } from "@app/services/secret/secret-version-tag-dal";
@@ -38,7 +37,6 @@ type TSecretSnapshotServiceFactoryDep = {
folderDAL: Pick<TSecretFolderDALFactory, "findById" | "findBySecretPath" | "delete" | "insertMany" | "find">; folderDAL: Pick<TSecretFolderDALFactory, "findById" | "findBySecretPath" | "delete" | "insertMany" | "find">;
permissionService: Pick<TPermissionServiceFactory, "getProjectPermission">; permissionService: Pick<TPermissionServiceFactory, "getProjectPermission">;
licenseService: Pick<TLicenseServiceFactory, "isValidLicense">; licenseService: Pick<TLicenseServiceFactory, "isValidLicense">;
projectDAL: Pick<TProjectDALFactory, "findById">;
}; };
export type TSecretSnapshotServiceFactory = ReturnType<typeof secretSnapshotServiceFactory>; export type TSecretSnapshotServiceFactory = ReturnType<typeof secretSnapshotServiceFactory>;
@@ -50,7 +48,6 @@ export const secretSnapshotServiceFactory = ({
snapshotSecretDAL, snapshotSecretDAL,
snapshotFolderDAL, snapshotFolderDAL,
folderDAL, folderDAL,
projectDAL,
secretDAL, secretDAL,
permissionService, permissionService,
licenseService, licenseService,
@@ -84,9 +81,7 @@ export const secretSnapshotServiceFactory = ({
const folder = await folderDAL.findBySecretPath(projectId, environment, path); const folder = await folderDAL.findBySecretPath(projectId, environment, path);
if (!folder) throw new BadRequestError({ message: "Folder not found" }); if (!folder) throw new BadRequestError({ message: "Folder not found" });
const project = await projectDAL.findById(projectId); return snapshotDAL.countOfSnapshotsByFolderId(folder.id);
const count = await snapshotDAL.countOfSnapshotsByFolderId(folder.id);
return Math.min(count, project.pitVersionLimit);
}; };
const listSnapshots = async ({ const listSnapshots = async ({
@@ -118,16 +113,7 @@ export const secretSnapshotServiceFactory = ({
const folder = await folderDAL.findBySecretPath(projectId, environment, path); const folder = await folderDAL.findBySecretPath(projectId, environment, path);
if (!folder) throw new BadRequestError({ message: "Folder not found" }); if (!folder) throw new BadRequestError({ message: "Folder not found" });
const { pitVersionLimit } = await projectDAL.findById(projectId); const snapshots = await snapshotDAL.find({ folderId: folder.id }, { limit, offset, sort: [["createdAt", "desc"]] });
const computedQueryLimit = Math.min(pitVersionLimit - offset, limit);
if (offset > pitVersionLimit || computedQueryLimit <= 0) {
return [];
}
const snapshots = await snapshotDAL.find(
{ folderId: folder.id },
{ limit: computedQueryLimit, offset, sort: [["createdAt", "desc"]] }
);
return snapshots; return snapshots;
}; };
@@ -341,7 +341,6 @@ export const snapshotDALFactory = (db: TDbClient) => {
.select("id"); .select("id");
const batchEntries = folderBatch.map((folder) => folder.id); const batchEntries = folderBatch.map((folder) => folder.id);
logger.info("UUID offset:", uuidOffset);
if (folderBatch.length) { if (folderBatch.length) {
try { try {
-1
View File
@@ -535,7 +535,6 @@ export const registerRoutes = async (
licenseService, licenseService,
folderDAL, folderDAL,
secretDAL, secretDAL,
projectDAL,
snapshotDAL, snapshotDAL,
snapshotFolderDAL, snapshotFolderDAL,
snapshotSecretDAL, snapshotSecretDAL,
+2 -11
View File
@@ -72,7 +72,7 @@ type TSecretServiceFactoryDep = {
secretDAL: TSecretDALFactory; secretDAL: TSecretDALFactory;
secretTagDAL: TSecretTagDALFactory; secretTagDAL: TSecretTagDALFactory;
secretVersionDAL: TSecretVersionDALFactory; secretVersionDAL: TSecretVersionDALFactory;
projectDAL: Pick<TProjectDALFactory, "checkProjectUpgradeStatus" | "findProjectBySlug" | "findById">; projectDAL: Pick<TProjectDALFactory, "checkProjectUpgradeStatus" | "findProjectBySlug">;
projectEnvDAL: Pick<TProjectEnvDALFactory, "findOne">; projectEnvDAL: Pick<TProjectEnvDALFactory, "findOne">;
folderDAL: Pick< folderDAL: Pick<
TSecretFolderDALFactory, TSecretFolderDALFactory,
@@ -1354,16 +1354,7 @@ export const secretServiceFactory = ({
); );
ForbiddenError.from(permission).throwUnlessCan(ProjectPermissionActions.Read, ProjectPermissionSub.SecretRollback); ForbiddenError.from(permission).throwUnlessCan(ProjectPermissionActions.Read, ProjectPermissionSub.SecretRollback);
const { pitVersionLimit } = await projectDAL.findById(folder.projectId); const secretVersions = await secretVersionDAL.find({ secretId }, { offset, limit, sort: [["createdAt", "desc"]] });
const computedQueryLimit = Math.min(pitVersionLimit - offset, limit);
if (offset > pitVersionLimit || computedQueryLimit <= 0) {
return [];
}
const secretVersions = await secretVersionDAL.find(
{ secretId },
{ offset, limit: computedQueryLimit, sort: [["createdAt", "desc"]] }
);
return secretVersions; return secretVersions;
}; };
@@ -22,7 +22,7 @@ export const PointInTimeVersionLimitSection = () => {
const { const {
control, control,
formState: { isSubmitting }, formState: { isSubmitting, isDirty },
handleSubmit handleSubmit
} = useForm<TForm>({ } = useForm<TForm>({
resolver: zodResolver(formSchema), resolver: zodResolver(formSchema),
@@ -79,7 +79,12 @@ export const PointInTimeVersionLimitSection = () => {
)} )}
/> />
</div> </div>
<Button colorSchema="secondary" type="submit" isLoading={isSubmitting} disabled={!isAdmin}> <Button
colorSchema="secondary"
type="submit"
isLoading={isSubmitting}
disabled={!isAdmin || !isDirty}
>
Save Save
</Button> </Button>
</form> </form>