Compare commits
20 Commits
52216495c2
...
stable-reb
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f76c5ac33b | ||
|
|
6e0976a284 | ||
|
|
060a2bc917 | ||
|
|
4171b2f6e9 | ||
|
|
35a0bbb867 | ||
|
|
5cdc77ccf3 | ||
|
|
bb021633a3 | ||
|
|
93616d3a1a | ||
|
|
2fd2b6ad8a | ||
|
|
e3a19234a9 | ||
|
|
a233cfc4fd | ||
|
|
036567bc7c | ||
|
|
ccc6d90578 | ||
|
|
c3add8da27 | ||
|
|
5426a388ba | ||
|
|
034c951d9b | ||
|
|
d6d695e6c0 | ||
|
|
47d8c7d98d | ||
|
|
3a91fafe8f | ||
|
|
d9a91fe5b1 |
@@ -6438,8 +6438,8 @@ async function stopTimer(token, entryId) {
|
||||
}
|
||||
|
||||
// src/plugin.ts
|
||||
var CURRENT_VERSION = "1.0.15";
|
||||
var GITEA_BASE = "https://gitea.pdmarf.co.uk/pdm/stream_deck_notion_timer/raw/branch/master";
|
||||
var CURRENT_VERSION = "1.0.40";
|
||||
var GITEA_BASE = "https://gitea.pdmarf.co.uk/pdm/stream_deck_notion_timer/raw/branch/stable-rebuild";
|
||||
var SIGNING_PUBLIC_KEY = `-----BEGIN PUBLIC KEY-----
|
||||
MCowBQYDK2VwAyEAN7ko8TUpuPzPAJuKAZCRjV0c4ZSlou5d9pUAF6o12b4=
|
||||
-----END PUBLIC KEY-----`;
|
||||
@@ -6456,32 +6456,67 @@ function fetchWithTimeout2(url) {
|
||||
const timer = setTimeout(() => controller.abort(), 1e4);
|
||||
return fetch(url, { signal: controller.signal }).finally(() => clearTimeout(timer));
|
||||
}
|
||||
async function checkForUpdates() {
|
||||
async function checkForUpdates(sendStatus) {
|
||||
try {
|
||||
const resp = await fetchWithTimeout2(`${GITEA_BASE}/version.json`);
|
||||
if (!resp.ok) return;
|
||||
if (!resp.ok) {
|
||||
sendStatus?.("Update check failed");
|
||||
return;
|
||||
}
|
||||
const { version } = await resp.json();
|
||||
if (!/^\d+\.\d+\.\d+$/.test(version)) return;
|
||||
if (!isNewerVersion(version, CURRENT_VERSION)) return;
|
||||
if (!isNewerVersion(version, CURRENT_VERSION)) {
|
||||
sendStatus?.(`Already up to date (v${CURRENT_VERSION})`);
|
||||
return;
|
||||
}
|
||||
sendStatus?.(`Updating to v${version}\u2026`);
|
||||
const [pluginResp, sigResp] = await Promise.all([
|
||||
fetchWithTimeout2(`${GITEA_BASE}/com.pdma.notion-timer.sdPlugin/bin/plugin.js`),
|
||||
fetchWithTimeout2(`${GITEA_BASE}/com.pdma.notion-timer.sdPlugin/bin/plugin.js.sig`)
|
||||
]);
|
||||
if (!pluginResp.ok || !sigResp.ok) return;
|
||||
if (!pluginResp.ok || !sigResp.ok) {
|
||||
sendStatus?.("Download failed");
|
||||
return;
|
||||
}
|
||||
const newCode = await pluginResp.text();
|
||||
const sigBytes = Buffer.from(await sigResp.arrayBuffer());
|
||||
const { verify } = await import("node:crypto");
|
||||
const valid = verify(null, Buffer.from(newCode), SIGNING_PUBLIC_KEY, sigBytes);
|
||||
if (!valid) {
|
||||
plugin_default.logger.error("Update rejected: signature verification failed");
|
||||
sendStatus?.("Update rejected: invalid signature");
|
||||
return;
|
||||
}
|
||||
const fs3 = await import("fs");
|
||||
const path5 = await import("path");
|
||||
const pluginRoot = path5.join(path5.dirname(__filename), "..");
|
||||
const ASSETS = [
|
||||
"ui/property-inspector.html",
|
||||
"ui/global-property-inspector.html",
|
||||
"imgs/idle.png",
|
||||
"imgs/running.png"
|
||||
];
|
||||
const PLUGIN_BASE = `${GITEA_BASE}/com.pdma.notion-timer.sdPlugin`;
|
||||
const assetResps = await Promise.all(ASSETS.map((p) => fetchWithTimeout2(`${PLUGIN_BASE}/${p}`)));
|
||||
for (let i = 0; i < ASSETS.length; i++) {
|
||||
if (assetResps[i].ok) {
|
||||
fs3.writeFileSync(path5.join(pluginRoot, ASSETS[i]), Buffer.from(await assetResps[i].arrayBuffer()));
|
||||
}
|
||||
}
|
||||
const LEGACY = ["imgs/idle.svg", "imgs/running.svg"];
|
||||
for (const f of LEGACY) {
|
||||
try {
|
||||
fs3.unlinkSync(path5.join(pluginRoot, f));
|
||||
} catch {
|
||||
}
|
||||
}
|
||||
fs3.writeFileSync(__filename, newCode);
|
||||
plugin_default.logger.info(`Updated to ${version}, restarting\u2026`);
|
||||
process.exit(0);
|
||||
} catch (err) {
|
||||
plugin_default.logger.error(`Update check failed: ${err instanceof Error ? err.message : String(err)}`);
|
||||
const msg = err instanceof Error ? err.message : String(err);
|
||||
plugin_default.logger.error(`Update check failed: ${msg}`);
|
||||
sendStatus?.(`Error: ${msg}`);
|
||||
}
|
||||
}
|
||||
var HARDCODED = {
|
||||
@@ -6493,17 +6528,38 @@ async function getGlobal() {
|
||||
return { ...stored, ...HARDCODED };
|
||||
}
|
||||
var memRunningEntryId = void 0;
|
||||
async function getRunningEntryId() {
|
||||
if (memRunningEntryId === void 0) {
|
||||
const stored = await plugin_default.settings.getGlobalSettings();
|
||||
memRunningEntryId = stored.runningEntryId ?? null;
|
||||
}
|
||||
return memRunningEntryId;
|
||||
}
|
||||
async function setRunningEntry(entryId) {
|
||||
memRunningEntryId = entryId;
|
||||
var memRunningActionId = void 0;
|
||||
async function loadRunningState() {
|
||||
if (memRunningEntryId !== void 0) return;
|
||||
const stored = await plugin_default.settings.getGlobalSettings();
|
||||
await plugin_default.settings.setGlobalSettings({ ...stored, runningEntryId: entryId });
|
||||
memRunningEntryId = stored.runningEntryId ?? null;
|
||||
memRunningActionId = stored.runningActionId ?? null;
|
||||
}
|
||||
function setRunningEntry(entryId, actionId) {
|
||||
memRunningEntryId = entryId;
|
||||
memRunningActionId = actionId;
|
||||
plugin_default.settings.getGlobalSettings().then((stored) => plugin_default.settings.setGlobalSettings({ ...stored, runningEntryId: entryId, runningActionId: actionId })).catch((err) => plugin_default.logger.error("Failed to persist running state:", err));
|
||||
}
|
||||
async function sendProjectsToPI(tokenOverride) {
|
||||
try {
|
||||
const global = await getGlobal();
|
||||
const token = tokenOverride ?? global.notionToken;
|
||||
if (!token) {
|
||||
await plugin_default.ui.sendToPropertyInspector({ event: "projects", data: [], error: "Enter your Notion API token above.", version: CURRENT_VERSION });
|
||||
return;
|
||||
}
|
||||
const [projects, usersResult] = await Promise.all([
|
||||
fetchProjects(token, global.projectsDbId),
|
||||
fetchUsers(token).catch((err) => {
|
||||
plugin_default.logger.error("Failed to fetch users:", err);
|
||||
return [];
|
||||
})
|
||||
]);
|
||||
await plugin_default.ui.sendToPropertyInspector({ event: "projects", data: projects, users: usersResult, version: CURRENT_VERSION });
|
||||
} catch (err) {
|
||||
plugin_default.logger.error("Failed to fetch projects:", err);
|
||||
await plugin_default.ui.sendToPropertyInspector({ event: "projects", data: [], error: String(err), version: CURRENT_VERSION });
|
||||
}
|
||||
}
|
||||
function isConfigured(g) {
|
||||
return !!(g.notionToken && g.userId);
|
||||
@@ -6512,101 +6568,75 @@ function buttonTitle(projectName) {
|
||||
return projectName.replace(/^[\p{Extended_Pictographic}\uFE0F\s]+/u, "").trim();
|
||||
}
|
||||
var TimerToggle = class extends SingletonAction {
|
||||
settingsCache = /* @__PURE__ */ new Map();
|
||||
projectCache = /* @__PURE__ */ new Map();
|
||||
pendingKeyDown = /* @__PURE__ */ new Set();
|
||||
async onWillAppear(ev) {
|
||||
const { activeEntryId, projectName } = ev.payload.settings;
|
||||
const title = buttonTitle(projectName || "");
|
||||
const running = await getRunningEntryId();
|
||||
const isRunning = !!activeEntryId && activeEntryId === running;
|
||||
if (activeEntryId && !isRunning) {
|
||||
const cleared = { ...ev.payload.settings, activeEntryId: null };
|
||||
await ev.action.setSettings(cleared);
|
||||
this.settingsCache.set(ev.action.id, cleared);
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
this.projectCache.set(ev.action.id, ev.payload.settings);
|
||||
const title = buttonTitle(ev.payload.settings.projectName || "");
|
||||
await loadRunningState();
|
||||
const isRunning = memRunningActionId === ev.action.id;
|
||||
if (isRunning) {
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`\u23F1 ${title}`)]);
|
||||
} else {
|
||||
this.settingsCache.set(ev.action.id, ev.payload.settings);
|
||||
if (isRunning) {
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`\u23F1 ${title}`)]);
|
||||
} else {
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
}
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
}
|
||||
}
|
||||
async onPropertyInspectorDidAppear(ev) {
|
||||
try {
|
||||
const global = await getGlobal();
|
||||
if (!global.notionToken) {
|
||||
await plugin_default.ui.sendToPropertyInspector({ event: "projects", data: [], error: "Enter your Notion API token above.", version: CURRENT_VERSION });
|
||||
return;
|
||||
}
|
||||
const [projects, usersResult] = await Promise.all([
|
||||
fetchProjects(global.notionToken, global.projectsDbId),
|
||||
fetchUsers(global.notionToken).catch((err) => {
|
||||
plugin_default.logger.error("Failed to fetch users:", err);
|
||||
return [];
|
||||
})
|
||||
]);
|
||||
await plugin_default.ui.sendToPropertyInspector({ event: "projects", data: projects, users: usersResult, version: CURRENT_VERSION });
|
||||
} catch (err) {
|
||||
plugin_default.logger.error("Failed to fetch projects:", err);
|
||||
await plugin_default.ui.sendToPropertyInspector({ event: "projects", data: [], error: String(err), version: CURRENT_VERSION });
|
||||
}
|
||||
async onPropertyInspectorDidAppear(_ev) {
|
||||
await sendProjectsToPI();
|
||||
}
|
||||
async onKeyDown(ev) {
|
||||
this.settingsCache.set(ev.action.id, ev.payload.settings);
|
||||
const global = await getGlobal();
|
||||
const { projectId, projectName, activeEntryId } = ev.payload.settings;
|
||||
const title = buttonTitle(projectName || "");
|
||||
if (!isConfigured(global)) {
|
||||
await ev.action.showAlert();
|
||||
return;
|
||||
}
|
||||
if (!projectId) {
|
||||
await ev.action.showAlert();
|
||||
return;
|
||||
}
|
||||
if (this.pendingKeyDown.has(ev.action.id)) return;
|
||||
this.pendingKeyDown.add(ev.action.id);
|
||||
try {
|
||||
if (activeEntryId) {
|
||||
await stopTimer(global.notionToken, activeEntryId);
|
||||
const stopped = { ...ev.payload.settings, activeEntryId: null };
|
||||
await ev.action.setSettings(stopped);
|
||||
this.settingsCache.set(ev.action.id, stopped);
|
||||
await ev.action.setState(0);
|
||||
await ev.action.setTitle(title);
|
||||
await setRunningEntry(null);
|
||||
} else {
|
||||
const prevEntryId = await getRunningEntryId();
|
||||
if (prevEntryId) {
|
||||
await stopTimer(global.notionToken, prevEntryId);
|
||||
const { projectId, projectName } = ev.payload.settings;
|
||||
const title = buttonTitle(projectName || "");
|
||||
const isRunning = memRunningActionId === ev.action.id;
|
||||
if (projectId) {
|
||||
if (isRunning) {
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
} else {
|
||||
for (const other of this.actions) {
|
||||
if (other.id === ev.action.id) continue;
|
||||
const otherSettings = this.settingsCache.get(other.id);
|
||||
if (otherSettings?.activeEntryId === prevEntryId) {
|
||||
const stopped = { ...otherSettings, activeEntryId: null };
|
||||
await other.setSettings(stopped);
|
||||
this.settingsCache.set(other.id, stopped);
|
||||
await other.setState(0);
|
||||
await other.setTitle(buttonTitle(otherSettings.projectName || ""));
|
||||
if (memRunningActionId === other.id) {
|
||||
const s = this.projectCache.get(other.id);
|
||||
await Promise.all([other.setState(0), other.setTitle(buttonTitle(s?.projectName || ""))]);
|
||||
}
|
||||
}
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`\u23F1 ${title}`)]);
|
||||
}
|
||||
const entryId = await startTimer(
|
||||
global.notionToken,
|
||||
global.timingDbId,
|
||||
projectId,
|
||||
projectName,
|
||||
global.userId
|
||||
);
|
||||
const started = { ...ev.payload.settings, activeEntryId: entryId };
|
||||
await ev.action.setSettings(started);
|
||||
this.settingsCache.set(ev.action.id, started);
|
||||
await setRunningEntry(entryId);
|
||||
await ev.action.setState(1);
|
||||
await ev.action.setTitle(`\u23F1 ${title}`);
|
||||
}
|
||||
} catch (err) {
|
||||
plugin_default.logger.error("Timer toggle failed:", err);
|
||||
await ev.action.showAlert();
|
||||
const global = await getGlobal();
|
||||
if (!isConfigured(global)) {
|
||||
await ev.action.showAlert();
|
||||
return;
|
||||
}
|
||||
if (!projectId) {
|
||||
await ev.action.showAlert();
|
||||
return;
|
||||
}
|
||||
try {
|
||||
if (isRunning) {
|
||||
await stopTimer(global.notionToken, memRunningEntryId);
|
||||
setRunningEntry(null, null);
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
} else {
|
||||
if (memRunningEntryId) {
|
||||
await stopTimer(global.notionToken, memRunningEntryId);
|
||||
}
|
||||
const entryId = await startTimer(global.notionToken, global.timingDbId, projectId, projectName, global.userId);
|
||||
setRunningEntry(entryId, ev.action.id);
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`\u23F1 ${title}`)]);
|
||||
}
|
||||
} catch (err) {
|
||||
await Promise.all([
|
||||
ev.action.setState(isRunning ? 1 : 0),
|
||||
ev.action.setTitle(isRunning ? `\u23F1 ${title}` : title)
|
||||
]);
|
||||
plugin_default.logger.error("Timer toggle failed:", err);
|
||||
await ev.action.showAlert();
|
||||
}
|
||||
} finally {
|
||||
this.pendingKeyDown.delete(ev.action.id);
|
||||
}
|
||||
}
|
||||
};
|
||||
@@ -6621,6 +6651,14 @@ plugin_default.ui.onSendToPlugin(async (ev) => {
|
||||
const title = buttonTitle(ev.payload.settings.projectName || "");
|
||||
if (title) await ev.action.setTitle(title);
|
||||
}
|
||||
if (ev.payload.event === "refreshProjects") {
|
||||
await sendProjectsToPI(ev.payload.token);
|
||||
}
|
||||
if (ev.payload.event === "checkForUpdates") {
|
||||
const send = (msg) => plugin_default.ui.sendToPropertyInspector({ event: "updateStatus", message: msg });
|
||||
send("Checking\u2026");
|
||||
await checkForUpdates(send);
|
||||
}
|
||||
});
|
||||
plugin_default.connect();
|
||||
setTimeout(() => checkForUpdates(), 1e4);
|
||||
|
||||
Binary file not shown.
@@ -2,7 +2,7 @@
|
||||
"Author": "Pete Marfleet",
|
||||
"Description": "Toggle Notion time tracking for a project with a single button press.",
|
||||
"Name": "Notion Timer",
|
||||
"Version": "1.0.0",
|
||||
"Version": "1.0.39",
|
||||
"SDKVersion": 2,
|
||||
"Software": { "MinimumVersion": "5.0" },
|
||||
"OS": [{ "Platform": "mac", "MinimumVersion": "10.11" }],
|
||||
|
||||
@@ -88,6 +88,26 @@
|
||||
}
|
||||
#credStatus.ok { color: #4caf50; }
|
||||
#credStatus.error { color: #e57373; }
|
||||
#updateBtn {
|
||||
display: block;
|
||||
width: 100%;
|
||||
margin-top: 10px;
|
||||
padding: 6px;
|
||||
background: #2a2a2a;
|
||||
border: 1px solid #444;
|
||||
border-radius: 4px;
|
||||
color: #ccc;
|
||||
font-size: 12px;
|
||||
cursor: pointer;
|
||||
}
|
||||
#updateBtn:hover { background: #333; }
|
||||
#updateStatus {
|
||||
font-size: 11px;
|
||||
color: #888;
|
||||
text-align: center;
|
||||
margin-top: 4px;
|
||||
min-height: 14px;
|
||||
}
|
||||
</style>
|
||||
</head>
|
||||
<body>
|
||||
@@ -125,6 +145,8 @@
|
||||
|
||||
<p id="statusText"></p>
|
||||
<p id="versionText"></p>
|
||||
<button id="updateBtn">Check for Updates</button>
|
||||
<p id="updateStatus"></p>
|
||||
|
||||
<script src="libs/constants.js"></script>
|
||||
<script src="libs/prototypes.js"></script>
|
||||
@@ -139,6 +161,8 @@
|
||||
var currentSettings = {};
|
||||
var credSaveTimer = null;
|
||||
var credConfigured = false;
|
||||
var globalUserId = "";
|
||||
var cachedUsers = [];
|
||||
|
||||
function setStatus(msg, cls) {
|
||||
var el = document.getElementById("statusText");
|
||||
@@ -171,27 +195,35 @@
|
||||
userId: document.getElementById("userId").value,
|
||||
};
|
||||
$PI.setGlobalSettings(creds);
|
||||
globalUserId = creds.userId;
|
||||
setCredStatus("Credentials saved.", "ok");
|
||||
}
|
||||
|
||||
function populateUsers(users, savedUserId) {
|
||||
function scheduleCredSave() {
|
||||
clearTimeout(credSaveTimer);
|
||||
credSaveTimer = setTimeout(function() {
|
||||
saveCredentials();
|
||||
var token = document.getElementById("notionToken").value.trim();
|
||||
if (token) {
|
||||
setStatus("Loading…", "");
|
||||
$PI.sendToPlugin({ event: "refreshProjects", token: token });
|
||||
}
|
||||
}, 600);
|
||||
}
|
||||
|
||||
function populateUsers(users, userId) {
|
||||
cachedUsers = users;
|
||||
var sel = document.getElementById("userId");
|
||||
var current = savedUserId || sel.value;
|
||||
sel.innerHTML = '<option value="">— Select your name —</option>';
|
||||
users.forEach(function(u) {
|
||||
var opt = document.createElement("option");
|
||||
opt.value = u.id;
|
||||
opt.textContent = u.name;
|
||||
if (u.id === current) opt.selected = true;
|
||||
if (u.id === userId) opt.selected = true;
|
||||
sel.appendChild(opt);
|
||||
});
|
||||
}
|
||||
|
||||
function scheduleCredSave() {
|
||||
clearTimeout(credSaveTimer);
|
||||
credSaveTimer = setTimeout(saveCredentials, 600);
|
||||
}
|
||||
|
||||
function save() {
|
||||
var sel = document.getElementById("projectSelect");
|
||||
var opt = sel.options[sel.selectedIndex];
|
||||
@@ -229,16 +261,19 @@
|
||||
document.getElementById("projectSelect").addEventListener("change", save);
|
||||
document.getElementById("notionToken").addEventListener("input", scheduleCredSave);
|
||||
document.getElementById("userId").addEventListener("change", saveCredentials);
|
||||
document.getElementById("updateBtn").addEventListener("click", function() {
|
||||
document.getElementById("updateStatus").textContent = "";
|
||||
$PI.sendToPlugin({ event: "checkForUpdates" });
|
||||
});
|
||||
});
|
||||
|
||||
$PI.onDidReceiveGlobalSettings(function(jsn) {
|
||||
var s = jsn.payload.settings || {};
|
||||
document.getElementById("notionToken").value = s.notionToken || "";
|
||||
if (s.userId) {
|
||||
var sel = document.getElementById("userId");
|
||||
if (sel.querySelector('option[value="' + s.userId + '"]')) {
|
||||
sel.value = s.userId;
|
||||
}
|
||||
globalUserId = s.userId || "";
|
||||
if (globalUserId && cachedUsers.length > 0) {
|
||||
// Users already loaded — re-populate with correct selection
|
||||
populateUsers(cachedUsers, globalUserId);
|
||||
}
|
||||
|
||||
credConfigured = !!(s.notionToken && s.userId);
|
||||
@@ -268,13 +303,15 @@
|
||||
|
||||
$PI.onSendToPropertyInspector(ACTION_UUID, function(jsn) {
|
||||
var payload = jsn.payload;
|
||||
if (payload.event === "updateStatus") {
|
||||
document.getElementById("updateStatus").textContent = payload.message;
|
||||
}
|
||||
if (payload.event === "projects") {
|
||||
if (payload.version) {
|
||||
document.getElementById("versionText").textContent = "v" + payload.version;
|
||||
}
|
||||
if (payload.users) {
|
||||
var savedUserId = document.getElementById("userId").value;
|
||||
populateUsers(payload.users, savedUserId);
|
||||
populateUsers(payload.users, globalUserId);
|
||||
}
|
||||
if (payload.error) {
|
||||
setStatus(payload.error, "error");
|
||||
|
||||
@@ -7,7 +7,7 @@ TMP_DIR=$(mktemp -d)
|
||||
PLUGIN_FILE="${TMP_DIR}/notion-timer.streamDeckPlugin"
|
||||
|
||||
echo "Downloading Notion Timer..."
|
||||
curl -sL "${GITEA}/${REPO}/raw/branch/master/notion-timer.streamDeckPlugin" -o "${PLUGIN_FILE}"
|
||||
curl -sL "${GITEA}/${REPO}/raw/branch/stable-rebuild/notion-timer.streamDeckPlugin" -o "${PLUGIN_FILE}"
|
||||
|
||||
echo "Installing — Stream Deck will open automatically..."
|
||||
open "${PLUGIN_FILE}"
|
||||
|
||||
Binary file not shown.
250
src/plugin.ts
250
src/plugin.ts
@@ -1,5 +1,5 @@
|
||||
const CURRENT_VERSION = "1.0.15";
|
||||
const GITEA_BASE = "https://gitea.pdmarf.co.uk/pdm/stream_deck_notion_timer/raw/branch/master";
|
||||
const CURRENT_VERSION = "1.0.40";
|
||||
const GITEA_BASE = "https://gitea.pdmarf.co.uk/pdm/stream_deck_notion_timer/raw/branch/stable-rebuild";
|
||||
const SIGNING_PUBLIC_KEY = `-----BEGIN PUBLIC KEY-----
|
||||
MCowBQYDK2VwAyEAN7ko8TUpuPzPAJuKAZCRjV0c4ZSlou5d9pUAF6o12b4=
|
||||
-----END PUBLIC KEY-----`;
|
||||
@@ -19,19 +19,23 @@ function fetchWithTimeout(url: string): Promise<Response> {
|
||||
return fetch(url, { signal: controller.signal }).finally(() => clearTimeout(timer));
|
||||
}
|
||||
|
||||
async function checkForUpdates(): Promise<void> {
|
||||
async function checkForUpdates(sendStatus?: (msg: string) => void): Promise<void> {
|
||||
try {
|
||||
const resp = await fetchWithTimeout(`${GITEA_BASE}/version.json`);
|
||||
if (!resp.ok) return;
|
||||
if (!resp.ok) { sendStatus?.("Update check failed"); return; }
|
||||
const { version } = await resp.json() as { version: string };
|
||||
if (!/^\d+\.\d+\.\d+$/.test(version)) return;
|
||||
if (!isNewerVersion(version, CURRENT_VERSION)) return;
|
||||
if (!isNewerVersion(version, CURRENT_VERSION)) {
|
||||
sendStatus?.(`Already up to date (v${CURRENT_VERSION})`);
|
||||
return;
|
||||
}
|
||||
|
||||
sendStatus?.(`Updating to v${version}…`);
|
||||
const [pluginResp, sigResp] = await Promise.all([
|
||||
fetchWithTimeout(`${GITEA_BASE}/com.pdma.notion-timer.sdPlugin/bin/plugin.js`),
|
||||
fetchWithTimeout(`${GITEA_BASE}/com.pdma.notion-timer.sdPlugin/bin/plugin.js.sig`),
|
||||
]);
|
||||
if (!pluginResp.ok || !sigResp.ok) return;
|
||||
if (!pluginResp.ok || !sigResp.ok) { sendStatus?.("Download failed"); return; }
|
||||
|
||||
const newCode = await pluginResp.text();
|
||||
const sigBytes = Buffer.from(await sigResp.arrayBuffer());
|
||||
@@ -40,15 +44,40 @@ async function checkForUpdates(): Promise<void> {
|
||||
const valid = verify(null, Buffer.from(newCode), SIGNING_PUBLIC_KEY, sigBytes);
|
||||
if (!valid) {
|
||||
streamDeck.logger.error("Update rejected: signature verification failed");
|
||||
sendStatus?.("Update rejected: invalid signature");
|
||||
return;
|
||||
}
|
||||
|
||||
const fs = await import("fs");
|
||||
const path = await import("path");
|
||||
const pluginRoot = path.join(path.dirname(__filename), "..");
|
||||
|
||||
const ASSETS = [
|
||||
"ui/property-inspector.html",
|
||||
"ui/global-property-inspector.html",
|
||||
"imgs/idle.png",
|
||||
"imgs/running.png",
|
||||
];
|
||||
const PLUGIN_BASE = `${GITEA_BASE}/com.pdma.notion-timer.sdPlugin`;
|
||||
const assetResps = await Promise.all(ASSETS.map(p => fetchWithTimeout(`${PLUGIN_BASE}/${p}`)));
|
||||
for (let i = 0; i < ASSETS.length; i++) {
|
||||
if (assetResps[i].ok) {
|
||||
fs.writeFileSync(path.join(pluginRoot, ASSETS[i]), Buffer.from(await assetResps[i].arrayBuffer()));
|
||||
}
|
||||
}
|
||||
|
||||
const LEGACY = ["imgs/idle.svg", "imgs/running.svg"];
|
||||
for (const f of LEGACY) {
|
||||
try { fs.unlinkSync(path.join(pluginRoot, f)); } catch { /* already gone */ }
|
||||
}
|
||||
|
||||
fs.writeFileSync(__filename, newCode);
|
||||
streamDeck.logger.info(`Updated to ${version}, restarting…`);
|
||||
process.exit(0);
|
||||
} catch (err) {
|
||||
streamDeck.logger.error(`Update check failed: ${err instanceof Error ? err.message : String(err)}`);
|
||||
const msg = err instanceof Error ? err.message : String(err);
|
||||
streamDeck.logger.error(`Update check failed: ${msg}`);
|
||||
sendStatus?.(`Error: ${msg}`);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -67,12 +96,12 @@ interface GlobalSettings {
|
||||
projectsDbId: string;
|
||||
userId: string;
|
||||
runningEntryId?: string | null;
|
||||
runningActionId?: string | null;
|
||||
}
|
||||
|
||||
interface TimerSettings {
|
||||
projectId: string;
|
||||
projectName: string;
|
||||
activeEntryId: string | null;
|
||||
}
|
||||
|
||||
const HARDCODED = {
|
||||
@@ -85,159 +114,152 @@ async function getGlobal(): Promise<GlobalSettings> {
|
||||
return { ...stored, ...HARDCODED };
|
||||
}
|
||||
|
||||
// In-memory cache so onWillAppear can check running state without an async round-trip
|
||||
let memRunningEntryId: string | null | undefined = undefined; // undefined = not yet loaded
|
||||
// In-memory running state — avoids async round-trips on every button press
|
||||
let memRunningEntryId: string | null | undefined = undefined;
|
||||
let memRunningActionId: string | null | undefined = undefined;
|
||||
|
||||
async function getRunningEntryId(): Promise<string | null> {
|
||||
if (memRunningEntryId === undefined) {
|
||||
const stored = await streamDeck.settings.getGlobalSettings<GlobalSettings>();
|
||||
memRunningEntryId = stored.runningEntryId ?? null;
|
||||
}
|
||||
return memRunningEntryId;
|
||||
async function loadRunningState(): Promise<void> {
|
||||
if (memRunningEntryId !== undefined) return;
|
||||
const stored = await streamDeck.settings.getGlobalSettings<GlobalSettings>();
|
||||
memRunningEntryId = stored.runningEntryId ?? null;
|
||||
memRunningActionId = stored.runningActionId ?? null;
|
||||
}
|
||||
|
||||
async function setRunningEntry(entryId: string | null): Promise<void> {
|
||||
memRunningEntryId = entryId;
|
||||
const stored = await streamDeck.settings.getGlobalSettings<GlobalSettings>();
|
||||
await streamDeck.settings.setGlobalSettings({ ...stored, runningEntryId: entryId });
|
||||
function setRunningEntry(entryId: string | null, actionId: string | null): void {
|
||||
memRunningEntryId = entryId;
|
||||
memRunningActionId = actionId;
|
||||
// Persist in background — do not await, so the visual is never blocked
|
||||
streamDeck.settings.getGlobalSettings<GlobalSettings>()
|
||||
.then(stored => streamDeck.settings.setGlobalSettings({ ...stored, runningEntryId: entryId, runningActionId: actionId }))
|
||||
.catch(err => streamDeck.logger.error("Failed to persist running state:", err));
|
||||
}
|
||||
|
||||
async function sendProjectsToPI(tokenOverride?: string): Promise<void> {
|
||||
try {
|
||||
const global = await getGlobal();
|
||||
const token = tokenOverride ?? global.notionToken;
|
||||
if (!token) {
|
||||
await streamDeck.ui.sendToPropertyInspector({ event: "projects", data: [], error: "Enter your Notion API token above.", version: CURRENT_VERSION });
|
||||
return;
|
||||
}
|
||||
const [projects, usersResult] = await Promise.all([
|
||||
fetchProjects(token, global.projectsDbId),
|
||||
fetchUsers(token).catch((err) => {
|
||||
streamDeck.logger.error("Failed to fetch users:", err);
|
||||
return [];
|
||||
}),
|
||||
]);
|
||||
await streamDeck.ui.sendToPropertyInspector({ event: "projects", data: projects, users: usersResult, version: CURRENT_VERSION });
|
||||
} catch (err) {
|
||||
streamDeck.logger.error("Failed to fetch projects:", err);
|
||||
await streamDeck.ui.sendToPropertyInspector({ event: "projects", data: [], error: String(err), version: CURRENT_VERSION });
|
||||
}
|
||||
}
|
||||
|
||||
function isConfigured(g: GlobalSettings): boolean {
|
||||
return !!(g.notionToken && g.userId);
|
||||
}
|
||||
|
||||
// Strip leading emoji characters so the button title shows just the project name
|
||||
function buttonTitle(projectName: string): string {
|
||||
return projectName.replace(/^[\p{Extended_Pictographic}\uFE0F\s]+/u, "").trim();
|
||||
}
|
||||
|
||||
@action({ UUID: "com.pdma.notion-timer.toggle" })
|
||||
class TimerToggle extends SingletonAction<TimerSettings> {
|
||||
private settingsCache = new Map<string, TimerSettings>();
|
||||
private projectCache = new Map<string, TimerSettings>();
|
||||
private pendingKeyDown = new Set<string>();
|
||||
|
||||
async onWillAppear(ev: WillAppearEvent<TimerSettings>): Promise<void> {
|
||||
const { activeEntryId, projectName } = ev.payload.settings;
|
||||
const title = buttonTitle(projectName || "");
|
||||
|
||||
// Use in-memory cache to determine correct state before rendering — no flash
|
||||
const running = await getRunningEntryId();
|
||||
const isRunning = !!activeEntryId && activeEntryId === running;
|
||||
|
||||
if (activeEntryId && !isRunning) {
|
||||
// Self-heal: this button thinks it's running but it's not — clear it
|
||||
const cleared = { ...ev.payload.settings, activeEntryId: null };
|
||||
await ev.action.setSettings(cleared);
|
||||
this.settingsCache.set(ev.action.id, cleared);
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
this.projectCache.set(ev.action.id, ev.payload.settings);
|
||||
const title = buttonTitle(ev.payload.settings.projectName || "");
|
||||
await loadRunningState();
|
||||
const isRunning = memRunningActionId === ev.action.id;
|
||||
if (isRunning) {
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`⏱ ${title}`)]);
|
||||
} else {
|
||||
this.settingsCache.set(ev.action.id, ev.payload.settings);
|
||||
if (isRunning) {
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`⏱ ${title}`)]);
|
||||
} else {
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
}
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
}
|
||||
}
|
||||
|
||||
async onPropertyInspectorDidAppear(ev: PropertyInspectorDidAppearEvent<TimerSettings>): Promise<void> {
|
||||
try {
|
||||
const global = await getGlobal();
|
||||
if (!global.notionToken) {
|
||||
await streamDeck.ui.sendToPropertyInspector({ event: "projects", data: [], error: "Enter your Notion API token above.", version: CURRENT_VERSION });
|
||||
return;
|
||||
}
|
||||
const [projects, usersResult] = await Promise.all([
|
||||
fetchProjects(global.notionToken, global.projectsDbId),
|
||||
fetchUsers(global.notionToken).catch((err) => {
|
||||
streamDeck.logger.error("Failed to fetch users:", err);
|
||||
return [];
|
||||
}),
|
||||
]);
|
||||
await streamDeck.ui.sendToPropertyInspector({ event: "projects", data: projects, users: usersResult, version: CURRENT_VERSION });
|
||||
} catch (err) {
|
||||
streamDeck.logger.error("Failed to fetch projects:", err);
|
||||
await streamDeck.ui.sendToPropertyInspector({ event: "projects", data: [], error: String(err), version: CURRENT_VERSION });
|
||||
}
|
||||
async onPropertyInspectorDidAppear(_ev: PropertyInspectorDidAppearEvent<TimerSettings>): Promise<void> {
|
||||
await sendProjectsToPI();
|
||||
}
|
||||
|
||||
async onKeyDown(ev: KeyDownEvent<TimerSettings>): Promise<void> {
|
||||
this.settingsCache.set(ev.action.id, ev.payload.settings);
|
||||
const global = await getGlobal();
|
||||
const { projectId, projectName, activeEntryId } = ev.payload.settings;
|
||||
const title = buttonTitle(projectName || "");
|
||||
|
||||
if (!isConfigured(global)) {
|
||||
await ev.action.showAlert();
|
||||
return;
|
||||
}
|
||||
|
||||
if (!projectId) {
|
||||
await ev.action.showAlert();
|
||||
return;
|
||||
}
|
||||
|
||||
if (this.pendingKeyDown.has(ev.action.id)) return;
|
||||
this.pendingKeyDown.add(ev.action.id);
|
||||
try {
|
||||
if (activeEntryId) {
|
||||
await stopTimer(global.notionToken, activeEntryId);
|
||||
const stopped = { ...ev.payload.settings, activeEntryId: null };
|
||||
await ev.action.setSettings(stopped);
|
||||
this.settingsCache.set(ev.action.id, stopped);
|
||||
await ev.action.setState(0);
|
||||
await ev.action.setTitle(title);
|
||||
await setRunningEntry(null);
|
||||
} else {
|
||||
const prevEntryId = await getRunningEntryId();
|
||||
const { projectId, projectName } = ev.payload.settings;
|
||||
const title = buttonTitle(projectName || "");
|
||||
const isRunning = memRunningActionId === ev.action.id;
|
||||
|
||||
// Stop previous timer
|
||||
if (prevEntryId) {
|
||||
await stopTimer(global.notionToken, prevEntryId);
|
||||
for (const other of this.actions) {
|
||||
if (other.id === ev.action.id) continue;
|
||||
const otherSettings = this.settingsCache.get(other.id);
|
||||
if (otherSettings?.activeEntryId === prevEntryId) {
|
||||
const stopped = { ...otherSettings, activeEntryId: null };
|
||||
await other.setSettings(stopped);
|
||||
this.settingsCache.set(other.id, stopped);
|
||||
await other.setState(0);
|
||||
await other.setTitle(buttonTitle(otherSettings.projectName || ""));
|
||||
}
|
||||
// Instant visual feedback — no setSettings, no flash
|
||||
if (projectId) {
|
||||
if (isRunning) {
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
} else {
|
||||
for (const other of this.actions) {
|
||||
if (other.id === ev.action.id) continue;
|
||||
if (memRunningActionId === other.id) {
|
||||
const s = this.projectCache.get(other.id);
|
||||
await Promise.all([other.setState(0), other.setTitle(buttonTitle(s?.projectName || ""))]);
|
||||
}
|
||||
}
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`⏱ ${title}`)]);
|
||||
}
|
||||
}
|
||||
|
||||
const entryId = await startTimer(
|
||||
global.notionToken,
|
||||
global.timingDbId,
|
||||
projectId,
|
||||
projectName,
|
||||
global.userId,
|
||||
);
|
||||
const started = { ...ev.payload.settings, activeEntryId: entryId };
|
||||
await ev.action.setSettings(started);
|
||||
this.settingsCache.set(ev.action.id, started);
|
||||
await setRunningEntry(entryId);
|
||||
await ev.action.setState(1);
|
||||
await ev.action.setTitle(`⏱ ${title}`);
|
||||
const global = await getGlobal();
|
||||
if (!isConfigured(global)) { await ev.action.showAlert(); return; }
|
||||
if (!projectId) { await ev.action.showAlert(); return; }
|
||||
|
||||
try {
|
||||
if (isRunning) {
|
||||
await stopTimer(global.notionToken, memRunningEntryId!);
|
||||
setRunningEntry(null, null);
|
||||
await Promise.all([ev.action.setState(0), ev.action.setTitle(title)]);
|
||||
} else {
|
||||
if (memRunningEntryId) {
|
||||
await stopTimer(global.notionToken, memRunningEntryId);
|
||||
}
|
||||
const entryId = await startTimer(global.notionToken, global.timingDbId, projectId, projectName, global.userId);
|
||||
setRunningEntry(entryId, ev.action.id);
|
||||
await Promise.all([ev.action.setState(1), ev.action.setTitle(`⏱ ${title}`)]);
|
||||
}
|
||||
} catch (err) {
|
||||
// Revert visual on error
|
||||
await Promise.all([
|
||||
ev.action.setState(isRunning ? 1 : 0),
|
||||
ev.action.setTitle(isRunning ? `⏱ ${title}` : title),
|
||||
]);
|
||||
streamDeck.logger.error("Timer toggle failed:", err);
|
||||
await ev.action.showAlert();
|
||||
}
|
||||
} finally {
|
||||
this.pendingKeyDown.delete(ev.action.id);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
const timerAction = new TimerToggle();
|
||||
streamDeck.actions.registerAction(timerAction);
|
||||
|
||||
// v2 requires using streamDeck.ui.onSendToPlugin — the SingletonAction method does not fire
|
||||
streamDeck.ui.onSendToPlugin<{ event: string; settings?: TimerSettings }>(async (ev) => {
|
||||
streamDeck.ui.onSendToPlugin<{ event: string; settings?: TimerSettings; token?: string }>(async (ev) => {
|
||||
if (ev.payload.event === "saveSettings" && ev.payload.settings) {
|
||||
await ev.action.setSettings(ev.payload.settings);
|
||||
const title = buttonTitle(ev.payload.settings.projectName || "");
|
||||
if (title) await ev.action.setTitle(title);
|
||||
}
|
||||
if (ev.payload.event === "refreshProjects") {
|
||||
await sendProjectsToPI(ev.payload.token);
|
||||
}
|
||||
if (ev.payload.event === "checkForUpdates") {
|
||||
const send = (msg: string) => streamDeck.ui.sendToPropertyInspector({ event: "updateStatus", message: msg });
|
||||
send("Checking…");
|
||||
await checkForUpdates(send);
|
||||
}
|
||||
});
|
||||
|
||||
streamDeck.connect();
|
||||
|
||||
// Check for updates 10 seconds after startup to avoid disrupting initial connection
|
||||
setTimeout(() => checkForUpdates(), 10_000);
|
||||
|
||||
@@ -1 +1 @@
|
||||
{ "version": "1.0.15" }
|
||||
{ "version": "1.0.40" }
|
||||
|
||||
Reference in New Issue
Block a user