Initial work on uptime for observability homepage API

x-pack/plugins/uptime/common/runtime_types/ping/histogram.ts

@@ -21,6 +21,7 @@ export interface GetPingHistogramParams {
   dateEnd: string;
   filters?: string;
   monitorId?: string;
+  bucketSize?: string;
 }
 
 export interface HistogramResult {

x-pack/plugins/uptime/kibana.json

@@ -2,7 +2,7 @@
   "configPath": ["xpack", "uptime"],
   "id": "uptime",
   "kibanaVersion": "kibana",
-  "optionalPlugins": ["capabilities", "data", "home"],
+  "optionalPlugins": ["capabilities", "data", "home", "observability"],
   "requiredPlugins": [
     "alerts",
     "embeddable",

x-pack/plugins/uptime/public/apps/plugin.ts

@@ -27,10 +27,14 @@ import {
 } from '../../../../../src/plugins/data/public';
 import { alertTypeInitializers } from '../lib/alert_types';
 import { kibanaService } from '../state/kibana_service';
+import { fetchIndexStatus } from '../state/api';
+import { ObservabilityPluginSetup } from '../../../observability/public';
+import { fetchUptimeOverviewData } from './uptime_overview_fetcher';
 
 export interface ClientPluginsSetup {
   data: DataPublicPluginSetup;
   home: HomePublicPluginSetup;
+  observability: ObservabilityPluginSetup;
   triggers_actions_ui: TriggersAndActionsUIPublicPluginSetup;
 }
 
@@ -63,6 +67,16 @@ export class UptimePlugin
       });
     }
 
