Core usage data (#79101)

* Core Telemetry service * CoreTelemetryService mock * Add missing config values back, cleanup * Core usage collector * HttpConfig path is 'server' * Fix tests * CoreTelemetry -> CoreUsageData * Improve tests / docs * Fix telemetry_check * Don't catch fetch function exceptions, let usage collector handle it * Code review * Collect saved object index usage data * Fix tests and telemetry_check * explicitly import/export usage data types for telemetry_check * Remove OS data for now, test for SO usage data * Fix tests * Polish core docs * This shouldn't be here
elastic · Oct 5, 2020 · cd38380 · cd38380
1 parent 7eeb4ee
commit cd38380
Show file tree

Hide file tree

Showing 22 changed files with 1,462 additions and 4 deletions.
diff --git a/src/core/server/core_usage_data/core_usage_data_service.mock.ts b/src/core/server/core_usage_data/core_usage_data_service.mock.ts
@@ -0,0 +1,153 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import { PublicMethodsOf } from '@kbn/utility-types';
+import { BehaviorSubject } from 'rxjs';
+import { CoreUsageDataService } from './core_usage_data_service';
+import { CoreUsageData, CoreUsageDataStart } from './types';
+
+const createStartContractMock = () => {
+  const startContract: jest.Mocked<CoreUsageDataStart> = {
+    getCoreUsageData: jest.fn().mockResolvedValue(
+      new BehaviorSubject<CoreUsageData>({
+        config: {
+          elasticsearch: {
+            apiVersion: 'master',
+            customHeadersConfigured: false,
+            healthCheckDelayMs: 2500,
+            logQueries: false,
+            numberOfHostsConfigured: 1,
+            pingTimeoutMs: 30000,
+            requestHeadersWhitelistConfigured: false,
+            requestTimeoutMs: 30000,
+            shardTimeoutMs: 30000,
+            sniffIntervalMs: -1,
+            sniffOnConnectionFault: false,
+            sniffOnStart: false,
+            ssl: {
+              alwaysPresentCertificate: false,
+              certificateAuthoritiesConfigured: false,
+              certificateConfigured: false,
+              keyConfigured: false,
+              verificationMode: 'full',
+              keystoreConfigured: false,
+              truststoreConfigured: false,
+            },
+          },
+          http: {
+            basePathConfigured: false,
+            compression: {
+              enabled: true,
+              referrerWhitelistConfigured: false,
+            },
+            keepaliveTimeout: 120000,
+            maxPayloadInBytes: 1048576,
+            requestId: {
+              allowFromAnyIp: false,
+              ipAllowlistConfigured: false,
+            },
+            rewriteBasePath: false,
+            socketTimeout: 120000,
+            ssl: {
+              certificateAuthoritiesConfigured: false,
+              certificateConfigured: false,
+              cipherSuites: [
+                'ECDHE-RSA-AES128-GCM-SHA256',
+                'ECDHE-ECDSA-AES128-GCM-SHA256',
+                'ECDHE-RSA-AES256-GCM-SHA384',
+                'ECDHE-ECDSA-AES256-GCM-SHA384',
+                'DHE-RSA-AES128-GCM-SHA256',
+                'ECDHE-RSA-AES128-SHA256',
+                'DHE-RSA-AES128-SHA256',
+                'ECDHE-RSA-AES256-SHA384',
+                'DHE-RSA-AES256-SHA384',
+                'ECDHE-RSA-AES256-SHA256',
+                'DHE-RSA-AES256-SHA256',
+                'HIGH',
+                '!aNULL',
+                '!eNULL',
+                '!EXPORT',
+                '!DES',
+                '!RC4',
+                '!MD5',
+                '!PSK',
+                '!SRP',
+                '!CAMELLIA',
+              ],
+              clientAuthentication: 'none',
+              keyConfigured: false,
+              keystoreConfigured: false,
+              redirectHttpFromPortConfigured: false,
+              supportedProtocols: ['TLSv1.1', 'TLSv1.2'],
+              truststoreConfigured: false,
+            },
+            xsrf: {
+              disableProtection: false,
+              whitelistConfigured: false,
+            },
+          },
+          logging: {
+            appendersTypesUsed: [],
+            loggersConfiguredCount: 0,
+          },
+          savedObjects: {
+            maxImportExportSizeBytes: 10000,
+            maxImportPayloadBytes: 10485760,
+          },
+        },
+        environment: {
+          memory: {
+            heapSizeLimit: 1,
+            heapTotalBytes: 1,
+            heapUsedBytes: 1,
+          },
+        },
+        services: {
+          savedObjects: {
+            indices: [
+              {
+                docsCount: 1,
+                docsDeleted: 1,
+                alias: 'test_index',
+                primaryStoreSizeBytes: 1,
+                storeSizeBytes: 1,
+              },
+            ],
+          },
+        },
+      })
+    ),
+  };
+
+  return startContract;
+};
+
+const createMock = () => {
+  const mocked: jest.Mocked<PublicMethodsOf<CoreUsageDataService>> = {
+    setup: jest.fn(),
+    start: jest.fn().mockReturnValue(createStartContractMock()),
+    stop: jest.fn(),
+  };
+  return mocked;
+};
+
+export const coreUsageDataServiceMock = {
+  create: createMock,
+  createStartContract: createStartContractMock,
+};