mirror of
https://github.com/pezkuwichain/pezkuwi-api.git
synced 2026-04-22 11:27:57 +00:00
chore: update to version 16.5.9, align with pezkuwichain brand and fix tests
This commit is contained in:
@@ -46,7 +46,7 @@ function createChildKey (info: AllInfo): string {
|
||||
*/
|
||||
export function childKey (instanceId: string, api: DeriveApi): (paraId: string | number | BN) => Observable<string | null> {
|
||||
return memo(instanceId, (paraId: string | number | BN): Observable<string | null> =>
|
||||
api.query.crowdloan.funds<Option<PezkuwiRuntimeCommonCrowdloanFundInfo>>(paraId).pipe(
|
||||
api.query['crowdloan']['funds']<Option<PezkuwiRuntimeCommonCrowdloanFundInfo>>(paraId).pipe(
|
||||
map((optInfo) =>
|
||||
optInfo.isSome
|
||||
? createChildKey(optInfo.unwrap())
|
||||
|
||||
@@ -3,4 +3,4 @@
|
||||
|
||||
// Do not edit, auto-generated by @pezkuwi/dev
|
||||
|
||||
export const packageInfo = { name: '@pezkuwi/api-derive', path: 'auto', type: 'auto', version: '16.5.4' };
|
||||
export const packageInfo = { name: '@pezkuwi/api-derive', path: 'auto', type: 'auto', version: '16.5.9' };
|
||||
|
||||
@@ -90,14 +90,14 @@ function parse (id: ParaId, [active, retryQueue, selectedThreads, didUpdate, inf
|
||||
*/
|
||||
export function info (instanceId: string, api: DeriveApi): (id: ParaId | number) => Observable<DeriveTeyrchainFull | null> {
|
||||
return memo(instanceId, (id: ParaId | number): Observable<DeriveTeyrchainFull | null> =>
|
||||
api.query.registrar && api.query['teyrchains']
|
||||
api.query['registrar'] && api.query['teyrchains']
|
||||
? api.queryMulti<Result>([
|
||||
api.query.registrar['active'],
|
||||
api.query.registrar['retryQueue'],
|
||||
api.query.registrar['selectedThreads'],
|
||||
api.query['registrar']['active'],
|
||||
api.query['registrar']['retryQueue'],
|
||||
api.query['registrar']['selectedThreads'],
|
||||
api.query['teyrchains']['didUpdate'],
|
||||
[api.query.registrar.paras, id],
|
||||
[api.query.registrar.pendingSwap, id],
|
||||
[api.query['registrar']['paras'], id],
|
||||
[api.query['registrar']['pendingSwap'], id],
|
||||
[api.query['teyrchains']['heads'], id],
|
||||
[api.query['teyrchains']['relayDispatchQueue'], id]
|
||||
])
|
||||
|
||||
@@ -45,15 +45,15 @@ function parse ([ids, didUpdate, relayDispatchQueueSizes, infos, pendingSwaps]:
|
||||
*/
|
||||
export function overview (instanceId: string, api: DeriveApi): () => Observable<DeriveTeyrchain[]> {
|
||||
return memo(instanceId, (): Observable<DeriveTeyrchain[]> =>
|
||||
api.query.registrar?.['teyrchains'] && api.query['teyrchains']
|
||||
? api.query.registrar['teyrchains']<ParaId[]>().pipe(
|
||||
api.query['registrar']?.['teyrchains'] && api.query['teyrchains']
|
||||
? api.query['registrar']['teyrchains']<ParaId[]>().pipe(
|
||||
switchMap((paraIds) =>
|
||||
combineLatest([
|
||||
of(paraIds),
|
||||
api.query['teyrchains']['didUpdate']<DidUpdate>(),
|
||||
api.query['teyrchains']['relayDispatchQueueSize'].multi<RelayDispatchQueueSize>(paraIds),
|
||||
api.query.registrar.paras.multi<ParaInfoResult>(paraIds),
|
||||
api.query.registrar.pendingSwap.multi<PendingSwap>(paraIds)
|
||||
api.query['registrar']['paras'].multi<ParaInfoResult>(paraIds),
|
||||
api.query['registrar']['pendingSwap'].multi<PendingSwap>(paraIds)
|
||||
])
|
||||
),
|
||||
map(parse)
|
||||
|
||||
Reference in New Issue
Block a user