Move api-derive to correct location (#4343)

* Move api-derive to correct location * Adjust (linting ok) * No composite * ApiDerive split * Adjust * Still WIP, getting closer * It lints * derive build issues sorted * It builds :) * Add system_health to mock * api-augment usage * Cleanups * Adjust paths * linting * Some <'s * Revert <>'s * linting * ordering * Augmentation tweaks * yarn.lock * export
2021-12-18 09:18:55 +02:00
parent 7b8a6e89d9
commit 4913cf65fd
178 changed files with 720 additions and 685 deletions
@@ -0,0 +1,4 @@
+// Copyright 2017-2021 @polkadot/api-derive authors & contributors
+// SPDX-License-Identifier: Apache-2.0
+
+export * from './receivedHeartbeats';
@@ -0,0 +1,58 @@
+// Copyright 2017-2021 @polkadot/api-derive authors & contributors
+// SPDX-License-Identifier: Apache-2.0
+
+import type { Observable } from 'rxjs';
+import type { Option, u32, WrapperOpaque } from '@polkadot/types';
+import type { AccountId } from '@polkadot/types/interfaces';
+import type { PalletImOnlineBoundedOpaqueNetworkState } from '@polkadot/types/lookup';
+import type { DeriveApi, DeriveHeartbeats } from '../types';
+
+import { combineLatest, map, of, switchMap } from 'rxjs';
+
+import { BN_ZERO } from '@polkadot/util';
+
+import { memo } from '../util';
+
+type HeartbeatsOpt = Option<WrapperOpaque<PalletImOnlineBoundedOpaqueNetworkState>>;
+
+function mapResult ([result, validators, heartbeats, numBlocks]: [DeriveHeartbeats, AccountId[], HeartbeatsOpt[], u32[]]): DeriveHeartbeats {
+  validators.forEach((validator, index): void => {
+    const validatorId = validator.toString();
+    const blockCount = numBlocks[index];
+    const hasMessage = !heartbeats[index].isEmpty;
+    const prev = result[validatorId];
+
+    if (!prev || prev.hasMessage !== hasMessage || !prev.blockCount.eq(blockCount)) {
+      result[validatorId] = {
+        blockCount,
+        hasMessage,
+        isOnline: hasMessage || blockCount.gt(BN_ZERO)
+      };
+    }
+  });
+
+  return result;
+}
+
+/**
+ * @description Return a boolean array indicating whether the passed accounts had received heartbeats in the current session
+ */
+export function receivedHeartbeats (instanceId: string, api: DeriveApi): () => Observable<DeriveHeartbeats> {
+  return memo(instanceId, (): Observable<DeriveHeartbeats> =>
+    api.query.imOnline?.receivedHeartbeats
+      ? api.derive.staking.overview().pipe(
+        switchMap(({ currentIndex, validators }): Observable<[DeriveHeartbeats, AccountId[], HeartbeatsOpt[], u32[]]> =>
+          combineLatest([
+            of({}),
+            of(validators),
+            api.query.imOnline.receivedHeartbeats.multi(
+              validators.map((_address, index) => [currentIndex, index])),
+            api.query.imOnline.authoredBlocks.multi(
+              validators.map((address) => [currentIndex, address]))
+          ])
+        ),
+        map(mapResult)
+      )
+      : of({})
+  );
+}