Version 15.4.6

Author: Rocket-Quack

erpnext_tse/__init__.py

@@ -1 +1 @@
-__version__ = "15.4.5"
+__version__ = "15.4.6"

erpnext_tse/erpnext_tse/doctype/dsfinv_k_cash_register/dsfinv_k_cash_register_list.js

@@ -3,6 +3,95 @@
 
 (() => {
 	const DOCTYPE = "DSFinV-K Cash Register";
+	const SETTINGS_DOCTYPE = "TSE Settings";
+	const SETTINGS_FLAG_FIELD = "recovery_sync_enabled";
+	const SETTINGS_ENABLED_FIELD = "enabled";
+
+	const RECOVERY_BTN_LABEL = __("Recovery Sync");
+	const RECOVERY_SUCCESS_MSG = __("Recovery sync queued.");
+	const RECOVERY_FAILED_MSG = __("Could not start recovery sync.");
+	const RECOVERY_FREEZE_MSG = __("Starting recovery sync...");
+	const RECOVERY_EVENT = "dsfinv_k_cash_register_recovery_done";
+	const RECOVERY_METHOD =
+		"erpnext_tse.erpnext_tse.doctype.dsfinv_k_cash_register.recovery.enqueue_recovery_sync";
+
+	function toInt(val) {
+		if (val === true) return 1;
+		if (val === false) return 0;
+		const n = parseInt(val, 10);
+		return Number.isFinite(n) ? n : 0;
+	}
+
+	async function getRecoveryEnabled() {
+		try {
+			const [recovery, enabled] = await Promise.all([
+				frappe.db.get_single_value(SETTINGS_DOCTYPE, SETTINGS_FLAG_FIELD),
+				frappe.db.get_single_value(SETTINGS_DOCTYPE, SETTINGS_ENABLED_FIELD),
+			]);
+			return toInt(recovery) === 1 && toInt(enabled) === 1;
+		} catch (e) {
+			return false;
+		}
+	}
+
+	function ensurePage(listview) {
+		return listview && listview.page;
+	}
+
+	let subscribed = false;
+
+	function ensureRealtimeSubscription() {
+		if (subscribed || !frappe.realtime) return;
+		frappe.realtime.on(RECOVERY_EVENT, (data) => {
+			const message = (data && data.message) || __("Recovery sync finished.");
+			frappe.show_alert({ message, indicator: "green" }, 7);
+		});
+		subscribed = true;
+	}
+
+	async function updateRecoveryButton(listview) {
+		if (!ensurePage(listview)) return;
+		ensureRealtimeSubscription();
+
+		if (listview.page.remove_inner_button) {
+			listview.page.remove_inner_button(RECOVERY_BTN_LABEL);
+		}
+
+		const enabled = await getRecoveryEnabled();
+		if (!enabled) return;
+
+		listview.page.add_inner_button(RECOVERY_BTN_LABEL, () => {
+			triggerRecoverySync();
+		});
+	}
+
+	async function triggerRecoverySync() {
+		try {
+			const r = await frappe.call({
+				method: RECOVERY_METHOD,
+				freeze: true,
+				freeze_message: RECOVERY_FREEZE_MSG,
+			});
+
+			const payload = r.message || {};
+			const jobId = payload.job_id || payload.name || payload.id;
+			const message = jobId
+				? __("Recovery sync queued (Job ID: {0})", [jobId])
+				: RECOVERY_SUCCESS_MSG;
+
+			frappe.msgprint({
+				message,
+				indicator: "green",
+			});
+		} catch (err) {
+			const msg = err?.message || err || RECOVERY_FAILED_MSG;
+			frappe.msgprint({
+				title: __("Recovery Sync"),
+				message: msg,
+				indicator: "red",
+			});
+		}
+	}
 
 	const INDICATORS = {
 		ACTIVE: { color: "green" },
@@ -20,5 +109,13 @@
 	frappe.listview_settings[DOCTYPE] = {
 		add_fields: ["status"],
 		get_indicator: indicatorFor,
+
+		onload(listview) {
+			setTimeout(() => updateRecoveryButton(listview), 0);
+		},
+
+		refresh(listview) {
+			setTimeout(() => updateRecoveryButton(listview), 0);
+		},
 	};
 })();