Hello from my module!
+ + `, + }; + } + + getActions(): UIAction[] { + return [ + { + id: "do-something", + label: "Do Something", + handler: async () => { + // Perform action + return { message: "Action completed!" }; + }, + }, + ]; + } +} +``` + +Add to `console.config.json`: +```json +{ + "uiModules": { + "my-module": "core/my-module/ui" + } +} +``` + +## UIHooks Interface + +| Method | Return Type | Description | +|--------|-------------|-------------| +| `getAppIcon()` | `UIAppIcon` | Desktop icon displayed in the app grid | +| `getAppWindow()` | `UIAppWindow` | Window/panel shown when icon is clicked | +| `getActions()` | `UIAction[]` | Actions invokable from the frontend | +| `getStatusData()` | `RecordConfiguration
+Status
+${message}
+ `; + + document.body.appendChild(notification); + + // Play click sound for feedback + if (typeof clickButton === "function") { + clickButton(); + } + + // Auto-remove after 4 seconds + setTimeout(() => { + notification.style.animation = "slideOut 0.3s ease-in"; + setTimeout(() => notification.remove(), 300); + }, 4000); +} + +// Add CSS animation styles +const styleSheet = document.createElement("style"); +styleSheet.textContent = ` + @keyframes slideIn { + from { + transform: translateX(100%); + opacity: 0; + } + to { + transform: translateX(0); + opacity: 1; + } + } + @keyframes slideOut { + from { + transform: translateX(0); + opacity: 1; + } + to { + transform: translateX(100%); + opacity: 0; + } + } +`; +document.head.appendChild(styleSheet); diff --git a/src/logic/context.ts b/src/services/context.ts similarity index 100% rename from src/logic/context.ts rename to src/services/context.ts diff --git a/src/logic/grpc.ts b/src/services/grpc.ts similarity index 100% rename from src/logic/grpc.ts rename to src/services/grpc.ts diff --git a/src/logic/mqtt.ts b/src/services/mqtt.ts similarity index 54% rename from src/logic/mqtt.ts rename to src/services/mqtt.ts index 537a9af..b2c0a56 100644 --- a/src/logic/mqtt.ts +++ b/src/services/mqtt.ts @@ -1,8 +1,7 @@ import { connect } from "mqtt"; import { enqueue } from "./grpc"; -import { interact } from "./arweave"; -import { encode } from "./encode"; -import { m3ter as m3terContract } from "./context"; +import { encode } from "../lib/encode"; +import { app, m3ter as m3terContract } from "./context"; import { deleteMeterByPublicKey, getAllTransactionRecords, @@ -14,64 +13,66 @@ import { updateMeterDevEui, updateMeterNonce, } from "../store/sqlite"; -import { State, TransactionRecord } from "../types"; -import { getProverURL, sendPendingTransactionsToProver } from "./prover"; -import { decodePayload } from "./decode"; -import { verifyPayloadSignature } from "../utils"; -import { - getLatestTransactionNonce, - pruneAndSyncOnchain, - getCrossChainRevenue, - getOwedFromPriceContext, -} from "./sync"; -import { createMeterLogger, MeterLogger } from "../utils/logger"; -import { publishPendingTransactionsToStreamr } from "./streamr"; +import type { State, TransactionRecord } from "../types"; +import { decodePayload } from "../lib/decode"; +import { runHook, verifyPayloadSignature } from "../lib/utils"; +import { getLatestTransactionNonce, pruneAndSyncOnchain, getCrossChainRevenue, getOwedFromPriceContext } from "../lib/sync"; +import { createMeterLogger } from "../utils/logger"; const CHIRPSTACK_HOST = process.env.CHIRPSTACK_HOST; -const SYNC_EPOCH = 100; // after 100 transactions, sync with blockchain const deviceLocks = new Map{{label}}
+