feat(piefed): PiefedResponseError, improve error handling (#30)

Author: aeharding

src/errors.ts

@@ -1,3 +1,5 @@
+import { PiefedErrorResponse } from "./types";
+
 export class FediverseError extends Error {
   constructor(message: string, errorOptions?: ErrorOptions) {
     super(message, errorOptions);
@@ -12,6 +14,25 @@ export class InvalidPayloadError extends FediverseError {
   }
 }
 
+export class ResponseError extends FediverseError {
+  status: number;
+
+  constructor(status: number, message?: string) {
+    super(message ?? `${status}`);
+    this.status = status;
+    this.name = "ResponseError";
+  }
+}
+export class PiefedResponseError extends ResponseError {
+  response: PiefedErrorResponse;
+
+  constructor(status: number, payload: PiefedErrorResponse) {
+    super(status, payload.message);
+    this.response = payload;
+    this.name = "PiefedResponseError";
+  }
+}
+
 export class UnexpectedResponseError extends FediverseError {
   constructor(message: string) {
     super(message);

src/providers/piefed/index.ts

@@ -5,9 +5,15 @@ import {
   BaseClientOptions,
   RequestOptions,
 } from "../../BaseClient";
-import { InvalidPayloadError, UnsupportedError } from "../../errors";
+import {
+  InvalidPayloadError,
+  PiefedResponseError,
+  ResponseError,
+  UnsupportedError,
+} from "../../errors";
 import { cleanThreadiverseParams } from "../../helpers";
 import buildSafeClient from "../../SafeClient";
+import { PiefedErrorResponse } from "../../schemas";
 import {
   ListPersonContent,
   ListPersonContentResponse,
@@ -23,9 +29,13 @@ import { components, paths } from "./schema";
 async function validateResponse(response: Response) {
   if (!response.ok) {
     const data = await response.json();
-    if ("error" in data && typeof data.error === "string") {
-      throw new Error(data.error);
-    }
+
+    const parsed = PiefedErrorResponse.safeParse(data);
+
+    if (parsed.success)
+      throw new PiefedResponseError(response.status, parsed.data);
+
+    throw new ResponseError(response.status);
   }
 }
 

src/schemas/PiefedErrorResponse.ts

@@ -0,0 +1,7 @@
+import { z } from "zod/v4-mini";
+
+export const PiefedErrorResponse = z.object({
+  code: z.number(),
+  message: z.string(),
+  status: z.string(),
+});

src/schemas/index.ts

@@ -49,5 +49,7 @@ export * from "./SiteAggregates";
 export * from "./SubscribedType";
 export * from "./UploadImageResponse";
 
+export * from "./PiefedErrorResponse";
+
 // Should be last (can't access lexical declaration 'PersonView' before initialization)
 export * from "./list";

src/types/index.ts

@@ -122,6 +122,7 @@ export type PersonContentItem = z.infer<typeof schemas.PersonContentItem>;
 export type PersonMention = z.infer<typeof schemas.PersonMention>;
 export type PersonMentionView = z.infer<typeof schemas.PersonMentionView>;
 export type PersonView = z.infer<typeof schemas.PersonView>;
+export type PiefedErrorResponse = z.infer<typeof schemas.PiefedErrorResponse>;
 export type Post = z.infer<typeof schemas.Post>;
 export type PostAggregates = z.infer<typeof schemas.PostAggregates>;
 export type PostReport = z.infer<typeof schemas.PostReport>;