Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "@pipedream/sdk",
"version": "2.0.4",
"version": "2.0.5",
"private": false,
"repository": "github:PipedreamHQ/pipedream-sdk-typescript",
"type": "commonjs",
Expand Down
4 changes: 2 additions & 2 deletions src/Client.ts
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ export declare namespace PipedreamClient {
/** Override the x-pd-environment header */
projectEnvironment?: core.Supplier<Pipedream.ProjectEnvironment | undefined>;
/** Additional headers to include in requests. */
headers?: Record<string, string | core.Supplier<string | undefined> | undefined>;
headers?: Record<string, string | core.Supplier<string | null | undefined> | null | undefined>;
}

export interface RequestOptions {
Expand All @@ -47,7 +47,7 @@ export declare namespace PipedreamClient {
/** Additional query string parameters to include in the request. */
queryParams?: Record<string, unknown>;
/** Additional headers to include in the request. */
headers?: Record<string, string | core.Supplier<string | undefined> | undefined>;
headers?: Record<string, string | core.Supplier<string | null | undefined> | null | undefined>;
}
}

Expand Down
18 changes: 18 additions & 0 deletions src/api/errors/TooManyRequestsError.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
/**
* This file was auto-generated by Fern from our API Definition.
*/

import * as errors from "../../errors/index.js";
import * as core from "../../core/index.js";

export class TooManyRequestsError extends errors.PipedreamError {
constructor(body?: unknown, rawResponse?: core.RawResponse) {
super({
message: "TooManyRequestsError",
statusCode: 429,
body: body,
rawResponse: rawResponse,
});
Object.setPrototypeOf(this, TooManyRequestsError.prototype);
}
}
1 change: 1 addition & 0 deletions src/api/errors/index.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
export * from "./TooManyRequestsError.js";
1 change: 1 addition & 0 deletions src/api/index.ts
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@
export * from "./resources/index.js";
export * from "./types/index.js";
export * from "./errors/index.js";
89 changes: 62 additions & 27 deletions src/api/resources/accounts/client/Client.ts
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ export declare namespace Accounts {
/** Override the x-pd-environment header */
projectEnvironment?: core.Supplier<Pipedream.ProjectEnvironment | undefined>;
/** Additional headers to include in requests. */
headers?: Record<string, string | core.Supplier<string | undefined> | undefined>;
headers?: Record<string, string | core.Supplier<string | null | undefined> | null | undefined>;
}

export interface RequestOptions {
Expand All @@ -34,7 +34,7 @@ export declare namespace Accounts {
/** Additional query string parameters to include in the request. */
queryParams?: Record<string, unknown>;
/** Additional headers to include in the request. */
headers?: Record<string, string | core.Supplier<string | undefined> | undefined>;
headers?: Record<string, string | core.Supplier<string | null | undefined> | null | undefined>;
}
}

Expand All @@ -51,6 +51,8 @@ export class Accounts {
* @param {Pipedream.AccountsListRequest} request
* @param {Accounts.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.accounts.list()
*/
Expand Down Expand Up @@ -121,11 +123,16 @@ export class Accounts {
};
}
if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}
switch (_response.error.reason) {
case "non-json":
Expand Down Expand Up @@ -166,6 +173,8 @@ export class Accounts {
* @param {Pipedream.CreateAccountOpts} request
* @param {Accounts.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.accounts.create({
* appSlug: "app_slug",
Expand Down Expand Up @@ -240,11 +249,16 @@ export class Accounts {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down Expand Up @@ -273,6 +287,8 @@ export class Accounts {
* @param {Pipedream.AccountsRetrieveRequest} request
* @param {Accounts.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.accounts.retrieve("account_id")
*/
Expand Down Expand Up @@ -331,11 +347,16 @@ export class Accounts {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down Expand Up @@ -363,6 +384,8 @@ export class Accounts {
* @param {string} accountId
* @param {Accounts.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.accounts.delete("account_id")
*/
Expand Down Expand Up @@ -401,11 +424,16 @@ export class Accounts {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down Expand Up @@ -433,6 +461,8 @@ export class Accounts {
* @param {string} appId
* @param {Accounts.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.accounts.deleteByApp("app_id")
*/
Expand Down Expand Up @@ -471,11 +501,16 @@ export class Accounts {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down
89 changes: 62 additions & 27 deletions src/api/resources/actions/client/Client.ts
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ export declare namespace Actions {
/** Override the x-pd-environment header */
projectEnvironment?: core.Supplier<Pipedream.ProjectEnvironment | undefined>;
/** Additional headers to include in requests. */
headers?: Record<string, string | core.Supplier<string | undefined> | undefined>;
headers?: Record<string, string | core.Supplier<string | null | undefined> | null | undefined>;
}

export interface RequestOptions {
Expand All @@ -34,7 +34,7 @@ export declare namespace Actions {
/** Additional query string parameters to include in the request. */
queryParams?: Record<string, unknown>;
/** Additional headers to include in the request. */
headers?: Record<string, string | core.Supplier<string | undefined> | undefined>;
headers?: Record<string, string | core.Supplier<string | null | undefined> | null | undefined>;
}
}

Expand All @@ -51,6 +51,8 @@ export class Actions {
* @param {Pipedream.ActionsListRequest} request
* @param {Actions.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.actions.list()
*/
Expand Down Expand Up @@ -115,11 +117,16 @@ export class Actions {
};
}
if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}
switch (_response.error.reason) {
case "non-json":
Expand Down Expand Up @@ -160,6 +167,8 @@ export class Actions {
* @param {string} componentId - The key that uniquely identifies the component (e.g., 'slack-send-message')
* @param {Actions.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.actions.retrieve("component_id")
*/
Expand Down Expand Up @@ -210,11 +219,16 @@ export class Actions {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down Expand Up @@ -242,6 +256,8 @@ export class Actions {
* @param {Pipedream.ConfigurePropOpts} request
* @param {Actions.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.actions.configureProp({
* id: "id",
Expand Down Expand Up @@ -302,11 +318,16 @@ export class Actions {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down Expand Up @@ -334,6 +355,8 @@ export class Actions {
* @param {Pipedream.ReloadPropsOpts} request
* @param {Actions.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.actions.reloadProps({
* id: "id",
Expand Down Expand Up @@ -393,11 +416,16 @@ export class Actions {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down Expand Up @@ -425,6 +453,8 @@ export class Actions {
* @param {Pipedream.RunActionOpts} request
* @param {Actions.RequestOptions} requestOptions - Request-specific configuration.
*
* @throws {@link Pipedream.TooManyRequestsError}
*
* @example
* await client.actions.run({
* id: "id",
Expand Down Expand Up @@ -484,11 +514,16 @@ export class Actions {
}

if (_response.error.reason === "status-code") {
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
switch (_response.error.statusCode) {
case 429:
throw new Pipedream.TooManyRequestsError(_response.error.body, _response.rawResponse);
default:
throw new errors.PipedreamError({
statusCode: _response.error.statusCode,
body: _response.error.body,
rawResponse: _response.rawResponse,
});
}
}

switch (_response.error.reason) {
Expand Down
Loading