Compare commits
16 Commits
0dcd07a89f
...
dev
| Author | SHA1 | Date | |
|---|---|---|---|
| 873280d027 | |||
| ae27a2cdf5 | |||
| 5bf54f0d44 | |||
| 5c9bdc771d | |||
| dcef90d11f | |||
| afeaeba313 | |||
| 302dd7e965 | |||
| fb578fbf40 | |||
| a22ec0a7da | |||
| e3691e1f0a | |||
| 513f597080 | |||
| 6db3c5f4cc | |||
| cf1e389df1 | |||
| e48b5b3d4e | |||
| 2df7e18916 | |||
| e287e6197e |
15
.env.example
15
.env.example
@@ -1,5 +1,14 @@
|
|||||||
# LOG_LEVEL options: CRITICAL, ERROR, WARNING, INFO, DEBUG, NOTSET
|
# LOG_LEVEL options: CRITICAL, ERROR, WARNING, INFO, DEBUG, NOTSET
|
||||||
HOMESERVER_URL = "https://matrix.org"
|
|
||||||
USER_ID = "@botbot_user:matrix.org"
|
|
||||||
PASSWORD = "botbot_password"
|
|
||||||
LOG_LEVEL=INFO
|
LOG_LEVEL=INFO
|
||||||
|
|
||||||
|
# Matrix Configuration
|
||||||
|
MATRIX_HOMESERVER_URL="https://matrix.org"
|
||||||
|
MATRIX_USER_ID="@botbot_user:matrix.org"
|
||||||
|
MATRIX_PASSWORD="botbot_password"
|
||||||
|
MATRIX_LOGIN_TRIES=5 # Number of login attempts before giving up, default is 5
|
||||||
|
MATRIX_LOGIN_DELAY_INCREMENT=5 # Delay increment,in seconds, between login attempts, default is 5
|
||||||
|
AI_HANDLER_URL="http://ai_service:8000"
|
||||||
|
|
||||||
|
# OpenAI API Key
|
||||||
|
OPENAI_API_KEY=your_openai_api_key_here
|
||||||
|
AI_HANDLER_TOKEN=common_token_here
|
||||||
|
|||||||
132
README.md
132
README.md
@@ -1,3 +1,131 @@
|
|||||||
# botbot
|
# Botbot
|
||||||
|
|
||||||
Botbot, your not so friendly Bot
|
*Botbot, your not so friendly Bot*
|
||||||
|
|
||||||
|
**Botbot** aimsto be a multi‑service chat assistant for [Matrix](https://matrix.org) that captures room conversations, stores them, and uses Large‑Language‑Models to provide concise summaries, answer follow‑up questions, and surface action points.
|
||||||
|
|
||||||
|
### Roadmap / Aspirational goals
|
||||||
|
|
||||||
|
* Persistent conversation store (PostgreSQL) for long‑range context.
|
||||||
|
* Pluggable LLM back‑ends (local models, Ollama, etc.).
|
||||||
|
* Structured meeting summaries with action‑items and deadlines.
|
||||||
|
* Additional chat front‑ends (Telegram, WhatsApp, …).
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Architecture
|
||||||
|
|
||||||
|
```mermaid
|
||||||
|
flowchart LR
|
||||||
|
MS["matrix_service<br/>(Python & nio)"]
|
||||||
|
AI["ai_service<br/>(FastAPI)"]
|
||||||
|
Redis["Redis<br/>Deduplicates replies / guarantees idempotency"]
|
||||||
|
|
||||||
|
MS -- "HTTP (Bearer token)" --> AI
|
||||||
|
AI -- "Matrix Events" --> MS
|
||||||
|
|
||||||
|
MS -.-> Redis
|
||||||
|
AI -.-> Redis
|
||||||
|
```
|
||||||
|
|
||||||
|
| Component | Image / Entry‑Point | Purpose |
|
||||||
|
| ------------------- | ------------------------------------- | ------------------------------------------------------------------------------------- |
|
||||||
|
| **matrix\_service** | `python matrix_service/main.py` | Listens to Matrix rooms, forwards each message to `ai_service`, posts the reply back. |
|
||||||
|
| **ai\_service** | `python ai_service/main.py` (FastAPI) | Builds a prompt, calls the configured LLM (OpenAI today), caches the reply in Redis. |
|
||||||
|
| **redis** | `redis:7` | Reply cache & simple key/value store. |
|
||||||
|
|
||||||
|
The services talk to each other over the internal Docker network. Authentication between them is a static bearer token (`AI_HANDLER_TOKEN`).
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Current Features
|
||||||
|
|
||||||
|
* **Auto‑Join on Invite** – secure E2EE join including device verification.
|
||||||
|
* **Stateless AI handler** – FastAPI endpoint `/api/v1/message` receiving a JSON payload.
|
||||||
|
* **Idempotent replies** – duplicate Matrix events reuse the cached answer.
|
||||||
|
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Quick Start (development)
|
||||||
|
|
||||||
|
```bash
|
||||||
|
# clone & cd
|
||||||
|
$ git clone https://gitea.alluna.pt/jfig/botbot.git
|
||||||
|
$ cd botbot
|
||||||
|
|
||||||
|
# copy environment template
|
||||||
|
$ cp .env.example .env
|
||||||
|
# edit .env with your homeserver, credentials and OpenAI key
|
||||||
|
|
||||||
|
# start everything (hot‑reload volumes mounted)
|
||||||
|
$ docker compose up --build
|
||||||
|
```
|
||||||
|
|
||||||
|
The default compose file launches three containers:
|
||||||
|
|
||||||
|
* `matrix_service` – watches your rooms
|
||||||
|
* `ai_service` – handles AI prompts
|
||||||
|
* `redis` – reply cache
|
||||||
|
|
||||||
|
Stop with <kbd>Ctrl‑C</kbd> or `docker compose down`.
|
||||||
|
|
||||||
|
### Production (single image per service)
|
||||||
|
|
||||||
|
Build once, then deploy with your orchestrator of choice:
|
||||||
|
|
||||||
|
```bash
|
||||||
|
$ docker compose -f docker-compose.yml --profile prod build
|
||||||
|
$ docker compose -f docker-compose.yml --profile prod up -d
|
||||||
|
```
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Configuration
|
||||||
|
|
||||||
|
All settings are environment variables. The table below reflects the current codebase (commit `ae27a2c`).
|
||||||
|
|
||||||
|
| Variable | Service | Default | Description |
|
||||||
|
| ------------------------------ | --------------- | ------------------------ | ---------------------------------------- |
|
||||||
|
| `LOG_LEVEL` | both | `INFO` | Python logging level. |
|
||||||
|
| `MATRIX_HOMESERVER_URL` | matrix\_service | – | Matrix homeserver base URL. |
|
||||||
|
| `MATRIX_USER_ID` | matrix\_service | – | Full user id of the bot. |
|
||||||
|
| `MATRIX_PASSWORD` | matrix\_service | – | Password for the bot account. |
|
||||||
|
| `MATRIX_LOGIN_TRIES` | matrix\_service | `5` | Number of login attempts before exit. |
|
||||||
|
| `MATRIX_LOGIN_DELAY_INCREMENT` | matrix\_service | `5` | Seconds added per retry. |
|
||||||
|
| `AI_HANDLER_URL` | matrix\_service | `http://ai_service:8000` | Where to POST messages. |
|
||||||
|
| `AI_HANDLER_TOKEN` | both | – | Shared bearer token (keep secret). |
|
||||||
|
| `OPENAI_API_KEY` | ai\_service | – | Key for `openai` Python SDK. |
|
||||||
|
| `REDIS_URL` | ai\_service | `redis://redis:6379` | Connection string used by `redis-py`. |
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## API (ai\_service)
|
||||||
|
|
||||||
|
```http
|
||||||
|
POST /api/v1/message
|
||||||
|
Authorization: Bearer <AI_HANDLER_TOKEN>
|
||||||
|
Content-Type: application/json
|
||||||
|
|
||||||
|
{
|
||||||
|
"roomId": "!foo:matrix.org",
|
||||||
|
"userId": "@alice:matrix.org",
|
||||||
|
"eventId": "$abc123",
|
||||||
|
"serverTimestamp": 1714821630123,
|
||||||
|
"content": "Hello there"
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
Returns `{"reply": "Hello Alice!"}` or HTTP 401/500 on error.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## Contributing
|
||||||
|
|
||||||
|
Pull requests are welcome! Please open an issue first to discuss what you want to change. All source code is formatted with **ruff** / **black** – run `pre-commit run --all-files` before pushing.
|
||||||
|
|
||||||
|
---
|
||||||
|
|
||||||
|
## License
|
||||||
|
|
||||||
|
[MIT](LICENSE)
|
||||||
|
|||||||
12
ai_service/Dockerfile
Normal file
12
ai_service/Dockerfile
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
FROM python:3.11-slim
|
||||||
|
|
||||||
|
WORKDIR /app
|
||||||
|
|
||||||
|
COPY requirements.txt ./
|
||||||
|
|
||||||
|
RUN pip install --no-cache-dir -r requirements.txt
|
||||||
|
|
||||||
|
COPY main.py ./
|
||||||
|
|
||||||
|
CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "8000"]
|
||||||
|
|
||||||
66
ai_service/main.py
Normal file
66
ai_service/main.py
Normal file
@@ -0,0 +1,66 @@
|
|||||||
|
import os
|
||||||
|
from dotenv import load_dotenv
|
||||||
|
from fastapi import FastAPI, Header, HTTPException
|
||||||
|
from pydantic import BaseModel
|
||||||
|
from openai import OpenAI
|
||||||
|
import logging
|
||||||
|
import redis
|
||||||
|
|
||||||
|
LOG_LEVEL = os.getenv("LOG_LEVEL", "INFO").upper()
|
||||||
|
AI_TOKEN = os.environ["AI_HANDLER_TOKEN"]
|
||||||
|
|
||||||
|
AIclient = OpenAI(
|
||||||
|
api_key=os.environ["OPENAI_API_KEY"],
|
||||||
|
)
|
||||||
|
|
||||||
|
r = redis.Redis.from_url(os.environ.get("REDIS_URL", "redis://redis:6379"))
|
||||||
|
|
||||||
|
# --- Logging Setup ---
|
||||||
|
numeric_level = getattr(logging, LOG_LEVEL, logging.INFO)
|
||||||
|
logging.basicConfig(
|
||||||
|
level=numeric_level,
|
||||||
|
format="%(asctime)s %(levelname)s %(name)s: %(message)s"
|
||||||
|
)
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
class MessagePayload(BaseModel):
|
||||||
|
roomId: str
|
||||||
|
userId: str
|
||||||
|
eventId: str
|
||||||
|
serverTimestamp: int
|
||||||
|
content: str
|
||||||
|
|
||||||
|
app = FastAPI()
|
||||||
|
|
||||||
|
@app.post("/api/v1/message")
|
||||||
|
async def message(
|
||||||
|
payload: MessagePayload,
|
||||||
|
authorization: str = Header(None)
|
||||||
|
):
|
||||||
|
if authorization != f"Bearer {AI_TOKEN}":
|
||||||
|
raise HTTPException(status_code=401, detail="Unauthorized")
|
||||||
|
|
||||||
|
# Idempotency: ignore duplicates
|
||||||
|
if r.get(payload.eventId):
|
||||||
|
return {"reply": r.get(payload.eventId).decode()}
|
||||||
|
|
||||||
|
# Build prompt (very simple example)
|
||||||
|
prompt = f"User {payload.userId} said: {payload.content}\nBot:"
|
||||||
|
chat_response = AIclient.chat.completions.create(
|
||||||
|
model="gpt-3.5-turbo",
|
||||||
|
messages=[
|
||||||
|
{"role": "system", "content": "You are a helpful assistant."},
|
||||||
|
{"role": "user", "content": prompt}
|
||||||
|
],
|
||||||
|
max_tokens=150,
|
||||||
|
n=1,
|
||||||
|
stop=None,
|
||||||
|
temperature=0.7,
|
||||||
|
)
|
||||||
|
|
||||||
|
reply = chat_response.choices[0].message.content.strip()
|
||||||
|
|
||||||
|
# Cache reply for idempotency
|
||||||
|
r.set(payload.eventId, reply, ex=3600)
|
||||||
|
|
||||||
|
return {"reply": reply}
|
||||||
6
ai_service/requirements.txt
Normal file
6
ai_service/requirements.txt
Normal file
@@ -0,0 +1,6 @@
|
|||||||
|
python-dotenv>=1.0.0
|
||||||
|
openai>=1.0.0
|
||||||
|
fastapi>=0.95
|
||||||
|
uvicorn>=0.22
|
||||||
|
redis>=4.5
|
||||||
|
pydantic>=1.10
|
||||||
@@ -1,11 +1,29 @@
|
|||||||
services:
|
services:
|
||||||
botbot:
|
matrix_service:
|
||||||
build: .
|
build: ./matrix_service
|
||||||
env_file:
|
environment:
|
||||||
- .env
|
- MATRIX_HOMESERVER_URL
|
||||||
|
- MATRIX_USER_ID
|
||||||
|
- MATRIX_PASSWORD
|
||||||
|
- AI_HANDLER_URL
|
||||||
|
- AI_HANDLER_TOKEN
|
||||||
volumes:
|
volumes:
|
||||||
- ./:/app # Mount source for hot-reload
|
- ./matrix_service:/app
|
||||||
- matrix_data:/app/data # Persist Matrix client store and tokens
|
- matrix_data:/app/data
|
||||||
|
depends_on:
|
||||||
|
- ai_service
|
||||||
|
|
||||||
|
ai_service:
|
||||||
|
build: ./ai_service
|
||||||
|
environment:
|
||||||
|
- OPENAI_API_KEY=${OPENAI_API_KEY}
|
||||||
|
- AI_HANDLER_TOKEN=${AI_HANDLER_TOKEN}
|
||||||
|
- REDIS_URL=redis://redis:6379
|
||||||
|
depends_on:
|
||||||
|
- redis
|
||||||
|
|
||||||
|
redis:
|
||||||
|
image: redis:7
|
||||||
restart: unless-stopped
|
restart: unless-stopped
|
||||||
|
|
||||||
volumes:
|
volumes:
|
||||||
|
|||||||
100
main.py
100
main.py
@@ -1,100 +0,0 @@
|
|||||||
import os
|
|
||||||
import asyncio
|
|
||||||
import logging
|
|
||||||
from dotenv import load_dotenv
|
|
||||||
from nio import AsyncClient, AsyncClientConfig, MatrixRoom, RoomMessageText, InviteMemberEvent
|
|
||||||
from nio.responses import LoginResponse
|
|
||||||
|
|
||||||
# --- Load environment variables ---
|
|
||||||
load_dotenv()
|
|
||||||
HOMESERVER_URL = os.getenv("HOMESERVER_URL")
|
|
||||||
USER_ID = os.getenv("USER_ID")
|
|
||||||
PASSWORD = os.getenv("PASSWORD")
|
|
||||||
LOG_LEVEL = os.getenv("LOG_LEVEL", "INFO").upper()
|
|
||||||
|
|
||||||
# --- Logging Setup ---
|
|
||||||
# Convert string level to numeric
|
|
||||||
numeric_level = getattr(logging, LOG_LEVEL, logging.INFO)
|
|
||||||
logging.basicConfig(
|
|
||||||
level=numeric_level,
|
|
||||||
format="%(asctime)s %(levelname)s %(name)s: %(message)s"
|
|
||||||
)
|
|
||||||
logger = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
async def message_callback(room: MatrixRoom, event: RoomMessageText):
|
|
||||||
"""
|
|
||||||
Called when a new text message is received.
|
|
||||||
"""
|
|
||||||
logger.debug("Message callback triggered")
|
|
||||||
if event.sender == USER_ID:
|
|
||||||
return
|
|
||||||
|
|
||||||
body = event.body.strip().lower()
|
|
||||||
logger.info("Message from %s in %s: %s", event.sender, room.display_name, event.body)
|
|
||||||
|
|
||||||
if event.body.strip().lower() == "!ping":
|
|
||||||
await client.room_send(
|
|
||||||
room_id=room.room_id,
|
|
||||||
message_type="m.room.message",
|
|
||||||
content={"msgtype": "m.text", "body": "Pong!"}
|
|
||||||
)
|
|
||||||
logger.info("Replied with Pong! to %s", event.sender)
|
|
||||||
elif body== "hello botbot":
|
|
||||||
await client.room_send(
|
|
||||||
room_id=room.room_id,
|
|
||||||
message_type="m.room.message",
|
|
||||||
content={
|
|
||||||
"msgtype": "m.text",
|
|
||||||
"body": "Hello! How can I assist you today?",
|
|
||||||
},
|
|
||||||
ignore_unverified_devices=True
|
|
||||||
)
|
|
||||||
logger.info("Replied with greeting to %s", event.sender)
|
|
||||||
|
|
||||||
async def invite_cb(room, event):
|
|
||||||
"""
|
|
||||||
Called when the bot is invited to a room.
|
|
||||||
"""
|
|
||||||
logger.debug("Invite callback triggered")
|
|
||||||
if event.state_key == USER_ID:
|
|
||||||
await client.join(room.room_id)
|
|
||||||
logger.info("Auto-joined invited room %s", room.room_id)
|
|
||||||
|
|
||||||
async def main():
|
|
||||||
global client
|
|
||||||
logger.debug(HOMESERVER_URL)
|
|
||||||
logger.debug(USER_ID)
|
|
||||||
# Configure client with persistent store
|
|
||||||
config = AsyncClientConfig(
|
|
||||||
store_sync_tokens=True,
|
|
||||||
encryption_enabled=True,
|
|
||||||
)
|
|
||||||
client = AsyncClient(
|
|
||||||
HOMESERVER_URL,
|
|
||||||
USER_ID,
|
|
||||||
store_path="/app/data",
|
|
||||||
config=config
|
|
||||||
)
|
|
||||||
|
|
||||||
# Login
|
|
||||||
resp = await client.login(password=PASSWORD)
|
|
||||||
logger.debug("Login response raw: %r", resp.__dict__)
|
|
||||||
if not isinstance(resp, LoginResponse) or not resp.access_token:
|
|
||||||
error_msg = getattr(resp, 'message', repr(resp))
|
|
||||||
logger.error("Login failed: %s", error_msg)
|
|
||||||
await client.close()
|
|
||||||
return
|
|
||||||
logger.info("Logged in successfully as %s", USER_ID)
|
|
||||||
|
|
||||||
# Register callback and start syncing
|
|
||||||
client.add_event_callback(message_callback, RoomMessageText)
|
|
||||||
client.add_event_callback(invite_cb, InviteMemberEvent)
|
|
||||||
logger.info("Starting sync loop with timeout=30000ms")
|
|
||||||
await client.sync_forever(timeout=30000)
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
try:
|
|
||||||
asyncio.run(main())
|
|
||||||
except KeyboardInterrupt:
|
|
||||||
logger.info("Received interrupt, shutting down client")
|
|
||||||
asyncio.run(client.close())
|
|
||||||
@@ -4,10 +4,12 @@ FROM python:3.11-slim
|
|||||||
WORKDIR /app
|
WORKDIR /app
|
||||||
|
|
||||||
# Install system dependencies
|
# Install system dependencies
|
||||||
RUN apt-get update && \
|
RUN apt-get update && apt-get install -y --no-install-recommends \
|
||||||
apt-get install -y --no-install-recommends \
|
libolm-dev \
|
||||||
libolm-dev build-essential python3-dev && \
|
build-essential \
|
||||||
rm -rf /var/lib/apt/lists/*
|
python3-dev \
|
||||||
|
&& \
|
||||||
|
apt-get clean && rm -rf /var/lib/apt/lists/*
|
||||||
|
|
||||||
# Install dependencies
|
# Install dependencies
|
||||||
COPY requirements.txt .
|
COPY requirements.txt .
|
||||||
174
matrix_service/main.py
Normal file
174
matrix_service/main.py
Normal file
@@ -0,0 +1,174 @@
|
|||||||
|
import os
|
||||||
|
import logging
|
||||||
|
from dotenv import load_dotenv
|
||||||
|
|
||||||
|
import asyncio
|
||||||
|
import httpx
|
||||||
|
|
||||||
|
from nio import AsyncClient, AsyncClientConfig, MatrixRoom, RoomMessageText, InviteMemberEvent
|
||||||
|
from nio.responses import LoginResponse
|
||||||
|
|
||||||
|
|
||||||
|
# --- Load environment variables ---
|
||||||
|
load_dotenv()
|
||||||
|
MATRIX_HOMESERVER_URL = os.getenv("MATRIX_HOMESERVER_URL")
|
||||||
|
MATRIX_USER_ID = os.getenv("MATRIX_USER_ID")
|
||||||
|
MATRIX_PASSWORD = os.getenv("MATRIX_PASSWORD")
|
||||||
|
MATRIX_LOGIN_TRIES = int(os.getenv("MATRIX_LOGIN_TRIES", 5))
|
||||||
|
MATRIX_LOGIN_DELAY_INCREMENT = int(os.getenv("MATRIX_LOGIN_DELAY_INCREMENT", 5))
|
||||||
|
|
||||||
|
LOG_LEVEL = os.getenv("LOG_LEVEL", "INFO").upper()
|
||||||
|
|
||||||
|
AI_HANDLER_URL = os.getenv("AI_HANDLER_URL")
|
||||||
|
AI_HANDLER_TOKEN = os.getenv("AI_HANDLER_TOKEN")
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
# --- Logging Setup ---
|
||||||
|
numeric_level = getattr(logging, LOG_LEVEL, logging.INFO)
|
||||||
|
logging.basicConfig(
|
||||||
|
level=numeric_level,
|
||||||
|
format="%(asctime)s %(levelname)s %(name)s: %(message)s"
|
||||||
|
)
|
||||||
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
|
|
||||||
|
async def main() -> None:
|
||||||
|
|
||||||
|
async def trust_all_devices(client) -> None:
|
||||||
|
"""
|
||||||
|
Mark every other user's device as verified so we can receive their
|
||||||
|
future Megolm keys without being blocked.
|
||||||
|
"""
|
||||||
|
for room_id in client.rooms:
|
||||||
|
try:
|
||||||
|
devices_in_room = client.room_devices(room_id)
|
||||||
|
for user_id, user_devices in devices_in_room.items():
|
||||||
|
if user_id == client.user_id:
|
||||||
|
continue
|
||||||
|
for dev_id, device in user_devices.items():
|
||||||
|
if not client.device_store.is_device_verified(device):
|
||||||
|
logger.info(f"Trusting {dev_id} for {user}")
|
||||||
|
client.verify_device(device)
|
||||||
|
except Exception:
|
||||||
|
logger.exception(f"Error trusting devices in {room_id}")
|
||||||
|
|
||||||
|
async def on_invite(room, event):
|
||||||
|
"""
|
||||||
|
Handle an invite event by joining the room and trusting all devices.
|
||||||
|
"""
|
||||||
|
if isinstance(event, InviteMemberEvent):
|
||||||
|
await client.join(room.room_id)
|
||||||
|
logger.info("Joined %s", room.room_id)
|
||||||
|
await trust_all_devices(client)
|
||||||
|
|
||||||
|
async def send_message(room: MatrixRoom, message: str) -> None:
|
||||||
|
"""
|
||||||
|
Send a message to `room`.
|
||||||
|
"""
|
||||||
|
try:
|
||||||
|
await trust_all_devices(client)
|
||||||
|
|
||||||
|
await client.share_group_session(
|
||||||
|
room.room_id,
|
||||||
|
ignore_unverified_devices=True
|
||||||
|
)
|
||||||
|
|
||||||
|
await client.room_send(
|
||||||
|
room_id=room.room_id,
|
||||||
|
message_type="m.room.message",
|
||||||
|
content={
|
||||||
|
"msgtype": "m.text",
|
||||||
|
"body": message
|
||||||
|
},
|
||||||
|
ignore_unverified_devices=True
|
||||||
|
)
|
||||||
|
logger.info("Sent message to %s: %s", room.room_id, message)
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(f"Error sending message: {e}")
|
||||||
|
|
||||||
|
|
||||||
|
async def on_message(room: MatrixRoom, event: RoomMessageText) -> None:
|
||||||
|
"""
|
||||||
|
Handle incoming messages.
|
||||||
|
"""
|
||||||
|
|
||||||
|
# Check if the message is from the bot itself
|
||||||
|
if event.sender == client.user_id:
|
||||||
|
return
|
||||||
|
|
||||||
|
logger.info("Received '%s' from %s in %s", event.body.strip(), event.sender, room.display_name)
|
||||||
|
|
||||||
|
|
||||||
|
if isinstance(event, RoomMessageText):
|
||||||
|
logger.info(f"Received message in {room.room_id}: {event.body}")
|
||||||
|
payload = {
|
||||||
|
"roomId": event.room_id,
|
||||||
|
"userId": event.sender,
|
||||||
|
"eventId": event.event_id,
|
||||||
|
"serverTimestamp": event.server_timestamp,
|
||||||
|
"content": event.body
|
||||||
|
}
|
||||||
|
headers = {"Authorization": f"Bearer {AI_HANDLER_TOKEN}"}
|
||||||
|
async with httpx.AsyncClient() as http:
|
||||||
|
try:
|
||||||
|
resp = await http.post(f"{AI_HANDLER_URL}/api/v1/message", json=payload, headers=headers)
|
||||||
|
resp.raise_for_status()
|
||||||
|
data = resp.json()
|
||||||
|
if data.get("reply"):
|
||||||
|
await trust_all_devices(client)
|
||||||
|
await send_message(room, data["reply"])
|
||||||
|
logger.info("Reply sent: %s", data["reply"])
|
||||||
|
except httpx.HTTPStatusError as e:
|
||||||
|
logger.error(f"HTTP error: {e.response.status_code} - {e.response.text}")
|
||||||
|
except Exception:
|
||||||
|
logger.exception("Error while calling AI handler")
|
||||||
|
|
||||||
|
# --- Initialize the client ---
|
||||||
|
# Create the data directory if it doesn't exist
|
||||||
|
try:
|
||||||
|
os.makedirs("/app/data", exist_ok=True)
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(f"Error creating data directory: {e}")
|
||||||
|
return
|
||||||
|
|
||||||
|
# Initialize the client
|
||||||
|
config = AsyncClientConfig(store_sync_tokens=True, encryption_enabled=True)
|
||||||
|
client = AsyncClient(MATRIX_HOMESERVER_URL, MATRIX_USER_ID, store_path="/app/data", config=config)
|
||||||
|
|
||||||
|
for i in range(MATRIX_LOGIN_TRIES):
|
||||||
|
try:
|
||||||
|
login_response=await client.login(password=MATRIX_PASSWORD)
|
||||||
|
break
|
||||||
|
except Exception as e:
|
||||||
|
logger.error("Login failed: %s", login_response)
|
||||||
|
logger.error(f"Login attempt {i+1} failed: {e}")
|
||||||
|
if i == MATRIX_LOGIN_TRIES - 1:
|
||||||
|
return
|
||||||
|
await asyncio.sleep(MATRIX_LOGIN_DELAY_INCREMENT * (i + 1))
|
||||||
|
logger.info("Logged in successfully")
|
||||||
|
|
||||||
|
logger.debug("Upload one time Olm keys")
|
||||||
|
try:
|
||||||
|
await client.keys_upload()
|
||||||
|
except Exception as e:
|
||||||
|
logger.error(f"Error uploading keys: {e}")
|
||||||
|
return
|
||||||
|
|
||||||
|
await trust_all_devices(client)
|
||||||
|
|
||||||
|
client.add_event_callback(on_invite, InviteMemberEvent)
|
||||||
|
client.add_event_callback(on_message, RoomMessageText)
|
||||||
|
|
||||||
|
logger.info("Starting sync loop")
|
||||||
|
await client.sync_forever(timeout=30000) # timeout should be moved to Variable
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == "__main__":
|
||||||
|
try:
|
||||||
|
asyncio.run(main())
|
||||||
|
except KeyboardInterrupt:
|
||||||
|
logger.info("Shutting down")
|
||||||
|
asyncio.run(client.close())
|
||||||
|
|
||||||
4
matrix_service/requirements.txt
Normal file
4
matrix_service/requirements.txt
Normal file
@@ -0,0 +1,4 @@
|
|||||||
|
matrix-nio[e2e]>=0.25.0
|
||||||
|
python-dotenv>=1.0.0
|
||||||
|
httpx>=0.23.0
|
||||||
|
pydantic>=1.10
|
||||||
@@ -1,2 +0,0 @@
|
|||||||
matrix-nio[e2e]>=0.25.0
|
|
||||||
python-dotenv>=1.0.0
|
|
||||||
Reference in New Issue
Block a user