});
observer.observe(modal, { attributes: true, attributeFilter: ['class'] });
})();
+
+ // Logs functionality
+ let logStreamSource = null;
+ let currentLogPage = 0;
+ const logsPerPage = 100;
+
+ async function refreshLogs() {
+ const level = document.getElementById('log-level-filter').value;
+ const entityType = document.getElementById('log-entity-filter').value;
+ const search = document.getElementById('log-search').value;
+
+ const params = new URLSearchParams({
+ limit: logsPerPage,
+ offset: currentLogPage * logsPerPage,
+ order: 'desc'
+ });
+
+ if (level) params.append('level', level);
+ if (entityType) params.append('entity_type', entityType);
+ if (search) params.append('search', search);
+
+ try {
+ const headers = {};
+ const token = localStorage.getItem('token');
+ if (token) {
+ headers['Authorization'] = `Bearer ${token}`;
+ }
+
+ const response = await fetch(`${window.ROOT_PATH || ''}/admin/logs?${params}`, {
+ headers: headers,
+ credentials: 'same-origin'
+ });
+
+ if (!response.ok) throw new Error(`HTTP ${response.status}`);
+
+ const data = await response.json();
+ displayLogs(data.logs);
+ updateLogStats(data.stats);
+ updateLogCount(data.total);
+ } catch (error) {
+ console.error('Error fetching logs:', error);
+ showErrorMessage('Failed to fetch logs');
+ }
+ }
+
+ function displayLogs(logs) {
+ const tbody = document.getElementById('logs-tbody');
+ tbody.innerHTML = '';
+
+ logs.forEach(log => {
+ const row = document.createElement('tr');
+ row.className = 'hover:bg-gray-50 dark:hover:bg-gray-700';
+
+ const timestamp = new Date(log.timestamp).toLocaleString();
+ const levelClass = getLevelClass(log.level);
+ const entity = log.entity_name || log.entity_id || '-';
+
+ row.innerHTML = `
+ |
+ ${timestamp}
+ |
+
+
+ ${log.level}
+
+ |
+
+ ${log.entity_type ? `${log.entity_type}: ${entity}` : entity}
+ |
+
+ ${escapeHtml(log.message)}
+ |
+ `;
+
+ tbody.appendChild(row);
+ });
+ }
+
+ function getLevelClass(level) {
+ switch(level) {
+ case 'debug': return 'bg-gray-100 text-gray-800';
+ case 'info': return 'bg-blue-100 text-blue-800';
+ case 'warning': return 'bg-yellow-100 text-yellow-800';
+ case 'error': return 'bg-red-100 text-red-800';
+ case 'critical': return 'bg-red-600 text-white';
+ default: return 'bg-gray-100 text-gray-800';
+ }
+ }
+
+ function updateLogStats(stats) {
+ if (!stats) return;
+
+ const statsDiv = document.getElementById('log-stats');
+ const levelDist = stats.level_distribution || {};
+ const entityDist = stats.entity_distribution || {};
+
+ let html = `
+
+ Buffer: ${stats.usage_percent || 0}% (${stats.buffer_size_mb || 0}/${stats.max_size_mb || 0} MB)
+ Total: ${stats.total_logs || 0} logs
+ `;
+
+ if (Object.keys(levelDist).length > 0) {
+ html += 'Levels: ';
+ for (const [level, count] of Object.entries(levelDist)) {
+ html += `${level}(${count}) `;
+ }
+ html += '';
+ }
+
+ html += '
';
+ statsDiv.innerHTML = html;
+ }
+
+ function updateLogCount(total) {
+ document.getElementById('log-count').textContent = `${total} logs`;
+
+ // Update pagination buttons
+ document.getElementById('prev-page').disabled = currentLogPage === 0;
+ document.getElementById('next-page').disabled = (currentLogPage + 1) * logsPerPage >= total;
+ }
+
+ function toggleLogStream() {
+ const button = document.getElementById('stream-toggle');
+
+ if (logStreamSource) {
+ // Stop streaming
+ logStreamSource.close();
+ logStreamSource = null;
+ button.textContent = 'Start Live Stream';
+ button.className = 'px-3 py-2 bg-green-600 text-white rounded hover:bg-green-700';
+ } else {
+ // Start streaming
+ const level = document.getElementById('log-level-filter').value;
+ const entityType = document.getElementById('log-entity-filter').value;
+
+ const params = new URLSearchParams();
+ if (level) params.append('level', level);
+ if (entityType) params.append('entity_type', entityType);
+
+ // EventSource doesn't support custom headers, so we need to pass auth in query params
+ // or rely on cookie-based auth
+ const url = `${window.ROOT_PATH || ''}/admin/logs/stream?${params}`;
+ logStreamSource = new EventSource(url, { withCredentials: true });
+
+ logStreamSource.onmessage = (event) => {
+ const data = JSON.parse(event.data);
+ if (data.type === 'log_entry') {
+ prependLog(data.data);
+ }
+ };
+
+ logStreamSource.onerror = (error) => {
+ console.error('Stream error:', error);
+ toggleLogStream(); // Stop on error
+ };
+
+ button.textContent = 'Stop Live Stream';
+ button.className = 'px-3 py-2 bg-red-600 text-white rounded hover:bg-red-700';
+ }
+ }
+
+ function prependLog(log) {
+ const tbody = document.getElementById('logs-tbody');
+ const row = document.createElement('tr');
+ row.className = 'hover:bg-gray-50 dark:hover:bg-gray-700 animate-pulse';
+
+ const timestamp = new Date(log.timestamp).toLocaleString();
+ const levelClass = getLevelClass(log.level);
+ const entity = log.entity_name || log.entity_id || '-';
+
+ row.innerHTML = `
+
+ ${timestamp}
+ |
+
+
+ ${log.level}
+
+ |
+
+ ${log.entity_type ? `${log.entity_type}: ${entity}` : entity}
+ |
+
+ ${escapeHtml(log.message)}
+ |
+ `;
+
+ tbody.insertBefore(row, tbody.firstChild);
+
+ // Remove animation after a moment
+ setTimeout(() => row.classList.remove('animate-pulse'), 1000);
+
+ // Limit displayed rows
+ while (tbody.children.length > logsPerPage) {
+ tbody.removeChild(tbody.lastChild);
+ }
+ }
+
+ async function exportLogs(format) {
+ const level = document.getElementById('log-level-filter').value;
+ const entityType = document.getElementById('log-entity-filter').value;
+ const search = document.getElementById('log-search').value;
+
+ const params = new URLSearchParams({ format });
+ if (level) params.append('level', level);
+ if (entityType) params.append('entity_type', entityType);
+ if (search) params.append('search', search);
+
+ try {
+ // Use the same auth approach as other admin endpoints
+ const headers = {};
+ const token = localStorage.getItem('token');
+ if (token) {
+ headers['Authorization'] = `Bearer ${token}`;
+ }
+
+ const response = await fetch(`${window.ROOT_PATH || ''}/admin/logs/export?${params}`, {
+ headers: headers,
+ credentials: 'same-origin'
+ });
+
+ if (!response.ok) throw new Error(`HTTP ${response.status}`);
+
+ const blob = await response.blob();
+ const url = window.URL.createObjectURL(blob);
+ const a = document.createElement('a');
+ a.href = url;
+ a.download = `logs_export.${format}`;
+ document.body.appendChild(a);
+ a.click();
+ document.body.removeChild(a);
+ window.URL.revokeObjectURL(url);
+ } catch (error) {
+ console.error('Error exporting logs:', error);
+ showErrorMessage('Failed to export logs');
+ }
+ }
+
+ function showErrorMessage(message) {
+ const toast = document.createElement('div');
+ toast.className = 'fixed top-4 right-4 bg-red-600 text-white px-6 py-3 rounded-lg shadow-lg z-50 animate-pulse';
+ toast.textContent = message;
+ document.body.appendChild(toast);
+ setTimeout(() => toast.remove(), 5000);
+ }
+
+ function showSuccessMessage(message) {
+ const toast = document.createElement('div');
+ toast.className = 'fixed top-4 right-4 bg-green-600 text-white px-6 py-3 rounded-lg shadow-lg z-50';
+ toast.textContent = message;
+ document.body.appendChild(toast);
+ setTimeout(() => toast.remove(), 3000);
+ }
+
+ async function showLogFiles() {
+ try {
+ const headers = {};
+ const token = localStorage.getItem('token');
+ if (token) {
+ headers['Authorization'] = `Bearer ${token}`;
+ }
+
+ const response = await fetch(`${window.ROOT_PATH || ''}/admin/logs/file`, {
+ headers: headers,
+ credentials: 'same-origin'
+ });
+
+ if (!response.ok) {
+ const errorData = await response.json().catch(() => ({}));
+ throw new Error(errorData.detail || `HTTP ${response.status}`);
+ }
+
+ const data = await response.json();
+
+ if (data.files && data.files.length > 0) {
+ // Create a modal to show available files
+ const modal = document.createElement('div');
+ modal.className = 'fixed inset-0 bg-black bg-opacity-50 flex items-center justify-center z-50';
+ modal.innerHTML = `
+
+
Available Log Files
+
Directory: ${data.log_directory}
+
+ ${data.files.map(file => `
+ -
+
+
${file.name}
+
+ ${(file.size / 1024).toFixed(1)} KB - ${new Date(file.modified).toLocaleString()}
+
+
+ `).join('')}
+
+
+