Quickstart: give your AI agent Telegram in 5 minutes

// npm install @flow-engineer/messaging
import { FlowMessaging, contentText } from "@flow-engineer/messaging";

const flow = new FlowMessaging(); // reads FLOW_MESSAGING_KEY

for await (const event of flow.events.stream({ types: ["message.received"] })) {
  const said = contentText(event.data.message.content);
  console.log(`${event.conversation.channel}: ${said}`);
  await event.conversation.reply(`You said: ${said}`);
}

# The Python SDK is not published yet; this is the same agent over plain HTTP.
# pip install requests
import os, time, requests

API = "https://api.flow.engineer"
HEADERS = {
    "Authorization": f"Bearer {os.environ['FLOW_MESSAGING_KEY']}",
    "Flow-Version": "2026-11-01",
}

after = None
while True:
    params = {"type": "message.received", "limit": 100}
    if after:
        params["after"] = after
    page = requests.get(f"{API}/v1/events", headers=HEADERS, params=params, timeout=30).json()
    for event in page["data"]:
        after = event["id"]
        content = event["data"]["message"]["content"]
        said = content.get("text") or content.get("caption") or content.get("transcript") or ""
        requests.post(
            f"{API}/v1/conversations/{event['conversation']['id']}/messages",
            headers={**HEADERS, "Idempotency-Key": event["id"]},
            json={"content": {"type": "text", "text": f"You said: {said}"}},
            timeout=30,
        )
    if not page["has_more"]:
        time.sleep(1)

// The Go SDK is not published yet; this is the same agent over plain HTTP,
// standard library only.
package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"net/http"
	"net/url"
	"os"
	"time"
)

const api = "https://api.flow.engineer"

type event struct {
	ID           string `json:"id"`
	Conversation struct {
		ID string `json:"id"`
	} `json:"conversation"`
	Data struct {
		Message struct {
			Content struct {
				Type string `json:"type"`
				Text string `json:"text"`
			} `json:"content"`
		} `json:"message"`
	} `json:"data"`
}

func call(method, path string, body any, idempotencyKey string, out any) error {
	var buf bytes.Buffer
	if body != nil {
		if err := json.NewEncoder(&buf).Encode(body); err != nil {
			return err
		}
	}
	req, err := http.NewRequest(method, api+path, &buf)
	if err != nil {
		return err
	}
	req.Header.Set("Authorization", "Bearer "+os.Getenv("FLOW_MESSAGING_KEY"))
	req.Header.Set("Flow-Version", "2026-11-01")
	req.Header.Set("Content-Type", "application/json")
	if idempotencyKey != "" {
		req.Header.Set("Idempotency-Key", idempotencyKey)
	}
	res, err := http.DefaultClient.Do(req)
	if err != nil {
		return err
	}
	defer res.Body.Close()
	if res.StatusCode >= 300 {
		return fmt.Errorf("%s %s: %s", method, path, res.Status)
	}
	if out != nil {
		return json.NewDecoder(res.Body).Decode(out)
	}
	return nil
}

func main() {
	after := ""
	for {
		q := url.Values{"type": {"message.received"}, "limit": {"100"}}
		if after != "" {
			q.Set("after", after)
		}
		var page struct {
			Data    []event `json:"data"`
			HasMore bool    `json:"has_more"`
		}
		if err := call("GET", "/v1/events?"+q.Encode(), nil, "", &page); err != nil {
			fmt.Println(err)
			time.Sleep(2 * time.Second)
			continue
		}
		for _, ev := range page.Data {
			after = ev.ID
			reply := map[string]any{
				"content": map[string]any{"type": "text", "text": "You said: " + ev.Data.Message.Content.Text},
			}
			if err := call("POST", "/v1/conversations/"+ev.Conversation.ID+"/messages", reply, ev.ID, nil); err != nil {
				fmt.Println(err)
			}
		}
		if !page.HasMore {
			time.Sleep(time.Second)
		}
	}
}

# 1. Read the newest messages from the event log (oldest first; pass after=evt_... to page forward).
curl -G https://api.flow.engineer/v1/events \
  -H "Authorization: Bearer $FLOW_MESSAGING_KEY" \
  --data-urlencode "type=message.received"

# 2. Reply into the conversation from an event (data[].conversation.id).
curl https://api.flow.engineer/v1/conversations/conv_01JB8ZC3K5M7P9R1T3V5X7Z9B1/messages \
  -H "Authorization: Bearer $FLOW_MESSAGING_KEY" \
  -H "Content-Type: application/json" \
  -H "Idempotency-Key: $(uuidgen)" \
  -d '{"content": {"type": "text", "text": "Hello from my agent"}}'