Compare commits
5 Commits
main
...
display-ma
| Author | SHA1 | Date | |
|---|---|---|---|
| 2c79be36ef | |||
| 7f296f9857 | |||
| f64860125c | |||
| ebb0ccecf4 | |||
| baa0a8b1ba |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -96,3 +96,6 @@ Provider/AgentTasks/
|
|||||||
|
|
||||||
# OTA files
|
# OTA files
|
||||||
*.bundle
|
*.bundle
|
||||||
|
|
||||||
|
#png
|
||||||
|
*.png
|
||||||
|
|||||||
@@ -146,12 +146,12 @@ dependencies:
|
|||||||
type: service
|
type: service
|
||||||
version: 1.20.4
|
version: 1.20.4
|
||||||
lvgl/lvgl:
|
lvgl/lvgl:
|
||||||
component_hash: 184e532558c1c45fefed631f3e235423d22582aafb4630f3e8885c35281a49ae
|
component_hash: 17e68bfd21f0edf4c3ee838e2273da840bf3930e5dbc3bfa6c1190c3aed41f9f
|
||||||
dependencies: []
|
dependencies: []
|
||||||
source:
|
source:
|
||||||
registry_url: https://components.espressif.com/
|
registry_url: https://components.espressif.com/
|
||||||
type: service
|
type: service
|
||||||
version: 9.5.0
|
version: 9.4.0
|
||||||
direct_dependencies:
|
direct_dependencies:
|
||||||
- espressif/ethernet_init
|
- espressif/ethernet_init
|
||||||
- espressif/led_strip
|
- espressif/led_strip
|
||||||
@@ -159,6 +159,6 @@ direct_dependencies:
|
|||||||
- idf
|
- idf
|
||||||
- joltwallet/littlefs
|
- joltwallet/littlefs
|
||||||
- lvgl/lvgl
|
- lvgl/lvgl
|
||||||
manifest_hash: 96112412d371d78cc527b7d0904042e5a7ca7c4f25928de9483a1b53dd2a2f4e
|
manifest_hash: 0c7ea64d32655d6be4f726b7946e96626bce0de88c2dc8f091bb5e365d26a374
|
||||||
target: esp32s3
|
target: esp32s3
|
||||||
version: 2.0.0
|
version: 2.0.0
|
||||||
|
|||||||
20
Provider/fetch_png.py
Normal file
20
Provider/fetch_png.py
Normal file
@@ -0,0 +1,20 @@
|
|||||||
|
import urllib.request
|
||||||
|
import json
|
||||||
|
import time
|
||||||
|
|
||||||
|
# 1. Register a fake device
|
||||||
|
req = urllib.request.Request('http://calendink.local/api/devices/register', data=json.dumps({'mac': 'DE:BU:G0:44:55:66'}).encode('utf-8'), headers={'Content-Type': 'application/json'})
|
||||||
|
try:
|
||||||
|
with urllib.request.urlopen(req) as response:
|
||||||
|
print("Registered:", response.read().decode())
|
||||||
|
except Exception as e:
|
||||||
|
print("Error registering:", e)
|
||||||
|
|
||||||
|
time.sleep(1)
|
||||||
|
|
||||||
|
# 2. Download the PNG
|
||||||
|
try:
|
||||||
|
urllib.request.urlretrieve('http://calendink.local/api/devices/screen.png?mac=DE:BU:G0:44:55:66', 'test_png.png')
|
||||||
|
print("Downloaded test_png.png")
|
||||||
|
except Exception as e:
|
||||||
|
print("Error downloading PNG:", e)
|
||||||
@@ -5,6 +5,7 @@
|
|||||||
import Sidebar from "./lib/Sidebar.svelte";
|
import Sidebar from "./lib/Sidebar.svelte";
|
||||||
import TaskManager from "./lib/TaskManager.svelte";
|
import TaskManager from "./lib/TaskManager.svelte";
|
||||||
import UserManager from "./lib/UserManager.svelte";
|
import UserManager from "./lib/UserManager.svelte";
|
||||||
|
import DeviceManager from "./lib/DeviceManager.svelte";
|
||||||
import Spinner from "./lib/Spinner.svelte";
|
import Spinner from "./lib/Spinner.svelte";
|
||||||
|
|
||||||
/** @type {'loading' | 'ok' | 'error' | 'rebooting'} */
|
/** @type {'loading' | 'ok' | 'error' | 'rebooting'} */
|
||||||
@@ -13,7 +14,7 @@
|
|||||||
let showRebootConfirm = $state(false);
|
let showRebootConfirm = $state(false);
|
||||||
let isRecovering = $state(false);
|
let isRecovering = $state(false);
|
||||||
|
|
||||||
/** @type {'dashboard' | 'tasks' | 'users'} */
|
/** @type {'dashboard' | 'tasks' | 'users' | 'devices'} */
|
||||||
let currentView = $state("dashboard");
|
let currentView = $state("dashboard");
|
||||||
let mobileMenuOpen = $state(false);
|
let mobileMenuOpen = $state(false);
|
||||||
|
|
||||||
@@ -352,6 +353,11 @@
|
|||||||
<div class="bg-bg-card border border-border rounded-xl p-8 shadow-xl">
|
<div class="bg-bg-card border border-border rounded-xl p-8 shadow-xl">
|
||||||
<UserManager mode="manager" />
|
<UserManager mode="manager" />
|
||||||
</div>
|
</div>
|
||||||
|
{:else if currentView === 'devices'}
|
||||||
|
<!-- Device Management View -->
|
||||||
|
<div class="bg-bg-card border border-border rounded-xl p-6 shadow-xl">
|
||||||
|
<DeviceManager />
|
||||||
|
</div>
|
||||||
{/if}
|
{/if}
|
||||||
|
|
||||||
<!-- Reboot Confirmation Modal -->
|
<!-- Reboot Confirmation Modal -->
|
||||||
|
|||||||
196
Provider/frontend/src/lib/DeviceManager.svelte
Normal file
196
Provider/frontend/src/lib/DeviceManager.svelte
Normal file
@@ -0,0 +1,196 @@
|
|||||||
|
<script>
|
||||||
|
import { getDevices, updateDeviceLayout, registerDevice } from './api.js';
|
||||||
|
|
||||||
|
let devices = $state([]);
|
||||||
|
let loading = $state(true);
|
||||||
|
let error = $state('');
|
||||||
|
|
||||||
|
// Track XML edits per device (keyed by MAC)
|
||||||
|
let editingXml = $state({});
|
||||||
|
let savingMac = $state('');
|
||||||
|
let saveResult = $state('');
|
||||||
|
|
||||||
|
let defaultXml = $state('');
|
||||||
|
|
||||||
|
// Debug states
|
||||||
|
let debugRegistering = $state(false);
|
||||||
|
|
||||||
|
async function loadDevices() {
|
||||||
|
loading = true;
|
||||||
|
error = '';
|
||||||
|
try {
|
||||||
|
const data = await getDevices();
|
||||||
|
devices = data.devices;
|
||||||
|
defaultXml = data.default_layout;
|
||||||
|
} catch (e) {
|
||||||
|
error = e.message || 'Failed to load devices';
|
||||||
|
} finally {
|
||||||
|
loading = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function handleDebugRegister() {
|
||||||
|
debugRegistering = true;
|
||||||
|
try {
|
||||||
|
// Generate a fake MAC like "DE:BU:G0:xx:xx:xx"
|
||||||
|
const hex = () => Math.floor(Math.random() * 256).toString(16).padStart(2, '0').toUpperCase();
|
||||||
|
const fakeMac = `DE:BU:G0:${hex()}:${hex()}:${hex()}`;
|
||||||
|
await registerDevice(fakeMac);
|
||||||
|
await loadDevices();
|
||||||
|
} catch (e) {
|
||||||
|
error = e.message || 'Failed to register debug device';
|
||||||
|
} finally {
|
||||||
|
debugRegistering = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
async function handleSaveLayout(device) {
|
||||||
|
savingMac = device.mac;
|
||||||
|
saveResult = '';
|
||||||
|
try {
|
||||||
|
await updateDeviceLayout(device.mac, editingXml[device.mac] ?? device.xml_layout);
|
||||||
|
saveResult = 'ok';
|
||||||
|
await loadDevices();
|
||||||
|
} catch (e) {
|
||||||
|
saveResult = e.message || 'Save failed';
|
||||||
|
} finally {
|
||||||
|
savingMac = '';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Runs once on mount — no reactive deps
|
||||||
|
$effect(() => {
|
||||||
|
loadDevices();
|
||||||
|
});
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<div class="space-y-6">
|
||||||
|
<div class="flex items-center justify-between">
|
||||||
|
<div>
|
||||||
|
<h2 class="text-lg font-bold text-text-primary">Device Manager</h2>
|
||||||
|
<p class="text-xs text-text-secondary mt-1">
|
||||||
|
Manage registered e-ink devices and their screen layouts.
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
<button
|
||||||
|
onclick={loadDevices}
|
||||||
|
class="px-3 py-1.5 text-xs font-medium rounded-lg bg-accent/10 text-accent border border-accent/20 hover:bg-accent/20 transition-colors"
|
||||||
|
>
|
||||||
|
Refresh
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{#if loading}
|
||||||
|
<div class="text-center text-sm text-text-secondary py-8 animate-pulse">
|
||||||
|
Loading devices...
|
||||||
|
</div>
|
||||||
|
{:else if error}
|
||||||
|
<div class="text-center text-sm text-danger py-8">
|
||||||
|
{error}
|
||||||
|
</div>
|
||||||
|
{:else if devices.length === 0}
|
||||||
|
<div class="bg-bg-card-hover/50 border border-border rounded-xl p-8 text-center">
|
||||||
|
<p class="text-text-secondary text-sm">No devices registered yet.</p>
|
||||||
|
<p class="text-text-secondary text-xs mt-2">
|
||||||
|
Use <code class="bg-bg-card px-1.5 py-0.5 rounded text-[11px] font-mono text-accent">
|
||||||
|
curl -X POST -d '{{"mac":"AA:BB:CC:DD:EE:FF"}}' http://calendink.local/api/devices/register
|
||||||
|
</code> to register a device.
|
||||||
|
</p>
|
||||||
|
</div>
|
||||||
|
{:else}
|
||||||
|
<div class="grid grid-cols-1 gap-4">
|
||||||
|
{#each devices as device}
|
||||||
|
<div class="bg-bg-card border border-border rounded-xl overflow-hidden shadow-lg">
|
||||||
|
<!-- Device Header -->
|
||||||
|
<div class="px-5 py-3 border-b border-border flex items-center justify-between">
|
||||||
|
<div class="flex items-center gap-3">
|
||||||
|
<span class="text-base">📺</span>
|
||||||
|
<span class="text-sm font-mono font-bold text-text-primary">{device.mac}</span>
|
||||||
|
</div>
|
||||||
|
<div class="flex items-center gap-2">
|
||||||
|
{#if device.has_layout}
|
||||||
|
{#if device.xml_layout === defaultXml}
|
||||||
|
<span class="text-[10px] bg-accent/20 text-accent px-2 py-0.5 rounded-full uppercase tracking-wider font-semibold">
|
||||||
|
Default Layout
|
||||||
|
</span>
|
||||||
|
{:else}
|
||||||
|
<span class="text-[10px] bg-success/20 text-success px-2 py-0.5 rounded-full uppercase tracking-wider font-semibold">
|
||||||
|
Layout Set
|
||||||
|
</span>
|
||||||
|
{/if}
|
||||||
|
{:else}
|
||||||
|
<span class="text-[10px] bg-border/50 text-text-secondary px-2 py-0.5 rounded-full uppercase tracking-wider font-semibold">
|
||||||
|
No Layout
|
||||||
|
</span>
|
||||||
|
{/if}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<!-- XML Editor -->
|
||||||
|
<div class="p-5 space-y-3">
|
||||||
|
<label for="xml-{device.mac}" class="text-xs font-semibold text-text-secondary uppercase tracking-wider">
|
||||||
|
LVGL XML Layout
|
||||||
|
</label>
|
||||||
|
<!-- svelte-ignore a11y_autofocus -->
|
||||||
|
<textarea
|
||||||
|
id="xml-{device.mac}"
|
||||||
|
class="w-full h-32 bg-bg-primary border border-border rounded-lg p-3 text-xs font-mono text-text-primary resize-y focus:border-accent focus:outline-none transition-colors placeholder:text-text-secondary/50"
|
||||||
|
placeholder={defaultXml}
|
||||||
|
value={editingXml[device.mac] ?? device.xml_layout}
|
||||||
|
oninput={(e) => editingXml[device.mac] = e.currentTarget.value}
|
||||||
|
></textarea>
|
||||||
|
|
||||||
|
<div class="flex items-center justify-between">
|
||||||
|
<div class="flex items-center gap-2">
|
||||||
|
<a
|
||||||
|
href="/api/devices/screen.png?mac={device.mac}"
|
||||||
|
target="_blank"
|
||||||
|
class="text-xs text-accent hover:text-accent/80 transition-colors underline"
|
||||||
|
>
|
||||||
|
Preview PNG →
|
||||||
|
</a>
|
||||||
|
</div>
|
||||||
|
<button
|
||||||
|
onclick={() => handleSaveLayout(device)}
|
||||||
|
disabled={savingMac === device.mac}
|
||||||
|
class="px-4 py-2 text-xs font-medium rounded-lg transition-colors
|
||||||
|
bg-accent/10 text-accent border border-accent/20
|
||||||
|
hover:bg-accent/20 hover:border-accent/30
|
||||||
|
disabled:opacity-40 disabled:cursor-not-allowed"
|
||||||
|
>
|
||||||
|
{savingMac === device.mac ? 'Saving...' : 'Save Layout'}
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
{#if saveResult === 'ok' && savingMac === ''}
|
||||||
|
<div class="text-xs text-success">✓ Layout saved successfully</div>
|
||||||
|
{:else if saveResult && saveResult !== 'ok'}
|
||||||
|
<div class="text-xs text-danger">✗ {saveResult}</div>
|
||||||
|
{/if}
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
{/each}
|
||||||
|
</div>
|
||||||
|
{/if}
|
||||||
|
|
||||||
|
<details class="mt-8 border text-xs border-border rounded-lg bg-bg-card opacity-50 hover:opacity-100 transition-opacity">
|
||||||
|
<summary class="px-4 py-3 cursor-pointer font-medium text-text-secondary select-none">
|
||||||
|
Debug Tools
|
||||||
|
</summary>
|
||||||
|
<div class="p-4 border-t border-border border-dashed space-y-4">
|
||||||
|
<p class="text-text-secondary">
|
||||||
|
Quickly register a new device to format layouts.
|
||||||
|
</p>
|
||||||
|
<button
|
||||||
|
onclick={handleDebugRegister}
|
||||||
|
disabled={debugRegistering}
|
||||||
|
class="px-4 py-2 font-medium rounded-lg transition-colors
|
||||||
|
bg-accent/10 text-accent border border-accent/20
|
||||||
|
hover:bg-accent/20 hover:border-accent/30
|
||||||
|
disabled:opacity-40 disabled:cursor-not-allowed"
|
||||||
|
>
|
||||||
|
{debugRegistering ? 'Registering...' : 'Add Fake Device'}
|
||||||
|
</button>
|
||||||
|
</div>
|
||||||
|
</details>
|
||||||
|
</div>
|
||||||
@@ -11,6 +11,7 @@
|
|||||||
|
|
||||||
const navItems = [
|
const navItems = [
|
||||||
{ id: 'dashboard', label: 'Dashboard', icon: '🏠' },
|
{ id: 'dashboard', label: 'Dashboard', icon: '🏠' },
|
||||||
|
{ id: 'devices', label: 'Devices', icon: '📺' },
|
||||||
{ id: 'tasks', label: 'Tasks', icon: '📋' },
|
{ id: 'tasks', label: 'Tasks', icon: '📋' },
|
||||||
{ id: 'users', label: 'Users', icon: '👥' },
|
{ id: 'users', label: 'Users', icon: '👥' },
|
||||||
];
|
];
|
||||||
|
|||||||
@@ -274,3 +274,53 @@ export async function deleteTask(id) {
|
|||||||
}
|
}
|
||||||
return res.json();
|
return res.json();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ─── Device Management ───────────────────────────────────────────────────────
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Fetch all registered devices and the default layout.
|
||||||
|
* @returns {Promise<{default_layout: string, devices: Array<{mac: string, has_layout: boolean, xml_layout: string}>}>}
|
||||||
|
*/
|
||||||
|
export async function getDevices() {
|
||||||
|
const res = await trackedFetch(`${API_BASE}/api/devices`);
|
||||||
|
if (!res.ok) throw new Error(`HTTP ${res.status}: ${res.statusText}`);
|
||||||
|
return res.json();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Register a new device.
|
||||||
|
* @param {string} mac
|
||||||
|
* @returns {Promise<{status: string}>}
|
||||||
|
*/
|
||||||
|
export async function registerDevice(mac) {
|
||||||
|
const res = await trackedFetch(`${API_BASE}/api/devices/register`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({ mac })
|
||||||
|
});
|
||||||
|
if (!res.ok) {
|
||||||
|
const errorText = await res.text();
|
||||||
|
throw new Error(`Failed (${res.status}): ${errorText || res.statusText}`);
|
||||||
|
}
|
||||||
|
return res.json();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Update the LVGL XML layout for a device.
|
||||||
|
* @param {string} mac
|
||||||
|
* @param {string} xml
|
||||||
|
* @returns {Promise<{status: string}>}
|
||||||
|
*/
|
||||||
|
export async function updateDeviceLayout(mac, xml) {
|
||||||
|
const res = await trackedFetch(`${API_BASE}/api/devices/layout`, {
|
||||||
|
method: 'POST',
|
||||||
|
headers: { 'Content-Type': 'application/json' },
|
||||||
|
body: JSON.stringify({ mac, xml })
|
||||||
|
});
|
||||||
|
if (!res.ok) {
|
||||||
|
const errorText = await res.text();
|
||||||
|
throw new Error(`Failed (${res.status}): ${errorText || res.statusText}`);
|
||||||
|
}
|
||||||
|
return res.json();
|
||||||
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
{
|
{
|
||||||
"major": 0,
|
"major": 0,
|
||||||
"minor": 1,
|
"minor": 1,
|
||||||
"revision": 30
|
"revision": 32
|
||||||
}
|
}
|
||||||
99
Provider/main/api/devices/layout.cpp
Normal file
99
Provider/main/api/devices/layout.cpp
Normal file
@@ -0,0 +1,99 @@
|
|||||||
|
// POST /api/devices/layout — Update the XML layout for a device
|
||||||
|
// Body: {"mac": "AA:BB:CC:DD:EE:FF", "xml": "<lv_label .../>"}
|
||||||
|
|
||||||
|
#include "cJSON.h"
|
||||||
|
#include "esp_http_server.h"
|
||||||
|
#include "esp_log.h"
|
||||||
|
|
||||||
|
#include "types.hpp"
|
||||||
|
#include "device.hpp"
|
||||||
|
|
||||||
|
internal const char *kTagDeviceLayout = "API_DEV_LAYOUT";
|
||||||
|
|
||||||
|
internal esp_err_t api_devices_layout_handler(httpd_req_t *req)
|
||||||
|
{
|
||||||
|
httpd_resp_set_type(req, "application/json");
|
||||||
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
|
||||||
|
// The XML payload can be large, so use a bigger buffer
|
||||||
|
// DEVICE_XML_MAX (2048) + JSON overhead for mac key etc.
|
||||||
|
constexpr int kBufSize = DEVICE_XML_MAX + 256;
|
||||||
|
char *buf = (char *)malloc(kBufSize);
|
||||||
|
if (!buf)
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Out of memory");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
int total = 0;
|
||||||
|
int remaining = req->content_len;
|
||||||
|
if (remaining >= kBufSize)
|
||||||
|
{
|
||||||
|
free(buf);
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Payload too large");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
while (remaining > 0)
|
||||||
|
{
|
||||||
|
int received = httpd_req_recv(req, buf + total, remaining);
|
||||||
|
if (received <= 0)
|
||||||
|
{
|
||||||
|
free(buf);
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Receive error");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
total += received;
|
||||||
|
remaining -= received;
|
||||||
|
}
|
||||||
|
buf[total] = '\0';
|
||||||
|
|
||||||
|
cJSON *body = cJSON_Parse(buf);
|
||||||
|
free(buf);
|
||||||
|
|
||||||
|
if (!body)
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Invalid JSON");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
cJSON *mac_item = cJSON_GetObjectItem(body, "mac");
|
||||||
|
cJSON *xml_item = cJSON_GetObjectItem(body, "xml");
|
||||||
|
|
||||||
|
if (!cJSON_IsString(mac_item) || !mac_item->valuestring || strlen(mac_item->valuestring) == 0)
|
||||||
|
{
|
||||||
|
cJSON_Delete(body);
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Missing 'mac'");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!cJSON_IsString(xml_item) || !xml_item->valuestring)
|
||||||
|
{
|
||||||
|
cJSON_Delete(body);
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Missing 'xml'");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool ok = update_device_layout(mac_item->valuestring, xml_item->valuestring);
|
||||||
|
|
||||||
|
if (!ok)
|
||||||
|
{
|
||||||
|
cJSON_Delete(body);
|
||||||
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, "Device not found");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
ESP_LOGI(kTagDeviceLayout, "Updated layout for %s (%zu bytes)", mac_item->valuestring,
|
||||||
|
strlen(xml_item->valuestring));
|
||||||
|
|
||||||
|
cJSON_Delete(body);
|
||||||
|
|
||||||
|
httpd_resp_sendstr(req, "{\"status\":\"ok\"}");
|
||||||
|
return ESP_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
internal const httpd_uri_t api_devices_layout_uri = {
|
||||||
|
.uri = "/api/devices/layout",
|
||||||
|
.method = HTTP_POST,
|
||||||
|
.handler = api_devices_layout_handler,
|
||||||
|
.user_ctx = NULL};
|
||||||
45
Provider/main/api/devices/list.cpp
Normal file
45
Provider/main/api/devices/list.cpp
Normal file
@@ -0,0 +1,45 @@
|
|||||||
|
// GET /api/devices — List all registered devices
|
||||||
|
|
||||||
|
#include "cJSON.h"
|
||||||
|
#include "esp_http_server.h"
|
||||||
|
|
||||||
|
#include "types.hpp"
|
||||||
|
#include "device.hpp"
|
||||||
|
|
||||||
|
internal esp_err_t api_devices_get_handler(httpd_req_t *req)
|
||||||
|
{
|
||||||
|
httpd_resp_set_type(req, "application/json");
|
||||||
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
|
||||||
|
cJSON *root = cJSON_CreateObject();
|
||||||
|
cJSON_AddStringToObject(root, "default_layout", kDefaultLayoutXml);
|
||||||
|
|
||||||
|
cJSON *arr = cJSON_CreateArray();
|
||||||
|
cJSON_AddItemToObject(root, "devices", arr);
|
||||||
|
|
||||||
|
for (int i = 0; i < MAX_DEVICES; i++)
|
||||||
|
{
|
||||||
|
if (g_Devices[i].active)
|
||||||
|
{
|
||||||
|
cJSON *obj = cJSON_CreateObject();
|
||||||
|
cJSON_AddStringToObject(obj, "mac", g_Devices[i].mac);
|
||||||
|
cJSON_AddBoolToObject(obj, "has_layout", g_Devices[i].xml_layout[0] != '\0');
|
||||||
|
cJSON_AddStringToObject(obj, "xml_layout", g_Devices[i].xml_layout);
|
||||||
|
cJSON_AddItemToArray(arr, obj);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
const char *json = cJSON_PrintUnformatted(root);
|
||||||
|
httpd_resp_sendstr(req, json);
|
||||||
|
|
||||||
|
free((void *)json);
|
||||||
|
cJSON_Delete(root);
|
||||||
|
|
||||||
|
return ESP_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
internal const httpd_uri_t api_devices_get_uri = {
|
||||||
|
.uri = "/api/devices",
|
||||||
|
.method = HTTP_GET,
|
||||||
|
.handler = api_devices_get_handler,
|
||||||
|
.user_ctx = NULL};
|
||||||
79
Provider/main/api/devices/register.cpp
Normal file
79
Provider/main/api/devices/register.cpp
Normal file
@@ -0,0 +1,79 @@
|
|||||||
|
// POST /api/devices/register — Register a new device by MAC
|
||||||
|
// Body: {"mac": "AA:BB:CC:DD:EE:FF"}
|
||||||
|
|
||||||
|
#include "cJSON.h"
|
||||||
|
#include "esp_http_server.h"
|
||||||
|
#include "esp_log.h"
|
||||||
|
|
||||||
|
#include "types.hpp"
|
||||||
|
#include "device.hpp"
|
||||||
|
|
||||||
|
internal const char *kTagDeviceRegister = "API_DEV_REG";
|
||||||
|
|
||||||
|
internal esp_err_t api_devices_register_handler(httpd_req_t *req)
|
||||||
|
{
|
||||||
|
httpd_resp_set_type(req, "application/json");
|
||||||
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
|
||||||
|
char buf[128];
|
||||||
|
int received = httpd_req_recv(req, buf, sizeof(buf) - 1);
|
||||||
|
if (received <= 0)
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Empty body");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
buf[received] = '\0';
|
||||||
|
|
||||||
|
cJSON *body = cJSON_Parse(buf);
|
||||||
|
if (!body)
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Invalid JSON");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
cJSON *mac_item = cJSON_GetObjectItem(body, "mac");
|
||||||
|
if (!cJSON_IsString(mac_item) || !mac_item->valuestring || strlen(mac_item->valuestring) == 0)
|
||||||
|
{
|
||||||
|
cJSON_Delete(body);
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Missing 'mac'");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool was_new = false;
|
||||||
|
device_t *dev = register_device(mac_item->valuestring, &was_new);
|
||||||
|
|
||||||
|
if (!dev)
|
||||||
|
{
|
||||||
|
cJSON_Delete(body);
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Device limit reached");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
cJSON *resp = cJSON_CreateObject();
|
||||||
|
if (was_new)
|
||||||
|
{
|
||||||
|
cJSON_AddStringToObject(resp, "status", "ok");
|
||||||
|
ESP_LOGI(kTagDeviceRegister, "Registered new device: %s", dev->mac);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
cJSON_AddStringToObject(resp, "status", "already_registered");
|
||||||
|
}
|
||||||
|
cJSON_AddStringToObject(resp, "mac", dev->mac);
|
||||||
|
|
||||||
|
cJSON_Delete(body);
|
||||||
|
|
||||||
|
const char *json = cJSON_PrintUnformatted(resp);
|
||||||
|
httpd_resp_sendstr(req, json);
|
||||||
|
|
||||||
|
free((void *)json);
|
||||||
|
cJSON_Delete(resp);
|
||||||
|
|
||||||
|
return ESP_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
internal const httpd_uri_t api_devices_register_uri = {
|
||||||
|
.uri = "/api/devices/register",
|
||||||
|
.method = HTTP_POST,
|
||||||
|
.handler = api_devices_register_handler,
|
||||||
|
.user_ctx = NULL};
|
||||||
59
Provider/main/api/devices/screen.cpp
Normal file
59
Provider/main/api/devices/screen.cpp
Normal file
@@ -0,0 +1,59 @@
|
|||||||
|
// GET /api/devices/screen?mac=XX — Return the image URL for a device's current screen
|
||||||
|
|
||||||
|
#include "cJSON.h"
|
||||||
|
#include "esp_http_server.h"
|
||||||
|
|
||||||
|
#include "types.hpp"
|
||||||
|
#include "device.hpp"
|
||||||
|
|
||||||
|
internal esp_err_t api_devices_screen_handler(httpd_req_t *req)
|
||||||
|
{
|
||||||
|
httpd_resp_set_type(req, "application/json");
|
||||||
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
|
||||||
|
// Extract mac query parameter
|
||||||
|
char mac[18] = {};
|
||||||
|
size_t buf_len = httpd_req_get_url_query_len(req) + 1;
|
||||||
|
if (buf_len > 1)
|
||||||
|
{
|
||||||
|
char query[64] = {};
|
||||||
|
if (httpd_req_get_url_query_str(req, query, sizeof(query)) == ESP_OK)
|
||||||
|
{
|
||||||
|
httpd_query_key_value(query, "mac", mac, sizeof(mac));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (mac[0] == '\0')
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST, "Missing 'mac' query param");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
device_t *dev = find_device(mac);
|
||||||
|
if (!dev)
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, "Device not registered");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Build image_url: /api/devices/screen.png?mac=XX
|
||||||
|
char image_url[64];
|
||||||
|
snprintf(image_url, sizeof(image_url), "/api/devices/screen.png?mac=%s", mac);
|
||||||
|
|
||||||
|
cJSON *resp = cJSON_CreateObject();
|
||||||
|
cJSON_AddStringToObject(resp, "image_url", image_url);
|
||||||
|
|
||||||
|
const char *json = cJSON_PrintUnformatted(resp);
|
||||||
|
httpd_resp_sendstr(req, json);
|
||||||
|
|
||||||
|
free((void *)json);
|
||||||
|
cJSON_Delete(resp);
|
||||||
|
|
||||||
|
return ESP_OK;
|
||||||
|
}
|
||||||
|
|
||||||
|
internal const httpd_uri_t api_devices_screen_info_uri = {
|
||||||
|
.uri = "/api/devices/screen",
|
||||||
|
.method = HTTP_GET,
|
||||||
|
.handler = api_devices_screen_handler,
|
||||||
|
.user_ctx = NULL};
|
||||||
249
Provider/main/api/devices/screen_image.cpp
Normal file
249
Provider/main/api/devices/screen_image.cpp
Normal file
@@ -0,0 +1,249 @@
|
|||||||
|
// GET /api/devices/screen.png?mac=XX — Render and return a PNG for the device's
|
||||||
|
// current screen Uses LVGL to render the device's XML layout (or a fallback
|
||||||
|
// label) then encodes to PNG via lodepng.
|
||||||
|
|
||||||
|
#include "esp_heap_caps.h"
|
||||||
|
#include "esp_http_server.h"
|
||||||
|
#include "esp_log.h"
|
||||||
|
#include "lodepng/lodepng.h"
|
||||||
|
#include "lodepng_alloc.hpp"
|
||||||
|
#include "lv_setup.hpp"
|
||||||
|
#include "lvgl.h"
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
#include "device.hpp"
|
||||||
|
#include "types.hpp"
|
||||||
|
|
||||||
|
internal const char *kTagDeviceScreenImage = "API_DEV_SCREEN_IMG";
|
||||||
|
|
||||||
|
internal esp_err_t api_devices_screen_image_handler(httpd_req_t *req)
|
||||||
|
{
|
||||||
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
httpd_resp_set_hdr(req, "Cache-Control",
|
||||||
|
"no-cache, no-store, must-revalidate");
|
||||||
|
httpd_resp_set_type(req, "image/png");
|
||||||
|
|
||||||
|
// Extract mac query parameter
|
||||||
|
char mac[18] = {};
|
||||||
|
size_t buf_len = httpd_req_get_url_query_len(req) + 1;
|
||||||
|
if (buf_len > 1)
|
||||||
|
{
|
||||||
|
char query[64] = {};
|
||||||
|
if (httpd_req_get_url_query_str(req, query, sizeof(query)) == ESP_OK)
|
||||||
|
{
|
||||||
|
httpd_query_key_value(query, "mac", mac, sizeof(mac));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (mac[0] == '\0')
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_400_BAD_REQUEST,
|
||||||
|
"Missing 'mac' query param");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
device_t *dev = find_device(mac);
|
||||||
|
if (!dev)
|
||||||
|
{
|
||||||
|
httpd_resp_send_err(req, HTTPD_404_NOT_FOUND, "Device not registered");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
// --- LVGL rendering (mutex-protected) ---
|
||||||
|
if (xSemaphoreTake(g_LvglMutex, pdMS_TO_TICKS(5000)) != pdTRUE)
|
||||||
|
{
|
||||||
|
ESP_LOGE(kTagDeviceScreenImage, "Failed to get LVGL mutex");
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "LVGL busy");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
lv_obj_t *scr = lv_screen_active();
|
||||||
|
|
||||||
|
// Clear all children from the active screen
|
||||||
|
lv_obj_clean(scr);
|
||||||
|
|
||||||
|
// White background for grayscale
|
||||||
|
lv_obj_set_style_bg_color(scr, lv_color_white(), LV_PART_MAIN);
|
||||||
|
|
||||||
|
// Setup the MAC address subject so the XML can bind to it
|
||||||
|
static lv_subject_t mac_subject;
|
||||||
|
// Two buffers are needed by LVGL for string observers (current and previous)
|
||||||
|
static char mac_buf[18];
|
||||||
|
static char mac_prev_buf[18];
|
||||||
|
|
||||||
|
strncpy(mac_buf, mac, sizeof(mac_buf));
|
||||||
|
strncpy(mac_prev_buf, mac, sizeof(mac_prev_buf));
|
||||||
|
|
||||||
|
lv_subject_init_string(&mac_subject, mac_buf, mac_prev_buf, sizeof(mac_buf),
|
||||||
|
mac);
|
||||||
|
|
||||||
|
// Register the subject in the global XML scope under the name "device_mac"
|
||||||
|
lv_xml_component_scope_t *global_scope =
|
||||||
|
lv_xml_component_get_scope("globals");
|
||||||
|
if (global_scope)
|
||||||
|
{
|
||||||
|
lv_xml_register_subject(global_scope, "device_mac", &mac_subject);
|
||||||
|
ESP_LOGI(kTagDeviceScreenImage,
|
||||||
|
"Registered subject 'device_mac' with value: %s", mac);
|
||||||
|
}
|
||||||
|
|
||||||
|
bool render_success = false;
|
||||||
|
|
||||||
|
// 1. Prepare the XML payload
|
||||||
|
const char *xml_to_register = NULL;
|
||||||
|
static char
|
||||||
|
xml_buffer[DEVICE_XML_MAX + 100]; // static buffer to avoid stack overflow
|
||||||
|
|
||||||
|
if (dev->xml_layout[0] == '\0')
|
||||||
|
{
|
||||||
|
ESP_LOGI(kTagDeviceScreenImage, "Device %s has no layout xml.", mac);
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (strstr(dev->xml_layout, "<screen") != NULL)
|
||||||
|
{
|
||||||
|
// The user provided a correct <screen> wrapped XML
|
||||||
|
xml_to_register = dev->xml_layout;
|
||||||
|
ESP_LOGI(kTagDeviceScreenImage,
|
||||||
|
"XML already contains <screen>, passing directly to parser.");
|
||||||
|
}
|
||||||
|
|
||||||
|
// 2. Register the XML payload as a component
|
||||||
|
lv_result_t res =
|
||||||
|
lv_xml_register_component_from_data("current_device", xml_to_register);
|
||||||
|
|
||||||
|
if (res == LV_RESULT_OK)
|
||||||
|
{
|
||||||
|
ESP_LOGI(kTagDeviceScreenImage, "Successfully registered XML for device %s",
|
||||||
|
mac);
|
||||||
|
|
||||||
|
// 3. Since we enforce <screen> now, we always create a screen instance
|
||||||
|
lv_obj_t *new_scr = lv_xml_create_screen("current_device");
|
||||||
|
|
||||||
|
if (new_scr)
|
||||||
|
{
|
||||||
|
// We must load this newly created screen to make it active before
|
||||||
|
// rendering
|
||||||
|
lv_screen_load(new_scr);
|
||||||
|
scr = new_scr; // Update local pointer since active screen changed
|
||||||
|
render_success = true;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
ESP_LOGE(kTagDeviceScreenImage,
|
||||||
|
"lv_xml_create_screen failed for device %s", mac);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
ESP_LOGE(kTagDeviceScreenImage,
|
||||||
|
"lv_xml_register_component_from_data failed for device %s", mac);
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. Fallback if LVGL XML parsing or creation failed
|
||||||
|
if (!render_success)
|
||||||
|
{
|
||||||
|
ESP_LOGW(kTagDeviceScreenImage,
|
||||||
|
"XML render failed, falling back to raw text layout");
|
||||||
|
lv_obj_t *label = lv_label_create(scr);
|
||||||
|
lv_label_set_text(label, "XML Parsing Error\nSee serial log");
|
||||||
|
lv_obj_set_style_text_color(label, lv_color_black(), LV_PART_MAIN);
|
||||||
|
lv_obj_align(label, LV_ALIGN_CENTER, 0, 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
// Force LVGL to fully render the screen
|
||||||
|
lv_refr_now(g_LvglDisplay);
|
||||||
|
|
||||||
|
lv_draw_buf_t *draw_buf = lv_display_get_buf_active(g_LvglDisplay);
|
||||||
|
if (!draw_buf)
|
||||||
|
{
|
||||||
|
xSemaphoreGive(g_LvglMutex);
|
||||||
|
ESP_LOGE(kTagDeviceScreenImage, "No active draw buffer");
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR,
|
||||||
|
"Display uninitialized");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
uint32_t width = CONFIG_CALENDINK_DISPLAY_WIDTH;
|
||||||
|
uint32_t height = CONFIG_CALENDINK_DISPLAY_HEIGHT;
|
||||||
|
|
||||||
|
// Allocate bounding memory for quantizing RGB565 buffer into tightly packed
|
||||||
|
// 8-bit PNG data.
|
||||||
|
uint8_t *packed_data =
|
||||||
|
(uint8_t *)heap_caps_malloc(width * height, MALLOC_CAP_SPIRAM);
|
||||||
|
if (!packed_data)
|
||||||
|
{
|
||||||
|
packed_data = (uint8_t *)malloc(width * height);
|
||||||
|
if (!packed_data)
|
||||||
|
{
|
||||||
|
xSemaphoreGive(g_LvglMutex);
|
||||||
|
ESP_LOGE(kTagDeviceScreenImage, "Failed to allocate packed buffer");
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR,
|
||||||
|
"Out of memory");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// LVGL renders into RGB565 (2 bytes per pixel).
|
||||||
|
// Parse pixels, extract luminance, and quantize to 4 levels (0, 85, 170, 255).
|
||||||
|
for (uint32_t y = 0; y < height; ++y)
|
||||||
|
{
|
||||||
|
const uint16_t *src_row = (const uint16_t *)((const uint8_t *)draw_buf->data + (y * draw_buf->header.stride));
|
||||||
|
uint8_t *dst_row = packed_data + (y * width);
|
||||||
|
|
||||||
|
for (uint32_t x = 0; x < width; ++x)
|
||||||
|
{
|
||||||
|
uint16_t c = src_row[x];
|
||||||
|
// Expand 5/6/5 components
|
||||||
|
uint8_t r_5 = (c >> 11) & 0x1F;
|
||||||
|
uint8_t g_6 = (c >> 5) & 0x3F;
|
||||||
|
uint8_t b_5 = c & 0x1F;
|
||||||
|
|
||||||
|
// Unpack to 8-bit true values
|
||||||
|
uint8_t r = (r_5 << 3) | (r_5 >> 2);
|
||||||
|
uint8_t g = (g_6 << 2) | (g_6 >> 4);
|
||||||
|
uint8_t b = (b_5 << 3) | (b_5 >> 2);
|
||||||
|
|
||||||
|
// Simple luminance
|
||||||
|
uint8_t lum = (r * 77 + g * 150 + b * 29) >> 8;
|
||||||
|
|
||||||
|
// 4-level linear quantization (0, 85, 170, 255)
|
||||||
|
dst_row[x] = (lum >> 6) * 85;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Encode to PNG
|
||||||
|
unsigned char *png = nullptr;
|
||||||
|
size_t pngsize = 0;
|
||||||
|
|
||||||
|
lodepng_allocator_reset();
|
||||||
|
|
||||||
|
ESP_LOGI(kTagDeviceScreenImage, "Encoding %lux%lu PNG for device %s", width,
|
||||||
|
height, mac);
|
||||||
|
unsigned error = lodepng_encode_memory(&png, &pngsize, packed_data, width,
|
||||||
|
height, LCT_GREY, 8);
|
||||||
|
|
||||||
|
free(packed_data);
|
||||||
|
|
||||||
|
xSemaphoreGive(g_LvglMutex);
|
||||||
|
|
||||||
|
if (error)
|
||||||
|
{
|
||||||
|
ESP_LOGE(kTagDeviceScreenImage, "PNG encoding error %u: %s", error,
|
||||||
|
lodepng_error_text(error));
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR,
|
||||||
|
"PNG generation failed");
|
||||||
|
return ESP_FAIL;
|
||||||
|
}
|
||||||
|
|
||||||
|
ESP_LOGI(kTagDeviceScreenImage, "PNG ready: %zu bytes. Sending...", pngsize);
|
||||||
|
esp_err_t sendRes = httpd_resp_send(req, (const char *)png, pngsize);
|
||||||
|
|
||||||
|
return sendRes;
|
||||||
|
}
|
||||||
|
|
||||||
|
internal const httpd_uri_t api_devices_screen_image_uri = {
|
||||||
|
.uri = "/api/devices/screen.png",
|
||||||
|
.method = HTTP_GET,
|
||||||
|
.handler = api_devices_screen_image_handler,
|
||||||
|
.user_ctx = NULL};
|
||||||
57
Provider/main/api/devices/store.cpp
Normal file
57
Provider/main/api/devices/store.cpp
Normal file
@@ -0,0 +1,57 @@
|
|||||||
|
// Device data store: CRUD helpers
|
||||||
|
|
||||||
|
#include "device.hpp"
|
||||||
|
|
||||||
|
// Find a device by MAC address, returns nullptr if not found
|
||||||
|
internal device_t *find_device(const char *mac)
|
||||||
|
{
|
||||||
|
for (int i = 0; i < MAX_DEVICES; i++)
|
||||||
|
{
|
||||||
|
if (g_Devices[i].active && strcmp(g_Devices[i].mac, mac) == 0)
|
||||||
|
{
|
||||||
|
return &g_Devices[i];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nullptr;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Register a device by MAC. Returns pointer to device (existing or new).
|
||||||
|
// Sets *was_new to true if it was freshly registered.
|
||||||
|
internal device_t *register_device(const char *mac, bool *was_new)
|
||||||
|
{
|
||||||
|
*was_new = false;
|
||||||
|
|
||||||
|
// Check for existing
|
||||||
|
device_t *existing = find_device(mac);
|
||||||
|
if (existing)
|
||||||
|
{
|
||||||
|
return existing;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Find a free slot
|
||||||
|
for (int i = 0; i < MAX_DEVICES; i++)
|
||||||
|
{
|
||||||
|
if (!g_Devices[i].active)
|
||||||
|
{
|
||||||
|
strlcpy(g_Devices[i].mac, mac, sizeof(g_Devices[i].mac));
|
||||||
|
g_Devices[i].active = true;
|
||||||
|
strlcpy(g_Devices[i].xml_layout, kDefaultLayoutXml, sizeof(g_Devices[i].xml_layout));
|
||||||
|
*was_new = true;
|
||||||
|
return &g_Devices[i];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return nullptr; // All slots full
|
||||||
|
}
|
||||||
|
|
||||||
|
// Update the XML layout for a device. Returns true on success.
|
||||||
|
internal bool update_device_layout(const char *mac, const char *xml)
|
||||||
|
{
|
||||||
|
device_t *dev = find_device(mac);
|
||||||
|
if (!dev)
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
strlcpy(dev->xml_layout, xml, sizeof(dev->xml_layout));
|
||||||
|
return true;
|
||||||
|
}
|
||||||
9
Provider/main/api/devices/unity.cpp
Normal file
9
Provider/main/api/devices/unity.cpp
Normal file
@@ -0,0 +1,9 @@
|
|||||||
|
// Unity build entry for device endpoints
|
||||||
|
// clang-format off
|
||||||
|
#include "api/devices/store.cpp"
|
||||||
|
#include "api/devices/list.cpp"
|
||||||
|
#include "api/devices/register.cpp"
|
||||||
|
#include "api/devices/layout.cpp"
|
||||||
|
#include "api/devices/screen.cpp"
|
||||||
|
#include "api/devices/screen_image.cpp"
|
||||||
|
// clang-format on
|
||||||
@@ -1,12 +1,12 @@
|
|||||||
#include "../../lv_setup.hpp"
|
|
||||||
#include "../../lodepng/lodepng.h"
|
#include "../../lodepng/lodepng.h"
|
||||||
|
#include "../../lodepng_alloc.hpp"
|
||||||
|
#include "../../lv_setup.hpp"
|
||||||
|
#include "esp_heap_caps.h"
|
||||||
#include "esp_http_server.h"
|
#include "esp_http_server.h"
|
||||||
#include "esp_log.h"
|
#include "esp_log.h"
|
||||||
#include "esp_heap_caps.h"
|
|
||||||
#include "esp_random.h"
|
#include "esp_random.h"
|
||||||
#include "lvgl.h"
|
#include "lvgl.h"
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include "../../lodepng_alloc.hpp"
|
|
||||||
|
|
||||||
internal const char *kTagDisplayImage = "API_DISPLAY_IMAGE";
|
internal const char *kTagDisplayImage = "API_DISPLAY_IMAGE";
|
||||||
|
|
||||||
@@ -14,8 +14,10 @@ internal esp_err_t api_display_image_handler(httpd_req_t *req)
|
|||||||
{
|
{
|
||||||
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
httpd_resp_set_hdr(req, "Access-Control-Allow-Origin", "*");
|
||||||
|
|
||||||
// We are generating PNG on the fly, don't let it be cached locally immediately
|
// We are generating PNG on the fly, don't let it be cached locally
|
||||||
httpd_resp_set_hdr(req, "Cache-Control", "no-cache, no-store, must-revalidate");
|
// immediately
|
||||||
|
httpd_resp_set_hdr(req, "Cache-Control",
|
||||||
|
"no-cache, no-store, must-revalidate");
|
||||||
httpd_resp_set_type(req, "image/png");
|
httpd_resp_set_type(req, "image/png");
|
||||||
|
|
||||||
if (xSemaphoreTake(g_LvglMutex, pdMS_TO_TICKS(5000)) != pdTRUE)
|
if (xSemaphoreTake(g_LvglMutex, pdMS_TO_TICKS(5000)) != pdTRUE)
|
||||||
@@ -29,7 +31,8 @@ internal esp_err_t api_display_image_handler(httpd_req_t *req)
|
|||||||
// esp_random() returns 32 bits, we just take the lowest 8.
|
// esp_random() returns 32 bits, we just take the lowest 8.
|
||||||
uint8_t rand_gray = esp_random() & 0xFF;
|
uint8_t rand_gray = esp_random() & 0xFF;
|
||||||
lv_obj_t *active_screen = lv_screen_active();
|
lv_obj_t *active_screen = lv_screen_active();
|
||||||
lv_obj_set_style_bg_color(active_screen, lv_color_make(rand_gray, rand_gray, rand_gray), LV_PART_MAIN);
|
// lv_obj_set_style_bg_color(active_screen, lv_color_make(rand_gray,
|
||||||
|
// rand_gray, rand_gray), LV_PART_MAIN);
|
||||||
|
|
||||||
// Force a screen refresh to get the latest rendered frame
|
// Force a screen refresh to get the latest rendered frame
|
||||||
lv_refr_now(g_LvglDisplay);
|
lv_refr_now(g_LvglDisplay);
|
||||||
@@ -39,34 +42,63 @@ internal esp_err_t api_display_image_handler(httpd_req_t *req)
|
|||||||
{
|
{
|
||||||
xSemaphoreGive(g_LvglMutex);
|
xSemaphoreGive(g_LvglMutex);
|
||||||
ESP_LOGE(kTagDisplayImage, "No active draw buffer available");
|
ESP_LOGE(kTagDisplayImage, "No active draw buffer available");
|
||||||
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Display uninitialized");
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR,
|
||||||
|
"Display uninitialized");
|
||||||
return ESP_FAIL;
|
return ESP_FAIL;
|
||||||
}
|
}
|
||||||
|
|
||||||
uint32_t width = CONFIG_CALENDINK_DISPLAY_WIDTH;
|
uint32_t width = CONFIG_CALENDINK_DISPLAY_WIDTH;
|
||||||
uint32_t height = CONFIG_CALENDINK_DISPLAY_HEIGHT;
|
uint32_t height = CONFIG_CALENDINK_DISPLAY_HEIGHT;
|
||||||
|
|
||||||
// LodePNG expects tightly packed data without stride padding.
|
// We allocate a new buffer for the tightly packed 8-bit PNG grayscale data.
|
||||||
// Ensure we copy the data if stride differs from width.
|
// Converting RGB565 frame to 4-level grayscale (quantized to 0, 85, 170, 255).
|
||||||
uint8_t *packed_data = (uint8_t *)draw_buf->data;
|
uint8_t *packed_data =
|
||||||
bool needs_free = false;
|
(uint8_t *)heap_caps_malloc(width * height, MALLOC_CAP_SPIRAM);
|
||||||
|
if (!packed_data)
|
||||||
if (draw_buf->header.stride != width)
|
|
||||||
{
|
{
|
||||||
ESP_LOGI(kTagDisplayImage, "Stride %lu differs from width %lu. Repacking buffer...", draw_buf->header.stride, width);
|
packed_data = (uint8_t *)malloc(width * height); // Fallback
|
||||||
packed_data = (uint8_t *)heap_caps_malloc(width * height, MALLOC_CAP_SPIRAM);
|
|
||||||
if (!packed_data)
|
if (!packed_data)
|
||||||
{
|
{
|
||||||
xSemaphoreGive(g_LvglMutex);
|
xSemaphoreGive(g_LvglMutex);
|
||||||
ESP_LOGE(kTagDisplayImage, "Failed to allocate packed buffer in PSRAM");
|
ESP_LOGE(kTagDisplayImage, "Failed to allocate packed buffer");
|
||||||
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "Out of memory");
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR,
|
||||||
|
"Out of memory");
|
||||||
return ESP_FAIL;
|
return ESP_FAIL;
|
||||||
}
|
}
|
||||||
needs_free = true;
|
}
|
||||||
|
|
||||||
|
// LVGL renders into RGB565 (2 bytes per pixel).
|
||||||
|
// Iterating to create an 8-bit grayscale PNG using 4 specific values.
|
||||||
for (uint32_t y = 0; y < height; ++y)
|
for (uint32_t y = 0; y < height; ++y)
|
||||||
{
|
{
|
||||||
memcpy(packed_data + (y * width), (uint8_t *)draw_buf->data + (y * draw_buf->header.stride), width);
|
const uint16_t *src_row =
|
||||||
|
(const uint16_t *)((const uint8_t *)draw_buf->data +
|
||||||
|
(y * draw_buf->header.stride));
|
||||||
|
uint8_t *dst_row = packed_data + (y * width);
|
||||||
|
|
||||||
|
for (uint32_t x = 0; x < width; ++x)
|
||||||
|
{
|
||||||
|
uint16_t c = src_row[x];
|
||||||
|
// Note: LVGL may use swapped bytes for SPI rendering depending on config,
|
||||||
|
// but in memory RGB565 is standard if no SWAP is active. Usually standard
|
||||||
|
// RGB565 format: R(5) G(6) B(5)
|
||||||
|
uint8_t r_5 = (c >> 11) & 0x1F;
|
||||||
|
uint8_t g_6 = (c >> 5) & 0x3F;
|
||||||
|
uint8_t b_5 = c & 0x1F;
|
||||||
|
|
||||||
|
// Expand to 8 bits
|
||||||
|
uint8_t r = (r_5 << 3) | (r_5 >> 2);
|
||||||
|
uint8_t g = (g_6 << 2) | (g_6 >> 4);
|
||||||
|
uint8_t b = (b_5 << 3) | (b_5 >> 2);
|
||||||
|
|
||||||
|
// Simple luminance calculation (fast)
|
||||||
|
uint8_t lum = (r * 77 + g * 150 + b * 29) >> 8;
|
||||||
|
|
||||||
|
// Quantize to 4 levels (0..3)
|
||||||
|
uint8_t level = lum >> 6;
|
||||||
|
|
||||||
|
// Expand level back to 8-bit for PNG: 0, 85, 170, 255
|
||||||
|
dst_row[x] = level * 85;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -76,27 +108,28 @@ internal esp_err_t api_display_image_handler(httpd_req_t *req)
|
|||||||
size_t pngsize = 0;
|
size_t pngsize = 0;
|
||||||
|
|
||||||
// We are about to start a huge memory operation inside LodePNG.
|
// We are about to start a huge memory operation inside LodePNG.
|
||||||
// We reset our 2MB PSRAM bump allocator to 0 bytes used.
|
// We reset our 3MB PSRAM bump allocator to 0 bytes used.
|
||||||
lodepng_allocator_reset();
|
lodepng_allocator_reset();
|
||||||
|
|
||||||
ESP_LOGI(kTagDisplayImage, "Encoding %lux%lu frame to PNG...", width, height);
|
ESP_LOGI(kTagDisplayImage, "Encoding %lux%lu frame to PNG...", width, height);
|
||||||
unsigned error = lodepng_encode_memory(&png, &pngsize, packed_data, width, height, LCT_GREY, 8);
|
unsigned error = lodepng_encode_memory(&png, &pngsize, packed_data, width,
|
||||||
|
height, LCT_GREY, 8);
|
||||||
|
|
||||||
if (needs_free)
|
|
||||||
{
|
|
||||||
free(packed_data);
|
free(packed_data);
|
||||||
}
|
|
||||||
|
|
||||||
xSemaphoreGive(g_LvglMutex);
|
xSemaphoreGive(g_LvglMutex);
|
||||||
|
|
||||||
if (error)
|
if (error)
|
||||||
{
|
{
|
||||||
ESP_LOGE(kTagDisplayImage, "PNG encoding error %u: %s", error, lodepng_error_text(error));
|
ESP_LOGE(kTagDisplayImage, "PNG encoding error %u: %s", error,
|
||||||
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR, "PNG generation failed");
|
lodepng_error_text(error));
|
||||||
|
httpd_resp_send_err(req, HTTPD_500_INTERNAL_SERVER_ERROR,
|
||||||
|
"PNG generation failed");
|
||||||
return ESP_FAIL;
|
return ESP_FAIL;
|
||||||
}
|
}
|
||||||
|
|
||||||
ESP_LOGI(kTagDisplayImage, "Prepared PNG, size: %zu bytes. Sending to client...", pngsize);
|
ESP_LOGI(kTagDisplayImage,
|
||||||
|
"Prepared PNG, size: %zu bytes. Sending to client...", pngsize);
|
||||||
esp_err_t res = httpd_resp_send(req, (const char *)png, pngsize);
|
esp_err_t res = httpd_resp_send(req, (const char *)png, pngsize);
|
||||||
|
|
||||||
// No need to free(png) because it is managed by our bump allocator
|
// No need to free(png) because it is managed by our bump allocator
|
||||||
@@ -106,8 +139,7 @@ internal esp_err_t api_display_image_handler(httpd_req_t *req)
|
|||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
|
|
||||||
httpd_uri_t api_display_image_uri = {
|
httpd_uri_t api_display_image_uri = {.uri = "/api/display/image.png",
|
||||||
.uri = "/api/display/image.png",
|
|
||||||
.method = HTTP_GET,
|
.method = HTTP_GET,
|
||||||
.handler = api_display_image_handler,
|
.handler = api_display_image_handler,
|
||||||
.user_ctx = NULL};
|
.user_ctx = NULL};
|
||||||
|
|||||||
25
Provider/main/device.hpp
Normal file
25
Provider/main/device.hpp
Normal file
@@ -0,0 +1,25 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <cstring>
|
||||||
|
|
||||||
|
#include "types.hpp"
|
||||||
|
|
||||||
|
constexpr int MAX_DEVICES = 8;
|
||||||
|
constexpr int DEVICE_XML_MAX = 2048;
|
||||||
|
|
||||||
|
constexpr char kDefaultLayoutXml[] =
|
||||||
|
"<screen>\n"
|
||||||
|
" <view width=\"100%\" height=\"100%\" layout=\"flex\" flex_flow=\"column\" style_flex_main_place=\"center\" style_flex_track_place=\"center\" style_pad_row=\"10\">\n"
|
||||||
|
" <lv_label text=\"Hello World\" />\n"
|
||||||
|
" <lv_label bind_text=\"device_mac\" />\n"
|
||||||
|
" </view>\n"
|
||||||
|
"</screen>";
|
||||||
|
|
||||||
|
struct device_t
|
||||||
|
{
|
||||||
|
char mac[18]; // "AA:BB:CC:DD:EE:FF\0"
|
||||||
|
bool active; // Slot in use
|
||||||
|
char xml_layout[DEVICE_XML_MAX]; // LVGL XML string for the current screen
|
||||||
|
};
|
||||||
|
|
||||||
|
internal device_t g_Devices[MAX_DEVICES] = {};
|
||||||
@@ -20,6 +20,7 @@
|
|||||||
#include "api/system/info.cpp"
|
#include "api/system/info.cpp"
|
||||||
#include "api/system/reboot.cpp"
|
#include "api/system/reboot.cpp"
|
||||||
#include "api/display/unity.cpp"
|
#include "api/display/unity.cpp"
|
||||||
|
#include "api/devices/unity.cpp"
|
||||||
#include "api/tasks/unity.cpp"
|
#include "api/tasks/unity.cpp"
|
||||||
#include "api/users/unity.cpp"
|
#include "api/users/unity.cpp"
|
||||||
|
|
||||||
@@ -264,7 +265,7 @@ internal httpd_handle_t start_webserver(void)
|
|||||||
|
|
||||||
httpd_config_t config = HTTPD_DEFAULT_CONFIG();
|
httpd_config_t config = HTTPD_DEFAULT_CONFIG();
|
||||||
config.uri_match_fn = httpd_uri_match_wildcard;
|
config.uri_match_fn = httpd_uri_match_wildcard;
|
||||||
config.max_uri_handlers = 20;
|
config.max_uri_handlers = 26;
|
||||||
config.max_open_sockets = 24;
|
config.max_open_sockets = 24;
|
||||||
config.lru_purge_enable = true;
|
config.lru_purge_enable = true;
|
||||||
config.stack_size = 16384;
|
config.stack_size = 16384;
|
||||||
@@ -301,6 +302,13 @@ internal httpd_handle_t start_webserver(void)
|
|||||||
httpd_register_uri_handler(server, &api_tasks_update_uri);
|
httpd_register_uri_handler(server, &api_tasks_update_uri);
|
||||||
httpd_register_uri_handler(server, &api_tasks_delete_uri);
|
httpd_register_uri_handler(server, &api_tasks_delete_uri);
|
||||||
|
|
||||||
|
// Register device API routes
|
||||||
|
httpd_register_uri_handler(server, &api_devices_get_uri);
|
||||||
|
httpd_register_uri_handler(server, &api_devices_register_uri);
|
||||||
|
httpd_register_uri_handler(server, &api_devices_layout_uri);
|
||||||
|
httpd_register_uri_handler(server, &api_devices_screen_info_uri);
|
||||||
|
httpd_register_uri_handler(server, &api_devices_screen_image_uri);
|
||||||
|
|
||||||
// Populate dummy data for development (debug builds only)
|
// Populate dummy data for development (debug builds only)
|
||||||
#ifndef NDEBUG
|
#ifndef NDEBUG
|
||||||
seed_users();
|
seed_users();
|
||||||
|
|||||||
@@ -18,4 +18,4 @@ dependencies:
|
|||||||
espressif/mdns: ^1.4.1
|
espressif/mdns: ^1.4.1
|
||||||
espressif/ethernet_init: ^1.3.0
|
espressif/ethernet_init: ^1.3.0
|
||||||
joltwallet/littlefs: "^1.20" # https://github.com/joltwallet/esp_littlefs
|
joltwallet/littlefs: "^1.20" # https://github.com/joltwallet/esp_littlefs
|
||||||
lvgl/lvgl: "^9.2.0"
|
lvgl/lvgl: "9.4.0"
|
||||||
|
|||||||
@@ -4,31 +4,38 @@
|
|||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
|
||||||
// LVGL's LodePNG memory optimization
|
// LVGL's LodePNG memory optimization
|
||||||
// Instead of standard heap allocations which fragment quickly and crash on the ESP32,
|
// Instead of standard heap allocations which fragment quickly and crash on the
|
||||||
// we allocate a single massive buffer in PSRAM and just bump a pointer during encode!
|
// ESP32, we allocate a single massive buffer in PSRAM and just bump a pointer
|
||||||
|
// during encode!
|
||||||
|
|
||||||
static const char *kTagLodeAlloc = "LODE_ALLOC";
|
static const char *kTagLodeAlloc = "LODE_ALLOC";
|
||||||
|
|
||||||
// 2MB buffer for LodePNG encoding intermediate state.
|
// 2MB buffer for LodePNG encoding intermediate state.
|
||||||
// A typical 800x480 grayscale PNG should compress to ~50-100KB, but the dynamic window
|
// A typical 800x480 grayscale PNG should compress to ~50-100KB, but the dynamic
|
||||||
// matching and filtering algorithms need a good amount of scratch space.
|
// window matching and filtering algorithms need a good amount of scratch space.
|
||||||
// We can tune this down to 1MB if 2MB is too aggressive, but PSRAM provides 8MB.
|
// We can tune this down to 1MB if 2MB is too aggressive, but PSRAM provides
|
||||||
#define LODEPNG_ALLOC_POOL_SIZE (2 * 1024 * 1024)
|
// 8MB.
|
||||||
|
#define LODEPNG_ALLOC_POOL_SIZE (1 * 1024 * 1024)
|
||||||
|
|
||||||
static uint8_t *s_lodepng_pool = nullptr;
|
static uint8_t *s_lodepng_pool = nullptr;
|
||||||
static size_t s_lodepng_pool_used = 0;
|
static size_t s_lodepng_pool_used = 0;
|
||||||
|
|
||||||
void lodepng_allocator_init()
|
void lodepng_allocator_init()
|
||||||
{
|
{
|
||||||
if (s_lodepng_pool != nullptr) return;
|
if (s_lodepng_pool != nullptr)
|
||||||
|
return;
|
||||||
|
|
||||||
ESP_LOGI(kTagLodeAlloc, "Allocating %d bytes in PSRAM for LodePNG bump allocator...", LODEPNG_ALLOC_POOL_SIZE);
|
ESP_LOGI(kTagLodeAlloc,
|
||||||
|
"Allocating %d bytes in PSRAM for LodePNG bump allocator...",
|
||||||
|
LODEPNG_ALLOC_POOL_SIZE);
|
||||||
|
|
||||||
// SPIRAM fallback to internal if someone tests without a PSRAM chip
|
// SPIRAM fallback to internal if someone tests without a PSRAM chip
|
||||||
s_lodepng_pool = (uint8_t*)heap_caps_malloc(LODEPNG_ALLOC_POOL_SIZE, MALLOC_CAP_SPIRAM);
|
s_lodepng_pool =
|
||||||
|
(uint8_t *)heap_caps_malloc(LODEPNG_ALLOC_POOL_SIZE, MALLOC_CAP_SPIRAM);
|
||||||
if (!s_lodepng_pool)
|
if (!s_lodepng_pool)
|
||||||
{
|
{
|
||||||
s_lodepng_pool = (uint8_t*)heap_caps_malloc(LODEPNG_ALLOC_POOL_SIZE, MALLOC_CAP_DEFAULT);
|
s_lodepng_pool = (uint8_t *)heap_caps_malloc(LODEPNG_ALLOC_POOL_SIZE,
|
||||||
|
MALLOC_CAP_DEFAULT);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!s_lodepng_pool)
|
if (!s_lodepng_pool)
|
||||||
@@ -37,10 +44,7 @@ void lodepng_allocator_init()
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void lodepng_allocator_reset()
|
void lodepng_allocator_reset() { s_lodepng_pool_used = 0; }
|
||||||
{
|
|
||||||
s_lodepng_pool_used = 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
void lodepng_allocator_free()
|
void lodepng_allocator_free()
|
||||||
{
|
{
|
||||||
@@ -56,8 +60,10 @@ void lodepng_allocator_free()
|
|||||||
// Custom Allocators injected into lodepng.c
|
// Custom Allocators injected into lodepng.c
|
||||||
// ----------------------------------------------------
|
// ----------------------------------------------------
|
||||||
|
|
||||||
// To support realloc properly, we prefix each allocation with an 8-byte header storing the size.
|
// To support realloc properly, we prefix each allocation with an 8-byte header
|
||||||
struct AllocHeader {
|
// storing the size.
|
||||||
|
struct AllocHeader
|
||||||
|
{
|
||||||
size_t size;
|
size_t size;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -65,7 +71,8 @@ void* lodepng_custom_malloc(size_t size)
|
|||||||
{
|
{
|
||||||
if (!s_lodepng_pool)
|
if (!s_lodepng_pool)
|
||||||
{
|
{
|
||||||
ESP_LOGE(kTagLodeAlloc, "lodepng_malloc called before lodepng_allocator_init!");
|
ESP_LOGE(kTagLodeAlloc,
|
||||||
|
"lodepng_malloc called before lodepng_allocator_init!");
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -75,7 +82,9 @@ void* lodepng_custom_malloc(size_t size)
|
|||||||
|
|
||||||
if (s_lodepng_pool_used + total_alloc > LODEPNG_ALLOC_POOL_SIZE)
|
if (s_lodepng_pool_used + total_alloc > LODEPNG_ALLOC_POOL_SIZE)
|
||||||
{
|
{
|
||||||
ESP_LOGE(kTagLodeAlloc, "LodePNG pool exhausted! Requested: %zu, Used: %zu, Total: %d", size, s_lodepng_pool_used, LODEPNG_ALLOC_POOL_SIZE);
|
ESP_LOGE(kTagLodeAlloc,
|
||||||
|
"LodePNG pool exhausted! Requested: %zu, Used: %zu, Total: %d",
|
||||||
|
size, s_lodepng_pool_used, LODEPNG_ALLOC_POOL_SIZE);
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -118,7 +127,8 @@ void* lodepng_custom_realloc(void* ptr, size_t new_size)
|
|||||||
// Let's see if this ptr was the *very last* allocation.
|
// Let's see if this ptr was the *very last* allocation.
|
||||||
// If so, we can just expand it in place!
|
// If so, we can just expand it in place!
|
||||||
size_t old_aligned_size = (old_size + 7) & ~7;
|
size_t old_aligned_size = (old_size + 7) & ~7;
|
||||||
if (orig_ptr + sizeof(AllocHeader) + old_aligned_size == s_lodepng_pool + s_lodepng_pool_used)
|
if (orig_ptr + sizeof(AllocHeader) + old_aligned_size ==
|
||||||
|
s_lodepng_pool + s_lodepng_pool_used)
|
||||||
{
|
{
|
||||||
// We are at the end! Just bump further!
|
// We are at the end! Just bump further!
|
||||||
size_t new_aligned_size = (new_size + 7) & ~7;
|
size_t new_aligned_size = (new_size + 7) & ~7;
|
||||||
@@ -126,7 +136,8 @@ void* lodepng_custom_realloc(void* ptr, size_t new_size)
|
|||||||
|
|
||||||
if (s_lodepng_pool_used + size_diff > LODEPNG_ALLOC_POOL_SIZE)
|
if (s_lodepng_pool_used + size_diff > LODEPNG_ALLOC_POOL_SIZE)
|
||||||
{
|
{
|
||||||
ESP_LOGE(kTagLodeAlloc, "LodePNG pool exhausted during in-place realloc!");
|
ESP_LOGE(kTagLodeAlloc,
|
||||||
|
"LodePNG pool exhausted during in-place realloc!");
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,8 +1,11 @@
|
|||||||
#include "lv_setup.hpp"
|
#include "lv_setup.hpp"
|
||||||
|
|
||||||
#include "esp_heap_caps.h"
|
#include "esp_heap_caps.h"
|
||||||
#include "esp_log.h"
|
#include "esp_log.h"
|
||||||
#include "esp_timer.h"
|
#include "esp_timer.h"
|
||||||
#include "freertos/task.h"
|
#include "freertos/task.h"
|
||||||
|
#include "lodepng_alloc.hpp"
|
||||||
|
|
||||||
#include "types.hpp"
|
#include "types.hpp"
|
||||||
|
|
||||||
internal const char *kTagLvgl = "LVGL";
|
internal const char *kTagLvgl = "LVGL";
|
||||||
@@ -30,10 +33,12 @@ internal uint32_t my_tick_get_cb()
|
|||||||
return (uint32_t)(esp_timer_get_time() / 1000);
|
return (uint32_t)(esp_timer_get_time() / 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
internal void lv_dummy_flush_cb(lv_display_t *disp, const lv_area_t *area, uint8_t *px_map)
|
internal void lv_dummy_flush_cb(lv_display_t *disp, const lv_area_t *area,
|
||||||
|
uint8_t *px_map)
|
||||||
{
|
{
|
||||||
// Headless display, so we don't actually flush to SPI/I2C.
|
// Headless display, so we don't actually flush to SPI/I2C.
|
||||||
// We just tell LVGL that the "flush" is completed so it unblocks wait_for_flushing.
|
// We just tell LVGL that the "flush" is completed so it unblocks
|
||||||
|
// wait_for_flushing.
|
||||||
lv_display_flush_ready(disp);
|
lv_display_flush_ready(disp);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -46,6 +51,22 @@ internal void lv_draw_sample_ui()
|
|||||||
lv_obj_t *label = lv_label_create(scr);
|
lv_obj_t *label = lv_label_create(scr);
|
||||||
lv_label_set_text(label, "Calendink Provider\nLVGL Headless Renderer");
|
lv_label_set_text(label, "Calendink Provider\nLVGL Headless Renderer");
|
||||||
lv_obj_align(label, LV_ALIGN_CENTER, 0, 0);
|
lv_obj_align(label, LV_ALIGN_CENTER, 0, 0);
|
||||||
|
|
||||||
|
static lv_style_t style;
|
||||||
|
lv_style_init(&style);
|
||||||
|
|
||||||
|
lv_style_set_line_color(&style, lv_palette_main(LV_PALETTE_GREY));
|
||||||
|
lv_style_set_line_width(&style, 6);
|
||||||
|
lv_style_set_line_rounded(&style, true);
|
||||||
|
|
||||||
|
/*Create an object with the new style*/
|
||||||
|
lv_obj_t *obj = lv_line_create(scr);
|
||||||
|
lv_obj_add_style(obj, &style, 0);
|
||||||
|
|
||||||
|
static lv_point_precise_t p[] = {{10, 30}, {30, 50}, {100, 0}};
|
||||||
|
lv_line_set_points(obj, p, 3);
|
||||||
|
|
||||||
|
lv_obj_center(obj);
|
||||||
}
|
}
|
||||||
|
|
||||||
void setup_lvgl()
|
void setup_lvgl()
|
||||||
@@ -68,14 +89,16 @@ void setup_lvgl()
|
|||||||
lodepng_allocator_init();
|
lodepng_allocator_init();
|
||||||
|
|
||||||
// Allocate draw buffers in PSRAM
|
// Allocate draw buffers in PSRAM
|
||||||
// Using LV_COLOR_FORMAT_L8 (1 byte per pixel)
|
// Using LV_COLOR_FORMAT_RGB565 (2 bytes per pixel)
|
||||||
size_t buf_size = LV_DRAW_BUF_SIZE(width, height, LV_COLOR_FORMAT_L8);
|
size_t buf_size = LV_DRAW_BUF_SIZE(width, height, LV_COLOR_FORMAT_RGB565);
|
||||||
|
|
||||||
// Fallback to MALLOC_CAP_DEFAULT if we can't get SPIRAM (for debugging without it)
|
// Fallback to MALLOC_CAP_DEFAULT if we can't get SPIRAM (for debugging
|
||||||
|
// without it)
|
||||||
void *buf1 = heap_caps_malloc(buf_size, MALLOC_CAP_SPIRAM);
|
void *buf1 = heap_caps_malloc(buf_size, MALLOC_CAP_SPIRAM);
|
||||||
if (!buf1)
|
if (!buf1)
|
||||||
{
|
{
|
||||||
ESP_LOGW(kTagLvgl, "Failed to allocate LVGL draw buffer in PSRAM, falling back to internal RAM");
|
ESP_LOGW(kTagLvgl, "Failed to allocate LVGL draw buffer in PSRAM, falling "
|
||||||
|
"back to internal RAM");
|
||||||
buf1 = heap_caps_malloc(buf_size, MALLOC_CAP_DEFAULT);
|
buf1 = heap_caps_malloc(buf_size, MALLOC_CAP_DEFAULT);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -87,10 +110,12 @@ void setup_lvgl()
|
|||||||
|
|
||||||
g_LvglDrawBuffer = (uint8_t *)buf1;
|
g_LvglDrawBuffer = (uint8_t *)buf1;
|
||||||
|
|
||||||
lv_display_set_buffers(g_LvglDisplay, buf1, nullptr, buf_size, LV_DISPLAY_RENDER_MODE_FULL);
|
// Explicitly set the color format of the display FIRST
|
||||||
|
// so that stride and byte-per-pixel calculations align with our buffer.
|
||||||
|
lv_display_set_color_format(g_LvglDisplay, LV_COLOR_FORMAT_RGB565);
|
||||||
|
|
||||||
// Explicitly set the color format of the display if it's set in sdkconfig/driver
|
lv_display_set_buffers(g_LvglDisplay, buf1, nullptr, buf_size,
|
||||||
lv_display_set_color_format(g_LvglDisplay, LV_COLOR_FORMAT_L8);
|
LV_DISPLAY_RENDER_MODE_FULL);
|
||||||
|
|
||||||
// Create the background task for the LVGL timer
|
// Create the background task for the LVGL timer
|
||||||
xTaskCreate(lvgl_tick_task, "LVGL Tick", 4096, nullptr, 5, nullptr);
|
xTaskCreate(lvgl_tick_task, "LVGL Tick", 4096, nullptr, 5, nullptr);
|
||||||
@@ -102,5 +127,6 @@ void setup_lvgl()
|
|||||||
xSemaphoreGive(g_LvglMutex);
|
xSemaphoreGive(g_LvglMutex);
|
||||||
}
|
}
|
||||||
|
|
||||||
ESP_LOGI(kTagLvgl, "LVGL fully initialized. Display %lux%lu created.", width, height);
|
ESP_LOGI(kTagLvgl, "LVGL fully initialized. Display %lux%lu created.", width,
|
||||||
|
height);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,15 +27,16 @@ CONFIG_ETHERNET_SPI_POLLING0_MS=0
|
|||||||
|
|
||||||
# Enable PSRAM
|
# Enable PSRAM
|
||||||
CONFIG_SPIRAM=y
|
CONFIG_SPIRAM=y
|
||||||
CONFIG_ESP32S3_SPIRAM_SUPPORT=y
|
|
||||||
CONFIG_SPIRAM_MODE_OCT=y
|
CONFIG_SPIRAM_MODE_OCT=y
|
||||||
CONFIG_SPIRAM_SPEED_80M=y
|
CONFIG_SPIRAM_SPEED_80M=y
|
||||||
CONFIG_SPIRAM_FETCH_INSTRUCTIONS=y
|
CONFIG_SPIRAM_FETCH_INSTRUCTIONS=y
|
||||||
CONFIG_SPIRAM_RODATA=y
|
CONFIG_SPIRAM_RODATA=y
|
||||||
|
|
||||||
# LVGL Configuration
|
# LVGL Configuration
|
||||||
CONFIG_LV_COLOR_DEPTH_8=y
|
CONFIG_LV_COLOR_DEPTH_16=y
|
||||||
CONFIG_LV_USE_SYSMON=n
|
CONFIG_LV_USE_SYSMON=n
|
||||||
|
CONFIG_LV_USE_OBJ_NAME=y
|
||||||
|
CONFIG_LV_ATTRIBUTE_FAST_MEM_USE_IRAM=y
|
||||||
|
|
||||||
# LVGL Memory Allocator (Use ESP-IDF Heap instead of internal 64kB BSS pool!)
|
# LVGL Memory Allocator (Use ESP-IDF Heap instead of internal 64kB BSS pool!)
|
||||||
CONFIG_LV_USE_BUILTIN_MALLOC=n
|
CONFIG_LV_USE_BUILTIN_MALLOC=n
|
||||||
@@ -51,20 +52,19 @@ CONFIG_LV_BUILD_EXAMPLES=n
|
|||||||
CONFIG_LV_BUILD_DEMOS=n
|
CONFIG_LV_BUILD_DEMOS=n
|
||||||
|
|
||||||
# Disable unused software drawing color formats (Only L8 and A8 matter for grayscale)
|
# Disable unused software drawing color formats (Only L8 and A8 matter for grayscale)
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_RGB565=n
|
CONFIG_LV_DRAW_SW_SUPPORT_RGB565=y
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_RGB565_SWAPPED=n
|
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_RGB565A8=n
|
CONFIG_LV_DRAW_SW_SUPPORT_RGB565A8=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_RGB888=n
|
CONFIG_LV_DRAW_SW_SUPPORT_RGB888=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_XRGB8888=n
|
CONFIG_LV_DRAW_SW_SUPPORT_XRGB8888=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_ARGB8888=n
|
CONFIG_LV_DRAW_SW_SUPPORT_ARGB8888=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_ARGB8888_PREMULTIPLIED=n
|
CONFIG_LV_DRAW_SW_SUPPORT_ARGB8888_PREMULTIPLIED=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_L8=y
|
CONFIG_LV_DRAW_SW_SUPPORT_L8=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_AL88=n
|
CONFIG_LV_DRAW_SW_SUPPORT_AL88=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_A8=y
|
CONFIG_LV_DRAW_SW_SUPPORT_A8=n
|
||||||
CONFIG_LV_DRAW_SW_SUPPORT_I1=n
|
CONFIG_LV_DRAW_SW_SUPPORT_I1=n
|
||||||
|
|
||||||
# Disable complex drawing features to save memory (no shadows, no complex gradients)
|
# Enable complex drawing features (required for lines thicker than 1px, rounded lines, arcs, and gradients)
|
||||||
CONFIG_LV_DRAW_SW_COMPLEX=n
|
CONFIG_LV_DRAW_SW_COMPLEX=y
|
||||||
|
|
||||||
# Disable unneeded widgets for a simple static screen generator
|
# Disable unneeded widgets for a simple static screen generator
|
||||||
CONFIG_LV_USE_CHART=n
|
CONFIG_LV_USE_CHART=n
|
||||||
@@ -78,13 +78,13 @@ CONFIG_LV_USE_SPINBOX=n
|
|||||||
CONFIG_LV_USE_SPINNER=n
|
CONFIG_LV_USE_SPINNER=n
|
||||||
CONFIG_LV_USE_KEYBOARD=n
|
CONFIG_LV_USE_KEYBOARD=n
|
||||||
CONFIG_LV_USE_CALENDAR=n
|
CONFIG_LV_USE_CALENDAR=n
|
||||||
CONFIG_LV_USE_CHECKBOX=n
|
CONFIG_LV_USE_CHECKBOX=y
|
||||||
CONFIG_LV_USE_DROPDOWN=n
|
CONFIG_LV_USE_DROPDOWN=n
|
||||||
CONFIG_LV_USE_IMAGEBUTTON=n
|
CONFIG_LV_USE_IMAGEBUTTON=n
|
||||||
CONFIG_LV_USE_ROLLER=n
|
CONFIG_LV_USE_ROLLER=n
|
||||||
CONFIG_LV_USE_SCALE=n
|
CONFIG_LV_USE_SCALE=n
|
||||||
CONFIG_LV_USE_SLIDER=n
|
CONFIG_LV_USE_SLIDER=n
|
||||||
CONFIG_LV_USE_SWITCH=n
|
CONFIG_LV_USE_SWITCH=y
|
||||||
CONFIG_LV_USE_TEXTAREA=n
|
CONFIG_LV_USE_TEXTAREA=n
|
||||||
CONFIG_LV_USE_TABLE=n
|
CONFIG_LV_USE_TABLE=n
|
||||||
|
|
||||||
@@ -96,3 +96,7 @@ CONFIG_LV_THEME_DEFAULT_TRANSITION_TIME=0
|
|||||||
|
|
||||||
# Disable data observer patterns (unused in static render flow)
|
# Disable data observer patterns (unused in static render flow)
|
||||||
CONFIG_LV_USE_OBSERVER=n
|
CONFIG_LV_USE_OBSERVER=n
|
||||||
|
|
||||||
|
# Enable XML runtime for dynamic screen layouts (LVGL 9.4+)
|
||||||
|
CONFIG_LV_USE_XML=y
|
||||||
|
CONFIG_LV_USE_OBSERVER=y
|
||||||
|
|||||||
@@ -53,7 +53,15 @@ The following REST endpoints handle the device lifecycle and image generation:
|
|||||||
### Subsystems Config
|
### Subsystems Config
|
||||||
The ESP-IDF project configuration (`sdkconfig.defaults`) must be modified to enable the `CONFIG_LV_USE_XML=y` flag, which compiles the LVGL XML parser component into the firmware image.
|
The ESP-IDF project configuration (`sdkconfig.defaults`) must be modified to enable the `CONFIG_LV_USE_XML=y` flag, which compiles the LVGL XML parser component into the firmware image.
|
||||||
|
|
||||||
|
### XML Runtime Integration
|
||||||
|
The user provided documentation for the `LV_USE_XML` runtime feature. We must:
|
||||||
|
1. Call `lv_xml_register_component_from_data("current_device", dev->xml_layout)` to register the XML payload.
|
||||||
|
2. Check if the XML string contains `<screen>`. If it does, LVGL expects us to instantiate it as a full screen using `lv_obj_t * root = lv_xml_create_screen("current_device");`.
|
||||||
|
3. If it does not contain `<screen>`, it's just a regular component/widget, so we create it *on* the active screen using `lv_obj_t * root = lv_xml_create(scr, "current_device", NULL);`.
|
||||||
|
4. Fallback to a string label if the XML is empty or parsing fails.
|
||||||
|
|
||||||
### Frontend
|
### Frontend
|
||||||
- **DeviceManager.svelte:** A new component accessible from the Sidebar. It fetches the device list on load.
|
- **DeviceManager.svelte:** A new component accessible from the Sidebar. It fetches the device list on load.
|
||||||
- **XML Uploading:** For each device card, a text area allows the user to paste an LVGL XML string. Clicking "Save Layout" updates the device via `POST /api/devices/layout`.
|
- **XML Uploading:** For each device card, a text area allows the user to paste an LVGL XML string. Clicking "Save Layout" updates the device via `POST /api/devices/layout`.
|
||||||
|
- **Debug Features:** A collapsed section (e.g. `<details>`) in the UI will contain a button to "Register Debug Device" that triggers a POST to `/api/devices/register` with a random or hardcoded MAC (e.g., `00:11:22:33:44:55`).
|
||||||
- **Integration:** The `App.svelte` router will be updated to include the `'devices'` view state alongside Dashboard, Tasks, and Users.
|
- **Integration:** The `App.svelte` router will be updated to include the `'devices'` view state alongside Dashboard, Tasks, and Users.
|
||||||
|
|||||||
Reference in New Issue
Block a user