Inject Message

Inject a user message into a running agent execution.

The message is queued for the agent to absorb at its next natural breakpoint (between iterations). It is also persisted immediately to the conversation history.

Returns 409 if no active execution exists for the conversation.

POST /api/chat/inject

Inject Message

cURL

curl --request POST \
  --url https://your-domain.com/api/chat/inject \
  --header 'Content-Type: application/json' \
  --data '
{
  "conversation_id": "<string>",
  "content": "<string>"
}
'

import requests

url = "https://your-domain.com/api/chat/inject"

payload = {
    "conversation_id": "<string>",
    "content": "<string>"
}
headers = {"Content-Type": "application/json"}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({conversation_id: '<string>', content: '<string>'})
};

fetch('https://your-domain.com/api/chat/inject', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://your-domain.com/api/chat/inject",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'conversation_id' => '<string>',
    'content' => '<string>'
  ]),
  CURLOPT_HTTPHEADER => [
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://your-domain.com/api/chat/inject"

	payload := strings.NewReader("{\n  \"conversation_id\": \"<string>\",\n  \"content\": \"<string>\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://your-domain.com/api/chat/inject")
  .header("Content-Type", "application/json")
  .body("{\n  \"conversation_id\": \"<string>\",\n  \"content\": \"<string>\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://your-domain.com/api/chat/inject")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n  \"conversation_id\": \"<string>\",\n  \"content\": \"<string>\"\n}"

response = http.request(request)
puts response.read_body

200

{}

{
  "detail": [
    {
      "loc": [
        "<string>"
      ],
      "msg": "<string>",
      "type": "<string>",
      "input": "<unknown>",
      "ctx": {}
    }
  ]
}

Body

application/json

Request body for injecting a message into an active agent execution.

conversation_id · string · required

content · string · required

Response

200

application/json

Successful Response

The response is of type Response Inject Message Api Chat Inject Post · object.