How to Pass Session Context to Ads in OpenAI Assistants API

Overview

Ad relevance in a OpenAI Assistants API app comes from context. When you inject, you pass a session id, the live prompt, and optional metadata — that is what lets Monetzly match a recommendation to what the user is actually asking about in that turn.

The session id groups turns from the same conversation; the prompt drives per-turn relevance; metadata carries anything extra you want to target on. All are supplied per injection call.

OpenAI Assistants API apps are usually built for hosted chat assistants, file-search agents, and tool-calling assistants, so pass session context to ads typically comes up while a user is mid-conversation, the moment where monetization has to be additive rather than disruptive.

How this works on OpenAI Assistants API

The Node OpenAI SDK streams run/completion events. Map each text delta event to { content: delta } and feed the generator into sdk.inject(). The Monetzly side is standard; the only framework detail to confirm is the exact delta event field for your chosen mode (Assistants run stream vs Chat Completions).

Because Monetzly's inject() accepts any async token stream, the OpenAI Assistants API side of this task is just mapping your output to it, no rewrite of your OpenAI Assistants API model call.

Steps

1. Choose a stable session id for the conversation (reuse your OpenAI Assistants API session or thread id).
2. Pass the current user prompt on each injection call.
3. Add optional metadata (topic, user type) to sharpen targeting.

Integration snippet

import OpenAI from "openai";
import { MonetzlySDK } from "@monetzly/server-sdk";

const openai = new OpenAI();
const sdk = new MonetzlySDK({
  apiKey: process.env.MONETZLY_API_KEY!,
  serverAddress: process.env.MONETZLY_SERVER_ADDRESS!,
});
await sdk.connect();

const stream = await openai.chat.completions.create({
  model: "gpt-4o-mini", messages, stream: true,
});

async function* asChunks() {
  // TODO_VERIFY: for the Assistants run stream, read the text delta from the
  // run event instead of choices[0].delta.content.
  for await (const ev of stream) yield { content: ev.choices[0]?.delta?.content ?? "" };
}

for await (const t of sdk.inject(asChunks(), { prompt })) send(t.content ?? "");
await sdk.disconnect();

Frequently asked questions

Related