Skip to content

Commit

Permalink
js: Move JSON parsing out of SvixRequest logic
Browse files Browse the repository at this point in the history
  • Loading branch information
svix-jplatte committed Jan 29, 2025
1 parent 513854e commit d1a973a
Show file tree
Hide file tree
Showing 11 changed files with 60 additions and 54 deletions.
10 changes: 5 additions & 5 deletions javascript/src/api/application.ts
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ export class Application {
request.setQueryParam("order", options?.order);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseApplicationOut;
return JSON.parse(responseBody);
}

/** Create a new application. */
Expand All @@ -46,7 +46,7 @@ export class Application {
request.body = applicationIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as ApplicationOut;
return JSON.parse(responseBody);
}

/** Get the application with the UID from `applicationIn`, or create it if it doesn't exist yet. */
Expand All @@ -71,7 +71,7 @@ export class Application {
request.setPathParam("app_id", appId);

const responseBody = await request.send(this.requestCtx);
return responseBody as ApplicationOut;
return JSON.parse(responseBody);
}

/** Update an application. */
Expand All @@ -85,7 +85,7 @@ export class Application {
request.body = applicationIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as ApplicationOut;
return JSON.parse(responseBody);
}

/** Delete an application. */
Expand All @@ -108,6 +108,6 @@ export class Application {
request.body = applicationPatch;

const responseBody = await request.send(this.requestCtx);
return responseBody as ApplicationOut;
return JSON.parse(responseBody);
}
}
4 changes: 2 additions & 2 deletions javascript/src/api/authentication.ts
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ export class Authentication {
request.body = appPortalAccessIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as AppPortalAccessOut;
return JSON.parse(responseBody);
}

/** Expire all of the tokens associated with a specific application. */
Expand Down Expand Up @@ -68,7 +68,7 @@ export class Authentication {
request.setHeaderParam("idempotency-key", options?.idempotencyKey);

const responseBody = await request.send(this.requestCtx);
return responseBody as DashboardAccessOut;
return JSON.parse(responseBody);
}

/**
Expand Down
4 changes: 2 additions & 2 deletions javascript/src/api/background_task.ts
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ export class BackgroundTask {
request.setQueryParam("order", options?.order);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseBackgroundTaskOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -58,6 +58,6 @@ export class BackgroundTask {
request.setPathParam("task_id", taskId);

const responseBody = await request.send(this.requestCtx);
return responseBody as BackgroundTaskOut;
return JSON.parse(responseBody);
}
}
24 changes: 12 additions & 12 deletions javascript/src/api/endpoint.ts
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ export class Endpoint {
request.setQueryParam("order", options?.order);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseEndpointOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -77,7 +77,7 @@ export class Endpoint {
request.body = endpointIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointOut;
return JSON.parse(responseBody);
}

/** Get an endpoint. */
Expand All @@ -91,7 +91,7 @@ export class Endpoint {
request.setPathParam("endpoint_id", endpointId);

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointOut;
return JSON.parse(responseBody);
}

/** Update an endpoint. */
Expand All @@ -110,7 +110,7 @@ export class Endpoint {
request.body = endpointUpdate;

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointOut;
return JSON.parse(responseBody);
}

/** Delete an endpoint. */
Expand Down Expand Up @@ -142,7 +142,7 @@ export class Endpoint {
request.body = endpointPatch;

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointOut;
return JSON.parse(responseBody);
}

/** Get the additional headers to be sent with the webhook. */
Expand All @@ -159,7 +159,7 @@ export class Endpoint {
request.setPathParam("endpoint_id", endpointId);

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointHeadersOut;
return JSON.parse(responseBody);
}

