import { n as createLogger, t as Logger } from "./logger-aELKpp5T.mjs";
import { S as WorkflowStepContext, _ as WorkflowRuntimeOpts, a as ChannelAuthConfig, b as StepRunOptions, c as isChannelDefinition, f as isWorkflowDefinition, g as WorkflowOpts, i as isChannelExport, l as WorkflowDefinition, n as ChannelHandle, o as ChannelDefinition, p as isWorkflowExport, r as defineChannel, s as VerifyInput, t as ChannelExport, u as WorkflowExport, v as WorkflowContext, x as StepWaitOptions, y as WorkflowHandler } from "./define-BWpz3yEf.mjs";
import { a as ChannelGrant, c as ChannelMessage, d as ChannelPublishOptions, f as ChannelSocket, g as TakoStatus, h as FetchHandler, i as ChannelDefinitionTransport, m as ChannelSubscription, n as ChannelAuthorizeResponse, p as ChannelSubscribeOptions, r as ChannelConnectOptions, t as ChannelAuthorizeInput, u as ChannelPublishInput } from "./types-B5u76zpA.mjs";
import { t as loadSecrets } from "./secrets-DMrGmidS.mjs";

//#region src/channels.d.ts
interface RegistryEntry {
  name: string;
  definition: ChannelDefinition;
}
/**
 * Handle returned by the default export of a `<app_root>/channels/<name>.ts` file
 * (unparameterized) or by invoking a parameterized channel with its params.
 */
declare class ChannelRegistry {
  private entries;
  get all(): ReadonlyArray<RegistryEntry>;
  register(name: string, input: ChannelDefinition | {
    readonly definition: ChannelDefinition;
  }): void;
  clear(): void;
  /** Look up a discovered channel by its declared channel name. */
  findByName(name: string): RegistryEntry | undefined;
  resolve(channel: string): {
    definition: ChannelDefinition;
    params: Record<string, unknown>;
  } | null;
  authorize(input: ChannelAuthorizeInput): Promise<ChannelAuthorizeResponse>;
}
//#endregion
//#region src/tako/endpoints.d.ts
/**
 * Handle Tako internal endpoints (internal host only).
 *
 * Returns a Response for internal requests, or null for non-internal requests.
 */
declare function handleTakoEndpoint(request: Request, status: TakoStatus, channels: ChannelRegistry): Promise<Response | null>;
//#endregion
//#region src/tako/fetch-response.d.ts
declare function normalizeFetchResponse(response: Response): Response;
//#endregion
//#region src/tako/init.d.ts
/**
 * Shared server-runtime initialization.
 *
 * Every context that hosts a Tako server-side user module — production
 * server entry (`createEntrypoint.run`), Vite dev plugin, future edge
 * adapters — installs the same publisher + runtime registrations so that
 * `Channel.publish()`, `signal()`, and `defineWorkflow(...).enqueue()`
 * all work when invoked from app code.
 *
 * Worker entrypoints call `setWorkflowRuntime` separately because they
 * first need to configure `workflowsEngine` with an explicit
 * `WorkflowsClient` identity.
 */
declare function initServerRuntime(): void;
//#endregion
export { type ChannelAuthConfig, type ChannelConnectOptions, type ChannelDefinition, type ChannelDefinitionTransport, type ChannelExport, type ChannelGrant, type ChannelHandle, type ChannelMessage, type ChannelPublishInput, type ChannelPublishOptions, type ChannelSocket, type ChannelSubscribeOptions, type ChannelSubscription, type FetchHandler, type Logger, type StepRunOptions, type StepWaitOptions, type TakoStatus, type VerifyInput, type WorkflowContext, type WorkflowDefinition, type WorkflowExport, type WorkflowHandler, type WorkflowOpts, type WorkflowRuntimeOpts, type WorkflowStepContext, createLogger, defineChannel, handleTakoEndpoint, initServerRuntime, isChannelDefinition, isChannelExport, isWorkflowDefinition, isWorkflowExport, loadSecrets, normalizeFetchResponse };
//# sourceMappingURL=internal.d.mts.map