Merge pull request #23 from aaronlmathis/UI/Endpoint-Details

UI/endpoint details

Author: aaronlmathis

UI/src/app.d.ts

@@ -23,4 +23,18 @@ declare global {
 	}
 }
 
+declare module 'svelte-apexcharts' {
+	import { SvelteComponentTyped } from 'svelte';
+
+	export interface ApexChartProps {
+		options?: any;
+		series?: any;
+		type?: string;
+		width?: string | number;
+		height?: string | number;
+	}
+
+	export default class ApexChart extends SvelteComponentTyped<ApexChartProps> {}
+}
+
 export {};

UI/src/lib/api.ts

@@ -1,7 +1,7 @@
 /**
  * API client for GoSight backend
  */
-import type { AlertRule, AlertRulesResponse, EndpointsResponse, Endpoint } from './types';
+import type { AlertRule, AlertRulesResponse, EndpointsResponse, Endpoint, LogResponse } from './types';
 
 export interface ApiError {
 message: string;
@@ -223,7 +223,7 @@ export class LogsApi {
 		container_id?: string;
 		platform?: string;
 		[key: string]: any; // for dynamic tag_* and field_* and meta_* parameters
-	} = {}) {
+	} = {}): Promise<LogResponse> {
 		const searchParams = new URLSearchParams();
 
 		// Handle array parameters (levels, categories)
@@ -255,7 +255,7 @@ export class LogsApi {
 		return this.api.request(`/logs${query ? `?${query}` : ''}`);
 	}
 
-	async getRecent(limit = 50) {
+	async getRecent(limit = 50): Promise<LogResponse> {
 		return this.api.request(`/logs/latest?limit=${limit}`);
 	}
 }
@@ -633,7 +633,7 @@ async getMetrics(params?: any) {
 return this.metrics.getAll(params);
 }
 
-async getLogs(params?: any) {
+async getLogs(params?: any): Promise<LogResponse> {
 return this.logs.getAll(params);
 }
 

UI/src/lib/svelte-apexcharts.d.ts

@@ -0,0 +1,5 @@
+declare module 'svelte-apexcharts' {
+	export function chart(node: HTMLElement, options: any): {
+		update(options: any): void;
+	};
+}

UI/src/lib/types.ts

@@ -246,15 +246,25 @@ export interface EndpointMetric {
 
 // Metric types
 export interface Metric {
-	id: string;
+	id?: string;
 	name: string;
-	type: 'gauge' | 'counter' | 'histogram';
+	namespace?: string;
+	subnamespace?: string;
+	type?: 'gauge' | 'counter' | 'histogram';
 	value: number;
-	unit: string;
-	labels: Record<string, string>;
+	unit?: string;
+	labels?: Record<string, string>;
+	dimensions?: Record<string, string>;
 	timestamp: string;
 	endpointId?: string;
 	endpoint_id?: string;
+	stats?: {
+		min: number;
+		max: number;
+		count: number;
+		sum: number;
+	};
+	resolution?: number;
 }
 
 export interface MetricSeries {
@@ -287,29 +297,39 @@ export interface Event {
 }
 
 // Log types
+export interface LogMeta {
+	platform?: string;
+	app_name?: string;
+	app_version?: string;
+	container_id?: string;
+	container_name?: string;
+	unit?: string;
+	service?: string;
+	event_id?: string;
+	user?: string;
+	exe?: string;
+	path?: string;
+	extra?: Record<string, string>;
+}
+
 export interface LogEntry {
-	id: string;
-	timestamp: string;
-	level: 'debug' | 'info' | 'warning' | 'error' | 'fatal' | 'critical';
+	id?: string; // Optional client-side ID for deduplication
+	timestamp: string; // ISO timestamp
+	level: string;
 	message: string;
 	source: string;
 	category?: string;
-	endpointId?: string;
-	endpoint_id?: string;
-	endpoint_name?: string;
-	metadata?: Record<string, any>;
-	meta?: Record<string, any>;
+	pid?: number;
+	fields?: Record<string, string>;
 	tags?: Record<string, string>;
-	target?: string;
-	unit?: string;
-	app_name?: string;
-	service?: string;
-	event_id?: string;
-	user?: string;
-	container_id?: string;
-	container_name?: string;
-	platform?: string;
-	fields?: Record<string, any>;
+	meta?: LogMeta;
+}
+
+export interface LogResponse {
+	logs: LogEntry[];
+	next_cursor?: string;
+	has_more: boolean;
+	count: number;
 }
 
 // Process types

UI/src/lib/websocket.ts

@@ -164,5 +164,14 @@ export const websocketManager = {
       }
     });
     return unsubscribe;
+  },
+  
+  subscribeToProcesses(callback: (data: any) => void) {
+    const unsubscribe = processesWS.messages.subscribe((messages) => {
+      if (messages.length > 0) {
+        callback(messages[0]);
+      }
+    });
+    return unsubscribe;
   }
 };