api, api-{augment, base, contract, derive}, rpc-{augment, core, provider}, types, types-{augment, codec, create, known} 10.3.4

Author: github-actions[bot]

CHANGELOG.md

@@ -2,6 +2,7 @@
 
 ## master
 
+- api, api-{augment, base, contract, derive}, rpc-{augment, core, provider}, types, types-{augment, codec, create, known} 10.3.4
 - api, api-{augment, base, contract, derive}, rpc-{augment, core, provider}, types, types-{augment, codec, create, known} 10.3.3
 
 ## 0.2.35 Apr 10, 2023

api-augment/packageInfo.ts

@@ -1,3 +1,3 @@
 
 
-export const packageInfo = { name: '@polkadot/api-augment', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.3' };
+export const packageInfo = { name: '@polkadot/api-augment', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.4' };

api-base/packageInfo.ts

@@ -1,3 +1,3 @@
 
 
-export const packageInfo = { name: '@polkadot/api-base', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.3' };
+export const packageInfo = { name: '@polkadot/api-base', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.4' };

api-contract/packageInfo.ts

@@ -1,3 +1,3 @@
 
 
-export const packageInfo = { name: '@polkadot/api-contract', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.3' };
+export const packageInfo = { name: '@polkadot/api-contract', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.4' };

api-derive/chain/getBlock.ts

@@ -32,7 +32,7 @@ export function getBlock (instanceId: string, api: DeriveApi): (hash: Uint8Array
         combineLatest([
           of(signedBlock),
           queryAt.system.events(),
-          getAuthorDetails(signedBlock.block.header, queryAt)
+          getAuthorDetails(api, signedBlock.block.header, blockHash)
         ])
       ),
       map(([signedBlock, events, [, validators, author]]) =>

api-derive/chain/getHeader.ts

@@ -3,7 +3,7 @@ import type { Observable } from 'https://esm.sh/rxjs@7.8.0';
 import type { HeaderExtended } from '../type/types.ts';
 import type { DeriveApi } from '../types.ts';
 
-import { combineLatest, map, switchMap } from 'https://esm.sh/rxjs@7.8.0';
+import { map, switchMap } from 'https://esm.sh/rxjs@7.8.0';
 
 import { createHeaderExtended } from '../type/index.ts';
 import { memo } from '../util/index.ts';
@@ -25,12 +25,9 @@ import { getAuthorDetails } from './util.ts';
  */
 export function getHeader (instanceId: string, api: DeriveApi): (blockHash: Uint8Array | string) => Observable<HeaderExtended> {
   return memo(instanceId, (blockHash: Uint8Array | string): Observable<HeaderExtended> =>
-    combineLatest([
-      api.rpc.chain.getHeader(blockHash),
-      api.queryAt(blockHash)
-    ]).pipe(
-      switchMap(([header, queryAt]) =>
-        getAuthorDetails(header, queryAt)
+    api.rpc.chain.getHeader(blockHash).pipe(
+      switchMap((header) =>
+        getAuthorDetails(api, header, blockHash)
       ),
       map(([header, validators, author]) =>
         createHeaderExtended((validators || header).registry, header, validators, author)

api-derive/chain/subscribeNewHeads.ts

@@ -3,7 +3,7 @@ import type { Observable } from 'https://esm.sh/rxjs@7.8.0';
 import type { HeaderExtended } from '../type/types.ts';
 import type { DeriveApi } from '../types.ts';
 
-import { combineLatest, map, of, switchMap } from 'https://esm.sh/rxjs@7.8.0';
+import { map, switchMap } from 'https://esm.sh/rxjs@7.8.0';
 
 import { createHeaderExtended } from '../type/index.ts';
 import { memo } from '../util/index.ts';
@@ -26,13 +26,7 @@ export function subscribeNewHeads (instanceId: string, api: DeriveApi): () => Ob
   return memo(instanceId, (): Observable<HeaderExtended> =>
     api.rpc.chain.subscribeNewHeads().pipe(
       switchMap((header) =>
-        combineLatest([
-          of(header),
-          api.queryAt(header.hash)
-        ])
-      ),
-      switchMap(([header, queryAt]) =>
-        getAuthorDetails(header, queryAt)
+        getAuthorDetails(api, header)
       ),
       map(([header, validators, author]): HeaderExtended => {
         header.createdAtHash = header.hash;

api-derive/chain/util.ts

@@ -7,7 +7,7 @@ import type { SpCoreSr25519Public } from 'https://deno.land/x/polkadot/types/loo
 import type { Codec, IOption } from 'https://deno.land/x/polkadot/types/types/index.ts';
 import type { DeriveApi } from '../types.ts';
 
-import { combineLatest, map, mergeMap, of } from 'https://esm.sh/rxjs@7.8.0';
+import { combineLatest, map, mergeMap, of, switchMap } from 'https://esm.sh/rxjs@7.8.0';
 
 import { memo, unwrapBlockNumber } from '../util/index.ts';
 
@@ -22,7 +22,8 @@ export function createBlockNumberDerive <T extends { number: Compact<BlockNumber
     );
 }
 
-export function getAuthorDetails (header: Header, queryAt: QueryableStorage<'rxjs'>): Observable<[Header, Vec<AccountId> | null, AccountId | null]> {
+/** @internal */
+function getAuthorDetailsWithAt (header: Header, queryAt: QueryableStorage<'rxjs'>): Observable<[Header, Vec<AccountId> | null, AccountId | null]> {
   const validators = queryAt.session
     ? queryAt.session.validators()
     : of(null);
@@ -70,3 +71,22 @@ export function getAuthorDetails (header: Header, queryAt: QueryableStorage<'rxj
     of(null)
   ]);
 }
+
+export function getAuthorDetails (api: DeriveApi, header: Header, blockHash?: Uint8Array | string): Observable<[Header, Vec<AccountId> | null, AccountId | null]> {
+  // For on-chain state, we need to retrieve it as per the start
+  // of the block being constructed, i.e. session validators would
+  // be at the point of the block construction, not when all operations
+  // has been supplied.
+  //
+  // However for the first block (no parentHash available), we would
+  // just use the as-is
+  return api.queryAt(
+    header.parentHash.isEmpty
+      ? blockHash || header.hash
+      : header.parentHash
+  ).pipe(
+    switchMap((queryAt) =>
+      getAuthorDetailsWithAt(header, queryAt)
+    )
+  );
+}

api-derive/packageInfo.ts

@@ -1,3 +1,3 @@
 
 
-export const packageInfo = { name: '@polkadot/api-derive', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.3' };
+export const packageInfo = { name: '@polkadot/api-derive', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.4' };

api/packageInfo.ts

@@ -1,3 +1,3 @@
 
 
-export const packageInfo = { name: '@polkadot/api', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.3' };
+export const packageInfo = { name: '@polkadot/api', path: new URL(import.meta.url).pathname, type: 'deno', version: '10.3.4' };