[Monitoring] APM Monitoring UI

NOTICE.txt

@@ -185,25 +185,3 @@ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 THE SOFTWARE.
 
----
-This product uses "radioactive button" styles that were published on
-https://zurb.com/playground/radioactive-buttons under an "MIT" License.
-
-Copyright (c) ZURB
-Permission is hereby granted, free of charge, to any person obtaining a copy of
-this software and associated documentation files (the "Software"), to deal in the
-Software without restriction, including without limitation the rights to use, copy,
-modify, merge, publish, distribute, sublicense, and/or sell copies of the Software,
-and to permit persons to whom the Software is furnished to do so, subject to the
-following conditions:
-
-The above copyright notice and this permission notice shall be included in all
-copies or substantial portions of the Software.
-
-THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
-INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
-PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
-HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
-OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE
-SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
-

package.json

@@ -294,7 +294,6 @@
     "jest-cli": "^23.5.0",
     "jest-raw-loader": "^1.0.1",
     "jimp": "0.2.28",
-    "jsdom": "9.9.1",
     "json5": "^1.0.1",
     "karma": "1.7.0",
     "karma-chrome-launcher": "2.1.1",

packages/kbn-plugin-generator/sao_template/template/index.js

@@ -12,16 +12,16 @@ export default function (kibana) {
         title: '<%= startCase(name) %>',
         description: '<%= description %>',
         main: 'plugins/<%= snakeCase(name) %>/app',
-        <%_ if (generateScss) { -%>
-        styleSheetPath: require('path').resolve(__dirname, 'public/app.scss'),
-        <%_ } -%>
       },
       <%_ } -%>
       <%_ if (generateHack) { -%>
       hacks: [
         'plugins/<%= snakeCase(name) %>/hack'
       ]
       <%_ } -%>
