Webhook target support (#104)

* Add support for webhook targets

* Add changeset

* Fix type error

* fix

* Fix EOF lines

---------

Co-authored-by: Jordan Drake <jordan@plain.com>

Author: mattvagni

.changeset/hot-bags-boil.md

@@ -0,0 +1,5 @@
+---
+'@team-plain/typescript-sdk': minor
+---
+
+Add support for creating, updating, deleting and fetcing webhook targets.

src/client.ts

@@ -14,6 +14,7 @@ import {
   CreateCustomerEventDocument,
   CreateThreadDocument,
   CreateThreadEventDocument,
+  CreateWebhookTargetDocument,
   CustomerByEmailDocument,
   CustomerByIdDocument,
   type CustomerCardConfigPartsFragment,
@@ -26,6 +27,7 @@ import {
   CustomersDocument,
   DeleteCustomerCardConfigDocument,
   DeleteCustomerDocument,
+  DeleteWebhookTargetDocument,
   type EmailPartsFragment,
   type LabelPartsFragment,
   LabelTypeDocument,
@@ -49,10 +51,14 @@ import {
   ThreadsDocument,
   UnassignThreadDocument,
   UpdateCustomerCardConfigDocument,
+  UpdateWebhookTargetDocument,
   UpsertCustomerDocument,
   type UpsertResult,
   UserByEmailDocument,
   type UserPartsFragment,
+  WebhookTargetDocument,
+  type WebhookTargetPartsFragment,
+  WebhookTargetsDocument,
   type WorkspacePartsFragment,
 } from './graphql/types';
 import { request } from './request';
@@ -729,4 +735,74 @@ export class PlainClient {
 
     return unwrapData(res, (q) => nonNullable(q.createThreadEvent.threadEvent));
   }
+
+  async createWebhookTarget(
+    input: VariablesOf<typeof CreateWebhookTargetDocument>['input']
+  ): SDKResult<WebhookTargetPartsFragment> {
+    const res = await request(this.#ctx, {
+      query: CreateWebhookTargetDocument,
+      variables: {
+        input,
+      },
+    });
+
+    return unwrapData(res, (q) => nonNullable(q.createWebhookTarget.webhookTarget));
+  }
+
+  async updateWebhookTarget(
+    input: VariablesOf<typeof UpdateWebhookTargetDocument>['input']
+  ): SDKResult<WebhookTargetPartsFragment> {
+    const res = await request(this.#ctx, {
+      query: UpdateWebhookTargetDocument,
+      variables: {
+        input,
+      },
+    });
+
+    return unwrapData(res, (q) => nonNullable(q.updateWebhookTarget.webhookTarget));
+  }
+
+  async deleteWebhookTarget(
+    input: VariablesOf<typeof DeleteWebhookTargetDocument>['input']
+  ): SDKResult<null> {
+    const res = await request(this.#ctx, {
+      query: DeleteWebhookTargetDocument,
+      variables: {
+        input,
+      },
+    });
+
+    return unwrapData(res, () => null);
+  }
+
+  async getWebhookTargets(variables: VariablesOf<typeof WebhookTargetsDocument>): SDKResult<{
+    webhookTargets: WebhookTargetPartsFragment[];
+    pageInfo: PageInfoPartsFragment;
+  }> {
+    const res = await request(this.#ctx, {
+      query: WebhookTargetsDocument,
+      variables,
+    });
+
+    return unwrapData(res, (q) => ({
+      pageInfo: q.webhookTargets.pageInfo,
+      webhookTargets: q.webhookTargets.edges.map((edge) => edge.node),
+    }));
+  }
+
+  /**
+   * If the webhook target is not found it will return null
+   */
+  async getWebhookTargetById(
+    variables: VariablesOf<typeof WebhookTargetDocument>
+  ): SDKResult<WebhookTargetPartsFragment | null> {
+    const res = await request(this.#ctx, {
+      query: WebhookTargetDocument,
+      variables,
+    });
+
+    return unwrapData(res, (q) => {
+      return q.webhookTarget;
+    });
+  }
 }

src/graphql/fragments/webhookTargetEventSubscriptionParts.gql

@@ -0,0 +1,4 @@
+fragment WebhookTargetEventSubscriptionParts on WebhookTargetEventSubscription {
+  __typename
+  eventType
+}

src/graphql/fragments/webhookTargetParts.gql

@@ -0,0 +1,21 @@
+fragment WebhookTargetParts on WebhookTarget {
+  id
+  url
+  isEnabled
+  description
+  createdAt {
+    ...DateTimeParts
+  }
+  createdBy {
+    ...ActorParts
+  }
+  updatedAt {
+    ...DateTimeParts
+  }
+  updatedBy {
+    ...ActorParts
+  }
+  eventSubscriptions {
+    ...WebhookTargetEventSubscriptionParts
+  }
+}

src/graphql/mutations/createWebhookTarget.gql

@@ -0,0 +1,10 @@
+mutation createWebhookTarget($input: CreateWebhookTargetInput!) {
+  createWebhookTarget(input: $input) {
+    webhookTarget {
+      ...WebhookTargetParts
+    }
+    error {
+      ...MutationErrorParts
+    }
+  }
+}

src/graphql/mutations/deleteWebhookTarget.gql

@@ -0,0 +1,7 @@
+mutation deleteWebhookTarget($input: DeleteWebhookTargetInput!) {
+  deleteWebhookTarget(input: $input) {
+    error {
+      ...MutationErrorParts
+    }
+  }
+}

src/graphql/mutations/updateWebhookTarget.gql

@@ -0,0 +1,10 @@
+mutation updateWebhookTarget($input: UpdateWebhookTargetInput!) {
+  updateWebhookTarget(input: $input) {
+    webhookTarget {
+      ...WebhookTargetParts
+    }
+    error {
+      ...MutationErrorParts
+    }
+  }
+}

src/graphql/queries/webhookTarget.gql

@@ -0,0 +1,5 @@
+query webhookTarget($id: ID!) {
+  webhookTarget(webhookTargetId: $id) {
+    ...WebhookTargetParts
+  }
+}

src/graphql/queries/webhookTargets.gql

@@ -0,0 +1,13 @@
+query webhookTargets($first: Int, $after: String, $last: Int, $before: String) {
+  webhookTargets(first: $first, after: $after, last: $last, before: $before) {
+    edges {
+      cursor
+      node {
+        ...WebhookTargetParts
+      }
+    }
+    pageInfo {
+      ...PageInfoParts
+    }
+  }
+}