Retrieve detailed information about a specific meshcore node including recent adverts and location history.
+Retrieve detailed information about a specific meshcore node including recent adverts, location history, and MQTT uplink status.
public_key - The node's public key identifiernode_name - Display name of the nodelatitude/longitude - Current position coordinateshas_location - Whether the node has location data (0/1)is_repeater - Whether the node acts as a repeater (0/1)is_chat_node - Whether the node supports chat (0/1)is_room_server - Whether the node is a room server (0/1)has_name - Whether the node has a name (0/1)last_seen - Most recent activity timestampfirst_seen - First time this node was observedadv_timestamp - Advertisement timestamporigin_path_pubkey_tuples - Array of [origin, path, pubkey] tuplesadvert_count - Number of adverts in this groupearliest_timestamp/latest_timestamp - Time range for this advert grouplatitude/longitude - Position at time of advertis_repeater/is_chat_node/is_room_server/has_location - Node capabilities at time of advertmesh_timestamp - When this location was recordedlatitude/longitude - Location coordinateshas_packets - Whether any MQTT packets have been receivedis_uplinked - Whether node has been active in last 7 daystopics - Array of MQTT topic informationtopic - MQTT topic name (e.g., "meshcore", "meshcore/pdx")broker - MQTT broker URLlast_packet_time - Most recent packet timestamp for this topicis_recent - Whether this topic has been active in last 7 days (0/1)
@@ -269,13 +326,18 @@ export default function ApiDocsPage() {
"is_chat_node": 1,
"is_room_server": 0,
"has_name": 1,
- "last_seen": "2025-09-07T00:59:18"
+ "last_seen": "2025-09-07T00:59:18",
+ "first_seen": "2025-09-01T10:00:00"
},
"recentAdverts": [
{
- "mesh_timestamp": "2025-09-07T00:59:18",
- "path": "7ffb7e",
- "path_len": 3,
+ "adv_timestamp": "2025-09-07T00:59:18",
+ "origin_path_pubkey_tuples": [
+ ["origin_node", "7ffb7e", "origin_pubkey_hex"]
+ ],
+ "advert_count": 1,
+ "earliest_timestamp": "2025-09-07T00:59:18",
+ "latest_timestamp": "2025-09-07T00:59:18",
"latitude": 47.54969,
"longitude": -122.28085999999999,
"is_repeater": 1,
@@ -288,11 +350,27 @@ export default function ApiDocsPage() {
{
"mesh_timestamp": "2025-09-07T00:59:18",
"latitude": 47.54969,
- "longitude": -122.28085999999999,
- "path": "7ffb7e",
- "path_len": 3
+ "longitude": -122.28085999999999
}
- ]
+ ],
+ "mqtt": {
+ "is_uplinked": true,
+ "has_packets": true,
+ "topics": [
+ {
+ "topic": "meshcore",
+ "broker": "tcp://mqtt.davekeogh.com:1883",
+ "last_packet_time": "2025-09-07T00:59:18",
+ "is_recent": 1
+ },
+ {
+ "topic": "meshcore/pdx",
+ "broker": "tcp://mqtt.davekeogh.com:1883",
+ "last_packet_time": "2025-09-06T15:30:45",
+ "is_recent": 1
+ }
+ ]
+ }
}`}
This will return detailed information about the specified meshcore node including recent adverts, location history, and MQTT uplink status.
diff --git a/src/app/api/meshcore/node/[publicKey]/neighbors/route.ts b/src/app/api/meshcore/node/[publicKey]/neighbors/route.ts new file mode 100644 index 0000000..b1afa34 --- /dev/null +++ b/src/app/api/meshcore/node/[publicKey]/neighbors/route.ts @@ -0,0 +1,55 @@ +import { NextResponse } from "next/server"; +import { getMeshcoreNodeNeighbors } from "@/lib/clickhouse/actions"; + +export async function GET( + req: Request, + { params }: { params: Promise<{ publicKey: string }> } +) { + try { + const { publicKey } = await params; + const { searchParams } = new URL(req.url); + const lastSeen = searchParams.get("lastSeen"); + + if (!publicKey) { + return NextResponse.json({ + error: "Public key is required", + code: "MISSING_PUBLIC_KEY" + }, { status: 400 }); + } + + // Validate public key format (basic validation) + if (publicKey.length < 10) { + return NextResponse.json({ + error: "Invalid public key format", + code: "INVALID_PUBLIC_KEY" + }, { status: 400 }); + } + + const neighbors = await getMeshcoreNodeNeighbors(publicKey, lastSeen); + + // Check if the parent node exists by trying to get basic node info + // This is a lightweight check to ensure the node exists before returning neighbors + if (!neighbors || neighbors.length === 0) { + // We could add a check here to verify the parent node exists + // For now, we'll return an empty array which is valid for nodes with no neighbors + return NextResponse.json([]); + } + + return NextResponse.json(neighbors); + } catch (error) { + console.error("Error fetching meshcore node neighbors:", error); + + // Check if it's a ClickHouse connection error + if (error instanceof Error && error.message.includes('ClickHouse')) { + return NextResponse.json({ + error: "Database temporarily unavailable", + code: "DATABASE_ERROR" + }, { status: 503 }); + } + + return NextResponse.json({ + error: "Failed to fetch neighbors", + code: "INTERNAL_ERROR" + }, { status: 500 }); + } +} diff --git a/src/app/api/meshcore/node/[publicKey]/route.ts b/src/app/api/meshcore/node/[publicKey]/route.ts index 8146f1e..4904478 100644 --- a/src/app/api/meshcore/node/[publicKey]/route.ts +++ b/src/app/api/meshcore/node/[publicKey]/route.ts @@ -11,18 +11,45 @@ export async function GET( const limit = parseInt(searchParams.get("limit") || "50", 10); if (!publicKey) { - return NextResponse.json({ error: "Public key is required" }, { status: 400 }); + return NextResponse.json({ + error: "Public key is required", + code: "MISSING_PUBLIC_KEY" + }, { status: 400 }); + } + + // Validate public key format (basic validation) + if (publicKey.length < 10) { + return NextResponse.json({ + error: "Invalid public key format", + code: "INVALID_PUBLIC_KEY" + }, { status: 400 }); } const nodeInfo = await getMeshcoreNodeInfo(publicKey, limit); if (!nodeInfo) { - return NextResponse.json({ error: "Node not found" }, { status: 404 }); + return NextResponse.json({ + error: "Node not found", + code: "NODE_NOT_FOUND", + publicKey: publicKey + }, { status: 404 }); } return NextResponse.json(nodeInfo); } catch (error) { console.error("Error fetching meshcore node info:", error); - return NextResponse.json({ error: "Failed to fetch node info" }, { status: 500 }); + + // Check if it's a ClickHouse connection error + if (error instanceof Error && error.message.includes('ClickHouse')) { + return NextResponse.json({ + error: "Database temporarily unavailable", + code: "DATABASE_ERROR" + }, { status: 503 }); + } + + return NextResponse.json({ + error: "Failed to fetch node info", + code: "INTERNAL_ERROR" + }, { status: 500 }); } } diff --git a/src/app/api/meshcore/search/route.ts b/src/app/api/meshcore/search/route.ts new file mode 100644 index 0000000..b07841d --- /dev/null +++ b/src/app/api/meshcore/search/route.ts @@ -0,0 +1,82 @@ +import { NextResponse } from "next/server"; +import { searchMeshcoreNodes } from "@/lib/clickhouse/actions"; + +export async function GET(req: Request) { + try { + const { searchParams } = new URL(req.url); + const query = searchParams.get("q"); + const region = searchParams.get("region"); + const lastSeen = searchParams.get("lastSeen"); + const limit = parseInt(searchParams.get("limit") || "50", 10); + + // Validate limit + if (limit < 1 || limit > 200) { + return NextResponse.json({ + error: "Limit must be between 1 and 200", + code: "INVALID_LIMIT" + }, { status: 400 }); + } + + // If no query provided, return empty results + if (!query || query.trim().length === 0) { + return NextResponse.json({ + results: [], + total: 0, + query: query || "", + region: region || null + }); + } + + // Validate query length + if (query.length > 100) { + return NextResponse.json({ + error: "Query too long (max 100 characters)", + code: "QUERY_TOO_LONG" + }, { status: 400 }); + } + + // Validate lastSeen parameter + let lastSeenValue: string | null = null; + if (lastSeen !== null) { + const lastSeenNum = parseInt(lastSeen, 10); + if (isNaN(lastSeenNum) || lastSeenNum < 0) { + return NextResponse.json({ + error: "lastSeen must be a positive number (seconds)", + code: "INVALID_LAST_SEEN" + }, { status: 400 }); + } + lastSeenValue = lastSeen; + } + + const results = await searchMeshcoreNodes({ + query: query.trim(), + region: region || undefined, + lastSeen: lastSeenValue, + limit + }); + + return NextResponse.json({ + results, + total: results.length, + query: query.trim(), + region: region || null, + lastSeen: lastSeenValue, + limit + }); + } catch (error) { + console.error("Error searching meshcore nodes:", error); + + // Check if it's a ClickHouse connection error + if (error instanceof Error && error.message.includes('ClickHouse')) { + return NextResponse.json({ + error: "Database temporarily unavailable", + code: "DATABASE_ERROR" + }, { status: 503 }); + } + + return NextResponse.json({ + error: "Failed to search nodes", + code: "INTERNAL_ERROR" + }, { status: 500 }); + } +} diff --git a/src/app/favicon.ico b/src/app/favicon.ico deleted file mode 100644 index 718d6fea4835ec2d246af9800eddb7ffb276240c..0000000000000000000000000000000000000000 GIT binary patch literal 0 HcmV?d00001 literal 25931 zcmeHv30#a{`}aL_*G&7qml|y<+KVaDM2m#dVr!KsA!#An?kSQM(q<_dDNCpjEux83 zLb9Z^XxbDl(w>%i@8hT6>)&Gu{h#Oeyszu?xtw#Zb1mO{pgX9699l+Qppw7jXaYf~-84xW z)w4x8?=youko|}Vr~(D$UX