Edge events implementation unfinished

@@ -14,14 +14,16 @@
 /// limitations under the License.
 ///
 
-import {Inject, Injectable} from '@angular/core';
+import { Injectable } from '@angular/core';
 import { defaultHttpOptionsFromConfig, RequestConfig } from './http-utils';
 import { Observable } from 'rxjs';
 import { HttpClient } from '@angular/common/http';
-import { PageLink } from '@shared/models/page/page-link';
+import { PageLink, TimePageLink } from '@shared/models/page/page-link';
 import { PageData } from '@shared/models/page/page-data';
 import { EntitySubtype } from '@app/shared/models/entity-type.models';
 import { Edge, EdgeInfo, EdgeSearchQuery } from "@shared/models/edge.models";
+import { EntityId } from "@shared/models/id/entity-id";
+import { Event } from "@shared/models/event.models";
 @Injectable({
   providedIn: 'root'
 })
@@ -96,4 +98,8 @@ export class EdgeService {
     return this.http.post<Array<Edge>>('/api/edges', query, defaultHttpOptionsFromConfig(config));
   }
 
+  public getEdgeEvents(entityId: EntityId, pageLink: TimePageLink, config?: RequestConfig): Observable<PageData<Event>> {
+    return this.http.get<PageData<Event>>(`/api/edge/${entityId.id}/events` + `${pageLink.toQuery()}`,
+      defaultHttpOptionsFromConfig(config));
+  }
 }

@@ -38,4 +38,9 @@ export class EventService {
               `${pageLink.toQuery()}&tenantId=${tenantId}`,
       defaultHttpOptionsFromConfig(config));
   }
+
+  public getEdgeEvents(entityId: EntityId, pageLink: TimePageLink, config?: RequestConfig): Observable<PageData<Event>> {
+    return this.http.get<PageData<Event>>(`/api/edge/${entityId.id}/events` + `${pageLink.toQuery()}`,
+      defaultHttpOptionsFromConfig(config));
+  }
 }

@@ -20,25 +20,25 @@ import {
   EntityTableColumn,
   EntityTableConfig
 } from '@home/models/entity/entities-table-config.models';
-import { DebugEventType, Event, EventType } from '@shared/models/event.models';
-import { TimePageLink } from '@shared/models/page/page-link';
-import { TranslateService } from '@ngx-translate/core';
-import { DatePipe } from '@angular/common';
-import { MatDialog } from '@angular/material/dialog';
-import { EntityId } from '@shared/models/id/entity-id';
-import { EventService } from '@app/core/http/event.service';
-import { EventTableHeaderComponent } from '@home/components/event/event-table-header.component';
-import { EntityTypeResource } from '@shared/models/entity-type.models';
-import { Observable } from 'rxjs';
-import { PageData } from '@shared/models/page/page-data';
-import { Direction } from '@shared/models/page/sort-order';
-import { DialogService } from '@core/services/dialog.service';
-import { ContentType } from '@shared/models/constants';
+import {DebugEventType, Event, EventType} from '@shared/models/event.models';
+import {TimePageLink} from '@shared/models/page/page-link';
+import {TranslateService} from '@ngx-translate/core';
+import {DatePipe} from '@angular/common';
+import {MatDialog} from '@angular/material/dialog';
+import {EntityId} from '@shared/models/id/entity-id';
+import {EventService} from '@app/core/http/event.service';
+import {EventTableHeaderComponent} from '@home/components/event/event-table-header.component';
+import {EntityTypeResource} from '@shared/models/entity-type.models';
+import {Observable} from 'rxjs';
+import {PageData} from '@shared/models/page/page-data';
+import {Direction} from '@shared/models/page/sort-order';
+import {DialogService} from '@core/services/dialog.service';
+import {ContentType} from '@shared/models/constants';
 import {
   EventContentDialogComponent,
   EventContentDialogData
 } from '@home/components/event/event-content-dialog.component';
-import { sortObjectKeys } from '@core/utils';
+import {sortObjectKeys} from '@core/utils';
 
 export class EventTableConfig extends EntityTableConfig<Event, TimePageLink> {
 
@@ -104,7 +104,11 @@ export class EventTableConfig extends EntityTableConfig<Event, TimePageLink> {
   }
 
   fetchEvents(pageLink: TimePageLink): Observable<PageData<Event>> {
-    return this.eventService.getEvents(this.entityId, this.eventType, this.tenantId, pageLink);
+    if (this.eventTypeValue === EventType.EDGE_EVENT) {
+      return this.eventService.getEdgeEvents(this.entityId, pageLink);
+    } else {
+      return this.eventService.getEvents(this.entityId, this.eventType, this.tenantId, pageLink);
+    }
   }
 
   updateColumns(updateTableColumns: boolean = false): void {
@@ -159,6 +163,12 @@ export class EventTableConfig extends EntityTableConfig<Event, TimePageLink> {
             () => ({}), () => undefined, true)
         );
         break;
+      case EventType.EDGE_EVENT:
+        this.columns.push(
+          new EntityTableColumn<Event>('type', 'event.type', '100%',
+            (entity) => entity.type, entity => ({}), false),
+        );
+        break;
       case DebugEventType.DEBUG_RULE_NODE:
       case DebugEventType.DEBUG_RULE_CHAIN:
         this.columns[0].width = '100px';

@@ -64,8 +64,9 @@ export interface StatsEventBody extends BaseEventBody {
 }
 
 export interface EdgeEventBody extends BaseEventBody {
-  messagesProcessed: number;
-  errorsOccurred: number;
+  type: string;
+  action: string;
+  entityId: string;
 }
 
 export interface DebugRuleNodeEventBody extends BaseEventBody {
@@ -81,7 +82,7 @@ export interface DebugRuleNodeEventBody extends BaseEventBody {
   error: string;
 }
 
-export type EventBody = ErrorEventBody & LcEventEventBody & StatsEventBody & DebugRuleNodeEventBody;
+export type EventBody = ErrorEventBody & LcEventEventBody & StatsEventBody & DebugRuleNodeEventBody & EdgeEventBody;
 
 export interface Event extends BaseData<EventId> {
   tenantId: TenantId;