mirror of
https://github.com/awatertrevi/infisical.git
synced 2026-09-22 13:39:35 +00:00
Feat: Find project and include org dal
This commit is contained in:
@@ -279,6 +279,34 @@ export const projectDALFactory = (db: TDbClient) => {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const findProjectWithOrg = async (projectId: string) => {
|
||||||
|
// we just need the project, and we need to include a new .organization field that includes the org from the orgId reference
|
||||||
|
|
||||||
|
const project = await db(TableName.Project)
|
||||||
|
.where({ [`${TableName.Project}.id` as "id"]: projectId })
|
||||||
|
|
||||||
|
.join(TableName.Organization, `${TableName.Organization}.id`, `${TableName.Project}.orgId`)
|
||||||
|
|
||||||
|
.select(
|
||||||
|
db.ref("id").withSchema(TableName.Organization).as("organizationId"),
|
||||||
|
db.ref("name").withSchema(TableName.Organization).as("organizationName")
|
||||||
|
)
|
||||||
|
.select(selectAllTableCols(TableName.Project))
|
||||||
|
.first();
|
||||||
|
|
||||||
|
if (!project) {
|
||||||
|
throw new BadRequestError({ message: "Project not found" });
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
...ProjectsSchema.parse(project),
|
||||||
|
organization: {
|
||||||
|
id: project.organizationId,
|
||||||
|
name: project.organizationName
|
||||||
|
}
|
||||||
|
};
|
||||||
|
};
|
||||||
|
|
||||||
return {
|
return {
|
||||||
...projectOrm,
|
...projectOrm,
|
||||||
findAllProjects,
|
findAllProjects,
|
||||||
@@ -288,6 +316,7 @@ export const projectDALFactory = (db: TDbClient) => {
|
|||||||
findProjectById,
|
findProjectById,
|
||||||
findProjectByFilter,
|
findProjectByFilter,
|
||||||
findProjectBySlug,
|
findProjectBySlug,
|
||||||
|
findProjectWithOrg,
|
||||||
checkProjectUpgradeStatus
|
checkProjectUpgradeStatus
|
||||||
};
|
};
|
||||||
};
|
};
|
||||||
|
|||||||
Reference in New Issue
Block a user