iarv/meshview
1
0
Fork 1
mirror of https://github.com/pablorevilla-meshtastic/meshview.git synced 2026-03-04 23:27:46 +01:00
Code Issues Packages Projects Releases Wiki Activity

add API code for /api/packets

Browse Source
This commit is contained in:
Pablo Revilla
2025-08-06 16:16:28 -07:00
parent b2c307a392
commit fc8e63bdf7
2 changed files with 27 additions and 33 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
meshview/templates/firehose.html
View File

@@ -6,6 +6,8 @@
margin: 0 auto;
}
/* Removed .packet-fade-in animation CSS */
/*
.packet-fade-in {
animation: fadeIn 0.5s ease forwards;
opacity: 0;
@@ -16,6 +18,7 @@
opacity: 1;
}
}
*/
#pause-button {
white-space: nowrap;
@@ -66,18 +69,12 @@ function fetchUpdates() {
.then(res => res.json())
.then(data => {
if (data.packets && data.packets.length > 0) {
lastTime = data.latest_import_time;
lastTime = data.last_time;
const list = document.getElementById("packet_list");
for (const html of data.packets.reverse()) {
list.insertAdjacentHTML("afterbegin", html);
const firstChild = list.firstElementChild;
if (firstChild) {
firstChild.classList.add("packet-fade-in");
firstChild.addEventListener("animationend", () => {
firstChild.classList.remove("packet-fade-in");
}, { once: true });
}
// No animation here anymore
}
}
})
@@ -89,12 +86,16 @@ function fetchUpdates() {
document.addEventListener("DOMContentLoaded", () => {
const pauseBtn = document.getElementById("pause-button");
document.querySelector('select[name="portnum"]').addEventListener("change", (e) => {
const selected = e.target.value;
const url = new URL(window.location.href);
url.searchParams.set("portnum", selected);
window.location.href = url;
});
// Assuming you have a portnum selector somewhere (not shown in your snippet)
const portnumSelector = document.querySelector('select[name="portnum"]');
if (portnumSelector) {
portnumSelector.addEventListener("change", (e) => {
const selected = e.target.value;
const url = new URL(window.location.href);
url.searchParams.set("portnum", selected);
window.location.href = url;
});
}
pauseBtn.addEventListener("click", () => {
updatesPaused = !updatesPaused;
@@ -103,7 +104,7 @@ document.addEventListener("DOMContentLoaded", () => {
// Start fetching updates
fetchUpdates();
setInterval(fetchUpdates, 3000);
setInterval(fetchUpdates, 1000);
});
</script>

29
meshview/web.py
View File

@@ -399,39 +399,32 @@ async def packet_details(request):
@routes.get("/firehose/updates")
async def firehose_updates(request):
try:
# Parse `last_time` from query
last_time_str = request.query.get("last_time", None)
# Get `last_time` from query string
last_time_str = request.query.get("last_time")
last_time = None
if last_time_str:
try:
last_time = datetime.datetime.fromisoformat(last_time_str)
if last_time.tzinfo is None:
last_time = last_time.replace(tzinfo=datetime.timezone.utc)
except Exception as e:
print(f"Failed to parse last_time '{last_time_str}': {e}")
last_time = None
else:
last_time = None
# Query packets after last_time (microsecond precision)
packets = await store.get_packets(after=last_time, limit=10)
# Query packets using `after=last_time`
packets = await store.get_packets(
after=last_time,
limit=10,
)
# Convert to UI model
ui_packets = [Packet.from_model(p) for p in packets]
# Render HTML using Jinja2
# Render HTML using Jinja2 template
template = env.get_template("packet.html")
rendered_packets = [template.render(packet=p) for p in ui_packets]
# Prepare response
response = {
"packets": rendered_packets,
}
# Build response
response = {"packets": rendered_packets}
if ui_packets:
latest_import_time = max(p.import_time for p in ui_packets)
response["latest_import_time"] = latest_import_time.isoformat(timespec="seconds")
response["last_time"] = latest_import_time.isoformat()
return web.json_response(response)