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 .release-please-manifest.json
Original file line number Diff line number Diff line change
@@ -1,3 +1,3 @@
{
".": "0.4.5"
".": "0.5.0"
}
8 changes: 4 additions & 4 deletions .stats.yml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
configured_endpoints: 30
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/triglit%2Ftriglit-6adb2ace136bf74d9f70057816548b5dc9b3ced7a625862aefbc787ef731aad5.yml
openapi_spec_hash: 6afd1e92070452bb08999602775c6135
config_hash: 2b1cd9cfb3a07b42ea16d763355e61ea
configured_endpoints: 31
openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/triglit%2Ftriglit-a764b362cc7f0cc0e27f4288a948ae5f7495c073e0b05bf68fe7cff70bd4fd91.yml
openapi_spec_hash: fff16017770be5b1798130820585c72e
config_hash: a9236c7ca77fbb3b03a51c6f84b2c3a1
8 changes: 8 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,13 @@
# Changelog

## 0.5.0 (2025-11-21)

Full Changelog: [v0.4.5...v0.5.0](https://github.com/Triglit/typescript-sdk/compare/v0.4.5...v0.5.0)

### Features

* **api:** adiciona endpoint de ingest de eventos ([404d253](https://github.com/Triglit/typescript-sdk/commit/404d25384f67980df3bcda5c7b7db2325e9500d0))

## 0.4.5 (2025-11-18)

Full Changelog: [v0.4.4...v0.4.5](https://github.com/Triglit/typescript-sdk/compare/v0.4.4...v0.4.5)
Expand Down
2 changes: 2 additions & 0 deletions api.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ Types:

- <code><a href="./src/resources/triggers.ts">Trigger</a></code>
- <code><a href="./src/resources/triggers.ts">TriggerList</a></code>
- <code><a href="./src/resources/triggers.ts">TriggerIngestResponse</a></code>
- <code><a href="./src/resources/triggers.ts">TriggerTriggerByEventResponse</a></code>
- <code><a href="./src/resources/triggers.ts">TriggerTriggerWebhookResponse</a></code>

Expand All @@ -14,6 +15,7 @@ Methods:
- <code title="patch /v1/gateway/triggers/{triggerId}">client.triggers.<a href="./src/resources/triggers.ts">update</a>(triggerID, { ...params }) -> Trigger</code>
- <code title="get /v1/gateway/triggers">client.triggers.<a href="./src/resources/triggers.ts">list</a>({ ...params }) -> TriggersPageBased</code>
- <code title="delete /v1/gateway/triggers/{triggerId}">client.triggers.<a href="./src/resources/triggers.ts">delete</a>(triggerID) -> void</code>
- <code title="post /v1/gateway/triggers/ingest">client.triggers.<a href="./src/resources/triggers.ts">ingest</a>({ ...params }) -> TriggerIngestResponse</code>
- <code title="get /v1/gateway/triggers/workflow-version/{workflowVersionId}">client.triggers.<a href="./src/resources/triggers.ts">listByWorkflowVersion</a>(workflowVersionID, { ...params }) -> TriggersPageBased</code>
- <code title="post /v1/gateway/triggers/resume">client.triggers.<a href="./src/resources/triggers.ts">resumeExecution</a>({ ...params }) -> void</code>
- <code title="post /v1/gateway/triggers/webhook/by-event">client.triggers.<a href="./src/resources/triggers.ts">triggerByEvent</a>({ ...params }) -> TriggerTriggerByEventResponse</code>
Expand Down
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "triglit",
"version": "0.4.5",
"version": "0.5.0",
"description": "The official TypeScript library for the Triglit API",
"author": "Triglit <suporte@triglit.com>",
"types": "dist/index.d.ts",
Expand Down
4 changes: 4 additions & 0 deletions src/client.ts
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,8 @@ import {
import {
Trigger,
TriggerCreateParams,
TriggerIngestParams,
TriggerIngestResponse,
TriggerList,
TriggerListByWorkflowVersionParams,
TriggerListParams,
Expand Down Expand Up @@ -790,12 +792,14 @@ export declare namespace Triglit {
Triggers as Triggers,
type Trigger as Trigger,
type TriggerList as TriggerList,
type TriggerIngestResponse as TriggerIngestResponse,
type TriggerTriggerByEventResponse as TriggerTriggerByEventResponse,
type TriggerTriggerWebhookResponse as TriggerTriggerWebhookResponse,
type TriggersPageBased as TriggersPageBased,
type TriggerCreateParams as TriggerCreateParams,
type TriggerUpdateParams as TriggerUpdateParams,
type TriggerListParams as TriggerListParams,
type TriggerIngestParams as TriggerIngestParams,
type TriggerListByWorkflowVersionParams as TriggerListByWorkflowVersionParams,
type TriggerResumeExecutionParams as TriggerResumeExecutionParams,
type TriggerTriggerByEventParams as TriggerTriggerByEventParams,
Expand Down
2 changes: 2 additions & 0 deletions src/resources/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,13 @@ export {
Triggers,
type Trigger,
type TriggerList,
type TriggerIngestResponse,
type TriggerTriggerByEventResponse,
type TriggerTriggerWebhookResponse,
type TriggerCreateParams,
type TriggerUpdateParams,
type TriggerListParams,
type TriggerIngestParams,
type TriggerListByWorkflowVersionParams,
type TriggerResumeExecutionParams,
type TriggerTriggerByEventParams,
Expand Down
127 changes: 112 additions & 15 deletions src/resources/triggers.ts
Original file line number Diff line number Diff line change
Expand Up @@ -51,21 +51,31 @@ export class Triggers extends APIResource {
});
}

/**
* Retrieves a paginated list of triggers for a specific workflow version. Accepts
* both public and secret keys.
*/
listByWorkflowVersion(
workflowVersionID: string,
query: TriggerListByWorkflowVersionParams | null | undefined = {},
options?: RequestOptions,
): PagePromise<TriggersPageBased, Trigger> {
return this._client.getAPIList(
path`/v1/gateway/triggers/workflow-version/${workflowVersionID}`,
PageBased<Trigger>,
{ query, ...options },
);
}
/**
* Intelligently resumes paused executions for the same entityId and event, or
* triggers new workflows if no paused executions exist. This endpoint simplifies
* integration by automatically handling the decision between resuming and
* triggering.
*/
ingest(body: TriggerIngestParams, options?: RequestOptions): APIPromise<TriggerIngestResponse> {
return this._client.post('/v1/gateway/triggers/ingest', { body, ...options });
}

/**
* Retrieves a paginated list of triggers for a specific workflow version. Accepts
* both public and secret keys.
*/
listByWorkflowVersion(
workflowVersionID: string,
query: TriggerListByWorkflowVersionParams | null | undefined = {},
options?: RequestOptions,
): PagePromise<TriggersPageBased, Trigger> {
return this._client.getAPIList(
path`/v1/gateway/triggers/workflow-version/${workflowVersionID}`,
PageBased<Trigger>,
{ query, ...options },
);
}

/**
* Resumes a paused workflow execution with input data. Requires secret key
Expand Down Expand Up @@ -174,6 +184,71 @@ export interface TriggerList {
page: number;
}

export interface TriggerIngestResponse {
/**
* List of resumed executions
*/
resumed: Array<TriggerIngestResponse.Resumed>;

/**
* List of skipped executions
*/
skipped: Array<TriggerIngestResponse.Skipped>;

/**
* List of newly triggered workflows
*/
triggered: Array<TriggerIngestResponse.Triggered>;
}

export namespace TriggerIngestResponse {
export interface Resumed {
/**
* Entity ID
*/
entityId: string;

/**
* Run identifier that was resumed
*/
runId: string;

/**
* Workflow version identifier
*/
workflowVersionId: string;
}

export interface Skipped {
/**
* Reason why the execution was skipped
*/
reason: 'expired' | 'not_paused' | 'wrong_event' | 'filtered_out';

/**
* Run identifier (if applicable)
*/
runId?: string;
}

export interface Triggered {
/**
* Deduplication key
*/
dedupeKey: string;

/**
* Trigger identifier
*/
triggerId: string;

/**
* Run identifier (if workflow was started)
*/
runId?: string;
}
}

export interface TriggerTriggerByEventResponse {
/**
* Total number of triggers found and triggered
Expand Down Expand Up @@ -331,6 +406,26 @@ export interface TriggerListParams extends PageBasedParams {
workflowVersionId?: string;
}

export interface TriggerIngestParams {
event: string;

eventData?: { [key: string]: unknown };

resumeOptions?: TriggerIngestParams.ResumeOptions;

subTenantId?: string;
}

export namespace TriggerIngestParams {
export interface ResumeOptions {
resumeAll?: boolean;

runIds?: Array<string>;

workflowVersionIds?: Array<string>;
}
}

export interface TriggerListByWorkflowVersionParams extends PageBasedParams {}

export interface TriggerResumeExecutionParams {
Expand All @@ -357,12 +452,14 @@ export declare namespace Triggers {
export {
type Trigger as Trigger,
type TriggerList as TriggerList,
type TriggerIngestResponse as TriggerIngestResponse,
type TriggerTriggerByEventResponse as TriggerTriggerByEventResponse,
type TriggerTriggerWebhookResponse as TriggerTriggerWebhookResponse,
type TriggersPageBased as TriggersPageBased,
type TriggerCreateParams as TriggerCreateParams,
type TriggerUpdateParams as TriggerUpdateParams,
type TriggerListParams as TriggerListParams,
type TriggerIngestParams as TriggerIngestParams,
type TriggerListByWorkflowVersionParams as TriggerListByWorkflowVersionParams,
type TriggerResumeExecutionParams as TriggerResumeExecutionParams,
type TriggerTriggerByEventParams as TriggerTriggerByEventParams,
Expand Down
2 changes: 1 addition & 1 deletion src/version.ts
Original file line number Diff line number Diff line change
@@ -1 +1 @@
export const VERSION = '0.4.5'; // x-release-please-version
export const VERSION = '0.5.0'; // x-release-please-version
Loading
Loading