Add tools.sendEvent() to step function tooling

README.md

@@ -35,9 +35,9 @@ Inngest allows you to:
 <br />
 
 <p align="center">
-<a href="#getting-started">Getting started</a> · 
-<a href="#features">Features</a> · 
-<a href="#contributing">Contributing</a> · 
+<a href="#getting-started">Getting started</a> ·
+<a href="#features">Features</a> ·
+<a href="#contributing">Contributing</a> ·
 <a href="https://www.inngest.com/docs">Documentation</a>
 </p>
 

etc/inngest.api.md

@@ -14,29 +14,19 @@ export interface ClientOptions {
     name: string;
 }
 
-// Warning: (ae-forgotten-export) The symbol "EventName" needs to be exported by the entry point index.d.ts
-// Warning: (ae-forgotten-export) The symbol "InngestFunction" needs to be exported by the entry point index.d.ts
-//
-// @public
-export const createFunction: <Event_1 extends EventPayload>(nameOrOpts: string | FunctionOptions, event: EventName<Event_1>, fn: SingleStepFn<Event_1, string, "step">) => InngestFunction<any>;
-
-// @public
-export const createScheduledFunction: (nameOrOpts: string | FunctionOptions, cron: string, fn: SingleStepFn<null, string, "step">) => InngestFunction<any>;
-
-// @public
-export const createStepFunction: <T extends EventPayload>(nameOrOpts: string | FunctionOptions, event: EventName<T>, fn: MultiStepFn<Record<T["name"], T>, T["name"], string, "step">) => InngestFunction<any>;
-
 // @public
 export interface EventPayload {
     data: any;
     name: string;
     ts?: number;
-    user?: Record<string, any>;
+    user?: any;
     v?: string;
 }
 
 // @public
 export interface FunctionOptions {
+    // (undocumented)
+    fns?: Record<string, any>;
     id?: string;
     idempotency?: string;
     name: string;
@@ -51,30 +41,14 @@ export interface FunctionOptions {
 // @public
 export class Inngest<Events extends Record<string, EventPayload>> {
     constructor({ name, eventKey, inngestBaseUrl, fetch, }: ClientOptions);
-    createFunction<Event extends keyof Events, Name extends string, Fn extends SingleStepFn<Events[Event], Name, "step">>(
-    name: Name,
-    event: Event,
-    fn: Fn): InngestFunction<Events>;
-    createFunction<Event extends keyof Events, Opts extends FunctionOptions, Fn extends SingleStepFn<Events[Event], Opts extends FunctionOptions ? Opts["name"] : string, "step">>(
-    opts: Opts,
-    event: Event,
-    fn: Fn): InngestFunction<Events>;
-    createScheduledFunction<Name extends string>(
-    name: Name,
-    cron: string,
-    fn: SingleStepFn<null, Name, "step">): InngestFunction<Events>;
-    createScheduledFunction<Opts extends FunctionOptions>(
-    opts: Opts,
-    cron: string,
-    fn: SingleStepFn<null, Opts extends FunctionOptions ? Opts["name"] : string, "step">): InngestFunction<Events>;
-    createStepFunction<Event extends keyof Events, Name extends string, Fn extends MultiStepFn<Events, Event, Name, "step">>(
-    name: Name,
-    event: Event,
-    fn: Fn): InngestFunction<Events>;
-    createStepFunction<Event extends keyof Events, Opts extends FunctionOptions, Fn extends MultiStepFn<Events, Event, Opts extends FunctionOptions ? Opts["name"] : string, "step">>(
-    opts: Opts,
-    event: Event,
-    fn: Fn): InngestFunction<Events>;
+    // Warning: (ae-forgotten-export) The symbol "TriggerOptions" needs to be exported by the entry point index.d.ts
+    // Warning: (ae-forgotten-export) The symbol "Handler" needs to be exported by the entry point index.d.ts
+    // Warning: (ae-forgotten-export) The symbol "InngestFunction" needs to be exported by the entry point index.d.ts
+    //
+    // (undocumented)
+    createFunction<Trigger extends TriggerOptions<keyof Events & string>, NameOrOpts extends string | FunctionOptions>(nameOrOpts: NameOrOpts, trigger: Trigger, fn: Handler<Events, Trigger extends string ? Trigger : Trigger extends {
+        event: string;
+    } ? Trigger["event"] : string, NameOrOpts extends FunctionOptions ? NameOrOpts : never>): InngestFunction<Events>;
     readonly inngestBaseUrl: URL;
     readonly name: string;
     // Warning: (ae-forgotten-export) The symbol "SingleOrArray" needs to be exported by the entry point index.d.ts
@@ -86,10 +60,10 @@ export class Inngest<Events extends Record<string, EventPayload>> {
     eventKey: string): void;
 }
 
-// Warning: (ae-forgotten-export) The symbol "Handler" needs to be exported by the entry point index.d.ts
+// Warning: (ae-forgotten-export) The symbol "Handler_2" needs to be exported by the entry point index.d.ts
 //
 // @public
-export class InngestCommHandler<H extends Handler, TransformedRes> {
+export class InngestCommHandler<H extends Handler_2, TransformedRes> {
     constructor(
     frameworkName: string,
     appNameOrInngest: string | Inngest<any>,
@@ -116,7 +90,7 @@ export class InngestCommHandler<H extends Handler, TransformedRes> {
     // Warning: (ae-forgotten-export) The symbol "StepRunResponse" needs to be exported by the entry point index.d.ts
     //
     // (undocumented)
-    protected runStep(functionId: string, stepId: string, data: any): Promise<StepRunResponse>;
+    protected runStep(functionId: string, stepId: string | null, data: any): Promise<StepRunResponse>;
     // Warning: (ae-forgotten-export) The symbol "RegisterRequest" needs to be exported by the entry point index.d.ts
     protected get sdkHeader(): [
     prefix: string,
@@ -137,17 +111,6 @@ export class InngestCommHandler<H extends Handler, TransformedRes> {
     protected validateSignature(): boolean;
 }
 
-// @public
-export type MultiStepFn<Events extends Record<string, EventPayload>, Event extends keyof Events, FnId, StepId> = (arg: MultiStepFnArgs<Events, Event, FnId, StepId>) => void;
-
-// @public
-export interface MultiStepFnArgs<Events extends Record<string, EventPayload>, Event extends keyof Events, FnId, StepId> extends SingleStepFnArgs<Events[Event], FnId, StepId> {
-    // Warning: (ae-forgotten-export) The symbol "createStepTools" needs to be exported by the entry point index.d.ts
-    //
-    // (undocumented)
-    tools: ReturnType<typeof createStepTools<Events, Event>>[0];
-}
-
 // @public
 export class NonRetriableError extends Error {
     constructor(message: string, options?: {
@@ -173,20 +136,7 @@ functions: InngestFunction<any>[],
 opts?: RegisterOptions) => any;
 
 // @public
-export type SingleStepFn<Event, FnId, StepId> = (arg: SingleStepFnArgs<Event, FnId, StepId>) => any;
-
-// @public
-export interface SingleStepFnArgs<Event, FnId, StepId> {
-    ctx: {
-        fn_id: FnId;
-        step_id: StepId;
-    };
-    event: Event;
-    steps: Record<string, never>;
-}
-
-// @public
-export type TimeStr = `${`${number}w` | ""}${`${number}d` | ""}${`${number}h` | ""}${`${number}m` | ""}${`${number}s` | ""}${`${number}ms` | ""}`;
+export type TimeStr = `${`${number}w` | ""}${`${number}d` | ""}${`${number}h` | ""}${`${number}m` | ""}${`${number}s` | ""}`;
 
 // (No @packageDocumentation comment for this package)
 

package.json

@@ -55,8 +55,9 @@
     "cross-fetch": "^3.1.5",
     "h3": "^1.0.2",
     "hash.js": "^1.1.7",
+    "json-stringify-deterministic": "^1.0.8",
     "ms": "^2.1.3",
-    "sigmund": "^1.0.1",
+    "serialize-error-cjs": "^0.1.3",
     "type-fest": "^3.5.1",
     "zod": "^3.19.1"
   },
@@ -68,7 +69,6 @@
     "@types/jest": "^27.4.1",
     "@types/ms": "^0.7.31",
     "@types/sha.js": "^2.4.0",
-    "@types/sigmund": "^1.0.0",
     "@typescript-eslint/eslint-plugin": "^5.47.0",
     "@typescript-eslint/parser": "^5.47.0",
     "concurrently": "^7.4.0",

src/cloudflare.ts

@@ -60,6 +60,7 @@ export const serve: ServeHandler = (nameOrInngest, fns, opts) => {
           if (req.method === "POST") {
             return {
               fnId: url.searchParams.get(queryKeys.FnId) as string,
+              stepId: url.searchParams.get(queryKeys.StepId) as string,
               data: (await req.json()) as Record<string, any>,
               env,
               isProduction,