/** * Copyright (c) OpenLens Authors. All rights reserved. * Licensed under MIT License. See LICENSE in root directory for more information. */ import "./events.scss"; import React from "react"; import { computed, observable, makeObservable } from "mobx"; import { observer } from "mobx-react"; import { orderBy } from "lodash"; import { TabLayout } from "../layout/tab-layout-2"; import type { EventStore } from "./store"; import type { KubeObjectListLayoutProps } from "../kube-object-list-layout"; import { KubeObjectListLayout } from "../kube-object-list-layout"; import type { KubeEvent, KubeEventApi, KubeEventData } from "../../../common/k8s-api/endpoints/events.api"; import type { TableSortCallbacks, TableSortParams } from "../table"; import type { HeaderCustomizer } from "../item-object-list"; import { Tooltip } from "../tooltip"; import { Link } from "react-router-dom"; import type { IClassName } from "../../utils"; import { prevDefault, cssNames, stopPropagation } from "../../utils"; import { Icon } from "../icon"; import type { ApiManager } from "../../../common/k8s-api/api-manager"; import { withInjectables } from "@ogre-tools/injectable-react"; import navigateToEventsInjectable from "../../../common/front-end-routing/routes/cluster/events/navigate-to-events.injectable"; import { KubeObjectAge } from "../kube-object/age"; import { ReactiveDuration } from "../duration/reactive-duration"; import apiManagerInjectable from "../../../common/k8s-api/api-manager/manager.injectable"; import eventStoreInjectable from "./store.injectable"; import type { FilterByNamespace } from "../+namespaces/namespace-select-filter-model/filter-by-namespace.injectable"; import filterByNamespaceInjectable from "../+namespaces/namespace-select-filter-model/filter-by-namespace.injectable"; import type { GetDetailsUrl } from "../kube-detail-params/get-details-url.injectable"; import getDetailsUrlInjectable from "../kube-detail-params/get-details-url.injectable"; enum columnId { message = "message", namespace = "namespace", object = "object", type = "type", count = "count", source = "source", age = "age", lastSeen = "last-seen", } export interface EventsProps extends Partial> { className?: IClassName; compact?: boolean; compactLimit?: number; } const defaultProps: Partial = { compactLimit: 10, }; interface Dependencies { navigateToEvents: () => void; eventStore: EventStore; apiManager: ApiManager; filterByNamespace: FilterByNamespace; getDetailsUrl: GetDetailsUrl; } @observer class NonInjectedEvents extends React.Component { static defaultProps = defaultProps as object; @observable sorting: TableSortParams = { sortBy: columnId.age, orderBy: "asc", }; private sortingCallbacks: TableSortCallbacks = { [columnId.namespace]: event => event.getNs(), [columnId.type]: event => event.type, [columnId.object]: event => event.involvedObject.name, [columnId.count]: event => event.count, [columnId.age]: event => -event.getCreationTimestamp(), [columnId.lastSeen]: event => event.lastTimestamp ? -new Date(event.lastTimestamp).getTime() : 0, }; constructor(props: Dependencies & EventsProps) { super(props); makeObservable(this); } @computed get items(): KubeEvent[] { const items = this.props.eventStore.contextItems; const { sortBy, orderBy: order } = this.sorting; // we must sort items before passing to "KubeObjectListLayout -> Table" // to make it work with "compact=true" (proper table sorting actions + initial items) return orderBy(items, this.sortingCallbacks[sortBy], order); } @computed get visibleItems(): KubeEvent[] { const { compact, compactLimit } = this.props; if (compact) { return this.items.slice(0, compactLimit); } return this.items; } customizeHeader: HeaderCustomizer = ({ info, title, ...headerPlaceholders }) => { const { compact, eventStore } = this.props; const { items, visibleItems } = this; const allEventsAreShown = visibleItems.length === items.length; // handle "compact"-mode header if (compact) { if (allEventsAreShown) { return { title }; } return { title, info: ( {"("} {visibleItems.length} {" of "} {items.length} {")"} ), }; } return { info: ( <> {info} ), title, ...headerPlaceholders, }; }; render() { const { apiManager, eventStore, compact, compactLimit, className, ...layoutProps } = this.props; const events = ( this.visibleItems} virtual={!compact} tableProps={{ sortSyncWithUrl: false, sortByDefault: this.sorting, onSort: params => this.sorting = params, }} sortingCallbacks={this.sortingCallbacks} searchFilters={[ event => event.getSearchFields(), event => event.message, event => event.getSource(), event => event.involvedObject.name, ]} renderTableHeader={[ { title: "Type", className: "type", sortBy: columnId.type, id: columnId.type }, { title: "Message", className: "message", id: columnId.message }, { title: "Namespace", className: "namespace", sortBy: columnId.namespace, id: columnId.namespace }, { title: "Involved Object", className: "object", sortBy: columnId.object, id: columnId.object }, { title: "Source", className: "source", id: columnId.source }, { title: "Count", className: "count", sortBy: columnId.count, id: columnId.count }, { title: "Age", className: "age", sortBy: columnId.age, id: columnId.age }, { title: "Last Seen", className: "last-seen", sortBy: columnId.lastSeen, id: columnId.lastSeen }, ]} renderTableContents={event => { const { involvedObject, type, message } = event; const tooltipId = `message-${event.getId()}`; const isWarning = event.isWarning(); return [ type, // type of event: "Normal" or "Warning" { className: cssNames({ warning: isWarning }), title: ( <> {message} {message} ), }, compact ? ( this.props.filterByNamespace(event.getNs()))} > {event.getNs()} ) : event.getNs(), {`${involvedObject.kind}: ${involvedObject.name}`} , event.getSource(), event.count, , , ]; }} /> ); if (compact) { return events; } return ( {events} ); } } export const Events = withInjectables(NonInjectedEvents, { getProps: (di, props) => ({ ...props, navigateToEvents: di.inject(navigateToEventsInjectable), apiManager: di.inject(apiManagerInjectable), eventStore: di.inject(eventStoreInjectable), filterByNamespace: di.inject(filterByNamespaceInjectable), getDetailsUrl: di.inject(getDetailsUrlInjectable), }), });