mirror of
https://github.com/awatertrevi/infisical.git
synced 2026-09-22 13:39:35 +00:00
More lint
This commit is contained in:
@@ -36,7 +36,7 @@ export const registerPkiAcmeRouter = async (server: FastifyZodProvider) => {
|
|||||||
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
||||||
R extends FastifyRequest<any>,
|
R extends FastifyRequest<any>,
|
||||||
TSchema extends z.ZodSchema<unknown> | undefined = undefined,
|
TSchema extends z.ZodSchema<unknown> | undefined = undefined,
|
||||||
T = TSchema extends z.ZodSchema<infer R> ? R : string
|
T = TSchema extends z.ZodSchema<infer U> ? U : string
|
||||||
>({
|
>({
|
||||||
req,
|
req,
|
||||||
schema
|
schema
|
||||||
@@ -71,7 +71,7 @@ export const registerPkiAcmeRouter = async (server: FastifyZodProvider) => {
|
|||||||
if (!strBody) {
|
if (!strBody) {
|
||||||
done(null, undefined);
|
done(null, undefined);
|
||||||
}
|
}
|
||||||
const json = JSON.parse(strBody);
|
const json: unknown = JSON.parse(strBody);
|
||||||
done(null, json);
|
done(null, json);
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
const error = err as Error;
|
const error = err as Error;
|
||||||
|
|||||||
@@ -35,8 +35,9 @@ export const pkiAcmeChallengeDALFactory = (db: TDbClient) => {
|
|||||||
);
|
);
|
||||||
// Update status for pending orders that have all auths valid
|
// Update status for pending orders that have all auths valid
|
||||||
await (tx || db)(TableName.PkiAcmeOrder)
|
await (tx || db)(TableName.PkiAcmeOrder)
|
||||||
.whereIn("id", (qb) => {
|
.whereIn("id", async (qb) => {
|
||||||
qb.select("o2.id")
|
void (await qb
|
||||||
|
.select("o2.id")
|
||||||
.from({ o2: TableName.PkiAcmeOrder })
|
.from({ o2: TableName.PkiAcmeOrder })
|
||||||
.join({ oa2: TableName.PkiAcmeOrderAuth }, "o2.id", "oa2.orderId")
|
.join({ oa2: TableName.PkiAcmeOrderAuth }, "o2.id", "oa2.orderId")
|
||||||
.join({ a2: TableName.PkiAcmeAuth }, "oa2.authId", "a2.id")
|
.join({ a2: TableName.PkiAcmeAuth }, "oa2.authId", "a2.id")
|
||||||
@@ -47,7 +48,7 @@ export const pkiAcmeChallengeDALFactory = (db: TDbClient) => {
|
|||||||
])
|
])
|
||||||
// Only update orders that are pending
|
// Only update orders that are pending
|
||||||
.where("o2.status", AcmeOrderStatus.Pending)
|
.where("o2.status", AcmeOrderStatus.Pending)
|
||||||
.whereIn("o2.id", involvedOrderIds);
|
.whereIn("o2.id", involvedOrderIds));
|
||||||
})
|
})
|
||||||
.update({ status: AcmeOrderStatus.Ready });
|
.update({ status: AcmeOrderStatus.Ready });
|
||||||
}
|
}
|
||||||
@@ -74,8 +75,9 @@ export const pkiAcmeChallengeDALFactory = (db: TDbClient) => {
|
|||||||
if (updatedAuths.length > 0) {
|
if (updatedAuths.length > 0) {
|
||||||
// Update status for pending orders that have all auths valid
|
// Update status for pending orders that have all auths valid
|
||||||
await (tx || db)(TableName.PkiAcmeOrder)
|
await (tx || db)(TableName.PkiAcmeOrder)
|
||||||
.whereIn("id", (qb) => {
|
.whereIn("id", async (qb) => {
|
||||||
qb.select("o.id")
|
void (await qb
|
||||||
|
.select("o.id")
|
||||||
.from({ o: TableName.PkiAcmeOrder })
|
.from({ o: TableName.PkiAcmeOrder })
|
||||||
.join(TableName.PkiAcmeOrderAuth, "o.id", `${TableName.PkiAcmeOrderAuth}.orderId`)
|
.join(TableName.PkiAcmeOrderAuth, "o.id", `${TableName.PkiAcmeOrderAuth}.orderId`)
|
||||||
.join(TableName.PkiAcmeAuth, `${TableName.PkiAcmeOrderAuth}.authId`, `${TableName.PkiAcmeAuth}.id`)
|
.join(TableName.PkiAcmeAuth, `${TableName.PkiAcmeOrderAuth}.authId`, `${TableName.PkiAcmeAuth}.id`)
|
||||||
@@ -84,7 +86,7 @@ export const pkiAcmeChallengeDALFactory = (db: TDbClient) => {
|
|||||||
.whereIn(
|
.whereIn(
|
||||||
`${TableName.PkiAcmeAuth}.id`,
|
`${TableName.PkiAcmeAuth}.id`,
|
||||||
updatedAuths.map((auth) => auth.id)
|
updatedAuths.map((auth) => auth.id)
|
||||||
);
|
));
|
||||||
})
|
})
|
||||||
.update({ status: AcmeOrderStatus.Invalid });
|
.update({ status: AcmeOrderStatus.Invalid });
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user