Webhooks: Quick Reference

import OpenAI from "openai";

const client = new OpenAI({
  baseURL: "https://api.inference.net/v1/slow",
  apiKey: process.env.INFERENCE_API_KEY,
});

const response = await client.chat.completions.create({
  model: "google/gemma-3-27b-instruct/bf-16",
  messages: [{ role: "user", content: "Hello!" }],
  // @ts-expect-error metadata is not in the OpenAI SDK types
  metadata: { webhook_id: "YOUR_WEBHOOK_IDENTIFIER" },
});

import os
from openai import OpenAI

client = OpenAI(
    base_url="https://api.inference.net/v1/slow",
    api_key=os.environ["INFERENCE_API_KEY"],
)

response = client.chat.completions.create(
    model="google/gemma-3-27b-instruct/bf-16",
    messages=[{"role": "user", "content": "Hello!"}],
    extra_body={"metadata": {"webhook_id": "YOUR_WEBHOOK_IDENTIFIER"}},
)

curl https://api.inference.net/v1/slow/chat/completions \
  -H "Authorization: Bearer $INFERENCE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "google/gemma-3-27b-instruct/bf-16",
    "messages": [{"role": "user", "content": "Hello!"}],
    "metadata": {"webhook_id": "YOUR_WEBHOOK_IDENTIFIER"}
  }'

const embeddingResponse = await fetch(
  "https://api.inference.net/v1/async/embeddings",
  {
    method: "POST",
    headers: {
      Authorization: `Bearer ${process.env.INFERENCE_API_KEY}`,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      model: "qwen/qwen3-embedding-4b",
      input: ["Text to embed", "Another text to embed"],
      metadata: { webhook_id: "YOUR_WEBHOOK_IDENTIFIER" },
    }),
  },
);

import os
import requests

response = requests.post(
    "https://api.inference.net/v1/async/embeddings",
    headers={
        "Authorization": f"Bearer {os.environ['INFERENCE_API_KEY']}",
        "Content-Type": "application/json",
    },
    json={
        "model": "qwen/qwen3-embedding-4b",
        "input": ["Text to embed", "Another text to embed"],
        "metadata": {"webhook_id": "YOUR_WEBHOOK_IDENTIFIER"},
    },
)

curl https://api.inference.net/v1/async/embeddings \
  -H "Authorization: Bearer $INFERENCE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "model": "qwen/qwen3-embedding-4b",
    "input": ["Text to embed", "Another text to embed"],
    "metadata": {"webhook_id": "YOUR_WEBHOOK_IDENTIFIER"}
  }'

app.post("/webhook", express.json(), (req, res) => {
  res.status(200).json({ received: true });

  if (req.body.event === "generation.completed") {
    setImmediate(() => {
      console.log("Generation completed:", req.body.generation_id);
      // Your processing logic here
    });
  } else if (req.body.event === "async-embedding.completed") {
    setImmediate(() => {
      console.log("Embedding completed:", req.body.generation_id);
      console.log("Number of embeddings:", req.body.data.response.data.length);
    });
  } else if (req.body.event === "slow-group.completed") {
    setImmediate(() => {
      console.log("Group completed:", req.body.group_id);
      console.log("Group size:", req.body.data.group_size);
      req.body.data.generations.forEach((gen: any) => {
        console.log(`Generation ${gen.generationId}: ${gen.state}`);
      });
    });
  }
});

@app.post("/webhook")
async def handle_webhook(payload: dict, background_tasks: BackgroundTasks):
    background_tasks.add_task(process_webhook, payload)
    return {"received": True}

def process_webhook(payload):
    if payload["event"] == "generation.completed":
        print(f"Processing generation {payload['generation_id']}")
        # Your processing logic here
    elif payload["event"] == "async-embedding.completed":
        print(f"Processing embedding {payload['generation_id']}")
        print(f"Number of embeddings: {len(payload['data']['response']['data'])}")
    elif payload["event"] == "slow-group.completed":
        print(f"Processing group {payload['group_id']}")
        print(f"Group size: {payload['data']['group_size']}")
        for gen in payload["data"]["generations"]:
            print(f"Generation {gen['generationId']}: {gen['state']}")