/** Set the additional headers to be sent with the webhook. */
Expand Down Expand Up @@ -236,7 +236,7 @@ export class Endpoint {
request.body = recoverIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as RecoverOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -262,7 +262,7 @@ export class Endpoint {
request.body = replayIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as ReplayOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -281,7 +281,7 @@ export class Endpoint {
request.setPathParam("endpoint_id", endpointId);

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointSecretOut;
return JSON.parse(responseBody);
}

/**
Expand Down Expand Up @@ -326,7 +326,7 @@ export class Endpoint {
request.body = eventExampleIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as MessageOut;
return JSON.parse(responseBody);
}

/** Get basic statistics for the endpoint. */
Expand All @@ -346,7 +346,7 @@ export class Endpoint {
request.setQueryParam("until", options?.until);

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointStats;
return JSON.parse(responseBody);
}

/** Get the transformation code associated with this endpoint. */
Expand All @@ -363,7 +363,7 @@ export class Endpoint {
request.setPathParam("endpoint_id", endpointId);

const responseBody = await request.send(this.requestCtx);
return responseBody as EndpointTransformationOut;
return JSON.parse(responseBody);
}

/** Set or unset the transformation code associated with this endpoint. */
Expand Down
12 changes: 6 additions & 6 deletions javascript/src/api/event_type.ts
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,7 @@ export class EventType {
request.setQueryParam("with_content", options?.withContent);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseEventTypeOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -64,7 +64,7 @@ export class EventType {
request.body = eventTypeIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as EventTypeOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -84,7 +84,7 @@ export class EventType {
request.body = eventTypeImportOpenApiIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as EventTypeImportOpenApiOut;
return JSON.parse(responseBody);
}

/** Get an event type. */
Expand All @@ -97,7 +97,7 @@ export class EventType {
request.setPathParam("event_type_name", eventTypeName);

const responseBody = await request.send(this.requestCtx);
return responseBody as EventTypeOut;
return JSON.parse(responseBody);
}

/** Update an event type. */
Expand All @@ -114,7 +114,7 @@ export class EventType {
request.body = eventTypeUpdate;

const responseBody = await request.send(this.requestCtx);
return responseBody as EventTypeOut;
return JSON.parse(responseBody);
}

/**
Expand Down Expand Up @@ -154,6 +154,6 @@ export class EventType {
request.body = eventTypePatch;

const responseBody = await request.send(this.requestCtx);
return responseBody as EventTypeOut;
return JSON.parse(responseBody);
}
}
12 changes: 6 additions & 6 deletions javascript/src/api/integration.ts
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ export class Integration {
request.setQueryParam("order", options?.order);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseIntegrationOut;
return JSON.parse(responseBody);
}

/** Create an integration. */
Expand All @@ -51,7 +51,7 @@ export class Integration {
request.body = integrationIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as IntegrationOut;
return JSON.parse(responseBody);
}

/** Get an integration. */
Expand All @@ -65,7 +65,7 @@ export class Integration {
request.setPathParam("integ_id", integId);

const responseBody = await request.send(this.requestCtx);
return responseBody as IntegrationOut;
return JSON.parse(responseBody);
}

/** Update an integration. */
Expand All @@ -84,7 +84,7 @@ export class Integration {
request.body = integrationUpdate;

const responseBody = await request.send(this.requestCtx);
return responseBody as IntegrationOut;
return JSON.parse(responseBody);
}

/** Delete an integration. */
Expand Down Expand Up @@ -115,7 +115,7 @@ export class Integration {
request.setPathParam("integ_id", integId);

const responseBody = await request.send(this.requestCtx);
return responseBody as IntegrationKeyOut;
return JSON.parse(responseBody);
}

/** Rotate the integration's key. The previous key will be immediately revoked. */
Expand All @@ -134,6 +134,6 @@ export class Integration {
request.setHeaderParam("idempotency-key", options?.idempotencyKey);

const responseBody = await request.send(this.requestCtx);
return responseBody as IntegrationKeyOut;
return JSON.parse(responseBody);
}
}
6 changes: 3 additions & 3 deletions javascript/src/api/message.ts
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ export class Message {
request.setQueryParam("event_types", options?.eventTypes);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseMessageOut;
return JSON.parse(responseBody);
}

/**
Expand All @@ -84,7 +84,7 @@ export class Message {
request.body = messageIn;

const responseBody = await request.send(this.requestCtx);
return responseBody as MessageOut;
return JSON.parse(responseBody);
}

/** Get a message by its ID or eventID. */
Expand All @@ -100,7 +100,7 @@ export class Message {
request.setQueryParam("with_content", options?.withContent);

const responseBody = await request.send(this.requestCtx);
return responseBody as MessageOut;
return JSON.parse(responseBody);
}

/**
Expand Down
10 changes: 5 additions & 5 deletions javascript/src/api/message_attempt.ts
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,7 @@ export class MessageAttempt {
request.setQueryParam("event_types", options?.eventTypes);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseMessageAttemptOut;
return JSON.parse(responseBody);
}

/**
Expand Down Expand Up @@ -183,7 +183,7 @@ export class MessageAttempt {
request.setQueryParam("event_types", options?.eventTypes);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseMessageAttemptOut;
return JSON.parse(responseBody);
}

/**
Expand Down Expand Up @@ -219,7 +219,7 @@ export class MessageAttempt {
request.setQueryParam("event_types", options?.eventTypes);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseEndpointMessageOut;
return JSON.parse(responseBody);
}

/** `msg_id`: Use a message id or a message `eventId` */
Expand All @@ -238,7 +238,7 @@ export class MessageAttempt {
request.setPathParam("attempt_id", attemptId);

const responseBody = await request.send(this.requestCtx);
return responseBody as MessageAttemptOut;
return JSON.parse(responseBody);
}

/**
Expand Down Expand Up @@ -286,7 +286,7 @@ export class MessageAttempt {
request.setQueryParam("iterator", options?.iterator);

const responseBody = await request.send(this.requestCtx);
return responseBody as ListResponseMessageEndpointOut;
return JSON.parse(responseBody);
}

/** Resend a message to the specified endpoint. */
Expand Down
Loading

0 comments on commit d1a973a

Please sign in to comment.