adam/meshview
1
0
Fork 0
mirror of https://github.com/pablorevilla-meshtastic/meshview.git synced 2026-07-04 08:51:28 +02:00
Code Issues Packages Projects Releases Wiki Activity

add API code for /api/packets

Browse Source
This commit is contained in:
Pablo Revilla
2025-07-23 08:49:18 -07:00
parent f3dfdf6f04
commit 75a2189862
2 changed files with 144 additions and 128 deletions
Download Patch File Download Diff File Expand all files Collapse all files
API Documentation.md
+96 -103
View File
@@ -1,124 +1,117 @@
# API Documentation
This document describes the available REST API endpoints for **Chat** and **Nodes**. More will be added later.
## 1. Chat API
---
### GET `/api/chat`
Returns the most recent chat messages.
## **Chat API**
**Query Parameters**
- `limit` (optional, int): Maximum number of messages to return. Default: `100`.
### **`GET /api/chat`**
Fetches chat messages, with support for both initial loading and incremental updates.
#### **Query Parameters**
| Name | Type | Required | Description |
|----------|--------|----------|-------------|
| `limit` | int | No | Number of messages to return (default: 100, max: 200). |
| `since` | string | No | Return only messages with `import_time > since` (ISO 8601 format, e.g., `2025-07-21T12:00:00`). |
#### **Response (200 OK)**
**Response Example**
```json
{
"packets": [
{
"id": 123,
"import_time": "2025-07-22T14:12:00.123456",
"channel": "LongFast",
"from_node_id": 456789,
"long_name": "Node A",
"payload": "Hello world!"
}
],
"latest_import_time": "2025-07-22T14:12:00.123456"
}
```
**Fields:**
- `id`: Unique packet ID.
- `import_time`: ISO 8601 timestamp of when the message was imported.
- `channel`: Channel name.
- `from_node_id`: Numeric ID of the node that sent the message.
- `long_name`: Human-readable name of the node (if available).
- `payload`: Actual message text.
#### **Examples**
- **Get last 50 messages:**
```
GET /api/chat?limit=50
```
- **Get messages after a certain timestamp:**
```
GET /api/chat?since=2025-07-22T12:00:00
```
---
## **Nodes API**
### **`GET /api/nodes`**
Returns a list of all nodes, with optional filters based on "last seen" time.
#### **Query Parameters**
| Name | Type | Required | Description |
|-------------------|--------|----------|-------------|
| `hours` | int | No | Only return nodes seen within the last `N` hours. |
| `days` | int | No | Only return nodes seen within the last `N` days. |
| `last_seen_after` | string | No | Custom ISO 8601 timestamp for filtering (`2025-07-21T10:00:00`). |
**Note:** `hours` and `days` take precedence over `last_seen_after`.
#### **Response (200 OK)**
```json
{
"nodes": [
{
"node_id": 123456,
"long_name": "BaseStation",
"short_name": "BS",
"channel": "LongFast",
"last_seen": "2025-07-22T14:10:00.000000",
"hardware": "Heltec V3",
"firmware": "1.3.2",
"last_lat": 367919104,
"last_long": -1217003520,
"role": "CLIENT"
"import_time": "2025-07-22T12:45:00",
"from_node_id": 987654,
"from_node": "Alice",
"channel": "main",
"payload": "Hello, world!"
}
]
}
```
**Fields:**
- `node_id`: Unique ID of the node.
- `long_name`: Full descriptive name of the node.
- `short_name`: Short name or alias.
- `channel`: Channel the node is configured on.
- `last_seen`: ISO 8601 timestamp of the last time the node was seen.
- `hardware`: Hardware model (e.g., Heltec V3).
- `firmware`: Firmware version of the node.
- `role`: Node role (e.g., `CLIENT`, `ROUTER`, etc.).
---
#### **Examples**
- **All nodes:**
```
GET /api/nodes
```
- **Nodes seen in the last 1 hour:**
```
GET /api/nodes?hours=1
```
- **Nodes seen in the last 7 days:**
```
GET /api/nodes?days=7
```
- **Custom timestamp:**
```
GET /api/nodes?last_seen_after=2025-07-21T12:00:00
```
### GET `/api/chat/updates`
Returns chat messages imported after a given timestamp.
**Query Parameters**
- `last_time` (optional, ISO timestamp): Only messages imported after this time are returned.
**Response Example**
```json
{
"packets": [
{
"id": 124,
"import_time": "2025-07-22T12:50:00",
"from_node_id": 987654,
"from_node": "Alice",
"channel": "main",
"payload": "New message!"
}
],
"latest_import_time": "2025-07-22T12:50:00"
}
```
---
## **General Notes**
- All timestamps are returned in **localtime** (ISO 8601 format).
- Both endpoints return JSON responses with `application/json` content type.
- Error responses return `{"error": "message"}` with an appropriate HTTP status code (e.g., `500`).
## 2. Nodes API
### GET `/api/nodes`
Returns a list of all nodes, with optional filtering by last seen.
**Query Parameters**
- `hours` (optional, int): Return nodes seen in the last N hours.
- `days` (optional, int): Return nodes seen in the last N days.
- `last_seen_after` (optional, ISO timestamp): Return nodes seen after this time.
**Response Example**
```json
{
"nodes": [
{
"node_id": 1234,
"long_name": "Alice",
"short_name": "A",
"channel": "main",
"last_seen": "2025-07-22T12:40:00",
"hardware": "T-Beam",
"firmware": "1.2.3",
"role": "client",
"last_lat": 37.7749,
"last_long": -122.4194
}
]
}
```
---
## 3. Packets API
### GET `/api/packets`
Returns a list of packets with optional filters.
**Query Parameters**
- `limit` (optional, int): Maximum number of packets to return. Default: `200`.
- `since` (optional, ISO timestamp): Only packets imported after this timestamp are returned.
**Response Example**
```json
{
"packets": [
{
"id": 123,
"from_node_id": 5678,
"to_node_id": 91011,
"portnum": 1,
"import_time": "2025-07-22T12:45:00",
"payload": "Hello, Bob!"
}
]
}
```
---
### Notes
- All timestamps (`import_time`, `last_seen`) are returned in ISO 8601 format.
- `portnum` is an integer representing the packet type.
- `payload` is always a UTF-8 decoded string.
meshview/web.py
+48 -25
View File
@@ -321,29 +321,6 @@ async def packet_list(request):
return web.Response(status=500, text="Internal server error")
@routes.get("/packet_list_text/{node_id}")
async def packet_list_text(request):
node_id = int(request.match_info["node_id"])
portnum = int(request.query.get("portnum")) if request.query.get("portnum") else None
async with asyncio.TaskGroup() as tg:
raw_packets = tg.create_task(store.get_packets(node_id, portnum, limit=200))
packets = [Packet.from_model(p) for p in await raw_packets] # Convert generator to a list
# Convert packets to a plain text format with formatted import time and raw payload
text_data = "\n\n----------------------\n\n".join(
f"{packet.import_time.strftime('%-I:%M:%S %p - %m-%d-%Y')}\n{packet.raw_payload}"
for packet in packets
)
return web.Response(
text=text_data,
content_type="text/plain",
)
@routes.get("/packet_details/{packet_id}")
async def packet_details(request):
packet_id = int(request.match_info["packet_id"])
@@ -1095,7 +1072,7 @@ async def api_nodes(request):
content_type="text/plain"
)
@routes.get("/api/packets")
@routes.get("/api2/packets")
async def api_packets(request):
try:
node_id = request.query.get("node_id")
@@ -1432,7 +1409,7 @@ async def get_config(request):
return web.json_response({"error": "Invalid configuration format"}, status=500)
# API Section
#######################################################################
# How this works
# When your frontend calls /api/chat without since, it returns the most recent limit (default 100) messages.
# When your frontend calls /api/chat?since=ISO_TIMESTAMP, it returns only messages with import_time > since.
@@ -1558,6 +1535,52 @@ async def api_nodes(request):
print("Error in /api/nodes:", e)
return web.json_response({"error": "Failed to fetch nodes"}, status=500)
@routes.get("/api/packets")
async def api_packets(request):
try:
# Query parameters
limit = int(request.query.get("limit", 200))
since_str = request.query.get("since")
since_time = None
# Parse 'since' timestamp if provided
if since_str:
try:
since_time = datetime.datetime.fromisoformat(since_str)
except Exception as e:
print(f"Failed to parse 'since' timestamp '{since_str}': {e}")
# Fetch last N packets
packets = await store.get_packets(
node_id=0xFFFFFFFF,
portnum=None,
limit=limit
)
packets = [Packet.from_model(p) for p in packets]
# Apply "since" filter
if since_time:
packets = [p for p in packets if p.import_time > since_time]
# Build JSON response (no raw_payload)
packets_json = [{
"id": p.id,
"from_node_id": p.from_node_id,
"to_node_id": p.to_node_id,
"portnum": int(p.portnum),
"import_time": p.import_time.isoformat(),
"payload": p.payload
} for p in packets]
return web.json_response({"packets": packets_json})
except Exception as e:
print("Error in /api/packets:", str(e))
return web.json_response(
{"error": "Failed to fetch packets"},
status=500
)
async def run_server():
app = web.Application()