+      <%_ if (generateScss) { -%>
+      styleSheetPaths: require('path').resolve(__dirname, 'public/app.scss'),
+      <%_ } -%>
     },
 
     config(Joi) {

src/core/public/utils/index.ts

@@ -18,3 +18,4 @@
  */
 
 export { modifyUrl } from './modify_url';
+export { shareWeakReplay } from './share_weak_replay';

src/core/public/utils/share_weak_replay.test.ts

@@ -0,0 +1,243 @@
+/*
+ * 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 * as Rx from 'rxjs';
+import { map, materialize, take, toArray } from 'rxjs/operators';
+
+import { shareWeakReplay } from './share_weak_replay';
+
+let completedCounts = 0;
+
+function counter({ async = true }: { async?: boolean } = {}) {
+  let subCounter = 0;
+
+  function sendCount(subscriber: Rx.Subscriber<string>) {
+    let notifCounter = 0;
+    const sub = ++subCounter;
+
+    while (!subscriber.closed) {
+      subscriber.next(`${sub}:${++notifCounter}`);
+    }
+
+    completedCounts += 1;
+  }
+
+  return new Rx.Observable<string>(subscriber => {
+    if (!async) {
+      sendCount(subscriber);
+      return;
+    }
+
+    const id = setTimeout(() => sendCount(subscriber));
+    return () => clearTimeout(id);
+  });
+}
+
+async function record<T>(observable: Rx.Observable<T>) {
+  return observable
+    .pipe(
+      materialize(),
+      map(n => (n.kind === 'N' ? `N:${n.value}` : n.kind === 'E' ? `E:${n.error.message}` : 'C')),
+      toArray()
+    )
+    .toPromise();
+}
+
+afterEach(() => {
+  completedCounts = 0;
+});
+
+it('multicasts an observable to multiple children, unsubs once all children do, and resubscribes on next subscription', async () => {
+  const shared = counter().pipe(shareWeakReplay(1));
+
+  await expect(Promise.all([record(shared.pipe(take(1))), record(shared.pipe(take(2)))])).resolves
+    .toMatchInlineSnapshot(`
+Array [
+  Array [
+    "N:1:1",
+    "C",
+  ],
+  Array [
+    "N:1:1",
+    "N:1:2",
+    "C",
+  ],
+]
+`);
+
+  await expect(Promise.all([record(shared.pipe(take(3))), record(shared.pipe(take(4)))])).resolves
+    .toMatchInlineSnapshot(`
+Array [
+  Array [
+    "N:2:1",
+    "N:2:2",
+    "N:2:3",
+    "C",
+  ],
+  Array [
+    "N:2:1",
+    "N:2:2",
+    "N:2:3",
+    "N:2:4",
+    "C",
+  ],
+]
+`);
+
+  expect(completedCounts).toBe(2);
+});
+
+it('resubscribes if parent errors', async () => {
+  let errorCounter = 0;
+  const shared = counter().pipe(
+    map((v, i) => {
+      if (i === 3) {
+        throw new Error(`error ${++errorCounter}`);
+      }
+      return v;
+    }),
+    shareWeakReplay(2)
+  );
+
+  await expect(Promise.all([record(shared), record(shared)])).resolves.toMatchInlineSnapshot(`
+Array [
+  Array [
+    "N:1:1",
+    "N:1:2",
+    "N:1:3",
+    "E:error 1",
+  ],
+  Array [
+    "N:1:1",
+    "N:1:2",
+    "N:1:3",
+    "E:error 1",
+  ],
+]
+`);
+
+  await expect(Promise.all([record(shared), record(shared)])).resolves.toMatchInlineSnapshot(`
+Array [
+  Array [
+    "N:2:1",
+    "N:2:2",
+    "N:2:3",
+    "E:error 2",
+  ],
+  Array [
+    "N:2:1",
+    "N:2:2",
+    "N:2:3",
+    "E:error 2",
+  ],
+]
+`);
+
+  expect(completedCounts).toBe(2);
+});
+
+it('resubscribes if parent completes', async () => {
+  const shared = counter().pipe(
+    take(4),
+    shareWeakReplay(4)
+  );
+
+  await expect(Promise.all([record(shared.pipe(take(1))), record(shared)])).resolves
+    .toMatchInlineSnapshot(`
+Array [
+  Array [
+    "N:1:1",
+    "C",
+  ],
+  Array [
+    "N:1:1",
+    "N:1:2",
+    "N:1:3",
+    "N:1:4",
+    "C",
+  ],
+]
+`);
+
+  await expect(Promise.all([record(shared.pipe(take(2))), record(shared)])).resolves
+    .toMatchInlineSnapshot(`
+Array [
+  Array [
+    "N:2:1",
+    "N:2:2",
+    "C",
+  ],
+  Array [
+    "N:2:1",
+    "N:2:2",
+    "N:2:3",
+    "N:2:4",
+    "C",
+  ],
+]
+`);
+
+  expect(completedCounts).toBe(2);
+});
+
+it('supports parents that complete synchronously', async () => {
+  const next = jest.fn();
+  const complete = jest.fn();
+  const shared = counter({ async: false }).pipe(
+    take(3),
+    shareWeakReplay(1)
+  );
+
+  shared.subscribe({ next, complete });
+  expect(next.mock.calls).toMatchInlineSnapshot(`
+Array [
+  Array [
+    "1:1",
+  ],
+  Array [
+    "1:2",
+  ],
+  Array [
+    "1:3",
+  ],
+]
+`);
+  expect(complete).toHaveBeenCalledTimes(1);
+
+  next.mockClear();
+  complete.mockClear();
+
+  shared.subscribe({ next, complete });
+  expect(next.mock.calls).toMatchInlineSnapshot(`
+Array [
+  Array [
+    "2:1",
+  ],
+  Array [
+    "2:2",
+  ],
+  Array [
+    "2:3",
+  ],
+]
+`);
+  expect(complete).toHaveBeenCalledTimes(1);
+
+  expect(completedCounts).toBe(2);
+});

src/core/public/utils/share_weak_replay.ts

@@ -0,0 +1,66 @@
+/*
+ * 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 * as Rx from 'rxjs';
+import { takeUntil } from 'rxjs/operators';
+
+/**
+ * Just like the [`shareReplay()`](https://rxjs-dev.firebaseapp.com/api/operators/shareReplay) operator from
+ * RxJS except for a few key differences:
+ *
+ * - If all downstream subscribers unsubscribe the source subscription will be unsubscribed.
+ *
+ * - Replay-ability is only maintained while the source is active, if it completes or errors
+ *   then complete/error is sent to the current subscribers and the replay buffer is cleared.
+ *
+ * - Any subscription after the the source completes or errors will create a new subscription
+ *   to the source observable.
+ *
+ * @param bufferSize Optional, default is `Number.POSITIVE_INFINITY`
+ */
+export function shareWeakReplay<T>(bufferSize?: number): Rx.MonoTypeOperatorFunction<T> {
+  return (source: Rx.Observable<T>) => {
+    let subject: Rx.ReplaySubject<T> | undefined;
+    const stop$ = new Rx.Subject();
+
+    return new Rx.Observable(observer => {
+      if (!subject) {
+        subject = new Rx.ReplaySubject<T>(bufferSize);
+      }
+
+      subject.subscribe(observer).add(() => {
+        if (!subject) {
+          return;
+        }
+
+        if (subject.observers.length === 0) {
+          stop$.next();
+        }
+
+        if (subject.closed || subject.isStopped) {
+          subject = undefined;
+        }
+      });
+
+      if (subject && subject.observers.length === 1) {
+        source.pipe(takeUntil(stop$)).subscribe(subject);
+      }
+    });
+  };
+}

src/core_plugins/kbn_vislib_vis_types/public/controls/gauge_options.html

@@ -123,7 +123,7 @@
 
     <div id="gaugeOptionsRanges" ng-show="showColorRange" class="kuiSideBarCollapsibleSection">
       <div class="kuiSideBarSection">
-        <table class="vis-editor-agg-editor-ranges form-group" ng-show="editorState.params.gauge.colorsRange.length">
+        <table class="visEditorAgg__rangesTable form-group" ng-show="editorState.params.gauge.colorsRange.length">
           <tr>
             <th scope="col">
               <label id="gaugeOptionsCustomRangeFrom">From</label>

src/core_plugins/kbn_vislib_vis_types/public/controls/heatmap_options.html

@@ -118,7 +118,7 @@
       <div class="kuiSideBarSection">
         <table
           data-test-subj="heatmapCustomRangesTable"
-          class="vis-editor-agg-editor-ranges form-group"
+          class="visEditorAgg__rangesTable form-group"
           ng-show="editorState.params.colorsRange.length">
           <tr>
             <th scope="col">

src/core_plugins/kibana/index.js

@@ -66,9 +66,8 @@ export default function (kibana) {
         listed: false,
         description: 'the kibana you know and love',
         main: 'plugins/kibana/kibana',
-        styleSheetPath: `${__dirname}/public/index.scss`,
       },
-
+      styleSheetPaths: `${__dirname}/public/index.scss`,
       links: [
         {
           id: 'kibana:discover',