+    // This doesn't actually work
+    plugins.observability.dashboard.register({
+      appName: 'uptime',
+      hasData: async () => {
+        const status = await fetchIndexStatus();
+        return status.docCount > 0;
+      },
+      fetchData: fetchUptimeOverviewData,
+    });
+
     core.application.register({
       appRoute: '/app/uptime#/',
       id: PLUGIN.ID,

x-pack/plugins/uptime/public/apps/uptime_overview_fetcher.ts

@@ -0,0 +1,62 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { fetchPingHistogram, fetchSnapshotCount } from '../state/api';
+import { UptimeFetchDataResponse } from '../../../observability/public/typings/fetch_data_response';
+
+export async function fetchUptimeOverviewData({
+  startTime,
+  endTime,
+  bucketSize,
+}: {
+  startTime: string;
+  endTime: string;
+  bucketSize: string;
+}) {
+  const snapshot = await fetchSnapshotCount({
+    dateRangeStart: startTime,
+    dateRangeEnd: endTime,
+  });
+
+  const pings = await fetchPingHistogram({ dateStart: startTime, dateEnd: endTime, bucketSize });
+
+  const response: UptimeFetchDataResponse = {
+    title: 'Uptime',
+    appLink: '/app/uptime#/', // Todo is there some sort of helper that handles subpaths?
+    stats: {
+      monitors: {
+        type: 'number',
+        label: 'Monitors',
+        value: snapshot.total,
+      },
+      up: {
+        type: 'number',
+        label: 'Up',
+        value: snapshot.up,
+      },
+      down: {
+        type: 'number',
+        label: 'Down',
+        value: snapshot.down,
+      },
+    },
+    series: {
+      up: {
+        label: 'Up',
+        coordinates: pings.histogram.map((p) => {
+          return { x: p.x!, y: p.upCount || 0 };
+        }),
+      },
+      down: {
+        label: 'Down',
+        coordinates: pings.histogram.map((p) => {
+          return { x: p.x!, y: p.downCount || 0 };
+        }),
+      },
+    },
+  };
+  return response;
+}

x-pack/plugins/uptime/public/state/api/ping.ts

@@ -25,12 +25,14 @@ export const fetchPingHistogram: APIFn<GetPingHistogramParams, HistogramResult>
   dateStart,
   dateEnd,
   filters,
+  bucketSize,
 }) => {
   const queryParams = {
     dateStart,
     dateEnd,
     monitorId,
     filters,
+    bucketSize,
   };
 
   return await apiService.get(API_URLS.PING_HISTOGRAM, queryParams);

x-pack/plugins/uptime/server/lib/requests/__tests__/get_ping_histogram.test.ts

@@ -62,7 +62,6 @@ describe('getPingHistogram', () => {
       dynamicSettings: DYNAMIC_SETTINGS_DEFAULTS,
       from: 'now-15m',
       to: 'now',
-      filters: null,
     });
 
     expect(mockEsClient).toHaveBeenCalledTimes(1);
@@ -81,7 +80,7 @@ describe('getPingHistogram', () => {
       dynamicSettings: DYNAMIC_SETTINGS_DEFAULTS,
       from: 'now-15m',
       to: 'now',
-      filters: null,
+      filters: '',
     });
 
     expect(mockEsClient).toHaveBeenCalledTimes(1);

x-pack/plugins/uptime/server/lib/requests/get_ping_histogram.ts

@@ -8,22 +8,25 @@ import { UMElasticsearchQueryFn } from '../adapters';
 import { getFilterClause } from '../helper';
 import { HistogramResult, HistogramQueryResult } from '../../../common/runtime_types';
 import { QUERY } from '../../../common/constants';
+import { getHistogramInterval } from '../helper/get_histogram_interval';
 
 export interface GetPingHistogramParams {
   /** @member dateRangeStart timestamp bounds */
   from: string;
   /** @member dateRangeEnd timestamp bounds */
   to: string;
   /** @member filters user-defined filters */
-  filters?: string | null;
+  filters?: string;
   /** @member monitorId optional limit to monitorId */
-  monitorId?: string | null;
+  monitorId?: string;
+
+  bucketSize?: string;
 }
 
 export const getPingHistogram: UMElasticsearchQueryFn<
   GetPingHistogramParams,
   HistogramResult
-> = async ({ callES, dynamicSettings, from, to, filters, monitorId }) => {
+> = async ({ callES, dynamicSettings, from, to, filters, monitorId, bucketSize }) => {
   const boolFilters = filters ? JSON.parse(filters) : null;
   const additionalFilters = [];
   if (monitorId) {
@@ -34,6 +37,23 @@ export const getPingHistogram: UMElasticsearchQueryFn<
   }
   const filter = getFilterClause(from, to, additionalFilters);
 
+  const seriesHistogram: any = {};
+
+  if (bucketSize) {
+    seriesHistogram.date_histogram = {
+      field: '@timestamp',
+      fixed_interval:
+        bucketSize || getHistogramInterval(from, to, QUERY.DEFAULT_BUCKET_COUNT) + 'ms',
+      missing: 0,
+    };
+  } else {
+    seriesHistogram.auto_date_histogram = {
+      field: '@timestamp',
+      buckets: QUERY.DEFAULT_BUCKET_COUNT,
+      missing: 0,
+    };
+  }
+
   const params = {
     index: dynamicSettings.heartbeatIndices,
     body: {
@@ -45,10 +65,7 @@ export const getPingHistogram: UMElasticsearchQueryFn<
       size: 0,
       aggs: {
         timeseries: {
-          auto_date_histogram: {
-            field: '@timestamp',
-            buckets: QUERY.DEFAULT_BUCKET_COUNT,
-          },
+          ...seriesHistogram,
           aggs: {
             down: {
               filter: {

x-pack/plugins/uptime/server/rest_api/pings/get_ping_histogram.ts

@@ -18,10 +18,11 @@ export const createGetPingHistogramRoute: UMRestApiRouteFactory = (libs: UMServe
       dateEnd: schema.string(),
       monitorId: schema.maybe(schema.string()),
       filters: schema.maybe(schema.string()),
+      bucketSize: schema.maybe(schema.string()),
     }),
   },
   handler: async ({ callES, dynamicSettings }, _context, request, response): Promise<any> => {
-    const { dateStart, dateEnd, monitorId, filters } = request.query;
+    const { dateStart, dateEnd, monitorId, filters, bucketSize } = request.query;
 
     const result = await libs.requests.getPingHistogram({
       callES,
@@ -30,6 +31,7 @@ export const createGetPingHistogramRoute: UMRestApiRouteFactory = (libs: UMServe
       to: dateEnd,
       monitorId,
       filters,
+      bucketSize,
     });
 
     return response.ok({