Ingest messages from external platforms

Ingest messages from external platforms (Discord, Telegram, etc.) into the central messaging system. This endpoint handles messages from external sources and routes them to the appropriate agents through the central message bus.

POST /api/messaging/ingest-external

Ingest messages from external platforms

cURL

curl --request POST \
  --url http://localhost:3000/api/messaging/ingest-external \
  --header 'Content-Type: application/json' \
  --data '
{
  "agentId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
  "roomId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
  "userId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
  "text": "<string>",
  "sourceId": "<string>",
  "metadata": {}
}
'

import requests

url = "http://localhost:3000/api/messaging/ingest-external"

payload = {
    "agentId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
    "roomId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
    "userId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
    "text": "<string>",
    "sourceId": "<string>",
    "metadata": {}
}
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({
    agentId: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
    roomId: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
    userId: '3c90c3cc-0d44-4b50-8888-8dd25736052a',
    text: '<string>',
    sourceId: '<string>',
    metadata: {}
  })
};

fetch('http://localhost:3000/api/messaging/ingest-external', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_PORT => "3000",
  CURLOPT_URL => "http://localhost:3000/api/messaging/ingest-external",
  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([
    'agentId' => '3c90c3cc-0d44-4b50-8888-8dd25736052a',
    'roomId' => '3c90c3cc-0d44-4b50-8888-8dd25736052a',
    'userId' => '3c90c3cc-0d44-4b50-8888-8dd25736052a',
    'text' => '<string>',
    'sourceId' => '<string>',
    'metadata' => [
        
    ]
  ]),
  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 := "http://localhost:3000/api/messaging/ingest-external"

	payload := strings.NewReader("{\n  \"agentId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"roomId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"userId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"text\": \"<string>\",\n  \"sourceId\": \"<string>\",\n  \"metadata\": {}\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("http://localhost:3000/api/messaging/ingest-external")
  .header("Content-Type", "application/json")
  .body("{\n  \"agentId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"roomId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"userId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"text\": \"<string>\",\n  \"sourceId\": \"<string>\",\n  \"metadata\": {}\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("http://localhost:3000/api/messaging/ingest-external")

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

request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n  \"agentId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"roomId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"userId\": \"3c90c3cc-0d44-4b50-8888-8dd25736052a\",\n  \"text\": \"<string>\",\n  \"sourceId\": \"<string>\",\n  \"metadata\": {}\n}"

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

200

{
  "success": true
}

{
  "success": false,
  "error": {
    "code": "<string>",
    "message": "<string>",
    "details": "<string>"
  }
}

{
  "success": false,
  "error": {
    "code": "<string>",
    "message": "<string>",
    "details": "<string>"
  }
}

Body

application/json

agentId · string<uuid> · required

roomId · string<uuid> · required

userId · string<uuid> · required

text · string · required

sourceId · string · required

sourceType · enum<string> · required

Available options: discord, telegram, twitter

metadata · object

Response

200

application/json

Message ingested successfully

success · boolean