chore(sdk-v2): use tshy

Author: ryanleecode

.changeset/brown-lions-cross.md

@@ -0,0 +1,5 @@
+---
+"@systemfsoftware/trigger.dev_sdk-v2": patch
+---
+
+use tshy for building v2 sdk

packages/trigger-sdk-v2/package.json

@@ -1,34 +1,48 @@
 {
   "name": "@systemfsoftware/trigger.dev_sdk-v2",
+  "type": "module",
   "version": "2.5.0",
   "description": "trigger.dev Node.JS SDK",
   "license": "MIT",
-  "main": "./dist/index.js",
-  "types": "./dist/index.d.ts",
-  "module": "./dist/index.mjs",
+  "main": "./dist/commonjs/index.js",
+  "types": "./dist/commonjs/index.d.ts",
+  "module": "./dist/esm/index.js",
   "publishConfig": {
     "access": "public"
   },
-  "files": [
-    "dist"
-  ],
   "exports": {
+    "./package.json": "./package.json",
     ".": {
       "import": {
-        "types": "./dist/index.d.mts",
-        "default": "./dist/index.mjs"
+        "@trigger.dev/source": "./src/index.ts",
+        "types": "./dist/esm/index.d.ts",
+        "default": "./dist/esm/index.js"
       },
-      "require": "./dist/index.js",
-      "types": "./dist/index.d.ts"
+      "require": {
+        "types": "./dist/commonjs/index.d.ts",
+        "default": "./dist/commonjs/index.js"
+      }
+    }
+  },
+  "files": [
+    "dist"
+  ],
+  "tshy": {
+    "project": "./tsconfig.build.json",
+    "exports": {
+      "./package.json": "./package.json",
+      ".": "./src/index.ts"
     },
-    "./package.json": "./package.json"
+    "sourceDialects": [
+      "@trigger.dev/source"
+    ]
   },
   "scripts": {
     "prepare": "pnpm turbo build",
-    "clean": "rimraf dist",
-    "build": "pnpm run clean && pnpm run build:tsup",
-    "build:tsup": "tsup --dts-resolve",
-    "typecheck": "tsc --noEmit"
+    "clean": "rimraf dist .tshy .tshy-build",
+    "build": "pnpm run clean && tshy",
+    "typecheck": "tsc --noEmit",
+    "test": "echo 'no tests'"
   },
   "dependencies": {
     "@systemfsoftware/trigger.dev_core-v2": "workspace:^",
@@ -38,8 +52,7 @@
     "debug": "^4.3.4",
     "slug": "^6.0.0",
     "terminal-link": "^3.0.0",
-    "ws": "^8.11.0",
-    "typed-emitter": "^2.1.0"
+    "ws": "^8.11.0"
   },
   "peerDependencies": {
     "zod": "3.x",

packages/trigger-sdk-v2/src/apiClient.ts

@@ -1,50 +1,50 @@
 import {
   API_VERSIONS,
-  ApiEventLog,
+  type ApiEventLog,
   ApiEventLogSchema,
   CancelRunsForEventSchema,
   CancelRunsForJobSchema,
-  CompleteTaskBodyV2Input,
+  type CompleteTaskBodyV2Input,
   ConnectionAuthSchema,
-  EphemeralEventDispatcherRequestBody,
+  type EphemeralEventDispatcherRequestBody,
   EphemeralEventDispatcherResponseBodySchema,
-  FailTaskBodyInput,
+  type FailTaskBodyInput,
   GetEventSchema,
-  GetRunOptionsWithTaskDetails,
+  type GetRunOptionsWithTaskDetails,
   GetRunSchema,
   GetRunStatusesSchema,
-  GetRunsOptions,
+  type GetRunsOptions,
   GetRunsSchema,
-  InvokeJobRequestBody,
+  type InvokeJobRequestBody,
   InvokeJobResponseSchema,
-  InvokeOptions,
+  type InvokeOptions,
   JobRunStatusRecordSchema,
-  KeyValueStoreResponseBody,
+  type KeyValueStoreResponseBody,
   KeyValueStoreResponseBodySchema,
   RegisterScheduleResponseBodySchema,
   RegisterSourceEventSchemaV2,
-  RegisterSourceEventV2,
-  RegisterTriggerBodyV2,
-  RunTaskBodyInput,
+  type RegisterSourceEventV2,
+  type RegisterTriggerBodyV2,
+  type RunTaskBodyInput,
   RunTaskResponseWithCachedTasksBodySchema,
-  ScheduleMetadata,
-  SendEvent,
-  SendEventOptions,
+  type ScheduleMetadata,
+  type SendEvent,
+  type SendEventOptions,
   ServerTaskSchema,
-  StatusUpdate,
-  TriggerSource,
+  type StatusUpdate,
+  type TriggerSource,
   TriggerSourceSchema,
-  UpdateTriggerSourceBodyV2,
-  UpdateWebhookBody,
+  type UpdateTriggerSourceBodyV2,
+  type UpdateWebhookBody,
   assertExhaustive,
   urlWithSearchParams,
 } from "@systemfsoftware/trigger.dev_core";
-import { LogLevel, Logger } from "@systemfsoftware/trigger.dev_core-backend";
+import { type LogLevel, Logger } from "@systemfsoftware/trigger.dev_core-backend";
 import { env } from "node:process";
 
 import { z } from "zod";
-import { KeyValueStoreClient } from "./store/keyValueStoreClient";
-import { AutoYieldRateLimitError } from "./errors";
+import { KeyValueStoreClient } from "./store/keyValueStoreClient.js";
+import { AutoYieldRateLimitError } from "./errors.js";
 
 export type ApiClientOptions = {
   apiKey?: string;

packages/trigger-sdk-v2/src/errors.ts

@@ -1,66 +1,66 @@
-import { DisplayProperty } from "@systemfsoftware/trigger.dev_core";
-import { ErrorWithStack, SchemaError, type ServerTask } from "@systemfsoftware/trigger.dev_core";
+import { type DisplayProperty } from "@systemfsoftware/trigger.dev_core";
+import { type ErrorWithStack, type SchemaError, type ServerTask } from "@systemfsoftware/trigger.dev_core";
 import { Data } from "effect";
 
 export class ResumeWithTaskError extends Data.TaggedError("ResumeWithTaskError")<{
-  task: ServerTask;
+  readonly task: ServerTask;
 }> {
-  constructor(readonly task: ServerTask) {
+  constructor(task: ServerTask) {
     super({ task });
   }
 }
 
 export class ResumeWithParallelTaskError extends Data.TaggedError("ResumeWithTaskError")<{
-  task: ServerTask;
-  childErrors: ReadonlyArray<TriggerInternalError>;
+  readonly task: ServerTask;
+  readonly childErrors: ReadonlyArray<TriggerInternalError>;
 }> {
   constructor(
-    readonly task: ServerTask,
-    readonly childErrors: ReadonlyArray<TriggerInternalError>
+    task: ServerTask,
+    childErrors: ReadonlyArray<TriggerInternalError>
   ) {
     super({ task, childErrors });
   }
 }
 
 export class RetryWithTaskError extends Data.TaggedError("RetryWithTaskError")<{
-  cause: ErrorWithStack;
-  task: ServerTask;
-  retryAt: Date;
+  readonly cause: ErrorWithStack;
+  readonly task: ServerTask;
+  readonly retryAt: Date;
 }> {
   constructor(
-    readonly cause: ErrorWithStack,
-    readonly task: ServerTask,
-    readonly retryAt: Date
+    cause: ErrorWithStack,
+    task: ServerTask,
+    retryAt: Date
   ) {
     super({ cause, task, retryAt });
   }
 }
 
 export class CanceledWithTaskError extends Data.TaggedError("CanceledWithTaskError")<{
-  task: ServerTask;
+  readonly task: ServerTask;
 }> {
-  constructor(readonly task: ServerTask) {
+  constructor(task: ServerTask) {
     super({ task });
   }
 }
 
 export class YieldExecutionError extends Data.TaggedError("YieldExecutionError")<{
-  key: string;
+  readonly key: string;
 }> {
-  constructor(readonly key: string) {
+  constructor(key: string) {
     super({ key });
   }
 }
 
 export class AutoYieldExecutionError extends Data.TaggedError("YieldExecutionError")<{
-  location: string;
-  timeRemaining: number;
-  timeElapsed: number;
+  readonly location: string;
+  readonly timeRemaining: number;
+  readonly timeElapsed: number;
 }> {
   constructor(
-    readonly location: string,
-    readonly timeRemaining: number,
-    readonly timeElapsed: number
+    location: string,
+    timeRemaining: number,
+    timeElapsed: number
   ) {
     super({ location, timeRemaining, timeElapsed });
   }
@@ -69,33 +69,33 @@ export class AutoYieldExecutionError extends Data.TaggedError("YieldExecutionErr
 export class AutoYieldWithCompletedTaskExecutionError extends Data.TaggedError(
   "AutoYieldWithCompletedTaskExecutionError"
 )<{
-  id: string;
-  properties?: DisplayProperty[];
-  data: { location: string; timeRemaining: number; timeElapsed: number };
-  output?: string;
+  readonly id: string;
+  readonly properties?: DisplayProperty[];
+  readonly data: { location: string; timeRemaining: number; timeElapsed: number };
+  readonly output?: string;
 }> {
   constructor(
-    readonly id: string,
-    readonly properties: DisplayProperty[] | undefined,
-    readonly data: { location: string; timeRemaining: number; timeElapsed: number },
-    readonly output?: string
+    id: string,
+    properties: DisplayProperty[] | undefined,
+    data: { location: string; timeRemaining: number; timeElapsed: number },
+    output?: string
   ) {
     super({ id, properties, data, output });
   }
 }
 
 export class AutoYieldRateLimitError extends Data.TaggedError("AutoYieldRateLimitError")<{
-  resetAtTimestamp: number;
+  readonly resetAtTimestamp: number;
 }> {
-  constructor(readonly resetAtTimestamp: number) {
+  constructor(resetAtTimestamp: number) {
     super({ resetAtTimestamp });
   }
 }
 
 export class ParsedPayloadSchemaError extends Data.TaggedError("ParsedPayloadSchemaError")<{
-  schemaErrors: ReadonlyArray<SchemaError>;
+  readonly schemaErrors: ReadonlyArray<SchemaError>;
 }> {
-  constructor(readonly schemaErrors: ReadonlyArray<SchemaError>) {
+  constructor(schemaErrors: ReadonlyArray<SchemaError>) {
     super({ schemaErrors });
   }
 }
@@ -131,12 +131,12 @@ export function isTriggerError(err: unknown): err is TriggerInternalError {
 
 // This error isn't an internal error but it can be used by the user to figure out which task caused the error
 export class ErrorWithTask extends Data.TaggedError("ErrorWithTask")<{
-  cause: ServerTask;
-  message: string;
+  readonly cause: ServerTask;
+  readonly message: string;
 }> {
   constructor(
-    readonly cause: ServerTask,
-    readonly message: string
+    cause: ServerTask,
+    message: string
   ) {
     super({ cause, message });
   }

packages/trigger-sdk-v2/src/httpEndpoint.ts

@@ -1,17 +1,17 @@
 import {
-  DisplayProperty,
-  EventFilter,
-  HttpEndpointMetadata,
-  RequestFilter,
+  type DisplayProperty,
+  type EventFilter,
+  type HttpEndpointMetadata,
+  type RequestFilter,
   RequestWithRawBodySchema,
-  TriggerMetadata,
+  type TriggerMetadata,
 } from "@systemfsoftware/trigger.dev_core";
-import { ParsedPayloadSchemaError } from "./errors";
-import { Job } from "./job";
-import { TriggerClient } from "./triggerClient";
-import { EventSpecification, EventSpecificationExample, Trigger, VerifyResult } from "./types";
-import { formatSchemaErrors } from "./utils/formatSchemaErrors";
-import { slugifyId } from "./utils";
+import { ParsedPayloadSchemaError } from "./errors.js";
+import { Job } from "./job.js";
+import { TriggerClient } from "./triggerClient.js";
+import type { EventSpecification, EventSpecificationExample, Trigger, VerifyResult } from "./types.js";
+import { formatSchemaErrors } from "./utils/formatSchemaErrors.js";
+import { slugifyId } from "./utils.js";
 
 type HttpEndpointOptions<TEventSpecification extends EventSpecification<any>> = {
   id: string;

packages/trigger-sdk-v2/src/index.ts

@@ -4,31 +4,31 @@ if (TRIGGER_DOT_DEV_MARKER in globalThis) {
 }
 (globalThis as any)[TRIGGER_DOT_DEV_MARKER] = true;
 
-export * from "./job";
-export * from "./triggerClient";
-export * from "./integrations";
-export * from "./triggers/eventTrigger";
-export * from "./triggers/externalSource";
-export * from "./triggers/dynamic";
-export * from "./triggers/scheduled";
-export * from "./triggers/notifications";
-export * from "./triggers/invokeTrigger";
-export * from "./triggers/webhook";
-export * from "./io";
-export * from "./types";
-export * from "./utils";
-export * from "./security";
+export * from "./job.js";
+export * from "./triggerClient.js";
+export * from "./integrations.js";
+export * from "./triggers/eventTrigger.js";
+export * from "./triggers/externalSource.js";
+export * from "./triggers/dynamic.js";
+export * from "./triggers/scheduled.js";
+export * from "./triggers/notifications.js";
+export * from "./triggers/invokeTrigger.js";
+export * from "./triggers/webhook.js";
+export * from "./io.js";
+export * from "./types.js";
+export * from "./utils.js";
+export * from "./security.js";
 
-import { ServerTask } from "@systemfsoftware/trigger.dev_core";
-import { RedactString } from "./types";
-export { isTriggerError } from "./errors";
-export { retry } from "./retry";
+import type { ServerTask } from "@systemfsoftware/trigger.dev_core";
+import type { RedactString } from "./types.js";
+export { isTriggerError } from "./errors.js";
+export { retry } from "./retry.js";
 
 export type { NormalizedRequest, EventFilter } from "@systemfsoftware/trigger.dev_core";
 
 export type Task = ServerTask;
 
-import { ApiEventLog } from "@systemfsoftware/trigger.dev_core";
+import type { ApiEventLog } from "@systemfsoftware/trigger.dev_core";
 export type SentEvent = ApiEventLog;
 
 /*

packages/trigger-sdk-v2/src/integrations.ts

@@ -1,6 +1,5 @@
-import { ConnectionAuth, IntegrationMetadata } from "@systemfsoftware/trigger.dev_core";
-import { IO } from "./io";
-import { Prettify } from "@systemfsoftware/trigger.dev_core";
+import type { ConnectionAuth, IntegrationMetadata } from "@systemfsoftware/trigger.dev_core";
+import { IO } from "./io.js";
 export type { ConnectionAuth } from "@systemfsoftware/trigger.dev_core";
 
 export interface TriggerIntegration {