getHookByToken

Retrieve hook details and workflow run information by token.

Retrieves a hook by its unique token, returning the associated workflow run information and any metadata that was set when the hook was created. This function is useful for inspecting hook details before deciding whether to resume a workflow.

getHookByToken is a runtime function that must be called from outside a workflow function.

import { getHookByToken } from "workflow/api";

export async function POST(request: Request) {
  const { token } = await request.json();
  const hook = await getHookByToken(token);
  console.log("Hook belongs to run:", hook.runId);
}

Parameters

Name	Type	Description
`token`	string	The unique token identifying the hook

Returns

Returns a Promise<Hook> that resolves to:

Name	Type	Description
`runId`	string	The unique identifier of the workflow run this hook belongs to.
`hookId`	string	The unique identifier of this hook within the workflow run.
`token`	string	The secret token used to reference this hook.
`ownerId`	string	The owner ID (team or user) that owns this hook.
`projectId`	string	The project ID this hook belongs to.
`environment`	string	The environment (e.g., "production", "preview", "development") where this hook was created.
`createdAt`	Date	The timestamp when this hook was created.
`metadata`	unknown	Optional metadata associated with the hook, set when the hook was created.
`specVersion`	number	The spec version when this hook was created.
`isWebhook`	boolean	Whether this hook is resumable via the public webhook endpoint. undefined = legacy (treated as true for backwards compat).
`isSystem`	boolean	Whether this hook is a system-managed hook (e.g., for abort signals).

Basic Hook Lookup

Retrieve hook information before resuming:

import { getHookByToken, resumeHook } from "workflow/api";

export async function POST(request: Request) {
  const { token, data } = await request.json();

  try {
    // First, get the hook to inspect its metadata
    const hook = await getHookByToken(token); 

    console.log("Resuming workflow run:", hook.runId);
    console.log("Hook metadata:", hook.metadata);

    // Then resume the hook with the payload
    await resumeHook(token, data);

    return Response.json({
      success: true,
      runId: hook.runId
    });
  } catch (error) {
    return new Response("Hook not found", { status: 404 });
  }
}

Validating Hook Before Resume

Use getHookByToken to validate hook ownership or metadata before resuming:

import { getHookByToken, resumeHook } from "workflow/api";

export async function POST(request: Request) {
  const { token, userId, data } = await request.json();

  try {
    const hook = await getHookByToken(token); 
    const metadata = hook.metadata as { allowedUserId?: string } | undefined;

    // Validate that the hook metadata matches the user
    if (metadata?.allowedUserId !== userId) {
      return Response.json(
        { error: "Unauthorized to resume this hook" },
        { status: 403 }
      );
    }

    await resumeHook(token, data);
    return Response.json({ success: true, runId: hook.runId });
  } catch (error) {
    return Response.json({ error: "Hook not found" }, { status: 404 });
  }
}

Checking Hook Environment

Verify the hook belongs to the expected environment:

import { getHookByToken, resumeHook } from "workflow/api";

export async function POST(request: Request) {
  const { token, data } = await request.json();
  const expectedEnv = process.env.VERCEL_ENV || "development";

  try {
    const hook = await getHookByToken(token); 

    if (hook.environment !== expectedEnv) {
      return Response.json(
        { error: `Hook belongs to ${hook.environment} environment` },
        { status: 400 }
      );
    }

    await resumeHook(token, data);
    return Response.json({ runId: hook.runId });
  } catch (error) {
    return Response.json({ error: "Hook not found" }, { status: 404 });
  }
}

Logging Hook Information

Log hook details for debugging or auditing:

import { getHookByToken, resumeHook } from "workflow/api";

export async function POST(request: Request) {
  const url = new URL(request.url);
  const token = url.searchParams.get("token");

  if (!token) {
    return Response.json({ error: "Missing token" }, { status: 400 });
  }

  try {
    const hook = await getHookByToken(token); 

    // Log for auditing
    console.log({
      action: "hook_resume",
      runId: hook.runId,
      hookId: hook.hookId,
      projectId: hook.projectId,
      createdAt: hook.createdAt,
    });

    const body = await request.json();
    await resumeHook(token, body);

    return Response.json({ success: true });
  } catch (error) {
    return Response.json({ error: "Hook not found" }, { status: 404 });
  }
}

resumeHook() - Resume a hook with a payload.
createHook() - Create a hook in a workflow.
defineHook() - Type-safe hook helper.

推荐订阅源

Workflow SDK Documentation