secubox-openwrt/package/secubox/luci-app-secubox-admin/htdocs/luci-static/resources/secubox-admin/api.js

'use strict';
'require baseclass';
'require rpc';

// App Management
var callGetApps = rpc.declare({
	object: 'luci.secubox',
	method: 'get_appstore_apps',
	expect: { apps: [] }
});

var callInstallApp = rpc.declare({
	object: 'luci.secubox',
	method: 'install_appstore_app',
	params: ['app_id'],
	expect: { success: false }
});

var callRemoveApp = rpc.declare({
	object: 'luci.secubox',
	method: 'remove_appstore_app',
	params: ['app_id'],
	expect: { success: false }
});

// Module Management
var callGetModules = rpc.declare({
	object: 'luci.secubox',
	method: 'getModules',
	expect: { modules: [] }
});

var callEnableModule = rpc.declare({
	object: 'luci.secubox',
	method: 'enable_module',
	params: ['module'],
	expect: { success: false }
});

var callDisableModule = rpc.declare({
	object: 'luci.secubox',
	method: 'disable_module',
	params: ['module'],
	expect: { success: false }
});

// System Health
var callGetHealth = rpc.declare({
	object: 'luci.secubox',
	method: 'get_system_health',
	expect: { }
});

var callGetAlerts = rpc.declare({
	object: 'luci.secubox',
	method: 'get_alerts',
	expect: { alerts: [] }
});

// Logs
var callGetLogs = rpc.declare({
	object: 'luci.secubox',
	method: 'getLogs',
	params: ['service', 'lines'],
	expect: { logs: '' }
});

// Catalog Sources (with optimized timeout)
var callGetCatalogSources = rpc.declare({
	object: 'luci.secubox',
	method: 'get_catalog_sources',
	expect: { sources: [] },
	timeout: 15000  // 15 seconds (optimized backend with caching)
});

var callSetCatalogSource = rpc.declare({
	object: 'luci.secubox',
	method: 'set_catalog_source',
	params: ['source'],
	expect: { success: false },
	timeout: 20000  // 20 seconds
});

var callSyncCatalog = rpc.declare({
	object: 'luci.secubox',
	method: 'sync_catalog',
	params: ['source'],
	expect: { success: false },
	timeout: 90000  // Sync can take longer (90s for slow connections)
});

// Version Management (with optimized timeout)
var callCheckUpdates = rpc.declare({
	object: 'luci.secubox',
	method: 'check_updates',
	expect: { },
	timeout: 20000  // 20 seconds (optimized with persistent cache)
});

var callGetAppVersions = rpc.declare({
	object: 'luci.secubox',
	method: 'get_app_versions',
	params: ['app_id'],
	expect: { }
});

var callGetChangelog = rpc.declare({
	object: 'luci.secubox',
	method: 'get_changelog',
	params: ['app_id', 'from_version', 'to_version'],
	expect: { }
});

// Widget Data
var callGetWidgetData = rpc.declare({
	object: 'luci.secubox',
	method: 'get_widget_data',
	params: ['app_id'],
	expect: { }
});

// Utility functions
function formatBytes(bytes) {
	if (bytes === 0) return '0 B';
	var k = 1024;
	var sizes = ['B', 'KB', 'MB', 'GB', 'TB'];
	var i = Math.floor(Math.log(bytes) / Math.log(k));
	return Math.round(bytes / Math.pow(k, i) * 100) / 100 + ' ' + sizes[i];
}

function formatUptime(seconds) {
	var days = Math.floor(seconds / 86400);
	var hours = Math.floor((seconds % 86400) / 3600);
	var mins = Math.floor((seconds % 3600) / 60);
	return days + 'd ' + hours + 'h ' + mins + 'm';
}

function getAppStatus(app, modules) {
	// Determine if app is installed by checking modules
	var isInstalled = false;
	var isRunning = false;

	if (app.packages && app.packages.required) {
		for (var i = 0; i < app.packages.required.length; i++) {
			var pkg = app.packages.required[i];
			if (modules[pkg]) {
				isInstalled = true;
				isRunning = modules[pkg].running || false;
				break;
			}
		}
	}

	return {
		installed: isInstalled,
		running: isRunning,
		status: isRunning ? 'running' : (isInstalled ? 'stopped' : 'available')
	};
}

// Debug wrapper for RPC calls with retry logic
function debugRPC(name, call, options) {
	options = options || {};
	var maxRetries = options.retries || 2;
	var retryDelay = options.retryDelay || 1000;

	return function() {
		var args = Array.prototype.slice.call(arguments);
		var attemptCount = 0;
		var self = this;

		function attemptCall() {
			attemptCount++;
			console.log('[API-DEBUG] Calling:', name, 'with args:', args, '(attempt ' + attemptCount + ')');

			return call.apply(self, args).then(function(result) {
				console.log('[API-DEBUG] Success:', name, 'result:', result, '(attempt ' + attemptCount + ')');
				return result;
			}).catch(function(error) {
				console.error('[API-DEBUG] Error:', name, 'error:', error, '(attempt ' + attemptCount + '/' + (maxRetries + 1) + ')');
				console.error('[API-DEBUG] Error message:', error.message);
				console.error('[API-DEBUG] Error stack:', error.stack || 'no stack');

				// Retry on timeout errors
				if (attemptCount <= maxRetries && error.message && error.message.indexOf('timed out') !== -1) {
					console.warn('[API-DEBUG] Retrying', name, 'in', retryDelay, 'ms...');
					return new Promise(function(resolve) {
						setTimeout(function() {
							resolve(attemptCall());
						}, retryDelay);
					});
				}

				throw error;
			});
		}

		return attemptCall();
	};
}

// Export API with debug wrappers and retry logic
return baseclass.extend({
	// Apps
	getApps: debugRPC('getApps', callGetApps, { retries: 2, retryDelay: 1500 }),
	installApp: debugRPC('installApp', callInstallApp, { retries: 1 }),
	removeApp: debugRPC('removeApp', callRemoveApp, { retries: 1 }),

	// Modules
	getModules: debugRPC('getModules', callGetModules, { retries: 2, retryDelay: 1500 }),
	enableModule: debugRPC('enableModule', callEnableModule),
	disableModule: debugRPC('disableModule', callDisableModule),

	// System
	getHealth: debugRPC('getHealth', callGetHealth, { retries: 1 }),
	getAlerts: debugRPC('getAlerts', callGetAlerts, { retries: 1 }),
	getLogs: debugRPC('getLogs', callGetLogs),

	// Catalog Sources (critical - more retries)
	getCatalogSources: debugRPC('getCatalogSources', callGetCatalogSources, { retries: 3, retryDelay: 2000 }),
	setCatalogSource: debugRPC('setCatalogSource', callSetCatalogSource, { retries: 1 }),
	syncCatalog: debugRPC('syncCatalog', callSyncCatalog, { retries: 1 }),

	// Version Management (critical - more retries)
	checkUpdates: debugRPC('checkUpdates', callCheckUpdates, { retries: 3, retryDelay: 2000 }),
	getAppVersions: debugRPC('getAppVersions', callGetAppVersions, { retries: 1 }),
	getChangelog: debugRPC('getChangelog', callGetChangelog, { retries: 1 }),

	// Widget Data
	getWidgetData: debugRPC('getWidgetData', callGetWidgetData, { retries: 1 }),

	// Utilities
	formatBytes: formatBytes,
	formatUptime: formatUptime,
	getAppStatus: getAppStatus
});