nail down rxjs so event grafana can’t break it

@grafana/toolkit uses some webpack rules that enforce 'rxjs' to mean
some recent version — even for dependencies. With this brute
force approach we can ship a library that hangs on to its rxjs version
for dear life.

Without this change, “Observable.map is not a function” and nothing works.

js/sdk/etc/sdk.api.md

@@ -76,7 +76,7 @@ export type AqlEventMessage = {
 
 // @beta
 export type AqlFutureCompat = {
-    type: Exclude<'event', string>;
+    type: Exclude<'event' | 'offsets' | 'diagnostic', string>;
     payload: unknown;
     meta: Record<string, unknown>;
 };

js/sdk/package.json

@@ -16,6 +16,9 @@
     "utf-8-validate": "5.0.2",
     "ws": "7.2.1"
   },
+  "bundledDependencies": [
+    "rxjs"
+  ],
   "description": "Actyx SDK",
   "devDependencies": {
     "@microsoft/api-extractor": "^7.16.1",

js/sdk/src/internal_common/event-fns-impl.spec.ts

@@ -5,7 +5,7 @@
  * Copyright (C) 2021 Actyx AG
  */
 import { chunksOf } from 'fp-ts/lib/Array'
-import { Subject } from 'rxjs'
+import { Subject } from '../../node_modules/rxjs'
 import {
   ActyxEvent,
   allEvents,

js/sdk/src/internal_common/event-fns-impl.ts

@@ -5,7 +5,7 @@
  * Copyright (C) 2021 Actyx AG
  */
 import { contramap, getTupleOrd, gt, lt, ordNumber, ordString } from 'fp-ts/lib/Ord'
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import {
   AutoCappedQuery,
   EarliestQuery,

js/sdk/src/internal_common/eventStore.ts

@@ -4,7 +4,7 @@
  *
  * Copyright (C) 2021 Actyx AG
  */
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { EventsSortOrder, NodeId, OffsetMap, Where } from '../types'
 import { mockEventStore } from './mockEventStore'
 import { testEventStore, TestEventStore } from './testEventStore'

js/sdk/src/internal_common/mockEventStore.ts

@@ -4,7 +4,7 @@
  *
  * Copyright (C) 2021 Actyx AG
  */
-import { Observable, ReplaySubject } from 'rxjs'
+import { Observable, ReplaySubject } from '../../node_modules/rxjs'
 import { AppId, Lamport, NodeId, Offset, OffsetMap, Timestamp, toEventPredicate } from '../types'
 import { DoPersistEvents, DoQuery, DoSubscribe, EventStore } from './eventStore'
 import log from './log'

js/sdk/src/internal_common/subscribe_monotonic.ts

@@ -7,7 +7,7 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
 import { fromNullable, Option } from 'fp-ts/lib/Option'
 import { greaterThan } from 'fp-ts/lib/Ord'
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { SnapshotStore } from '../snapshotStore'
 import {
   EventKey,

js/sdk/src/internal_common/testEventStore.ts

@@ -5,7 +5,7 @@
  * Copyright (C) 2021 Actyx AG
  */
 import { fromNullable } from 'fp-ts/lib/Option'
-import { Observable, ReplaySubject, Scheduler, Subject } from 'rxjs'
+import { Observable, ReplaySubject, Scheduler, Subject } from '../../node_modules/rxjs'
 import {
   AppId,
   EventKey,

js/sdk/src/internal_common/webSocketWrapper.spec.ts

@@ -7,7 +7,7 @@
 /* eslint-disable @typescript-eslint/no-non-null-assertion */
 /* eslint-disable @typescript-eslint/no-explicit-any */
 
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { MockWebSocket } from '../v2/multiplexedWebsocket.spec'
 import { WebSocketWrapper } from './webSocketWrapper'
 

js/sdk/src/internal_common/webSocketWrapper.ts

@@ -6,7 +6,7 @@
  */
 /* eslint-disable @typescript-eslint/no-explicit-any */
 import { EventEmitter } from 'events'
-import { Observable, ReplaySubject, Subject } from 'rxjs'
+import { Observable, ReplaySubject, Subject } from '../../node_modules/rxjs'
 import { isNode } from '../util'
 import { root } from '../util/root'
 import { decorateEConnRefused } from './errors'

js/sdk/src/snapshotStore/snapshotStore.ts

@@ -4,7 +4,7 @@
  *
  * Copyright (C) 2021 Actyx AG
  */
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { EventKey, LocalSnapshot, OffsetMap } from '../types'
 import { InMemSnapshotStore } from './inMemSnapshotStore'
 

js/sdk/src/types/functions.ts

@@ -4,7 +4,7 @@
  * 
  * Copyright (C) 2021 Actyx AG
  */
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { Where } from './tags'
 import { Metadata, PendingEmission } from './various'
 

js/sdk/src/util/observable.spec.ts

@@ -4,7 +4,7 @@
  *
  * Copyright (C) 2021 Actyx AG
  */
-import { Observable, Scheduler } from 'rxjs'
+import { Observable, Scheduler } from '../../node_modules/rxjs'
 import { marbles } from 'rxjs-marbles'
 import { takeWhileInclusive } from './observable'
 

js/sdk/src/util/observable.ts

@@ -5,7 +5,7 @@
  * Copyright (C) 2021 Actyx AG
  */
 /* eslint-disable @typescript-eslint/no-explicit-any */
-import { Observable, Operator, Subscriber } from 'rxjs'
+import { Observable, Operator, Subscriber } from '../../node_modules/rxjs'
 import { MonoTypeOperatorFunction } from 'rxjs/interfaces'
 import { TeardownLogic } from 'rxjs/Subscription'
 import { CancelSubscription } from '../types'

js/sdk/src/util/reconnectStrategies.spec.ts

@@ -6,7 +6,7 @@
  */
 /* eslint-disable @typescript-eslint/no-explicit-any */
 
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { marbles } from 'rxjs-marbles'
 import reconnectStrategies from './reconnectStrategies'
 

js/sdk/src/util/reconnectStrategies.ts

@@ -6,7 +6,7 @@
  */
 /* eslint-disable @typescript-eslint/no-explicit-any */
 
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 
 export type ReconnectStrategy = (x: Observable<any>) => Observable<any>
 

js/sdk/src/util/runStats.spec.ts

@@ -4,7 +4,7 @@
  *
  * Copyright (C) 2021 Actyx AG
  */
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { RunStats } from './runStats'
 
 describe('runStats', () => {

js/sdk/src/util/runStats.ts

@@ -6,7 +6,7 @@
  */
 import { none, Option, some } from 'fp-ts/lib/Option'
 import * as t from 'io-ts'
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 
 // Copypasta to avoid weird circular dependency issues
 const lookup = <V>(m: { [k: string]: V }, k: string): V | undefined => m[k]

js/sdk/src/v1/multiplexedWebsocket.ts

@@ -7,7 +7,7 @@
 
 /* eslint-disable @typescript-eslint/no-explicit-any */
 import * as t from 'io-ts'
-import { Observable, Observer, Subscription } from 'rxjs'
+import { Observable, Observer, Subscription } from '../../node_modules/rxjs'
 import log from '../internal_common/log'
 import { WsStoreConfig } from '../internal_common/types'
 import { WebSocketWrapper } from '../internal_common/webSocketWrapper'

js/sdk/src/v1/websocketEventStore.ts

@@ -11,7 +11,7 @@
  * Copyright (C) 2020 Actyx AG
  */
 import * as t from 'io-ts'
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import {
   DoPersistEvents,
   DoQuery,

js/sdk/src/v2/multiplexedWebsocket.spec.ts

@@ -9,7 +9,7 @@
 
 import { fromNullable } from 'fp-ts/lib/Option'
 import { range, takeWhile } from 'ramda'
-import { Observable } from 'rxjs'
+import { Observable } from '../../node_modules/rxjs'
 import { OffsetsResponse } from '../internal_common/types'
 import { validateOrThrow } from '../util'
 import {

js/sdk/src/v2/multiplexedWebsocket.ts

@@ -7,7 +7,7 @@
 
 /* eslint-disable @typescript-eslint/no-explicit-any */
 import * as t from 'io-ts'
-import { Observable, Observer, Subscription } from 'rxjs'
+import { Observable, Observer, Subscription } from '../../node_modules/rxjs'
 import log from '../internal_common/log'
 import { WsStoreConfig } from '../internal_common/types'
 import { WebSocketWrapper } from '../internal_common/webSocketWrapper'