The wake-up call for AI agents.

import { createServer } from "node:http"import { McpServer, createMcpHandler } from "@modelcontextprotocol/server"import { toNodeHandler } from "@modelcontextprotocol/node"import { Wakeshift } from "@wakeshift/sdk"import { z } from "zod"const wake = new Wakeshift() // reads WAKESHIFT_KEYconst crawlFinished = wake.defineEvent("crawl.finished", {  description: "A site crawl finished",  args: z.object({ site: z.string() }),  payload: z.object({ pages: z.number() }),  text: (crawl, { site }) => `Crawl of ${site} finished: ${crawl.pages} pages`,  public: true, // open to every agent, not only your tools})const mcp = createMcpHandler(() => {  const server = new McpServer({ name: "crawler", version: "1.0.0" })  wake.attach(server) // agents can now subscribe  return server})createServer(toNodeHandler(mcp)).listen(3000)// When the crawl finishes, wake every agent waiting on itawait crawlFinished.emit({ site: "example.com" }, { pages: 1834 })

import asynciofrom mcp.server.mcpserver import MCPServerfrom pydantic import BaseModelfrom wakeshift import Wakeshiftclass Site(BaseModel):    site: strclass Crawl(BaseModel):    pages: intwake = Wakeshift()  # reads WAKESHIFT_KEYcrawl_finished = wake.define_event(    "crawl.finished", description="A site crawl finished", args=Site, payload=Crawl,    text=lambda crawl, s: f"Crawl of {s.site} finished: {crawl.pages} pages",    public=True,  # open to every agent, not only your tools)server = MCPServer("crawler")wake.attach(server)  # agents can now subscribe# When the crawl finishes, wake every agent waiting on itasyncio.run(crawl_finished.emit({"site": "example.com"}, {"pages": 1834}))

package crawlerimport (	"context"	"fmt"	"github.com/modelcontextprotocol/go-sdk/mcp"	"github.com/wakeshift/wakeshift-go")func Serve(ctx context.Context, srv *mcp.Server, key string) error {	wake, err := wakeshift.New(wakeshift.WithKey(key))	if err != nil {		return err	}	crawlFinished, err := wakeshift.DefineEvent(wake, "crawl.finished", wakeshift.EventDef[Site, Crawl]{		Description: "A site crawl finished",		Public:      true, // open to every agent, not only your tools		Text: func(c Crawl, s Site) string {			return fmt.Sprintf("Crawl of %s finished: %d pages", s.Site, c.Pages)		},	})	if err != nil {		return err	}	wake.Attach(srv, wakeshift.AttachOptions{}) // agents can now subscribe	// When the crawl finishes, wake every agent waiting on it	_, err = crawlFinished.Emit(ctx, Site{"example.com"}, Crawl{1834})	return err}type Site struct {	Site string `json:"site"`}type Crawl struct {	Pages int `json:"pages"`}