.ts

// 1. Current Approach
import { Inngest } from "inngest";

const inngest = new Inngest({ id: "my-app" });

// This function will be invoked by Inngest via HTTP any time
// the "app/user.signup" event is sent to to Inngest
export default inngest.createFunction(
  { id: "user-onboarding-communication" },
  { event: "app/user.signup" },
  async ({ event, step }) => {
    await step.run("Send welcome email", async () => {
      await sendEmail({
        email: event.data.email,
        template: "welcome",
      });
    });
  }
);

// 2. Proposal
import { router} from "./trpc"
import { procedure } from "inngest";
import { z } from "zod";

export const inngestRouter = router({
    // Example from above, auto generated event ID
    userOnboardCommunication: procedure({ // settings })
        .input(z.object({ email: z.string().email() }))
        .query(async { step, input} => {
            await step.run("Send welcome email", async () => {
                await sendEmail({
                    email: input.email,
                    template: "welcome",
                });
            });
        }),
    
    // External events, reusable events, defined on router, backwards compatible with current reusable event system.
    legacyEvent: procedure
        .eventInput("app/user.signup")
        .query(async { step, input} => {
            await step.run("Send welcome email", async () => {
                await sendEmail({
                    email: event.data.email,
                    template: "welcome",
                });
            });
        })

})