How to Test Ad Injection Locally in Flowise

Overview

You can develop ad injection for a Flowise app locally before going to production. Point the SDK at a local ad-server address and turn SSL off; everything else — the injection call, session context, fallback — behaves the same as production.

This lets you verify that your Flowise stream flows through injection and reaches the client correctly without needing production credentials wired up.

Flowise apps are usually built for visual chatbot building, no-code RAG, and prototyping agent flows, so test ad injection locally typically comes up while a user is mid-conversation, the moment where monetization has to be additive rather than disruptive.

How this works on Flowise

Flowise runs on Node, so the Monetzly SDK can live in the layer that consumes a flow's prediction stream. Call the Flowise prediction API with streaming enabled, adapt its SSE token events to { content }, and pass them through sdk.inject() before relaying to your users. Confirm the streaming response shape for your Flowise version / deployment.

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

Steps

1. Set the server address to your local host (e.g. localhost:8080) and disable SSL.
2. Run your Flowise app and send a test prompt through the injection path.
3. Confirm tokens stream to the client, then switch to your production host and SSL for release.

Integration snippet

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

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

// TODO_VERIFY: adapt to your Flowise streaming prediction response shape.
async function* flowiseChunks() {
  const res = await fetch(`${FLOWISE_URL}/api/v1/prediction/${flowId}`, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ question, streaming: true }),
  });
  for await (const token of parseSSE(res.body!)) yield { content: token };
}

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

Frequently asked questions

Related