a804a29516
* chore: Stripe paid apps flow * chore: Subscription * chore: Webhooks * chore: Abstract functions * chore: Lockfile * chore: Webhook handler * chore: Use catch-all * chore: Webhook changes, etc * chore: Cleanup * chore: Use actual price id * chore: Updates * chore: Install normally until expiry date * Disable team install for paid apps and cal.ai\ * Fix the same at another place * Fix Typescript error * redactedCause doesnt have message has enumerable prop * Fix reinstallation of an already installed app * chore: Remove unused deps * chore: Ensure index * chore: Price in usd * chore: PR suggestion * Fix missing packages in yarn.lock --------- Co-authored-by: Hariom <hariombalhara@gmail.com> Co-authored-by: Peer Richelsen <peeroke@gmail.com>
83 lines
2.5 KiB
TypeScript
83 lines
2.5 KiB
TypeScript
import { PrismaClientKnownRequestError, NotFoundError } from "@prisma/client/runtime/library";
|
|
import Stripe from "stripe";
|
|
import type { ZodIssue } from "zod";
|
|
import { ZodError } from "zod";
|
|
|
|
import { HttpError } from "../http-error";
|
|
import { redactError } from "../redactError";
|
|
|
|
function hasName(cause: unknown): cause is { name: string } {
|
|
return !!cause && typeof cause === "object" && "name" in cause;
|
|
}
|
|
|
|
function isZodError(cause: unknown): cause is ZodError {
|
|
return cause instanceof ZodError || (hasName(cause) && cause.name === "ZodError");
|
|
}
|
|
|
|
function parseZodErrorIssues(issues: ZodIssue[]): string {
|
|
return issues
|
|
.map((i) =>
|
|
i.code === "invalid_union"
|
|
? i.unionErrors.map((ue) => parseZodErrorIssues(ue.issues)).join("; ")
|
|
: i.code === "unrecognized_keys"
|
|
? i.message
|
|
: `${i.path.length ? `${i.code} in '${i.path}': ` : ""}${i.message}`
|
|
)
|
|
.join("; ");
|
|
}
|
|
|
|
export function getServerErrorFromUnknown(cause: unknown): HttpError {
|
|
if (isZodError(cause)) {
|
|
console.log("cause", cause);
|
|
return new HttpError({
|
|
statusCode: 400,
|
|
message: parseZodErrorIssues(cause.issues),
|
|
cause,
|
|
});
|
|
}
|
|
if (cause instanceof SyntaxError) {
|
|
return new HttpError({
|
|
statusCode: 500,
|
|
message: "Unexpected error, please reach out for our customer support.",
|
|
});
|
|
}
|
|
|
|
if (cause instanceof PrismaClientKnownRequestError) {
|
|
return getHttpError({ statusCode: 400, cause });
|
|
}
|
|
if (cause instanceof NotFoundError) {
|
|
return getHttpError({ statusCode: 404, cause });
|
|
}
|
|
if (cause instanceof Stripe.errors.StripeInvalidRequestError) {
|
|
return getHttpError({ statusCode: 400, cause });
|
|
}
|
|
if (cause instanceof HttpError) {
|
|
const redactedCause = redactError(cause);
|
|
return {
|
|
...redactedCause,
|
|
message: redactedCause.message,
|
|
cause: cause.cause,
|
|
url: cause.url,
|
|
statusCode: cause.statusCode,
|
|
method: cause.method,
|
|
};
|
|
}
|
|
if (cause instanceof Error) {
|
|
return getHttpError({ statusCode: 500, cause });
|
|
}
|
|
if (typeof cause === "string") {
|
|
// @ts-expect-error https://github.com/tc39/proposal-error-cause
|
|
return new Error(cause, { cause });
|
|
}
|
|
|
|
return new HttpError({
|
|
statusCode: 500,
|
|
message: `Unhandled error of type '${typeof cause}'. Please reach out for our customer support.`,
|
|
});
|
|
}
|
|
|
|
function getHttpError<T extends Error>({ statusCode, cause }: { statusCode: number; cause: T }) {
|
|
const redacted = redactError(cause);
|
|
return new HttpError({ statusCode, message: redacted.message, cause: redacted });
|
|
}
|