[CI Skip] 1.16.1

skip-checks: true

CHANGELOG.md

@@ -1,3 +1,12 @@
+# 1.16.1 May 26, 2020
+
+- Support for Polkadot CC1 types & signed extensions
+- Add support for Babe VRF secondary digests (author extraction)
+- Adjust `Perbill/Permill` `toHuman()` formatting to output percentage
+- Support for latest Substrate types & metadata
+- Update to latest TypeScript, eslint & typescript-eslint
+- `@polkadot/util` 2.11
+
 # 1.15.1 May 23, 2020
 
 - Adjust `keyPrefix()` with DoubleMap args (Thanks to https://github.com/KiChjang)

docs/examples/promise/03_listen_to_balance_change/index.js

@@ -1,6 +1,7 @@
 /* eslint-disable header/header */
 /* eslint-disable @typescript-eslint/require-await */
 /* eslint-disable @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/no-floating-promises */
 
 // Import the API
 const { ApiPromise } = require('@polkadot/api');

docs/examples/promise/03_listen_to_multiple_balances_change/index.js

@@ -1,6 +1,7 @@
 /* eslint-disable header/header */
 /* eslint-disable @typescript-eslint/require-await */
 /* eslint-disable @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/no-floating-promises */
 
 // Import the API
 const { ApiPromise } = require('@polkadot/api');

docs/examples/promise/08_system_events/index.js

@@ -1,6 +1,7 @@
 /* eslint-disable header/header */
 /* eslint-disable @typescript-eslint/require-await */
 /* eslint-disable @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/no-floating-promises */
 
 // Import the API
 const { ApiPromise } = require('@polkadot/api');

docs/examples/promise/09_transfer_events/index.js

@@ -1,6 +1,7 @@
 /* eslint-disable header/header */
 /* eslint-disable @typescript-eslint/require-await */
 /* eslint-disable @typescript-eslint/no-var-requires */
+/* eslint-disable @typescript-eslint/no-floating-promises */
 
 // Import the API & Provider and some utility functions
 const { ApiPromise } = require('@polkadot/api');

docs/examples/promise/10_upgrade_chain/index.js

@@ -1,6 +1,7 @@
 /* eslint-disable header/header */
 /* eslint-disable @typescript-eslint/require-await */
 /* eslint-disable @typescript-eslint/unbound-method */
+/* eslint-disable @typescript-eslint/no-floating-promises */
 
 // Import the API & Provider and some utility functions
 const { ApiPromise, WsProvider } = require('@polkadot/api');

lerna.json

@@ -9,5 +9,5 @@
   "packages": [
     "packages/*"
   ],
-  "version": "1.15.1"
+  "version": "1.16.1"
 }

package.json

@@ -27,8 +27,8 @@
     "@babel/core": "^7.9.6",
     "@babel/register": "^7.9.0",
     "@babel/runtime": "^7.9.6",
-    "@polkadot/dev": "^0.53.5",
-    "@polkadot/ts": "^0.3.22",
+    "@polkadot/dev": "^0.54.1",
+    "@polkadot/ts": "^0.3.23",
     "@polkadot/typegen": "workspace:packages/typegen",
     "@types/jest": "^25.2.3",
     "@vuepress/plugin-search": "^1.5.0",

packages/api-contract/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/api-contract",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "Interfaces for interacting with contracts and contract ABIs",
   "main": "index.js",
   "keywords": [
@@ -27,10 +27,10 @@
   "homepage": "https://github.com/polkadot-js/api/tree/master/packages/api-contract#readme",
   "dependencies": {
     "@babel/runtime": "^7.9.6",
-    "@polkadot/api": "1.15.1",
-    "@polkadot/rpc-core": "1.15.1",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/util": "^2.10.1",
+    "@polkadot/api": "1.16.1",
+    "@polkadot/rpc-core": "1.16.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/util": "^2.11.1",
     "bn.js": "^5.1.2",
     "rxjs": "^6.5.5"
   }

packages/api-contract/src/ContractRegistry.ts

@@ -19,7 +19,7 @@ function parseSelector (registry: Registry, fnname: string, input: ContractABIMe
     return registry.createType('u32', hexToU8a(input));
   } else if (typeof input === 'string') {
     try {
-      const array = JSON.parse(input);
+      const array = JSON.parse(input) as unknown[];
 
       assert(array.length === 4, `${fnname}: Invalid selector length`);
 
@@ -108,7 +108,7 @@ export default class ContractRegistry extends MetaRegistry {
 
   public createMessage (name: string, message: Partial<ContractABIMessage> & ContractABIMessageBase): ContractABIFn {
     const args = message.args.map(({ name, type }): ContractABIFnArg => {
-      assert(isObject(type), `Invalid type at index ${type}`);
+      assert(isObject(type), `Invalid type at index ${type.toString()}`);
 
       return {
         name: stringCamelCase(name),
@@ -183,6 +183,7 @@ export default class ContractRegistry extends MetaRegistry {
   public convertMessage ({ args, name, return_type: returnType, ...message }: ContractABIMessagePre): ContractABIMessage {
     return {
       ...message,
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       args: this.convertArgs(args),
       name: this._stringAt(name),
       returnType: returnType ? this.convertType(returnType) : null
@@ -191,6 +192,7 @@ export default class ContractRegistry extends MetaRegistry {
 
   public convertEvent ({ args }: ContractABIEventPre): ContractABIEvent {
     return {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       args: this.convertArgs(args)
     };
   }

packages/api-contract/src/MetaRegistry.ts

@@ -7,11 +7,11 @@ import { MetaRegistryItem, MetaRegistryJson, MetaTypeDefClikeEnum, MetaType, Met
 import { assert } from '@polkadot/util';
 import { displayType, withTypeString } from '@polkadot/types';
 
-const builtinMap: [(id: any) => boolean, MetaTypeInfo][] = [
-  [(id: any): boolean => typeof id === 'string', MetaTypeInfo.BuiltinPlain],
-  [(id: any): boolean => Array.isArray(id), MetaTypeInfo.BuiltinTuple],
-  [(id: any): boolean => !!(id['array.type']), MetaTypeInfo.BuiltinVecFixed],
-  [(id: any): boolean => !!(id['slice.type']), MetaTypeInfo.BuiltinVec]
+const builtinMap: [(id: unknown | unknown[] | { 'array.type': unknown } | { 'slice.type': unknown }) => boolean, MetaTypeInfo][] = [
+  [(id: any) => typeof id === 'string', MetaTypeInfo.BuiltinPlain],
+  [(id: any) => Array.isArray(id), MetaTypeInfo.BuiltinTuple],
+  [(id: any) => !!((id as { 'array.type': unknown })['array.type']), MetaTypeInfo.BuiltinVecFixed],
+  [(id: any) => !!((id as { 'slice.type': unknown })['slice.type']), MetaTypeInfo.BuiltinVec]
 ];
 
 const typeMap: [string, MetaTypeInfo][] = [
@@ -25,8 +25,8 @@ function detectedType ({ def, id }: MetaType): MetaTypeInfo {
   assert(!(def as MetaTypeDefUnion)['union.fields'], 'Invalid union type definition found');
 
   const lookup = def === 'builtin'
-    ? builtinMap.find(([test]): boolean => test(id))
-    : typeMap.find(([test]): boolean => !!(def as any)[test]);
+    ? builtinMap.find(([test]) => test(id))
+    : typeMap.find(([test]) => !!(def as unknown as Record<string, unknown>)[test]);
 
   return lookup
     ? lookup[1]
@@ -59,7 +59,7 @@ class MetadataRegistryLookup {
     }
   }
 
-  protected _itemAt (index: number, variant: MetaRegistryItem): any {
+  protected _itemAt (index: number, variant: MetaRegistryItem): string | MetaType | TypeDef {
     assert(this._hasItemAt(index, variant), `MetaRegistry: Invalid ${variant} index ${index} found in metadata`);
 
     switch (variant) {
@@ -72,24 +72,24 @@ class MetadataRegistryLookup {
     }
   }
 
-  protected _itemsAt (indices: number[], variant: MetaRegistryItem): any[] {
-    return indices.map((index: number): string => this._itemAt(index, variant));
+  protected _itemsAt (indices: number[], variant: MetaRegistryItem): (string | MetaType | TypeDef)[] {
+    return indices.map((index: number) => this._itemAt(index, variant));
   }
 
   protected _stringAt (index: StringIndex): string {
-    return this._itemAt(index, MetaRegistryItem.String);
+    return this._itemAt(index, MetaRegistryItem.String) as string;
   }
 
   public stringsAt (indices: StringIndex[]): string[] {
-    return this._itemsAt(indices, MetaRegistryItem.String);
+    return this._itemsAt(indices, MetaRegistryItem.String) as string[];
   }
 
   public typeAt (index: TypeIndex): MetaType {
-    return this._itemAt(index, MetaRegistryItem.Type);
+    return this._itemAt(index, MetaRegistryItem.Type) as MetaType;
   }
 
   public typesAt (indices: TypeIndex[]): MetaType[] {
-    return this._itemsAt(indices, MetaRegistryItem.Type);
+    return this._itemsAt(indices, MetaRegistryItem.Type) as MetaType[];
   }
 
   public hasTypeDefAt (index: TypeIndex): boolean {
@@ -98,7 +98,7 @@ class MetadataRegistryLookup {
 
   public typeDefAt (index: TypeIndex, extra: Pick<TypeDef, never> = {}): TypeDef {
     return {
-      ...this._itemAt(index, MetaRegistryItem.TypeDef),
+      ...this._itemAt(index, MetaRegistryItem.TypeDef) as TypeDef,
       ...extra
     };
   }
@@ -136,7 +136,7 @@ export default class MetaRegistry extends MetadataRegistryLookup {
     };
   }
 
-  private _typeDefDefFields (metaType: MetaType, typeIndex?: TypeIndex): Pick<TypeDef, never> {
+  private _typeDefDefFields (metaType: MetaType, typeIndex: TypeIndex = -1): Pick<TypeDef, never> {
     let typeDef;
 
     switch (detectedType(metaType)) {
@@ -234,7 +234,7 @@ export default class MetaRegistry extends MetadataRegistryLookup {
     };
   }
 
-  private _typeDefForBuiltinVec (id: MetaTypeIdVec, typeIndex?: TypeIndex): Pick<TypeDef, never> {
+  private _typeDefForBuiltinVec (id: MetaTypeIdVec, typeIndex: TypeIndex = -1): Pick<TypeDef, never> {
     const { 'slice.type': vecTypeIndex } = id;
 
     assert(!typeIndex || vecTypeIndex !== typeIndex, `MetaRegistry: self-referencing registry type at index ${typeIndex}`);
@@ -250,7 +250,7 @@ export default class MetaRegistry extends MetadataRegistryLookup {
     };
   }
 
-  private _typeDefForBuiltinVecFixed (id: MetaTypeIdVecFixed, typeIndex?: TypeIndex): Pick<TypeDef, never> {
+  private _typeDefForBuiltinVecFixed (id: MetaTypeIdVecFixed, typeIndex: TypeIndex = -1): Pick<TypeDef, never> {
     const { 'array.len': vecLength, 'array.type': vecTypeIndex } = id;
 
     assert(!vecLength || vecLength <= 256, 'MetaRegistry: Only support for [Type; <length>], where length <= 256');
@@ -301,7 +301,7 @@ export default class MetaRegistry extends MetadataRegistryLookup {
     };
   }
 
-  public typeDefForOption (id: MetaTypeIdCustom, typeIndex?: TypeIndex): Pick<TypeDef, any> {
+  public typeDefForOption (id: MetaTypeIdCustom, typeIndex: TypeIndex = -1): Pick<TypeDef, any> {
     assert(id['custom.params'] && id['custom.params'][0], `Invalid Option type defined at index ${typeIndex}`);
 
     return {
@@ -310,7 +310,7 @@ export default class MetaRegistry extends MetadataRegistryLookup {
     };
   }
 
-  public typeDefForResult (id: MetaTypeIdCustom, typeIndex?: TypeIndex): Pick<TypeDef, any> {
+  public typeDefForResult (id: MetaTypeIdCustom, typeIndex: TypeIndex = -1): Pick<TypeDef, any> {
     assert(id['custom.params'] && id['custom.params'][0] && id['custom.params'][1], `Invalid Result type defined at index ${typeIndex}`);
 
     return {

packages/api-contract/src/base/Blueprint.ts

@@ -47,6 +47,7 @@ export default class Blueprint<ApiType extends ApiTypes> extends BaseWithTx<ApiT
     assert(!!this.abi.constructors[constructorIndex], `Specified constructor index ${constructorIndex} does not exist`);
 
     return {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       signAndSend: this.decorateMethod(
         (account: IKeyringPair | string | AccountId | Address): BlueprintCreateResultSubscription<ApiType> => {
           return this._apiContracts

packages/api-contract/src/base/Code.ts

@@ -19,7 +19,6 @@ import { BaseWithTx } from './util';
 
 type CodePutCodeResultSubscription<ApiType extends ApiTypes> = Observable<CodePutCodeResult<ApiType>>;
 
-// eslint-disable-next-line @typescript-eslint/interface-name-prefix
 export interface CodePutCode<ApiType extends ApiTypes> {
   signAndSend (account: IKeyringPair | string | AccountId | Address): CodePutCodeResultSubscription<ApiType>;
 }
@@ -46,6 +45,7 @@ export default class Code<ApiType extends ApiTypes> extends BaseWithTx<ApiType>
 
   public createBlueprint = (maxGas: number | BN): CodePutCode<ApiType> => {
     return {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       signAndSend: this.decorateMethod(
         (account: IKeyringPair | string | AccountId | Address): CodePutCodeResultSubscription<ApiType> =>
           this._apiContracts

packages/api-contract/src/base/Contract.ts

@@ -21,7 +21,6 @@ type ContractCallResultSubscription<ApiType extends ApiTypes, CallType extends C
   ? Observable<ContractCallResult<CallType>>
   : Promise<ObsInnerType<ContractCallResult<CallType>>>;
 
-// eslint-disable-next-line @typescript-eslint/interface-name-prefix
 export interface ContractCall<ApiType extends ApiTypes, CallType extends ContractCallTypes> {
   send (account: IKeyringPair | string | AccountId | Address): ContractCallResultSubscription<ApiType, CallType>;
 }
@@ -45,6 +44,7 @@ export default class Contract<ApiType extends ApiTypes> extends BaseWithTxAndRpc
     const { def, fn } = this.getMessage(message);
 
     return {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       send: this.decorateMethod(
         as === 'rpc' && this.hasRpcContractsCall
           ? (account: IKeyringPair | string | AccountId | Address): ContractCallResult<'rpc'> =>

packages/api-contract/src/base/util.ts

@@ -46,7 +46,7 @@ export abstract class Base<ApiType extends ApiTypes> implements ContractBase<Api
       : 0;
     const def = this.abi.abi.contract.messages[index];
 
-    assert(!!def, `Attempted to access a contract message that does not exist: ${typeof nameOrIndex === 'number' ? `index ${nameOrIndex}` : nameOrIndex}`);
+    assert(!!def, `Attempted to access a contract message that does not exist: ${typeof nameOrIndex === 'number' ? `index ${nameOrIndex}` : (nameOrIndex || 'unknown')}`);
 
     const fn = this.abi.messages[def.name] || this.abi.messages[stringCamelCase(def.name)];
 

packages/api-contract/src/types.ts

@@ -23,6 +23,7 @@ export interface ContractBase<ApiType extends ApiTypes> {
 
 export interface ContractABITypePre {
   ty: TypeIndex;
+  // eslint-disable-next-line camelcase
   display_name: StringIndex[];
 }
 
@@ -56,6 +57,7 @@ export interface ContractABIMessageCommon {
 
 export interface ContractABIMessagePre extends ContractABIMessageCommon, ContractABIMessageBasePre {
   name: StringIndex;
+  // eslint-disable-next-line camelcase
   return_type: ContractABITypePre | null;
 }
 
@@ -187,6 +189,7 @@ export interface InterfaceAbi {
 }
 
 export interface InterfaceContractCalls {
+  // eslint-disable-next-line @typescript-eslint/ban-types
   [index: string]: Function;
 }
 

packages/api-derive/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/api-derive",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "Common functions used across Polkadot, derived from RPC calls and storage queries.",
   "main": "index.js",
   "keywords": [
@@ -28,17 +28,17 @@
   "homepage": "https://github.com/polkadot-js/api/tree/master/packages/api-derive#readme",
   "dependencies": {
     "@babel/runtime": "^7.9.6",
-    "@polkadot/api": "1.15.1",
-    "@polkadot/rpc-core": "1.15.1",
-    "@polkadot/rpc-provider": "1.15.1",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/util": "^2.10.1",
-    "@polkadot/util-crypto": "^2.10.1",
+    "@polkadot/api": "1.16.1",
+    "@polkadot/rpc-core": "1.16.1",
+    "@polkadot/rpc-provider": "1.16.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/util": "^2.11.1",
+    "@polkadot/util-crypto": "^2.11.1",
     "bn.js": "^5.1.2",
     "memoizee": "^0.4.14",
     "rxjs": "^6.5.5"
   },
   "devDependencies": {
-    "@polkadot/keyring": "^2.10.1"
+    "@polkadot/keyring": "^2.11.1"
   }
 }

packages/api-derive/src/democracy/referendumIds.ts

@@ -20,6 +20,7 @@ export function referendumIds (api: ApiInterfaceRx): () => Observable<BN[]> {
       ]).pipe(
         map(([first, total]): BN[] =>
           total.gt(first)
+            // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
             ? [...Array(total.sub(first).toNumber())].map((_, i): BN => first.addn(i))
             : []
         )

packages/api-derive/src/index.spec.ts

@@ -2,6 +2,10 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
+/* eslint-disable @typescript-eslint/no-unsafe-return */
+/* eslint-disable @typescript-eslint/no-unsafe-call */
+/* eslint-disable @typescript-eslint/restrict-template-expressions */
+
 import { Observable, from } from 'rxjs';
 import ApiRx from '@polkadot/api/rx/Api';
 import MockProvider from '@polkadot/rpc-provider/mock';
@@ -33,7 +37,7 @@ describe('derive', (): void => {
     const api = new ApiRx({ provider: new MockProvider(registry), registry });
 
     beforeAll((done): void => {
-      api.isReady.subscribe((): void => done());
+      api.isReady.subscribe(() => done());
     });
 
     testFunction(api)('accounts', 'idAndIndex', []);

packages/api-derive/src/index.ts

@@ -76,9 +76,11 @@ function injectFunctions<AllSections> (api: ApiInterfaceRx, allSections: AllSect
         .reduce((sectionAcc, _methodName): DeriveSection<typeof section> => {
           const methodName = _methodName as keyof typeof section;
           // Not sure what to do here, casting as any. Though the final types are good
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-call
           const method = (section[methodName] as any)(api);
 
           // idem
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-member-access
           (sectionAcc as any)[methodName] = method;
 
           return sectionAcc;

packages/api-derive/src/staking/erasExposure.ts

@@ -38,7 +38,7 @@ function mapStakers (era: EraIndex, stakers: KeysAndExposures): DeriveEraExposur
 
 export function _eraExposure (api: ApiInterfaceRx): (era: EraIndex, withActive: boolean) => Observable<DeriveEraExposure> {
   return memo((era: EraIndex, withActive: boolean): Observable<DeriveEraExposure> => {
-    const cacheKey = `${CACHE_KEY}-${era}`;
+    const cacheKey = `${CACHE_KEY}-${era.toString()}`;
     const cached = withActive
       ? undefined
       : deriveCache.get<DeriveEraExposure>(cacheKey);

packages/api-derive/src/staking/erasPoints.ts

@@ -40,7 +40,7 @@ export function _erasPoints (api: ApiInterfaceRx): (eras: EraIndex[], withActive
     const cached: DeriveEraPoints[] = withActive
       ? []
       : eras
-        .map((era) => deriveCache.get(`${CACHE_KEY}-${era}`))
+        .map((era) => deriveCache.get<DeriveEraPoints>(`${CACHE_KEY}-${era.toString()}`))
         .filter((value): value is DeriveEraPoints => !!value);
     const remaining = eras.filter((era) => !cached.some((cached) => era.eq(cached.era)));
 
@@ -50,7 +50,7 @@ export function _erasPoints (api: ApiInterfaceRx): (eras: EraIndex[], withActive
         map((points): DeriveEraPoints[] => {
           const query = mapPoints(remaining, points);
 
-          !withActive && query.forEach((q) => deriveCache.set(`${CACHE_KEY}-${q.era}`, q));
+          !withActive && query.forEach((q) => deriveCache.set(`${CACHE_KEY}-${q.era.toString()}`, q));
 
           return eras.map((era): DeriveEraPoints =>
             cached.find((cached) => era.eq(cached.era)) ||

packages/api-derive/src/staking/erasPrefs.ts

@@ -26,7 +26,7 @@ function mapPrefs (era: EraIndex, all: [StorageKey, ValidatorPrefs][]): DeriveEr
 
 export function _eraPrefs (api: ApiInterfaceRx): (era: EraIndex, withActive: boolean) => Observable<DeriveEraPrefs> {
   return memo((era: EraIndex, withActive: boolean): Observable<DeriveEraPrefs> => {
-    const cacheKey = `${CACHE_KEY}-${era}`;
+    const cacheKey = `${CACHE_KEY}-${era.toString()}`;
     const cached = withActive
       ? undefined
       : deriveCache.get<DeriveEraPrefs>(cacheKey);

packages/api-derive/src/staking/erasRewards.ts

@@ -30,7 +30,7 @@ export function _erasRewards (api: ApiInterfaceRx): (eras: EraIndex[], withActiv
     const cached: DeriveEraRewards[] = withActive
       ? []
       : eras
-        .map((era) => deriveCache.get(`${CACHE_KEY}-${era}`))
+        .map((era) => deriveCache.get<DeriveEraRewards>(`${CACHE_KEY}-${era.toString()}`))
         .filter((value): value is DeriveEraRewards => !!value);
     const remaining = eras.filter((era) => !cached.some((cached) => era.eq(cached.era)));
 
@@ -42,7 +42,7 @@ export function _erasRewards (api: ApiInterfaceRx): (eras: EraIndex[], withActiv
       map((optRewards) => {
         const query = mapRewards(remaining, optRewards);
 
-        !withActive && query.forEach((q) => deriveCache.set(`${CACHE_KEY}-${q.era}`, q));
+        !withActive && query.forEach((q) => deriveCache.set(`${CACHE_KEY}-${q.era.toString()}`, q));
 
         return eras.map((era): DeriveEraRewards =>
           cached.find((cached) => era.eq(cached.era)) ||

packages/api-derive/src/staking/erasSlashes.ts

@@ -32,7 +32,7 @@ function mapSlashes (era: EraIndex, noms: [StorageKey, Option<BalanceOf>][], val
 
 export function _eraSlashes (api: ApiInterfaceRx): (era: EraIndex, withActive: boolean) => Observable<DeriveEraSlashes> {
   return memo((era: EraIndex, withActive: boolean): Observable<DeriveEraSlashes> => {
-    const cacheKey = `${CACHE_KEY}-${era}`;
+    const cacheKey = `${CACHE_KEY}-${era.toString()}`;
     const cached = withActive
       ? undefined
       : deriveCache.get<DeriveEraSlashes>(cacheKey);

packages/api-derive/src/type/HeaderExtended.ts

@@ -9,7 +9,7 @@ import runtimeTypes from '@polkadot/types/interfaces/runtime/definitions';
 import { Struct } from '@polkadot/types';
 
 // We can ignore the properties, added via Struct.with
-const _Header: Constructor<Header> = Struct.with(runtimeTypes.types.Header as any) as any;
+const _Header = Struct.with(runtimeTypes.types.Header as any) as Constructor<Header>;
 
 /**
  * @name HeaderExtended

packages/api-derive/src/util/cache.ts

@@ -32,7 +32,7 @@ function wrapCache (keyStart: string, cache: DeriveCache): DeriveCache {
 
       return undefined;
     },
-    set: (partial: string, v: any): void => {
+    set: (partial: string, v: unknown): void => {
       cache.set(`${keyStart}${partial}`, { v, x: Date.now() });
     }
   };

packages/api-derive/src/util/cacheImpl.ts

@@ -4,7 +4,7 @@
 
 import { DeriveCache } from './types';
 
-const mapCache: Map<string, any> = new Map();
+const mapCache = new Map<string, any>();
 
 const deriveMapCache: DeriveCache = {
   del: (key: string): void => {
@@ -18,7 +18,7 @@ const deriveMapCache: DeriveCache = {
     }
   },
   get: <T = any> (key: string): T | undefined => {
-    return mapCache.get(key);
+    return mapCache.get(key) as T;
   },
   set: (key: string, value: any): void => {
     mapCache.set(key, value);
@@ -29,7 +29,7 @@ const deriveNoopCache: DeriveCache = {
   del: (): void => undefined,
   forEach: () => undefined,
   get: (): undefined => undefined,
-  set: (_: string, value: any): any => value
+  set: (_: string, value: unknown): unknown => value
 };
 
 export { deriveMapCache, deriveNoopCache };

packages/api/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/api",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "Promise and RxJS wrappers around the Polkadot JS RPC",
   "main": "index.js",
   "keywords": [
@@ -27,20 +27,20 @@
   "homepage": "https://github.com/polkadot-js/api/tree/master/packages/api#readme",
   "dependencies": {
     "@babel/runtime": "^7.9.6",
-    "@polkadot/api-derive": "1.15.1",
-    "@polkadot/keyring": "^2.10.1",
-    "@polkadot/metadata": "1.15.1",
-    "@polkadot/rpc-core": "1.15.1",
-    "@polkadot/rpc-provider": "1.15.1",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/types-known": "1.15.1",
-    "@polkadot/util": "^2.10.1",
-    "@polkadot/util-crypto": "^2.10.1",
+    "@polkadot/api-derive": "1.16.1",
+    "@polkadot/keyring": "^2.11.1",
+    "@polkadot/metadata": "1.16.1",
+    "@polkadot/rpc-core": "1.16.1",
+    "@polkadot/rpc-provider": "1.16.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/types-known": "1.16.1",
+    "@polkadot/util": "^2.11.1",
+    "@polkadot/util-crypto": "^2.11.1",
     "bn.js": "^5.1.2",
     "eventemitter3": "^4.0.4",
     "rxjs": "^6.5.5"
   },
   "devDependencies": {
-    "@polkadot/keyring": "^2.10.1"
+    "@polkadot/keyring": "^2.11.1"
   }
 }

packages/api/src/augment/tx.ts

@@ -16,7 +16,7 @@ import { AccountId, AccountIndex, Address, Balance, BalanceOf, BlockNumber, Call
 import { Period, Priority } from '@polkadot/types/interfaces/scheduler';
 import { Keys } from '@polkadot/types/interfaces/session';
 import { SocietyJudgement } from '@polkadot/types/interfaces/society';
-import { CompactAssignments, EraIndex, PhragmenScore, RewardDestination, ValidatorIndex, ValidatorPrefs } from '@polkadot/types/interfaces/staking';
+import { CompactAssignments, ElectionSize, EraIndex, PhragmenScore, RewardDestination, ValidatorIndex, ValidatorPrefs } from '@polkadot/types/interfaces/staking';
 import { Key } from '@polkadot/types/interfaces/system';
 import { Timepoint } from '@polkadot/types/interfaces/utility';
 import { VestingInfo } from '@polkadot/types/interfaces/vesting';
@@ -2363,45 +2363,22 @@ declare module '@polkadot/api/types/submittable' {
        * minimized (to ensure less variance)
        * 
        * # <weight>
-       * E: number of edges. m: size of winner committee. n: number of nominators. d: edge degree
-       * (16 for now) v: number of on-chain validator candidates.
-       * 
-       * NOTE: given a solution which is reduced, we can enable a new check the ensure `|E| < n +
-       * m`. We don't do this _yet_, but our offchain worker code executes it nonetheless.
-       * 
-       * major steps (all done in `check_and_replace_solution`):
-       * 
-       * - Storage: O(1) read `ElectionStatus`.
-       * - Storage: O(1) read `PhragmenScore`.
-       * - Storage: O(1) read `ValidatorCount`.
-       * - Storage: O(1) length read from `SnapshotValidators`.
-       * 
-       * - Storage: O(v) reads of `AccountId` to fetch `snapshot_validators`.
-       * - Memory: O(m) iterations to map winner index to validator id.
-       * - Storage: O(n) reads `AccountId` to fetch `snapshot_nominators`.
-       * - Memory: O(n + m) reads to map index to `AccountId` for un-compact.
-       * 
-       * - Storage: O(e) accountid reads from `Nomination` to read correct nominations.
-       * - Storage: O(e) calls into `slashable_balance_of_vote_weight` to convert ratio to staked.
-       * 
-       * - Memory: build_support_map. O(e).
-       * - Memory: evaluate_support: O(E).
-       * 
-       * - Storage: O(e) writes to `QueuedElected`.
-       * - Storage: O(1) write to `QueuedScore`
-       * 
-       * The weight of this call is 1/10th of the blocks total weight.
+       * See `crate::weight` module.
        * # </weight>
        **/
-      submitElectionSolution: AugmentedSubmittable<(winners: Vec<ValidatorIndex> | (ValidatorIndex | AnyNumber | Uint8Array)[], compactAssignments: CompactAssignments | { votes1?: any; votes2?: any; votes3?: any; votes4?: any; votes5?: any; votes6?: any; votes7?: any; votes8?: any; votes9?: any; votes10?: any; votes11?: any; votes12?: any; votes13?: any; votes14?: any; votes15?: any; votes16?: any } | string | Uint8Array, score: PhragmenScore, era: EraIndex | AnyNumber | Uint8Array) => SubmittableExtrinsic<ApiType>>;
+      submitElectionSolution: AugmentedSubmittable<(winners: Vec<ValidatorIndex> | (ValidatorIndex | AnyNumber | Uint8Array)[], compact: CompactAssignments | { votes1?: any; votes2?: any; votes3?: any; votes4?: any; votes5?: any; votes6?: any; votes7?: any; votes8?: any; votes9?: any; votes10?: any; votes11?: any; votes12?: any; votes13?: any; votes14?: any; votes15?: any; votes16?: any } | string | Uint8Array, score: PhragmenScore, era: EraIndex | AnyNumber | Uint8Array, size: ElectionSize | { validators?: any; nominators?: any } | string | Uint8Array) => SubmittableExtrinsic<ApiType>>;
       /**
        * Unsigned version of `submit_election_solution`.
        * 
        * Note that this must pass the [`ValidateUnsigned`] check which only allows transactions
        * from the local node to be included. In other words, only the block author can include a
        * transaction in the block.
+       * 
+       * # <weight>
+       * See `crate::weight` module.
+       * # </weight>
        **/
-      submitElectionSolutionUnsigned: AugmentedSubmittable<(winners: Vec<ValidatorIndex> | (ValidatorIndex | AnyNumber | Uint8Array)[], compactAssignments: CompactAssignments | { votes1?: any; votes2?: any; votes3?: any; votes4?: any; votes5?: any; votes6?: any; votes7?: any; votes8?: any; votes9?: any; votes10?: any; votes11?: any; votes12?: any; votes13?: any; votes14?: any; votes15?: any; votes16?: any } | string | Uint8Array, score: PhragmenScore, era: EraIndex | AnyNumber | Uint8Array) => SubmittableExtrinsic<ApiType>>;
+      submitElectionSolutionUnsigned: AugmentedSubmittable<(winners: Vec<ValidatorIndex> | (ValidatorIndex | AnyNumber | Uint8Array)[], compact: CompactAssignments | { votes1?: any; votes2?: any; votes3?: any; votes4?: any; votes5?: any; votes6?: any; votes7?: any; votes8?: any; votes9?: any; votes10?: any; votes11?: any; votes12?: any; votes13?: any; votes14?: any; votes15?: any; votes16?: any } | string | Uint8Array, score: PhragmenScore, era: EraIndex | AnyNumber | Uint8Array, size: ElectionSize | { validators?: any; nominators?: any } | string | Uint8Array) => SubmittableExtrinsic<ApiType>>;
       /**
        * Schedule a portion of the stash to be unlocked ready for transfer out after the bond
        * period ends. If this leaves an amount actively bonded less than

packages/api/src/base/Decorate.ts

@@ -31,7 +31,7 @@ import Events from './Events';
 
 interface MetaDecoration {
   callIndex?: Uint8Array;
-  meta: any;
+  meta: Record<string, unknown>;
   method: string;
   section: string;
   toJSON: () => any;
@@ -246,9 +246,9 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
       )
       // eslint-disable-next-line @typescript-eslint/no-unused-vars
       .forEach(([_, { method, section }]): void => {
-        delete (this._rpc as any)[section][method];
-        delete (this._rpcCore as any)[section][method];
-        delete (this._rx.rpc as any)[section][method];
+        delete (this._rpc as Record<string, Record<string, unknown>>)[section][method];
+        delete (this._rpcCore as unknown as Record<string, Record<string, unknown>>)[section][method];
+        delete (this._rx.rpc as Record<string, Record<string, unknown>>)[section][method];
       });
   }
 
@@ -257,11 +257,12 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
       const sectionName = _sectionName as keyof DecoratedRpc<ApiType, RpcInterface>;
 
       // out and section here are horrors to get right from a typing perspective :(
-      (out as any)[sectionName] = Object.entries(rpc[sectionName]).reduce((section, [methodName, method]): DecoratedRpcSection<ApiType, RpcInterface[typeof sectionName]> => {
+      (out as Record<string, unknown>)[sectionName] = Object.entries(rpc[sectionName]).reduce((section, [methodName, method]): DecoratedRpcSection<ApiType, RpcInterface[typeof sectionName]> => {
         //  skip subscriptions where we have a non-subscribe interface
         if (this.hasSubscriptions || !(methodName.startsWith('subscribe') || methodName.startsWith('unsubscribe'))) {
-          (section as any)[methodName] = decorateMethod(method, { methodName });
-          (section as any)[methodName].raw = decorateMethod(method.raw, { methodName });
+          (section as Record<string, unknown>)[methodName] = decorateMethod(method, { methodName }) as unknown;
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
+          (section as Record<string, { raw: unknown }>)[methodName].raw = decorateMethod(method.raw, { methodName }) as unknown;
         }
 
         return section;
@@ -272,10 +273,12 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
   }
 
   protected _decorateMulti<ApiType extends ApiTypes> (decorateMethod: DecorateMethod<ApiType>): QueryableStorageMulti<ApiType> {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-return
     return decorateMethod((calls: QueryableStorageMultiArg<ApiType>[]): Observable<Codec[]> =>
       this._rpcCore.state.subscribeStorage(
         calls.map((arg: QueryableStorageMultiArg<ApiType>): [QueryableStorageEntry<ApiType>, ...Arg[]] =>
           // the input is a QueryableStorageEntry, convert to StorageEntry
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-return
           Array.isArray(arg)
             ? [arg[0].creator, ...arg.slice(1)]
             : [arg.creator] as any)));
@@ -299,7 +302,8 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
     const decorated = (...params: Arg[]): SubmittableExtrinsic<ApiType> =>
       creator(method(...params));
 
-    return this._decorateFunctionMeta(method, decorated as any) as SubmittableExtrinsicFunction<ApiType>;
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-return
+    return this._decorateFunctionMeta(method as any, decorated as any) as unknown as SubmittableExtrinsicFunction<ApiType>;
   }
 
   protected _decorateStorage<ApiType extends ApiTypes> (storage: Storage, decorateMethod: DecorateMethod<ApiType>): QueryableStorage<ApiType> {
@@ -319,6 +323,7 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
     const getArgs = (...args: any[]): any[] => extractStorageArgs(creator, args);
 
     // FIXME We probably want to be able to query the full list with non-subs as well
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     const decorated = this.hasSubscriptions && creator.iterKey && creator.meta.type.isMap && creator.meta.type.asMap.linked.isTrue
       ? this._decorateStorageLinked(creator, decorateMethod)
       : decorateMethod((...args: any[]): Observable<Codec> => (
@@ -332,32 +337,41 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
           : this._rpcCore.state.getStorage(getArgs(...args))
       ), { methodName: creator.method });
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     decorated.creator = creator;
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
     decorated.at = decorateMethod((hash: Hash, arg1?: Arg, arg2?: Arg): Observable<Codec> =>
       this._rpcCore.state.getStorage(getArgs(arg1, arg2), hash));
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
     decorated.hash = decorateMethod((arg1?: Arg, arg2?: Arg): Observable<Hash> =>
       this._rpcCore.state.getStorageHash(getArgs(arg1, arg2)));
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     decorated.key = (arg1?: Arg, arg2?: Arg): string =>
       u8aToHex(compactStripLength(creator(creator.meta.type.isDoubleMap ? [arg1, arg2] : arg1))[1]);
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     decorated.keyPrefix = (key1?: Arg): string =>
       u8aToHex(creator.keyPrefix(key1));
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
     decorated.range = decorateMethod((range: [Hash, Hash?], arg1?: Arg, arg2?: Arg): Observable<[Hash, Codec][]> =>
       this._decorateStorageRange(decorated, [arg1, arg2], range));
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
     decorated.size = decorateMethod((arg1?: Arg, arg2?: Arg): Observable<u64> =>
       this._rpcCore.state.getStorageSize(getArgs(arg1, arg2)));
 
     // .keys() & .entries() only available on map types
     if (creator.iterKey && (creator.meta.type.isMap || creator.meta.type.isDoubleMap)) {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
       decorated.entries = decorateMethod(
         memo((doubleMapArg?: Arg): Observable<[StorageKey, Codec][]> =>
           this._retrieveMapEntries(creator, doubleMapArg)));
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
       decorated.keys = decorateMethod(
         memo((doubleMapArg?: Arg): Observable<StorageKey[]> =>
           this._retrieveMapKeys(creator, doubleMapArg)));
@@ -366,12 +380,13 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
     // only support multi where subs are available
     if (this.hasSubscriptions) {
       // When using double map storage function, user need to pass double map key as an array
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
       decorated.multi = decorateMethod((args: (Arg | Arg[])[]): Observable<Codec[]> =>
         this._rpcCore.state.subscribeStorage(
           args.map((arg: Arg[] | Arg): [StorageEntry, Arg | Arg[]] => [creator, arg])));
     }
 
-    return this._decorateFunctionMeta(creator, decorated) as unknown as QueryableStorageEntry<ApiType>;
+    return this._decorateFunctionMeta(creator as any, decorated) as unknown as QueryableStorageEntry<ApiType>;
   }
 
   private _decorateStorageRange<ApiType extends ApiTypes> (decorated: QueryableStorageEntry<ApiType>, args: [Arg?, Arg?], range: [Hash, Hash?]): Observable<[Hash, Codec][]> {
@@ -388,7 +403,7 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
   }
 
   private _decorateStorageLinked<ApiType extends ApiTypes> (creator: StorageEntry, decorateMethod: DecorateMethod<ApiType>): ReturnType<DecorateMethod<ApiType>> {
-    const result: Map<Codec, ITuple<[Codec, Linkage<Codec>]> | null> = new Map();
+    const result = new Map<Codec, ITuple<[Codec, Linkage<Codec>]> | null>();
     let subject: BehaviorSubject<LinkageResult>;
     let head: Codec | null = null;
     const iterKey = creator.iterKey;
@@ -451,9 +466,11 @@ export default abstract class Decorate<ApiType extends ApiTypes> extends Events
 
     // this handles the case where the head changes effectively, i.e. a new entry
     // appears at the top of the list, the new getNext gets kicked off
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-return
     return decorateMethod((...args: any[]): Observable<LinkageResult | [Codec, Linkage<Codec>]> =>
       args.length
         ? this._rpcCore.state
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
           .subscribeStorage<[[Codec, Linkage<Codec>]]>([[creator, ...args]])
           .pipe(map(([data]): [Codec, Linkage<Codec>] => data))
         : this._rpcCore.state

packages/api/src/base/Init.ts

@@ -62,6 +62,7 @@ export default abstract class Init<ApiType extends ApiTypes> extends Decorate<Ap
     // 'connected' event, then the `on('connected')` won't fire anymore. To
     // cater for this case, we call manually `this._onProviderConnect`.
     if (this._rpcCore.provider.isConnected()) {
+      // eslint-disable-next-line @typescript-eslint/no-floating-promises
       this.#onProviderConnect();
     }
   }
@@ -107,7 +108,7 @@ export default abstract class Init<ApiType extends ApiTypes> extends Decorate<Ap
     // manually build a list of all available methods in this RPC, we are
     // going to filter on it to align the cloned RPC without making a call
     Object.keys(source.rpc).forEach((section): void => {
-      Object.keys((source.rpc as any)[section]).forEach((method): void => {
+      Object.keys((source.rpc as Record<string, Record<string, unknown>>)[section]).forEach((method): void => {
         methods.push(`${section}_${method}`);
       });
     });
@@ -130,7 +131,7 @@ export default abstract class Init<ApiType extends ApiTypes> extends Decorate<Ap
           ? of(false)
           : this._rpcCore.state.getMetadata().pipe(
             map((metadata: Metadata): boolean => {
-              l.log(`Runtime version updated to ${version.specVersion}`);
+              l.log(`Runtime version updated to spec=${version.specVersion.toString()}, tx=${version.transactionVersion.toString()}`);
 
               this._runtimeMetadata = metadata;
               this._runtimeVersion = version;
@@ -167,7 +168,7 @@ export default abstract class Init<ApiType extends ApiTypes> extends Decorate<Ap
     await this._filterRpc();
 
     // retrieve metadata, either from chain  or as pass-in via options
-    const metadataKey = `${this._genesisHash}-${runtimeVersion.specVersion}`;
+    const metadataKey = `${this._genesisHash?.toHex() || '0x'}-${runtimeVersion.specVersion.toString()}`;
     const metadata = metadataKey in optMetadata
       ? new Metadata(this.registry, optMetadata[metadataKey])
       : await this._rpcCore.state.getMetadata().toPromise();
@@ -232,7 +233,7 @@ export default abstract class Init<ApiType extends ApiTypes> extends Decorate<Ap
         });
       }, KEEPALIVE_INTERVAL);
     } catch (_error) {
-      const error = new Error(`FATAL: Unable to initialize the API: ${_error.message}`);
+      const error = new Error(`FATAL: Unable to initialize the API: ${(_error as Error).message}`);
 
       l.error(error);
 

packages/api/src/base/index.ts

@@ -29,8 +29,8 @@ interface PkgJson {
 let pkgJson: PkgJson = { name: '@polkadot/api', version: '-' };
 
 import('../package.json')
-  .then((_pkgJson: any): void => {
-    pkgJson = _pkgJson;
+  .then((_pkgJson: unknown): void => {
+    pkgJson = _pkgJson as PkgJson;
   })
   .catch((): void => {
     // ignore

packages/api/src/checkTypes.manual.ts

@@ -87,7 +87,7 @@ async function query (api: ApiPromise, keyring: TestKeyringMap): Promise<void> {
   // check range types
   const entries = await api.query.system.events.range(['0x12345', '0x7890']);
 
-  console.log(`Received ${entries.length} entries, ${entries.map(([hash, events]) => `${hash.toHex()}: ${events.length} events`)}`);
+  console.log(`Received ${entries.length} entries, ${entries.map(([hash, events]) => `${hash.toHex()}: ${events.length} events`).join(', ')}`);
 }
 
 async function rpc (api: ApiPromise): Promise<void> {
@@ -105,6 +105,7 @@ async function rpc (api: ApiPromise): Promise<void> {
   await api.rpc.chain.getBlock.raw('0x123456');
 
   // using raw subs
+  // eslint-disable-next-line @typescript-eslint/no-floating-promises
   api.rpc.chain.subscribeNewHeads.raw((result: Uint8Array): void => {
     console.log(result);
   });
@@ -125,7 +126,7 @@ function types (api: ApiPromise): void {
 
 async function tx (api: ApiPromise, keyring: TestKeyringMap): Promise<void> {
   // transfer, also allows for BigInt inputs here
-  const transfer = api.tx.balances.transfer(keyring.bob.address, 123_456_789n);
+  const transfer = api.tx.balances.transfer(keyring.bob.address, 123456789n);
 
   console.log('transfer as Call', transfer as IMethod);
   console.log('transfer as Extrinsic', transfer as IExtrinsic);
@@ -161,6 +162,7 @@ async function tx (api: ApiPromise, keyring: TestKeyringMap): Promise<void> {
   // it allows for query & then using the submittable
   const second = api.tx.democracy.second(123, 5);
 
+  // eslint-disable-next-line @typescript-eslint/no-floating-promises
   second.signAndSend('123', (result): void => {
     console.log(result);
   });
@@ -173,12 +175,15 @@ async function main (): Promise<void> {
   const api = await ApiPromise.create();
   const keyring = testKeyring();
 
-  consts(api);
-  derive(api);
-  query(api, keyring);
-  rpc(api);
-  types(api);
-  tx(api, keyring);
+  // eslint-disable-next-line @typescript-eslint/no-floating-promises
+  Promise.all([
+    consts(api),
+    derive(api),
+    query(api, keyring),
+    rpc(api),
+    types(api),
+    tx(api, keyring)
+  ]);
 }
 
 // eslint-disable-next-line @typescript-eslint/unbound-method

packages/api/src/promise/Api.spec.ts

@@ -39,7 +39,7 @@ describe('ApiPromise', (): void => {
 
     const signer = new SingleAccountSigner(registry, aliceEd);
     const api = await ApiPromise.create({ provider, registry, signer });
-    const transfer = api.tx.balances.transfer(keyring.getPair('0xe659a7a1628cdd93febc04a4e0646ea20e9f5f0ce097d9a05290d4a9e054df4e').address, 321_564_789_876_512_345n);
+    const transfer = api.tx.balances.transfer(keyring.getPair('0xe659a7a1628cdd93febc04a4e0646ea20e9f5f0ce097d9a05290d4a9e054df4e').address, 321564789876512345n);
 
     return { api, transfer: await transfer.signAsync(aliceEd.address, {}) };
   }
@@ -57,8 +57,10 @@ describe('ApiPromise', (): void => {
       const metadata: any = {};
       const key = `${genesisHash}-${specVersion}`;
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
       metadata[key] = rpcData;
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       const api = await ApiPromise.create({ metadata, provider, registry } as ApiOptions);
 
       expect(api.genesisHash).toBeDefined();

packages/api/src/promise/Api.ts

@@ -25,6 +25,7 @@ function extractArgs (args: any[], needsCallback: boolean): [any[], Callback<Cod
   // If the last arg is a function, we pop it, put it into callback.
   // actualArgs will then hold the actual arguments to be passed to `method`
   if (args.length && isFunction(args[args.length - 1])) {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     callback = actualArgs.pop();
   }
 
@@ -38,6 +39,7 @@ function extractArgs (args: any[], needsCallback: boolean): [any[], Callback<Cod
 function promiseTracker (resolve: (value: () => void) => void, reject: (value: Error) => void): Tracker {
   let isCompleted = false;
 
+  // eslint-disable-next-line @typescript-eslint/ban-types
   const complete = (fn: Function, value: any): void => {
     if (!isCompleted) {
       isCompleted = true;
@@ -68,24 +70,22 @@ export function decorateMethod<Method extends AnyFunction> (method: Method, opti
     const [actualArgs, callback] = extractArgs(args, !!needsCallback);
 
     if (!callback) {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
       return method(...actualArgs).pipe(first()).toPromise() as Promise<ObsInnerType<ReturnType<Method>>>;
     }
 
     return new Promise((resolve, reject): void => {
       const tracker = promiseTracker(resolve, reject);
-      const subscription = method(...actualArgs)
-        .pipe(
-          // if we find an error (invalid params, etc), reject the promise
-          catchError((error): Observable<never> =>
-            tracker.reject(error)
-          ),
-          // upon the first result, resolve with the unsub function
-          tap((): void =>
-            tracker.resolve((): void => subscription.unsubscribe())
-          )
-        )
-        .subscribe(callback);
-    }) as any; // ???
+
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-assignment
+      const subscription: { unsubscribe: () => void } = method(...actualArgs).pipe(
+        // if we find an error (invalid params, etc), reject the promise
+        catchError((error): Observable<never> => tracker.reject(error)),
+        // upon the first result, resolve with the unsub function
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access,@typescript-eslint/no-unsafe-return
+        tap(() => tracker.resolve(() => subscription.unsubscribe()))
+      ).subscribe(callback);
+    }) as UnsubscribePromise;
   } as StorageEntryPromiseOverloads;
 }
 

packages/api/src/promise/Combinator.ts

@@ -41,6 +41,7 @@ export default class Combinator<T extends any[] = any[]> {
       this.#fns.push(fn);
 
       // Not quite 100% how to have a variable number at the front here
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-return,@typescript-eslint/ban-types
       return (fn as Function)(...args, this._createCallback(index));
     });
   }
@@ -54,7 +55,7 @@ export default class Combinator<T extends any[] = any[]> {
   }
 
   protected _createCallback (index: number): (value: any) => void {
-    return (value: any): void => {
+    return (value: unknown): void => {
       this.#fired[index] = true;
       this.#results[index] = value;
 
@@ -68,6 +69,7 @@ export default class Combinator<T extends any[] = any[]> {
     }
 
     try {
+      // eslint-disable-next-line @typescript-eslint/no-floating-promises
       this.#callback(this.#results as T);
     } catch (error) {
       // swallow, we don't want the handler to trip us up

packages/api/src/submittable/createClass.ts

@@ -41,6 +41,7 @@ export default function createClass <ApiType extends ApiTypes> ({ api, apiType,
       const [allOptions] = this.#makeSignAndSendOptions(options);
       const address = isKeyringPair(account) ? account.address : account.toString();
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-return,@typescript-eslint/no-unsafe-call
       return decorateMethod(
         (): Observable<RuntimeDispatchInfo> =>
           api.derive.tx.signingInfo(address, allOptions.nonce, allOptions.era).pipe(
@@ -70,6 +71,7 @@ export default function createClass <ApiType extends ApiTypes> ({ api, apiType,
     //
     // also supports signing through external signers
     public signAsync (account: AddressOrPair, optionsOrNonce?: Partial<SignerOptions>): SubmittableThis<ApiType, this> {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-return,@typescript-eslint/no-unsafe-call
       return decorateMethod(
         (): Observable<this> =>
           this.#observeSign(account, optionsOrNonce).pipe(mapTo(this))
@@ -90,6 +92,7 @@ export default function createClass <ApiType extends ApiTypes> ({ api, apiType,
       const [options, statusCb] = this.#makeSignAndSendOptions(optionsOrStatus, optionalStatusCb);
       const isSubscription = api.hasSubscriptions && (this.#ignoreStatusCb || !!statusCb);
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-return,@typescript-eslint/no-unsafe-call
       return decorateMethod(
         (): Observable<Codec> => (
           this.#observeSign(account, options).pipe(
@@ -112,6 +115,7 @@ export default function createClass <ApiType extends ApiTypes> ({ api, apiType,
     public send (statusCb?: Callback<ISubmittableResult>): SubmittableResultResult<ApiType> | SubmittableResultSubscription<ApiType> {
       const isSubscription = api.hasSubscriptions && (this.#ignoreStatusCb || !!statusCb);
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-return,@typescript-eslint/no-unsafe-call
       return decorateMethod(
         isSubscription
           ? this.#observeSubscribe

packages/api/src/submittable/createSubmittable.ts

@@ -22,6 +22,6 @@ export default function createSubmittable<ApiType extends ApiTypes> (apiType: Ap
       Submittable = createClass<ApiType>({ api, apiType, decorateMethod });
     }
 
-    return new Submittable(api.registry, extrinsic);
+    return new Submittable(api.registry, extrinsic) as SubmittableExtrinsic<ApiType>;
   };
 }

packages/api/src/submittable/types.ts

@@ -3,7 +3,7 @@
 // of the Apache-2.0 license. See the LICENSE file for details.
 
 import { AccountId, Address, Extrinsic, ExtrinsicStatus, EventRecord, Hash, RuntimeDispatchInfo } from '@polkadot/types/interfaces';
-import { AnyNumber, AnyU8a, Callback, Codec, IExtrinsicEra, IKeyringPair, SignatureOptions, Signer, ISubmittableResult } from '@polkadot/types/types';
+import { AnyNumber, AnyU8a, Callback, Codec, IExtrinsicEra, IKeyringPair, Signer, ISubmittableResult } from '@polkadot/types/types';
 import { ApiTypes } from '../types';
 
 import { Observable } from 'rxjs';
@@ -50,9 +50,9 @@ export interface SubmittableExtrinsic<ApiType extends ApiTypes> extends Extrinsi
 
   send(statusCb: Callback<ISubmittableResult>): SubmittableResultSubscription<ApiType>;
 
-  sign(account: IKeyringPair, _options?: Partial<SignatureOptions>): this;
+  sign(account: IKeyringPair, _options?: Partial<SignerOptions>): this;
 
-  signAsync(account: AddressOrPair, _options?: Partial<SignatureOptions>): SubmittableThis<ApiType, this>;
+  signAsync(account: AddressOrPair, _options?: Partial<SignerOptions>): SubmittableThis<ApiType, this>;
 
   signAndSend(account: AddressOrPair, options?: Partial<SignerOptions>): SubmittableResultResult<ApiType>;
 

packages/api/src/util/augmentObject.spec.ts

@@ -12,6 +12,7 @@ describe('augmentObject', (): void => {
   });
 
   afterEach((): void => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     spy.mockClear();
   });
 

packages/api/src/util/augmentObject.ts

@@ -74,7 +74,7 @@ function extractMethods (src: Record<string, Record<string, any>>, dst: Record<s
  * already available, but rather just adds new missing ites into the result object.
  * @internal
  */
-export default function augmentObject (prefix: string, src: Record<string, Record<string, any>>, dst: Record<string, Record<string, any>>, fromEmpty = false): Record<string, Record<string, any>> {
+export default function augmentObject (prefix: string, src: Record<string, Record<string, unknown>>, dst: Record<string, Record<string, unknown>>, fromEmpty = false): Record<string, Record<string, any>> {
   if (fromEmpty) {
     Object.keys(dst).forEach((key): void => {
       delete dst[key];
@@ -88,12 +88,12 @@ export default function augmentObject (prefix: string, src: Record<string, Recor
 
   return Object
     .keys(src)
-    .reduce((newSection, sectionName): Record<string, Record<string, any>> => {
+    .reduce((newSection, sectionName): Record<string, Record<string, unknown>> => {
       const section = src[sectionName];
 
       newSection[sectionName] = Object
         .keys(section)
-        .reduce((result, methodName): Record<string, any> => {
+        .reduce((result, methodName): Record<string, unknown> => {
           // TODO When it does match, check the actual details and warn when there are differences
           if (!result[methodName]) {
             result[methodName] = section[methodName];

packages/api/src/util/decorate.ts

@@ -14,17 +14,14 @@ export type DeriveAllSections<ApiType extends ApiTypes, AllSections extends AnyD
 
 // A technically unsafe version of Object.keys(obj) that assumes that
 // obj only has known properties of T
-function keys<T extends object> (obj: T): (keyof T)[] {
-  return Object.keys(obj) as (keyof T)[];
+function keys<T extends Record<string, unknown>> (obj: T): (keyof T)[] {
+  return Object.keys(obj);
 }
 
 /**
  * This is a methods decorator which keeps all type information.
  */
-function decorateMethods<ApiType extends ApiTypes, Section extends Record<string, AnyFunction>> (
-  section: Section,
-  decorateMethod: DecorateMethod<ApiType>
-): DeriveSection<ApiType, Section> {
+function decorateMethods<ApiType extends ApiTypes, Section extends Record<string, AnyFunction>> (section: Section, decorateMethod: DecorateMethod<ApiType>): DeriveSection<ApiType, Section> {
   return keys(section).reduce(
     <MethodName extends keyof Section>(
       acc: DeriveSection<ApiType, Section>,
@@ -32,7 +29,8 @@ function decorateMethods<ApiType extends ApiTypes, Section extends Record<string
     ): DeriveSection<ApiType, Section> => {
       const method = section[methodName];
 
-      acc[methodName] = decorateMethod(method);
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
+      acc[methodName] = decorateMethod(method) as MethodResult<ApiType, Section[MethodName]>;
 
       return acc;
     },

packages/api/src/util/filterEvents.ts

@@ -18,7 +18,7 @@ export default function filterEvents (extHash: H256, { block: { extrinsics, head
   if (index === -1) {
     // only warn on filtering with isInBlock (finalization finalizes after)
     if (status.isInBlock) {
-      l.warn(`block ${header.hash}: Unable to find extrinsic ${myHash} inside ${allHashes}`);
+      l.warn(`block ${header.hash.toHex()}: Unable to find extrinsic ${myHash} inside ${allHashes.join(', ')}`);
     }
 
     return;

packages/api/src/util/validate.spec.ts

@@ -35,8 +35,7 @@ describe('extractStorageArgs', (): void => {
 
   it('validates no-arg plain (failing when there are args)', (): void => {
     expect(
-      (): any[] =>
-        extractStorageArgs(storage.timestamp.now, [123, 456])
+      (): unknown => extractStorageArgs(storage.timestamp.now, [123, 456])
     ).toThrow('timestamp.now() does not take any arguments, 2 found');
   });
 

packages/api/src/util/validate.ts

@@ -35,7 +35,7 @@ function doMap (creator: StorageEntry, args: any[]): [StorageEntry] | [StorageEn
 
 // sets up the arguments in the form of [creator, args] ready to be used in a storage
 // call. Additionally, it verifies that the correct number of arguments have been passed
-export function extractStorageArgs (creator: StorageEntry, _args: any[]): any[] {
+export function extractStorageArgs (creator: StorageEntry, _args: any[]): [StorageEntry, [any, any]] | [StorageEntry] | [StorageEntry, any] {
   const args = _args.filter((arg) => !isUndefined(arg));
 
   if (creator.meta.type.isDoubleMap) {

packages/api/test/util/logEvents.ts

@@ -7,7 +7,7 @@ import { EventRecord } from '@polkadot/types/interfaces';
 import { SubmittableResult } from '../../src';
 
 // log all events for the transfers, calling done() when finalized
-export const logEvents = (done: () => {}): (r: SubmittableResult) => void =>
+export const logEvents = (done: () => Record<string, unknown>): (r: SubmittableResult) => void =>
   ({ events, status }: SubmittableResult): void => {
     console.log('Transaction status:', status.type);
 

packages/metadata/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/metadata",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "Helpers to extract information from runtime metadata",
   "main": "index.js",
   "publishConfig": {
@@ -27,13 +27,13 @@
   "homepage": "https://github.com/polkadot-js/api/tree/master/packages/type-metadata#readme",
   "dependencies": {
     "@babel/runtime": "^7.9.6",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/types-known": "1.15.1",
-    "@polkadot/util": "^2.10.1",
-    "@polkadot/util-crypto": "^2.10.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/types-known": "1.16.1",
+    "@polkadot/util": "^2.11.1",
+    "@polkadot/util-crypto": "^2.11.1",
     "bn.js": "^5.1.2"
   },
   "devDependencies": {
-    "@polkadot/keyring": "^2.10.1"
+    "@polkadot/keyring": "^2.11.1"
   }
 }

packages/metadata/src/Decorated/storage/fromMetadata/createFunction.spec.ts

@@ -14,6 +14,7 @@ describe('createFunction', (): void => {
   it('should create timestamp.now correctly', (): void => {
     expect(
       createFunction(registry, {
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
         meta: { type: {} } as any,
         method: 'Now',
         prefix: 'Timestamp',
@@ -29,6 +30,7 @@ describe('createFunction', (): void => {
       createFunction(
         registry,
         {
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
           meta: { type: {} } as any,
           method: 'authorityCount',
           prefix: 'Substrate',
@@ -50,6 +52,7 @@ describe('createFunction', (): void => {
       createFunction(
         registry,
         {
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
           meta: { type: {} } as any,
           method: 'authorityCount',
           prefix: 'Substrate',
@@ -74,6 +77,7 @@ describe('createFunction', (): void => {
 
     beforeAll((): void => {
       storageFn = createFunction(registry, {
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
         meta: {
           name: 'metaName',
           type: {
@@ -119,6 +123,7 @@ describe('createFunction', (): void => {
 
   it('allows creates double map function with a Null type key', (): void => {
     const storageFn = createFunction(registry, {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       meta: {
         type: {
           asDoubleMap: {
@@ -144,6 +149,7 @@ describe('createFunction', (): void => {
 
   it('allows creating of known DoubleMap keys (with Bytes)', (): void => {
     const storageFn = createFunction(registry, {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
       meta: {
         type: {
           asDoubleMap: {

packages/metadata/src/Decorated/storage/fromMetadata/createFunction.ts

@@ -73,10 +73,7 @@ function createKeyDoubleMap (registry: Registry, itemFn: CreateItemFn, stringKey
   const { meta: { name, type } } = itemFn;
 
   // since we are passing an almost-unknown through, trust, but verify
-  assert(
-    Array.isArray(args) && !isUndefined(args[0]) && !isNull(args[0]) && !isUndefined(args[1]) && !isNull(args[1]),
-    `${name} is a DoubleMap and requires two arguments`
-  );
+  assert(Array.isArray(args) && !isUndefined(args[0]) && !isNull(args[0]) && !isUndefined(args[1]) && !isNull(args[1]), `${(name || 'unknown').toString()} is a DoubleMap and requires two arguments`);
 
   // if this fails, we have bigger issues
   assert(!isUndefined(hasher2), '2 hashing functions should be defined for DoubleMaps');
@@ -110,7 +107,7 @@ function createKey (registry: Registry, itemFn: CreateItemFn, stringKey: string,
   if (type.isMap) {
     const map = type.asMap;
 
-    assert(!isUndefined(arg) && !isNull(arg), `${name} is a Map and requires one argument`);
+    assert(!isUndefined(arg) && !isNull(arg), `${name.toString()} is a Map and requires one argument`);
 
     param = createTypeUnsafe(registry, map.key.toString(), [arg]).toU8a();
   }
@@ -134,7 +131,7 @@ function expandWithMeta ({ meta, method, prefix, section }: CreateItemFn, storag
   // explicitly add the actual method in the toJSON, this gets used to determine caching and without it
   // instances (e.g. collective) will not work since it is only matched on param meta
   storageFn.toJSON = (): any => ({
-    ...(meta.toJSON() as any),
+    ...(meta.toJSON() as Record<string, unknown>),
     storage: { method, prefix, section }
   });
 

packages/metadata/src/Decorated/storage/fromMetadata/getHasher.ts

@@ -14,11 +14,11 @@ export type HasherFunction = (data: HasherInput) => Uint8Array;
 const DEFAULT_FN = (data: HasherInput): Uint8Array => xxhashAsU8a(data, 128);
 
 const HASHERS: Record<keyof typeof AllHashers, HasherFunction> = {
-  Blake2_128: (data: HasherInput): Uint8Array => // eslint-disable-line @typescript-eslint/camelcase
+  Blake2_128: (data: HasherInput): Uint8Array => // eslint-disable-line camelcase
     blake2AsU8a(data, 128),
-  Blake2_128Concat: (data: HasherInput): Uint8Array => // eslint-disable-line @typescript-eslint/camelcase
+  Blake2_128Concat: (data: HasherInput): Uint8Array => // eslint-disable-line camelcase
     u8aConcat(blake2AsU8a(data, 128), u8aToU8a(data)),
-  Blake2_256: (data: HasherInput): Uint8Array => // eslint-disable-line @typescript-eslint/camelcase
+  Blake2_256: (data: HasherInput): Uint8Array => // eslint-disable-line camelcase
     blake2AsU8a(data, 256),
   Identity: (data: HasherInput): Uint8Array =>
     u8aToU8a(data),

packages/metadata/src/Decorated/storage/fromMetadata/storage.ts

@@ -14,7 +14,7 @@ export default function getStorage (registry: Registry, metaVersion: number): St
     substrate: Object
       .entries(substrate)
       .reduce((storage: Record<string, StorageEntry>, [key, fn]): Record<string, StorageEntry> => {
-        (storage as any)[key] = fn(registry, metaVersion);
+        (storage as Record<string, unknown>)[key] = fn(registry, metaVersion);
 
         return storage;
       }, {})

packages/metadata/src/Metadata/MagicNumber.ts

@@ -2,7 +2,7 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
-import { Registry } from '@polkadot/types/types';
+import { AnyNumber, Registry } from '@polkadot/types/types';
 
 import { assert } from '@polkadot/util';
 
@@ -11,7 +11,7 @@ import U32 from '@polkadot/types/primitive/U32';
 export const MAGIC_NUMBER = 0x6174656d; // `meta`, reversed for Little Endian encoding
 
 export default class MagicNumber extends U32 {
-  constructor (registry: Registry, value?: any) {
+  constructor (registry: Registry, value?: AnyNumber) {
     super(registry, value);
 
     if (!this.isEmpty) {

packages/metadata/src/Metadata/MetadataVersioned.ts

@@ -33,13 +33,13 @@ type MetaAsX = 'asV0' | 'asV1' | 'asV2' | 'asV3' | 'asV4' | 'asV5' | 'asV6' | 'a
  * The versioned runtime metadata as a decoded structure
  */
 export default class MetadataVersioned extends Struct {
-  readonly #converted: Map<number, MetaMapped> = new Map();
+  readonly #converted = new Map<number, MetaMapped>();
 
-  constructor (registry: Registry, value?: any) {
+  constructor (registry: Registry, value?: unknown) {
     super(registry, {
       magicNumber: MagicNumber,
       metadata: 'MetadataAll'
-    }, value);
+    }, value as Map<unknown, unknown>);
 
     registry.setMetadata(this);
   }

packages/metadata/src/Metadata/util/flattenUniq.ts

@@ -2,9 +2,11 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
+type Types = string | Types[];
+
 /** @internal */
-export default function flattenUniq (list: any[]): any[] {
-  const flat = list.reduce((result, entry): any[] => {
+export default function flattenUniq (list: Types[]): string[] {
+  const flat = list.reduce((result: string[], entry): string[] => {
     return result.concat(
       Array.isArray(entry)
         ? flattenUniq(entry)
@@ -13,6 +15,6 @@ export default function flattenUniq (list: any[]): any[] {
   }, []);
 
   return [...new Set(flat)]
-    .filter((value: any): any => value)
+    .filter((value: string) => value)
     .sort();
 }

packages/metadata/src/Metadata/util/testUtil.ts

@@ -11,7 +11,7 @@ import getUniqTypes from './getUniqTypes';
 import Metadata from '../Metadata';
 
 /** @internal */
-export function decodeLatestSubstrate<Modules extends Codec> (registry: Registry, version: number, rpcData: string, staticSubstrate: object): void {
+export function decodeLatestSubstrate<Modules extends Codec> (registry: Registry, version: number, rpcData: string, staticSubstrate: Record<string, unknown>): void {
   it('decodes latest substrate properly', (): void => {
     const metadata = new Metadata(registry, rpcData);
 
@@ -49,14 +49,14 @@ export function defaultValues (registry: Registry, rpcData: string, withThrow =
     metadata.asLatest.modules.filter(({ storage }): boolean => storage.isSome).forEach((mod): void => {
       mod.storage.unwrap().items.forEach(({ fallback, name, type }): void => {
         const inner = unwrapStorageType(type);
-        const location = `${mod.name}.${name}: ${inner}`;
+        const location = `${mod.name.toString()}.${name.toString()}: ${inner}`;
 
         it(`creates default types for ${location}`, (): void => {
           expect((): void => {
             try {
               registry.createType(inner, fallback);
             } catch (error) {
-              const message = `${location}:: ${error.message}`;
+              const message = `${location}:: ${(error as Error).message}`;
 
               if (withThrow) {
                 throw new Error(message);

packages/metadata/src/Metadata/util/toCallsOnly.ts

@@ -26,7 +26,7 @@ function mapCalls (registry: Registry, _calls: Option<Vec<FunctionMetadataLatest
         })
       )
       : null
-  );
+  ) as Option<Vec<FunctionMetadataLatest>>;
 }
 
 /** @internal */

packages/metadata/src/Metadata/util/validateTypes.ts

@@ -8,9 +8,11 @@ import { getTypeDef } from '@polkadot/types/create';
 
 import flattenUniq from './flattenUniq';
 
+type Extracted = string | Extracted[];
+
 /** @internal */
-function extractTypes (types: string[]): any[] {
-  return types.map((type): any => {
+function extractTypes (types: string[]): Extracted[] {
+  return types.map((type): Extracted => {
     const decoded = getTypeDef(type);
 
     switch (decoded.info) {
@@ -38,12 +40,10 @@ function extractTypes (types: string[]): any[] {
 
 /** @internal */
 export default function validateTypes (registry: Registry, types: string[], throwError: boolean): void {
-  const missing = flattenUniq(extractTypes(types)).filter((type): boolean =>
-    !registry.hasType(type)
-  );
+  const missing = flattenUniq(extractTypes(types)).filter((type) => !registry.hasType(type));
 
   if (missing.length !== 0) {
-    const message = `Unknown types found, no types for ${missing}`;
+    const message = `Unknown types found, no types for ${missing.join(', ')}`;
 
     if (throwError) {
       throw new Error(message);

packages/metadata/src/Metadata/v11/static-substrate.json

@@ -3015,7 +3015,7 @@
                   "type": "Vec<ValidatorIndex>"
                 },
                 {
-                  "name": "compact_assignments",
+                  "name": "compact",
                   "type": "CompactAssignments"
                 },
                 {
@@ -3025,6 +3025,10 @@
                 {
                   "name": "era",
                   "type": "EraIndex"
+                },
+                {
+                  "name": "size",
+                  "type": "ElectionSize"
                 }
               ],
               "documentation": [
@@ -3073,34 +3077,7 @@
                 "    minimized (to ensure less variance)",
                 "",
                 " # <weight>",
-                " E: number of edges. m: size of winner committee. n: number of nominators. d: edge degree",
-                " (16 for now) v: number of on-chain validator candidates.",
-                "",
-                " NOTE: given a solution which is reduced, we can enable a new check the ensure `|E| < n +",
-                " m`. We don't do this _yet_, but our offchain worker code executes it nonetheless.",
-                "",
-                " major steps (all done in `check_and_replace_solution`):",
-                "",
-                " - Storage: O(1) read `ElectionStatus`.",
-                " - Storage: O(1) read `PhragmenScore`.",
-                " - Storage: O(1) read `ValidatorCount`.",
-                " - Storage: O(1) length read from `SnapshotValidators`.",
-                "",
-                " - Storage: O(v) reads of `AccountId` to fetch `snapshot_validators`.",
-                " - Memory: O(m) iterations to map winner index to validator id.",
-                " - Storage: O(n) reads `AccountId` to fetch `snapshot_nominators`.",
-                " - Memory: O(n + m) reads to map index to `AccountId` for un-compact.",
-                "",
-                " - Storage: O(e) accountid reads from `Nomination` to read correct nominations.",
-                " - Storage: O(e) calls into `slashable_balance_of_vote_weight` to convert ratio to staked.",
-                "",
-                " - Memory: build_support_map. O(e).",
-                " - Memory: evaluate_support: O(E).",
-                "",
-                " - Storage: O(e) writes to `QueuedElected`.",
-                " - Storage: O(1) write to `QueuedScore`",
-                "",
-                " The weight of this call is 1/10th of the blocks total weight.",
+                " See `crate::weight` module.",
                 " # </weight>"
               ]
             },
@@ -3112,7 +3089,7 @@
                   "type": "Vec<ValidatorIndex>"
                 },
                 {
-                  "name": "compact_assignments",
+                  "name": "compact",
                   "type": "CompactAssignments"
                 },
                 {
@@ -3122,6 +3099,10 @@
                 {
                   "name": "era",
                   "type": "EraIndex"
+                },
+                {
+                  "name": "size",
+                  "type": "ElectionSize"
                 }
               ],
               "documentation": [
@@ -3129,7 +3110,11 @@
                 "",
                 " Note that this must pass the [`ValidateUnsigned`] check which only allows transactions",
                 " from the local node to be included. In other words, only the block author can include a",
-                " transaction in the block."
+                " transaction in the block.",
+                "",
+                " # <weight>",
+                " See `crate::weight` module.",
+                " # </weight>"
               ]
             }
           ],
@@ -3404,6 +3389,12 @@
                 " The claimed score does not match with the one computed from the data."
               ]
             },
+            {
+              "name": "PhragmenBogusElectionSize",
+              "documentation": [
+                " The election size is invalid."
+              ]
+            },
             {
               "name": "CallNotAllowed",
               "documentation": [

packages/rpc-core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/rpc-core",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "A JavaScript wrapper for the Polkadot JsonRPC interface",
   "main": "index.js",
   "keywords": [
@@ -27,14 +27,14 @@
   "homepage": "https://github.com/polkadot-js/api/tree/master/packages/rpc-core#readme",
   "dependencies": {
     "@babel/runtime": "^7.9.6",
-    "@polkadot/metadata": "1.15.1",
-    "@polkadot/rpc-provider": "1.15.1",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/util": "^2.10.1",
+    "@polkadot/metadata": "1.16.1",
+    "@polkadot/rpc-provider": "1.16.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/util": "^2.11.1",
     "memoizee": "^0.4.14",
     "rxjs": "^6.5.5"
   },
   "devDependencies": {
-    "@polkadot/keyring": "^2.10.1"
+    "@polkadot/keyring": "^2.11.1"
   }
 }

packages/rpc-core/src/cached.spec.ts

@@ -84,6 +84,7 @@ describe('Cached Observables', (): void => {
 
   it('creates different observables for different methods but same arguments', (): void => {
     // params do not match here
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     const observable1 = (rpc.chain as any).subscribeNewHeads([123]);
     const observable2 = rpc.state.subscribeStorage([123]);
 

packages/rpc-core/src/index.spec.ts

@@ -28,6 +28,7 @@ describe('Api', (): void => {
       }
     });
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     expect(isFunction((rpc as any).testing.foo)).toBe(true);
     expect(rpc.sections.includes('testing')).toBe(true);
     expect(rpc.mapping.get('testing_foo')).toEqual({

packages/rpc-core/src/index.ts

@@ -63,7 +63,7 @@ function logErrorMessage (method: string, { params, type }: DefinitionRpc, error
 export default class Rpc implements RpcInterface {
   readonly #storageCache = new Map<string, string | null>();
 
-  public readonly mapping: Map<string, DefinitionRpcExt> = new Map();
+  public readonly mapping = new Map<string, DefinitionRpcExt>();
 
   public readonly provider: ProviderInterface;
 
@@ -134,7 +134,7 @@ export default class Rpc implements RpcInterface {
 
     // decorate the sections with base and user methods
     this.sections.forEach((sectionName): void => {
-      (this as any)[sectionName as Section] = {
+      (this as Record<string, unknown>)[sectionName as Section] = {
         ...this._createInterface(sectionName, jsonrpc[sectionName as 'babe'] || {}),
         ...this._createInterface(sectionName, userRpc[sectionName] || {})
       };
@@ -156,7 +156,7 @@ export default class Rpc implements RpcInterface {
         // `<S extends keyof RpcInterface, M extends keyof RpcInterface[S]>`
         // Not doing so, because it makes this class a little bit less readable,
         // and leaving it as-is doesn't harm much
-        (exposed as any)[method] = isSubscription
+        (exposed as Record<string, unknown>)[method] = isSubscription
           ? this._createMethodSubscribe(section, method, def as DefinitionRpcSub)
           : this._createMethodSend(section, method, def);
 
@@ -333,7 +333,7 @@ export default class Rpc implements RpcInterface {
       try {
         return this._formatStorageData(key, result);
       } catch (error) {
-        console.error(`Unable to decode storage ${key.section}.${key.method}:`, error.message);
+        console.error(`Unable to decode storage ${key.section || 'unknown'}.${key.method || 'unknown'}:`, (error as Error).message);
 
         throw error;
       }
@@ -341,10 +341,10 @@ export default class Rpc implements RpcInterface {
       const keys = params[0] as Vec<StorageKey>;
 
       return keys
-        ? this._formatStorageSet(keys, result.changes)
+        ? this._formatStorageSet(keys, (result as { changes: [string, string | null][] }).changes)
         : this.registry.createType('StorageChangeSet', result);
     } else if (rpc.type === 'Vec<StorageChangeSet>') {
-      const mapped = result.map(({ block, changes }: { block: string; changes: [string, string | null][] }): [Hash, Codec[]] => [
+      const mapped = (result as { block: string; changes: [string, string | null][] }[]).map(({ block, changes }): [Hash, Codec[]] => [
         this.registry.createType('Hash', block),
         this._formatStorageSet(params[0] as Vec<StorageKey>, changes)
       ]);
@@ -352,7 +352,7 @@ export default class Rpc implements RpcInterface {
       // we only query at a specific block, not a range - flatten
       return method === 'queryStorageAt'
         ? mapped[0][1]
-        : mapped;
+        : mapped as unknown as Codec[];
     }
 
     return createTypeUnsafe(this.registry, rpc.type, [result]);
@@ -404,7 +404,7 @@ export default class Rpc implements RpcInterface {
       try {
         results.push(this._formatStorageSetEntry(key, changes, withCache));
       } catch (error) {
-        console.error(`Unable to decode storage ${key.section}.${key.method}:`, error.message);
+        console.error(`Unable to decode storage ${key.section || 'unknown'}.${key.method || 'unknown'}:`, (error as Error).message);
 
         throw error;
       }

packages/rpc-core/src/methodSend.spec.ts

@@ -31,7 +31,7 @@ describe('methodSend', (): void => {
     };
 
     provider = {
-      send: jest.fn((method, params): Promise<any> => {
+      send: jest.fn((method, params: any[]): Promise<any> => {
         return Promise.resolve(params[0]);
       })
     };
@@ -41,8 +41,10 @@ describe('methodSend', (): void => {
 
   it('checks for mismatched parameters', (done): void => {
     // private method
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     const method = (rpc as any)._createMethodSend('test', 'bleh', methods.bleh);
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     method(1).subscribe(
       (): void => undefined,
       (error: Error): void => {
@@ -53,10 +55,13 @@ describe('methodSend', (): void => {
 
   it('calls the provider with the correct parameters', (done): void => {
     // private method
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     const method = (rpc as any)._createMethodSend('test', 'blah', methods.blah);
 
     // Args are length-prefixed, because it's a Bytes
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     method(new Uint8Array([2 << 2, 0x12, 0x34])).subscribe((): void => {
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
       expect(provider.send).toHaveBeenCalledWith('test_blah', ['0x1234']);
       done();
     });

packages/rpc-core/src/replay.spec.ts

@@ -18,7 +18,9 @@ describe('replay', (): void => {
 
   it('subscribes via the rpc section', (done): void => {
     // we don't honor types or number of params here
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     (rpc.chain as any).getBlockHash = jest.fn((): Observable<number> => of(1));
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
     (rpc.chain as any).getBlockHash(123, false).subscribe((): void => {
       expect(
         // eslint-disable-next-line @typescript-eslint/unbound-method
@@ -32,6 +34,7 @@ describe('replay', (): void => {
   it('returns the observable value', (done): void => {
     rpc.system.chain().subscribe((value: any): void => {
       if (value) {
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
         expect(value.toString()).toEqual('mockChain'); // Defined in MockProvider
         done();
       }
@@ -40,9 +43,9 @@ describe('replay', (): void => {
 
   it('replay(1) works as expected', (done): void => {
     const observable = rpc.system.chain();
-    let a: string | undefined;
+    let a: any | undefined;
 
-    observable.subscribe((value: any): void => { a = value; });
+    observable.subscribe((value?: unknown): void => { a = value; });
 
     setTimeout((): void => {
       // Subscribe again to the same observable, it should fire value immediately

packages/rpc-core/src/rxjs/drr.ts

@@ -18,7 +18,7 @@ interface Options {
 
 const l = logger('drr');
 
-const CMP = (a: any, b: any): boolean =>
+const CMP = (a: unknown, b: unknown): boolean =>
   JSON.stringify({ t: a }) === JSON.stringify({ t: b });
 
 const ERR = (error: Error): Observable<never> => {
@@ -40,7 +40,7 @@ export const drr = ({ skipChange = false, skipTimeout = false }: Options = {}):
     catchError(ERR),
     skipChange
       ? tap(NOOP)
-      : distinctUntilChanged(CMP),
+      : distinctUntilChanged<T>(CMP),
     publishReplay(1),
     skipTimeout
       ? refCount()

packages/rpc-provider/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/rpc-provider",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "Transport providers for the API",
   "main": "index.js",
   "keywords": [
@@ -27,17 +27,17 @@
   "homepage": "https://github.com/polkadot-js/api/tree/master/packages/rpc-provider#readme",
   "dependencies": {
     "@babel/runtime": "^7.9.6",
-    "@polkadot/metadata": "1.15.1",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/util": "^2.10.1",
-    "@polkadot/util-crypto": "^2.10.1",
+    "@polkadot/metadata": "1.16.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/util": "^2.11.1",
+    "@polkadot/util-crypto": "^2.11.1",
     "bn.js": "^5.1.2",
     "eventemitter3": "^4.0.4",
     "isomorphic-fetch": "^2.2.1",
     "websocket": "^1.0.31"
   },
   "devDependencies": {
-    "@polkadot/keyring": "^2.10.1",
+    "@polkadot/keyring": "^2.11.1",
     "mock-socket": "^9.0.3",
     "nock": "^12.0.3"
   }

packages/rpc-provider/src/coder/encodeObject.spec.ts

@@ -17,12 +17,12 @@ describe('encodeObject', (): void => {
 
   it('encodes a valid JsonRPC object', (): void => {
     expect(
-      coder.encodeObject('method', 'params')
+      coder.encodeObject('method', ['a', 'b'])
     ).toEqual({
       id: 1,
       jsonrpc: '2.0',
       method: 'method',
-      params: 'params'
+      params: ['a', 'b']
     });
     expect(coder.getId()).toEqual(1);
   });

packages/rpc-provider/src/coder/index.ts

@@ -24,7 +24,7 @@ function formatErrorData (data?: string | number): string {
 export default class RpcCoder {
   #id = 0;
 
-  public decodeResponse (response: JsonRpcResponse): any {
+  public decodeResponse (response: JsonRpcResponse): unknown {
     assert(response, 'Empty response object received');
     assert(response.jsonrpc === '2.0', 'Invalid jsonrpc field in decoded object');
 
@@ -51,7 +51,7 @@ export default class RpcCoder {
     );
   }
 
-  public encodeObject (method: string, params: any | any[]): JsonRpcRequest {
+  public encodeObject (method: string, params: unknown[]): JsonRpcRequest {
     return {
       id: ++this.#id,
       jsonrpc: '2.0',

packages/rpc-provider/src/http/index.spec.ts

@@ -32,13 +32,13 @@ describe('Http', (): void => {
     return http.subscribe('', '', [], (cb): void => {
       expect(cb).toEqual(expect.anything());
     }).catch((error): void => {
-      expect(error.message).toMatch(/does not have subscriptions/);
+      expect((error as Error).message).toMatch(/does not have subscriptions/);
     });
   });
 
   it('does not (yet) support unsubscribe', (): Promise<boolean | void> => {
     return http.unsubscribe('', '', 0).catch((error): void => {
-      expect(error.message).toMatch(/does not have subscriptions/);
+      expect((error as Error).message).toMatch(/does not have subscriptions/);
     });
   });
 });

packages/rpc-provider/src/http/index.ts

@@ -109,6 +109,7 @@ export default class HttpProvider implements ProviderInterface {
 
     assert(response.ok, `[${response.status}]: ${response.statusText}`);
 
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     const result = await response.json();
 
     return this.#coder.decodeResponse(result);

packages/rpc-provider/src/http/polyfill.spec.ts

@@ -10,14 +10,17 @@ describe('http/polyfill', (): void => {
   let origFetch: any;
 
   beforeEach((): void => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     origFetch = global.fetch;
   });
 
   afterEach((): void => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     global.fetch = origFetch;
   });
 
   it('polyfills with no exceptions (without fetch)', (): void => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     (global as any).fetch = undefined;
     require('./polyfill');
 
@@ -25,6 +28,7 @@ describe('http/polyfill', (): void => {
   });
 
   it('polyfills with no exceptions (with fetch)', (): void => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     (global as any).fetch = (): boolean => true;
     require('./polyfill');
 

packages/rpc-provider/src/http/send.spec.ts

@@ -21,6 +21,7 @@ describe('send', (): void => {
   });
 
   it('passes the body through correctly', (): Promise<void> => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     mock = mockHttp([{
       method: 'test_body',
       reply: {
@@ -31,6 +32,7 @@ describe('send', (): void => {
     return http
       .send('test_body', ['param'])
       .then((): void => {
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
         expect((mock.body as any).test_body).toEqual({
           id: 1,
           jsonrpc: '2.0',
@@ -41,6 +43,7 @@ describe('send', (): void => {
   });
 
   it('throws error when !response.ok', (): Promise<any> => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
     mock = mockHttp([{
       code: 500,
       method: 'test_error'
@@ -49,7 +52,7 @@ describe('send', (): void => {
     return http
       .send('test_error', [])
       .catch((error): void => {
-        expect(error.message).toMatch(/\[500\]: Internal Server/);
+        expect((error as Error).message).toMatch(/\[500\]: Internal Server/);
       });
   });
 });

packages/rpc-provider/src/mock/index.ts

@@ -2,7 +2,7 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
-/* eslint-disable @typescript-eslint/camelcase */
+/* eslint-disable camelcase */
 
 import { Header } from '@polkadot/types/interfaces';
 import { Codec, Registry } from '@polkadot/types/types';
@@ -22,14 +22,15 @@ import { randomAsU8a } from '@polkadot/util-crypto';
 
 const INTERVAL = 1000;
 const SUBSCRIPTIONS: string[] = Array.prototype.concat.apply(
-  [], Object.values(jsonrpc).map((section): string[] =>
+  [],
+  Object.values(jsonrpc).map((section): string[] =>
     Object
       .values(section)
       .filter(({ isSubscription }) => isSubscription)
       .map(({ jsonrpc }) => jsonrpc)
       .concat('chain_subscribeNewHead')
   )
-);
+) as string[];
 
 const keyring = testKeyring({ type: 'ed25519' });
 const l = logger('api-mock');
@@ -50,12 +51,14 @@ export default class Mock implements ProviderInterface {
 
   private prevNumber = new BN(-1);
 
-  private requests: Record<string, (...params: any[]) => any> = {
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  private requests: Record<string, (...params: any[]) => unknown> = {
+    // eslint-disable-next-line @typescript-eslint/no-unused-vars,@typescript-eslint/no-unsafe-member-access
     chain_getBlock: (hash: string): any => this.registry.createType('SignedBlock', rpcSignedBlock.result).toJSON(),
     // eslint-disable-next-line @typescript-eslint/no-unused-vars
     chain_getBlockHash: (blockNumber: number): string => '0x1234',
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     chain_getFinalizedHead: () => this.registry.createType('Header', rpcHeader.result).hash,
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     chain_getHeader: () => this.registry.createType('Header', rpcHeader.result).toJSON(),
     state_getKeys: (): string[] => [],
     state_getKeysPaged: (): string[] => [],
@@ -112,7 +115,7 @@ export default class Mock implements ProviderInterface {
   }
 
   // eslint-disable-next-line @typescript-eslint/require-await
-  public async send (method: string, params: any[]): Promise<any> {
+  public async send (method: string, params: any[]): Promise<unknown> {
     if (!this.requests[method]) {
       throw new Error(`provider.send: Invalid method '${method}'`);
     }
@@ -121,11 +124,11 @@ export default class Mock implements ProviderInterface {
   }
 
   // eslint-disable-next-line @typescript-eslint/require-await
-  public async subscribe (type: string, method: string, ...params: any[]): Promise<number> {
+  public async subscribe (type: string, method: string, ...params: unknown[]): Promise<number> {
     l.debug((): any => ['subscribe', method, params]);
 
     if (this.subscriptions[method]) {
-      const callback: MockStateSubscriptionCallback = params.pop();
+      const callback = params.pop() as MockStateSubscriptionCallback;
       const id = ++this.subscriptionId;
 
       this.subscriptions[method].callbacks[id] = callback;

packages/rpc-provider/src/mock/send.spec.ts

@@ -18,7 +18,7 @@ describe('send', (): void => {
     return mock
       .send('something_invalid', [])
       .catch((error): void => {
-        expect(error.message).toMatch(/Invalid method/);
+        expect((error as Error).message).toMatch(/Invalid method/);
       });
   });
 

packages/rpc-provider/src/mock/subscribe.spec.ts

@@ -18,7 +18,7 @@ describe('subscribe', (): void => {
     return mock
       .subscribe('test', 'test_notFound')
       .catch((error): void => {
-        expect(error.message).toMatch(/Invalid method 'test_notFound'/);
+        expect((error as Error).message).toMatch(/Invalid method 'test_notFound'/);
       });
   });
 
@@ -41,7 +41,7 @@ describe('subscribe', (): void => {
   });
 
   it('calls back with new headers', (done): Promise<number> => {
-    return mock.subscribe('chain_newHead', 'chain_subscribeNewHead', (_: any, header: any): void => {
+    return mock.subscribe('chain_newHead', 'chain_subscribeNewHead', (_: any, header: { number: number }): void => {
       if (header.number === 4) {
         done();
       }
@@ -51,7 +51,7 @@ describe('subscribe', (): void => {
   it('handles errors withing callbacks gracefully', (done): Promise<number> => {
     let hasThrown = false;
 
-    return mock.subscribe('chain_newHead', 'chain_subscribeNewHead', (_: any, header: any): void => {
+    return mock.subscribe('chain_newHead', 'chain_subscribeNewHead', (_: any, header: { number: number }): void => {
       if (!hasThrown) {
         hasThrown = true;
 

packages/rpc-provider/src/mock/types.ts

@@ -5,6 +5,7 @@
 import { Server } from 'mock-socket';
 import { Constructor } from '@polkadot/types/types';
 
+// eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
 export interface Global extends NodeJS.Global {
   WebSocket: Constructor<WebSocket>;
   fetch: any;
@@ -14,7 +15,7 @@ export interface Mock {
   body: Record<string, any>;
   requests: number;
   server: Server;
-  done: () => {};
+  done: () => Record<string, unknown>;
 }
 
 export type MockStateSubscriptionCallback = (error: Error | null, value: any) => void;

packages/rpc-provider/src/mock/unsubscribe.spec.ts

@@ -25,7 +25,7 @@ describe('unsubscribe', (): void => {
     return mock
       .unsubscribe('chain_newHead', 'chain_subscribeNewHead', 5)
       .catch((error): boolean => {
-        expect(error.message).toMatch(/Unable to find/);
+        expect((error as Error).message).toMatch(/Unable to find/);
 
         return false;
       });
@@ -41,7 +41,7 @@ describe('unsubscribe', (): void => {
         mock.unsubscribe('chain_newHead', 'chain_subscribeNewHead', id)
       )
       .catch((error): boolean => {
-        expect(error.message).toMatch(/Unable to find/);
+        expect((error as Error).message).toMatch(/Unable to find/);
 
         return false;
       });

packages/rpc-provider/src/types.ts

@@ -9,7 +9,7 @@ export interface JsonRpcObject {
 
 export interface JsonRpcRequest extends JsonRpcObject {
   method: string;
-  params: any[];
+  params: unknown[];
 }
 
 export interface JsonRpcResponseBaseError {
@@ -20,14 +20,14 @@ export interface JsonRpcResponseBaseError {
 
 interface JsonRpcResponseSingle {
   error?: JsonRpcResponseBaseError;
-  result?: any;
+  result?: unknown;
 }
 
 interface JsonRpcResponseSubscription {
   method?: string;
   params: {
     error?: JsonRpcResponseBaseError;
-    result: any;
+    result: unknown;
     subscription: number;
   };
 }

packages/rpc-provider/src/ws/Provider.ts

@@ -2,7 +2,7 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
-/* eslint-disable @typescript-eslint/camelcase */
+/* eslint-disable camelcase */
 
 import { JsonRpcResponse, ProviderInterface, ProviderInterfaceCallback, ProviderInterfaceEmitted, ProviderInterfaceEmitCb } from '../types';
 
@@ -108,6 +108,7 @@ export default class WsProvider implements WSProviderInterface {
     this.#websocket = null;
 
     if (autoConnectMs > 0) {
+      // eslint-disable-next-line @typescript-eslint/no-floating-promises
       this.connect();
     }
   }
@@ -247,9 +248,9 @@ export default class WsProvider implements WSProviderInterface {
    * ```
    */
   public async subscribe (type: string, method: string, params: any[], callback: ProviderInterfaceCallback): Promise<number> {
-    const id = await this.send(method, params, { callback, type });
+    const id = await this.send(method, params, { callback, type }) as Promise<number>;
 
-    return id as number;
+    return id;
   }
 
   /**
@@ -270,9 +271,9 @@ export default class WsProvider implements WSProviderInterface {
 
     delete this.#subscriptions[subscription];
 
-    const result = await this.send(method, [id]);
+    const result = await this.send(method, [id]) as Promise<boolean>;
 
-    return result as boolean;
+    return result;
   }
 
   #emit = (type: ProviderInterfaceEmitted, ...args: any[]): void => {
@@ -289,6 +290,7 @@ export default class WsProvider implements WSProviderInterface {
 
     if (this.#autoConnectMs > 0) {
       setTimeout((): void => {
+        // eslint-disable-next-line @typescript-eslint/no-floating-promises
         this.connect();
       }, this.#autoConnectMs);
     }
@@ -300,9 +302,10 @@ export default class WsProvider implements WSProviderInterface {
   }
 
   #onSocketMessage = (message: MessageEvent): void => {
-    l.debug((): any => ['received', message.data]);
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-return
+    l.debug(() => ['received', message.data]);
 
-    const response: JsonRpcResponse = JSON.parse(message.data as string);
+    const response = JSON.parse(message.data as string) as JsonRpcResponse;
 
     return isUndefined(response.method)
       ? this.#onSocketMessageResult(response)
@@ -320,7 +323,7 @@ export default class WsProvider implements WSProviderInterface {
 
     try {
       const { method, params, subscription } = handler;
-      const result = this.#coder.decodeResponse(response);
+      const result = this.#coder.decodeResponse(response) as string;
 
       // first send the result - in case of subs, we may have an update
       // immediately if we have some queued results already
@@ -348,7 +351,7 @@ export default class WsProvider implements WSProviderInterface {
   }
 
   #onSocketMessageSubscribe = (response: JsonRpcResponse): void => {
-    const method = ALIASSES[response.method as string] || response.method;
+    const method = ALIASSES[response.method as string] || response.method || 'invalid';
     const subId = `${method}::${response.params.subscription}`;
     const handler = this.#subscriptions[subId];
 

packages/rpc-provider/src/ws/getWSClass.spec.ts

@@ -21,6 +21,7 @@ describe('getWebScoket', (): void => {
   });
 
   it('polyfills with no exceptions (with WebSocket)', async (): Promise<void> => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     (global as any).WebSocket = undefined;
 
     const WS = await getWSClass();
@@ -29,6 +30,7 @@ describe('getWebScoket', (): void => {
   });
 
   it('polyfills with no exceptions (without WebSocket)', async (): Promise<void> => {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     (global as any).WebSocket = (): boolean => true;
 
     const WS = await getWSClass();

packages/rpc-provider/src/ws/onOpen.spec.ts

@@ -33,6 +33,7 @@ describe('onOpen', (): void => {
     }], 0);
     const sendPromise = ws.send('test_queue', []);
 
+    // eslint-disable-next-line @typescript-eslint/no-floating-promises
     ws.connect();
 
     return sendPromise.then((result): void => {

packages/rpc-provider/src/ws/send.spec.ts

@@ -50,7 +50,7 @@ describe('send', (): void => {
     return createWs()
       .send('test_encoding', [{ error: 'send error' }])
       .catch((error): void => {
-        expect(error.message).toEqual('send error');
+        expect((error as Error).message).toEqual('send error');
       });
   });
 
@@ -67,6 +67,7 @@ describe('send', (): void => {
       .send('test_body', ['param'])
       .then((): void => {
         expect(
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
           (mock.body as any).test_body
         ).toEqual('{"id":1,"jsonrpc":"2.0","method":"test_body","params":["param"]}');
       });
@@ -84,7 +85,7 @@ describe('send', (): void => {
     return createWs()
       .send('test_error', [])
       .catch((error): void => {
-        expect(error.message).toMatch(/666: error/);
+        expect((error as Error).message).toMatch(/666: error/);
       });
   });
 

packages/rpc-provider/test/mockHttp.ts

@@ -2,6 +2,8 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
+/* eslint-disable */
+
 import nock from 'nock';
 
 const TEST_HTTP_URL = 'http://localhost:9944';

packages/rpc-provider/test/mockWs.ts

@@ -7,7 +7,7 @@ import { Server } from 'mock-socket';
 const TEST_WS_URL = 'ws://localhost:9955';
 
 interface Scope {
-  body: { [index: string]: {} };
+  body: { [index: string]: Record<string, any> };
   requests: number;
   server: Server;
   done: any;
@@ -24,7 +24,7 @@ interface ErrorDef {
 interface ReplyDef {
   id: number;
   reply: {
-    result: any;
+    result: unknown;
   };
 }
 
@@ -50,7 +50,7 @@ function createReply ({ id, reply: { result } }: ReplyDef): any {
 }
 
 // scope definition returned
-function mockWs (requests: { method: string }[], wsUrl: string = TEST_WS_URL): Scope {
+function mockWs (requests: ({ method: string } & ErrorDef)[], wsUrl: string = TEST_WS_URL): Scope {
   const server = new Server(wsUrl);
 
   let requestCount = 0;
@@ -68,11 +68,13 @@ function mockWs (requests: { method: string }[], wsUrl: string = TEST_WS_URL): S
   server.on('connection', (socket): void => {
     // FIXME This whole any mess is a mess
     socket.on('message', (body: any): void => {
-      const request = requests[requestCount];
-      const response = (request as any).error
-        ? createError(request as any)
-        : createReply(request as any);
+      const request: any = requests[requestCount];
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-member-access
+      const response: any = request.error
+        ? createError(request)
+        : createReply(request);
 
+      // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment,@typescript-eslint/no-unsafe-member-access
       scope.body[request.method] = body;
       requestCount++;
 

packages/typegen/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@polkadot/typegen",
-  "version": "1.15.1",
+  "version": "1.16.1",
   "description": "Type generation scripts",
   "main": "index.js",
   "bin": {
@@ -36,11 +36,11 @@
     "@babel/core": "^7.9.6",
     "@babel/register": "^7.9.0",
     "@babel/runtime": "^7.9.6",
-    "@polkadot/api": "1.15.1",
-    "@polkadot/metadata": "1.15.1",
-    "@polkadot/rpc-provider": "1.15.1",
-    "@polkadot/types": "1.15.1",
-    "@polkadot/util": "^2.10.1",
+    "@polkadot/api": "1.16.1",
+    "@polkadot/metadata": "1.16.1",
+    "@polkadot/rpc-provider": "1.16.1",
+    "@polkadot/types": "1.16.1",
+    "@polkadot/util": "^2.11.1",
     "handlebars": "^4.7.6",
     "websocket": "^1.0.31",
     "yargs": "^15.3.1"

packages/typegen/src/extractChain.ts

@@ -19,7 +19,7 @@ async function run (ws: string): Promise<void> {
   ]);
 
   // output the chain info, for easy re-use
-  console.error(`// Generated via 'yarn run chain:info ${ws}'\n\nexport default {\n  chain: '${chain.toString()}',\n  genesisHash: '${api.genesisHash.toHex()}',\n  specVersion: ${api.runtimeVersion.specVersion.toNumber()},\n  ss58Format: ${props.ss58Format.unwrapOr(42)},\n  tokenDecimals: ${props.tokenDecimals.unwrapOr(0)},\n  tokenSymbol: '${props.tokenSymbol.unwrapOr('UNIT')}',\n  metaCalls: '${Buffer.from(api.runtimeMetadata.asCallsOnly.toU8a()).toString('base64')}'\n};`);
+  console.error(`// Generated via 'yarn run chain:info ${ws}'\n\nexport default {\n  chain: '${chain.toString()}',\n  genesisHash: '${api.genesisHash.toHex()}',\n  specVersion: ${api.runtimeVersion.specVersion.toNumber()},\n  ss58Format: ${props.ss58Format.unwrapOr(42).toString()},\n  tokenDecimals: ${props.tokenDecimals.unwrapOr(0).toString()},\n  tokenSymbol: '${props.tokenSymbol.unwrapOr('UNIT').toString()}',\n  metaCalls: '${Buffer.from(api.runtimeMetadata.asCallsOnly.toU8a()).toString('base64')}'\n};`);
 
   // show any missing types
   api.runtimeMetadata.getUniqTypes(false);

packages/typegen/src/fromChain.ts

@@ -12,13 +12,13 @@ import generateQuery from './generate/query';
 import generateTx from './generate/tx';
 import { HEADER, writeFile } from './util';
 
-let websocket: any = null;
+let websocket: WebSocket;
 
 function generate (metaHex: string, pkg: string | undefined, output: string, isStrict?: boolean): void {
   console.log(`Generating from metadata, ${formatNumber((metaHex.length - 2) / 2)} bytes`);
 
   const extraTypes = pkg
-    ? { [pkg]: require(path.join(process.cwd(), output, 'definitions')) }
+    ? { [pkg]: require(path.join(process.cwd(), output, 'definitions')) as Record<string, any> }
     : {};
 
   generateConst(path.join(process.cwd(), output, 'augment-api-consts.ts'), metaHex, extraTypes, isStrict);
@@ -38,7 +38,7 @@ function generate (metaHex: string, pkg: string | undefined, output: string, isS
   process.exit(0);
 }
 
-function onSocketClose (event: any): void {
+function onSocketClose (event: { code: number; reason: string }): void {
   console.error(`disconnected, code: '${event.code}' reason: '${event.reason}'`);
 
   process.exit(1);
@@ -89,6 +89,7 @@ export default function main (): void {
         websocket.onopen = onSocketOpen;
 
         websocket.onmessage = (message: any): void => {
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
           generate(JSON.parse(message.data).result, pkg, output, isStrict);
         };
       })
@@ -96,6 +97,7 @@ export default function main (): void {
         process.exit(1);
       });
   } else {
+    // eslint-disable-next-line @typescript-eslint/no-unsafe-member-access
     generate(require(path.join(process.cwd(), endpoint)).result, pkg, output, isStrict);
   }
 }

packages/typegen/src/fromDefs.ts

@@ -24,10 +24,10 @@ export default function main (): void {
   }).argv;
 
   // eslint-disable-next-line @typescript-eslint/no-var-requires
-  const userDefs = require(path.join(process.cwd(), input, 'definitions.ts'));
+  const userDefs = require(path.join(process.cwd(), input, 'definitions.ts')) as Record<string, any>;
   const userKeys = Object.keys(userDefs);
   const filteredBase = Object
-    .entries(substrateDefs)
+    .entries(substrateDefs as Record<string, unknown>)
     .filter(([key]) => {
       if (userKeys.includes(key)) {
         console.warn(`Override found for ${key} in user types, ignoring in @polkadot/types`);
@@ -37,7 +37,7 @@ export default function main (): void {
 
       return true;
     })
-    .reduce((defs: any, [key, value]) => {
+    .reduce((defs: Record<string, any>, [key, value]) => {
       defs[key] = value;
 
       return defs;

packages/typegen/src/generate/consts.ts

@@ -18,7 +18,7 @@ const generateForMetaTemplate = Handlebars.compile(template);
 /** @internal */
 function generateForMeta (meta: Metadata, dest: string, extraTypes: Record<string, Record<string, { types: Record<string, any> }>>, isStrict: boolean): void {
   writeFile(dest, (): string => {
-    const allTypes: Record<string, Record<string, { types: Record<string, any> }>> = { '@polkadot/types/interfaces': defaultDefs, ...extraTypes };
+    const allTypes: Record<string, Record<string, { types: Record<string, unknown> }>> = { '@polkadot/types/interfaces': defaultDefs, ...extraTypes };
     const imports = createImports(allTypes);
     const allDefs = Object.entries(allTypes).reduce((defs, [path, obj]) => {
       return Object.entries(obj).reduce((defs, [key, value]) => ({ ...defs, [`${path}/${key}`]: value }), defs);

packages/typegen/src/generate/interfaceRegistry.ts

@@ -9,6 +9,7 @@ import * as defaultDefinitions from '@polkadot/types/interfaces/definitions';
 import * as defaultPrimitives from '@polkadot/types/primitive';
 
 import { createImports, getDerivedTypes, readTemplate, setImports, writeFile } from '../util';
+import { ModuleTypes } from '../util/imports';
 
 const primitiveClasses = {
   ...defaultPrimitives,
@@ -19,9 +20,9 @@ const template = readTemplate('interfaceRegistry');
 const generateInterfaceTypesTemplate = Handlebars.compile(template);
 
 /** @internal */
-export function generateInterfaceTypes (importDefinitions: { [importPath: string]: object }, dest: string): void {
+export function generateInterfaceTypes (importDefinitions: { [importPath: string]: Record<string, ModuleTypes> }, dest: string): void {
   writeFile(dest, (): string => {
-    Object.entries(importDefinitions).reduce((acc, def) => Object.assign(acc, def), {} as object);
+    Object.entries(importDefinitions).reduce((acc, def) => Object.assign(acc, def), {});
 
     const imports = createImports(importDefinitions);
     const definitions = imports.definitions;
@@ -46,7 +47,8 @@ export function generateInterfaceTypes (importDefinitions: { [importPath: string
 
       uniqueTypes.forEach((type) => {
         existingTypes[type] = true;
-        items.push(...getDerivedTypes(definitions, type, types[type], imports));
+
+        items.push(...getDerivedTypes(definitions, type, types[type] as string, imports));
       });
     });
 

packages/typegen/src/generate/query.ts

@@ -15,10 +15,11 @@ import { TypeRegistry } from '@polkadot/types/create';
 import { stringCamelCase } from '@polkadot/util';
 
 import { TypeImports, createImports, compareName, formatType, getSimilarTypes, readTemplate, registerDefinitions, setImports, writeFile } from '../util';
+import { ModuleTypes } from '../util/imports';
 
 // From a storage entry metadata, we return [args, returnType]
 /** @internal */
-function entrySignature (allDefs: object, registry: Registry, storageEntry: StorageEntryMetadataLatest, imports: TypeImports): [string, string] {
+function entrySignature (allDefs: Record<string, ModuleTypes>, registry: Registry, storageEntry: StorageEntryMetadataLatest, imports: TypeImports): [string, string] {
   const format = (type: string): string => formatType(allDefs, type, imports);
   const outputType = unwrapStorageType(storageEntry.type, storageEntry.modifier.isOptional);
 
@@ -59,7 +60,7 @@ function entrySignature (allDefs: object, registry: Registry, storageEntry: Stor
     ];
   }
 
-  throw new Error(`entryArgs: Cannot parse args of entry ${storageEntry.name}`);
+  throw new Error(`entryArgs: Cannot parse args of entry ${storageEntry.name.toString()}`);
 }
 
 const template = readTemplate('query');

packages/typegen/src/generate/rpc.ts

@@ -60,7 +60,8 @@ export default function generateRpcTypes (dest = 'packages/api/src/augment/rpc.t
 
         if (args === undefined) {
           setImports(allDefs, imports, [def.type]);
-          args = def.params.map((param: any) => {
+
+          args = def.params.map((param) => {
             const similarTypes = getSimilarTypes(definitions, registry, param.type, imports);
 
             setImports(allDefs, imports, [param.type, ...similarTypes]);

packages/typegen/src/generate/tsDef.ts

@@ -2,14 +2,14 @@
 // This software may be modified and distributed under the terms
 // of the Apache-2.0 license. See the LICENSE file for details.
 
-import Handlebars from 'handlebars';
-
 import { TypeDef, TypeDefInfo } from '@polkadot/types/create/types';
+import { ModuleTypes } from '../util/imports';
 
+import Handlebars from 'handlebars';
 import path from 'path';
 import { getTypeDef } from '@polkadot/types/create';
 import * as defaultDefinitions from '@polkadot/types/interfaces/definitions';
-import { isString, stringCamelCase, stringUpperFirst } from '@polkadot/util';
+import { isString, stringCamelCase, stringUpperFirst, assert } from '@polkadot/util';
 
 import { TypeImports, createImports, exportInterface, exportType, readTemplate, formatType, setImports, writeFile } from '../util';
 
@@ -19,7 +19,7 @@ interface Imports extends TypeImports {
 
 // helper to generate a `readonly <Name>: <Type>;` getter
 /** @internal */
-export function createGetter (definitions: object, name = '', type: string, imports: TypeImports): string {
+export function createGetter (definitions: Record<string, ModuleTypes>, name = '', type: string, imports: TypeImports): string {
   setImports(definitions, imports, [type]);
 
   return `  readonly ${name}: ${type};\n`;
@@ -27,12 +27,12 @@ export function createGetter (definitions: object, name = '', type: string, impo
 
 /** @internal */
 // eslint-disable-next-line @typescript-eslint/no-unused-vars
-function errorUnhandled (definitions: object, def: TypeDef, imports: TypeImports): string {
-  throw new Error(`Generate: ${name}: Unhandled type ${TypeDefInfo[def.info]}`);
+function errorUnhandled (definitions: Record<string, ModuleTypes>, def: TypeDef, imports: TypeImports): string {
+  throw new Error(`Generate: ${def.name || ''}: Unhandled type ${TypeDefInfo[def.info]}`);
 }
 
 /** @internal */
-function tsExport (definitions: object, def: TypeDef, imports: TypeImports): string {
+function tsExport (definitions: Record<string, ModuleTypes>, def: TypeDef, imports: TypeImports): string {
   return exportInterface(def.name, formatType(definitions, def, imports));
 }
 
@@ -46,7 +46,7 @@ const tsPlain = tsExport;
 const tsTuple = tsExport;
 
 /** @internal */
-function tsEnum (definitions: object, { name: enumName, sub }: TypeDef, imports: TypeImports): string {
+function tsEnum (definitions: Record<string, ModuleTypes>, { name: enumName, sub }: TypeDef, imports: TypeImports): string {
   setImports(definitions, imports, ['Enum']);
 
   const keys = (sub as TypeDef[]).map(({ info, name = '', type }): string => {
@@ -64,21 +64,21 @@ function tsEnum (definitions: object, { name: enumName, sub }: TypeDef, imports:
         return `${isGetter}${asGetter}`;
 
       default:
-        throw new Error(`Enum: ${enumName}: Unhandled type ${TypeDefInfo[info]}`);
+        throw new Error(`Enum: ${enumName || 'undefined'}: Unhandled type ${TypeDefInfo[info]}`);
     }
   });
 
   return exportInterface(enumName, 'Enum', keys.join(''));
 }
 
-function tsInt (definitions: object, def: TypeDef, imports: TypeImports, type: 'Int' | 'UInt' = 'Int'): string {
+function tsInt (definitions: Record<string, ModuleTypes>, def: TypeDef, imports: TypeImports, type: 'Int' | 'UInt' = 'Int'): string {
   setImports(definitions, imports, [type]);
 
   return exportInterface(def.name, type);
 }
 
 /** @internal */
-function tsResultGetter (definitions: object, resultName = '', getter: 'Ok' | 'Error', def: TypeDef, imports: TypeImports): string {
+function tsResultGetter (definitions: Record<string, ModuleTypes>, resultName = '', getter: 'Ok' | 'Error', def: TypeDef, imports: TypeImports): string {
   const { info, type } = def;
   const asGetter = type === 'Null'
     ? ''
@@ -97,7 +97,7 @@ function tsResultGetter (definitions: object, resultName = '', getter: 'Ok' | 'E
 }
 
 /** @internal */
-function tsResult (definitions: object, def: TypeDef, imports: TypeImports): string {
+function tsResult (definitions: Record<string, ModuleTypes>, def: TypeDef, imports: TypeImports): string {
   const [okDef, errorDef] = (def.sub as TypeDef[]);
   const inner = [
     tsResultGetter(definitions, def.name, 'Error', errorDef, imports),
@@ -110,18 +110,20 @@ function tsResult (definitions: object, def: TypeDef, imports: TypeImports): str
 }
 
 /** @internal */
-function tsSet (definitions: object, { name: setName, sub }: TypeDef, imports: TypeImports): string {
+function tsSet (definitions: Record<string, ModuleTypes>, { name: setName, sub }: TypeDef, imports: TypeImports): string {
   setImports(definitions, imports, ['Set']);
 
-  const types = (sub as TypeDef[]).map(({ name }): string =>
-    createGetter(definitions, `is${name}`, 'boolean', imports)
-  );
+  const types = (sub as TypeDef[]).map(({ name }): string => {
+    assert(!!name, 'Invalid TypeDef found, no name specified');
+
+    return createGetter(definitions, `is${name}`, 'boolean', imports);
+  });
 
   return exportInterface(setName, 'Set', types.join(''));
 }
 
 /** @internal */
-function tsStruct (definitions: object, { name: structName, sub }: TypeDef, imports: TypeImports): string {
+function tsStruct (definitions: Record<string, ModuleTypes>, { name: structName, sub }: TypeDef, imports: TypeImports): string {
   setImports(definitions, imports, ['Struct']);
 
   const keys = (sub as TypeDef[]).map((typedef): string => {
@@ -134,12 +136,12 @@ function tsStruct (definitions: object, { name: structName, sub }: TypeDef, impo
 }
 
 /** @internal */
-function tsUInt (definitions: object, def: TypeDef, imports: TypeImports): string {
+function tsUInt (definitions: Record<string, ModuleTypes>, def: TypeDef, imports: TypeImports): string {
   return tsInt(definitions, def, imports, 'UInt');
 }
 
 /** @internal */
-function tsVec (definitions: object, def: TypeDef, imports: TypeImports): string {
+function tsVec (definitions: Record<string, ModuleTypes>, def: TypeDef, imports: TypeImports): string {
   const type = (def.sub as TypeDef).type;
 
   if (def.info === TypeDefInfo.VecFixed && type === 'u8') {
@@ -152,7 +154,7 @@ function tsVec (definitions: object, def: TypeDef, imports: TypeImports): string
 }
 
 /** @internal */
-function generateInterfaces (definitions: object, { types }: { types: Record<string, any> }, imports: Imports): [string, string][] {
+function generateInterfaces (definitions: Record<string, ModuleTypes>, { types }: { types: Record<string, any> }, imports: Imports): [string, string][] {
   // handlers are defined externally to use - this means that when we do a
   // `generators[typedef.info](...)` TS will show any unhandled types. Rather
   // we are being explicit in having no handlers where we do not support (yet)
@@ -194,7 +196,7 @@ const templateTypes = readTemplate('tsDef/types');
 const generateTsDefTypesTemplate = Handlebars.compile(templateTypes);
 
 /** @internal */
-function generateTsDefFor (importDefinitions: { [importPath: string]: object }, defName: string, { types }: { types: Record<string, any> }, outputDir: string): void {
+function generateTsDefFor (importDefinitions: { [importPath: string]: Record<string, ModuleTypes> }, defName: string, { types }: { types: Record<string, any> }, outputDir: string): void {
   const imports = { ...createImports(importDefinitions, { types }), interfaces: [] } as Imports;
   const definitions = imports.definitions;
   const interfaces = generateInterfaces(definitions, { types }, imports);
@@ -218,7 +220,7 @@ function generateTsDefFor (importDefinitions: { [importPath: string]: object },
 }
 
 /** @internal */
-export function generateTsDef (importDefinitions: { [importPath: string]: object }, outputDir: string, generatingPackage: string): void {
+export function generateTsDef (importDefinitions: { [importPath: string]: Record<string, ModuleTypes> }, outputDir: string, generatingPackage: string): void {
   writeFile(path.join(outputDir, 'types.ts'), (): string => {
     const definitions = importDefinitions[generatingPackage];
 

packages/typegen/src/generate/tx.ts

@@ -39,7 +39,7 @@ function generateForMeta (registry: Registry, meta: Metadata, dest: string, extr
 
     const modules = meta.asLatest.modules
       .sort(compareName)
-      .filter(({ calls }) => calls.unwrapOr([]).length)
+      .filter(({ calls }) => calls.unwrapOr([]).length !== 0)
       .map(({ calls, name }) => {
         setImports(allDefs, imports, ['Call', 'Extrinsic', 'SubmittableExtrinsic']);
 

packages/typegen/src/metadataMd.ts

@@ -3,6 +3,7 @@
 // of the Apache-2.0 license. See the LICENSE file for details.
 
 import { MetadataLatest } from '@polkadot/types/interfaces/metadata';
+import { Codec } from '@polkadot/types/types';
 
 import fs from 'fs';
 import Decorated from '@polkadot/metadata/Decorated';
@@ -81,8 +82,9 @@ function renderPage (page: Page): string {
 
       Object.keys(item).filter((i) => i !== 'name').forEach((bullet) => {
         md += `\n- **${bullet}**: ${
+          // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
           item[bullet] instanceof Vec
-            ? documentationVecToMarkdown(item[bullet] as Vec<Text>, 2)
+            ? documentationVecToMarkdown(item[bullet] as Vec<Text>, 2).toString()
             : item[bullet]
         }`;
       });
@@ -94,8 +96,9 @@ function renderPage (page: Page): string {
   return md;
 }
 
-function sortByName<T extends { name: any }> (a: T, b: T): number {
+function sortByName<T extends { name: Codec | string }> (a: T, b: T): number {
   // case insensitive (all-uppercase) sorting
+  // eslint-disable-next-line @typescript-eslint/no-unsafe-return,@typescript-eslint/no-unsafe-call,@typescript-eslint/no-unsafe-member-access
   return a.name.toString().toUpperCase().localeCompare(b.name.toString().toUpperCase());
 }
 
@@ -119,6 +122,7 @@ function addRpc (): string {
             .map((methodName) => {
               const method = section.rpc[methodName];
               const args = method.params.map(({ isOptional, name, type }: any): string => {
+                // eslint-disable-next-line @typescript-eslint/restrict-plus-operands
                 return name + (isOptional ? '?' : '') + ': `' + type + '`';
               }).join(', ');
               const type = '`' + method.type + '`';
@@ -155,7 +159,7 @@ function addConstants (metadata: MetadataLatest): string {
 
               return {
                 interface: '`' + `api.consts.${sectionName}.${methodName}` + '`',
-                name: `${methodName}: ` + '`' + func.type + '`',
+                name: `${methodName}: ` + '`' + func.type.toString() + '`',
                 ...(func.documentation.length && { summary: func.documentation })
               };
             }),
@@ -196,7 +200,8 @@ function addStorage (metadata: MetadataLatest): string {
       };
     });
 
-  const knownSection = JSON.parse(fs.readFileSync('docs/substrate/storage-known-section.json', 'utf8'));
+  // eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
+  const knownSection: any = JSON.parse(fs.readFileSync('docs/substrate/storage-known-section.json', 'utf8'));
 
   return renderPage({
     description: DESC_STORAGE,
@@ -211,7 +216,7 @@ function addExtrinsics (metadata: MetadataLatest): string {
     description: DESC_EXTRINSICS,
     sections: metadata.modules
       .sort(sortByName)
-      .filter((meta) => !meta.calls.isNone && meta.calls.unwrap().length)
+      .filter((meta) => !meta.calls.isNone && meta.calls.unwrap().length !== 0)
       .map((meta) => {
         const sectionName = stringCamelCase(meta.name.toString());
 
@@ -220,7 +225,7 @@ function addExtrinsics (metadata: MetadataLatest): string {
             .sort(sortByName)
             .map((func) => {
               const methodName = stringCamelCase(func.name.toString());
-              const args = Call.filterOrigin(func).map(({ name, type }): string => `${name}: ` + '`' + type + '`').join(', ');
+              const args = Call.filterOrigin(func).map(({ name, type }) => `${name.toString()}: ` + '`' + type.toString() + '`').join(', ');
 
               return {
                 interface: '`' + `api.tx.${sectionName}.${methodName}` + '`',
@@ -241,13 +246,13 @@ function addEvents (metadata: MetadataLatest): string {
     description: DESC_EVENTS,
     sections: metadata.modules
       .sort(sortByName)
-      .filter((meta) => !meta.events.isNone && meta.events.unwrap().length)
+      .filter((meta) => !meta.events.isNone && meta.events.unwrap().length !== 0)
       .map((meta) => ({
         items: meta.events.unwrap()
           .sort(sortByName)
           .map((func) => {
             const methodName = func.name.toString();
-            const args = func.args.map((type): string => '`' + type + '`').join(', ');
+            const args = func.args.map((type): string => '`' + type.toString() + '`').join(', ');
 
             return {
               name: `${methodName}(${args})`,

packages/typegen/src/util/derived.ts

@@ -24,7 +24,7 @@ import { isChildClass } from '@polkadot/util';
 
 import { isCompactEncodable } from './class';
 import { formatType } from './formatting';
-import { setImports, TypeImports } from './imports';
+import { setImports, ModuleTypes, TypeImports } from './imports';
 
 function arrayToStrType (arr: string[]): string {
   return `${arr.map((c): string => `'${c}'`).join(' | ')}`;
@@ -34,9 +34,9 @@ const voteConvictions = arrayToStrType(AllConvictions);
 
 // From `T`, generate `Compact<T>, Option<T>, Vec<T>`
 /** @internal */
-export function getDerivedTypes (definitions: object, type: string, primitiveName: string, imports: TypeImports): string[] {
+export function getDerivedTypes (definitions: Record<string, ModuleTypes>, type: string, primitiveName: string, imports: TypeImports): string[] {
   // `primitiveName` represents the actual primitive type our type is mapped to
-  const isCompact = isCompactEncodable((primitiveClasses as any)[primitiveName]);
+  const isCompact = isCompactEncodable((primitiveClasses as Record<string, any>)[primitiveName]);
   const def = getTypeDef(type);
 
   setImports(definitions, imports, ['Option', 'Vec', isCompact ? 'Compact' : '']);
@@ -73,7 +73,7 @@ export function getDerivedTypes (definitions: object, type: string, primitiveNam
 // - if param instanceof AbstractInt, then param: u64 | Uint8array | AnyNumber
 // etc
 /** @internal */
-export function getSimilarTypes (definitions: object, registry: Registry, _type: string, imports: TypeImports): string[] {
+export function getSimilarTypes (definitions: Record<string, ModuleTypes>, registry: Registry, _type: string, imports: TypeImports): string[] {
   const typeParts = _type.split('::');
   const type = typeParts[typeParts.length - 1];
   const possibleTypes = [type];

packages/typegen/src/util/formatting.ts

@@ -9,9 +9,17 @@ import { TypeDef, TypeDefInfo } from '@polkadot/types/create/types';
 import { getTypeDef } from '@polkadot/types/create';
 import { paramsNotation } from '@polkadot/types/codec/utils';
 
-import { setImports, TypeImports } from './imports';
+import { setImports, ModuleTypes, TypeImports } from './imports';
 import { readTemplate } from './file';
 
+interface This {
+  imports: TypeImports;
+  types: {
+    file: string;
+    types: string[];
+  }[]
+}
+
 const TYPES_NON_PRIMITIVE = ['Metadata'];
 
 export const HEADER = (type: 'chain' | 'defs'): string => `// Auto-generated via \`yarn polkadot-types-from-${type}\`, do not edit\n/* eslint-disable */\n\n`;
@@ -23,9 +31,8 @@ Handlebars.registerPartial({
 
 Handlebars.registerHelper({
   imports () {
-    const { imports, types } = this as any;
-
-    return [
+    const { imports, types } = this as unknown as This;
+    const defs = [
       {
         file: '@polkadot/types/types',
         types: Object.keys(imports.typesTypes)
@@ -34,7 +41,7 @@ Handlebars.registerHelper({
         file: '@polkadot/types/codec',
         types: Object
           .keys(imports.codecTypes)
-          .filter((name): boolean => name !== 'Tuple')
+          .filter((name) => name !== 'Tuple')
       },
       {
         file: '@polkadot/types/extrinsic',
@@ -48,25 +55,27 @@ Handlebars.registerHelper({
         file: '@polkadot/types/primitive',
         types: Object
           .keys(imports.primitiveTypes)
-          .filter((name): boolean => !TYPES_NON_PRIMITIVE.includes(name))
+          .filter((name) => !TYPES_NON_PRIMITIVE.includes(name))
       },
       {
         file: '@polkadot/types',
         types: Object
           .keys(imports.primitiveTypes)
-          .filter((name): boolean => TYPES_NON_PRIMITIVE.includes(name))
+          .filter((name) => TYPES_NON_PRIMITIVE.includes(name))
       },
       ...types
-    ].reduce((result, { file, types }): string => {
+    ];
+
+    return defs.reduce((result, { file, types }): string => {
       return types.length
         ? `${result}import { ${types.sort().join(', ')} } from '${file}';\n`
         : result;
     }, '');
   },
-  trim (options) {
+  trim (options: { fn: (self: unknown) => string }) {
     return options.fn(this).trim();
   },
-  upper (options) {
+  upper (options: { fn: (self: unknown) => string }) {
     return options.fn(this).toUpperCase();
   }
 });
@@ -172,7 +181,7 @@ function formatVec (inner: string): string {
  * Correctly format a given type
  */
 /** @internal */
-export function formatType (definitions: object, type: string | TypeDef, imports: TypeImports): string {
+export function formatType (definitions: Record<string, ModuleTypes>, type: string | TypeDef, imports: TypeImports): string {
   let typeDef: TypeDef;
 
   if (typeof type === 'string') {

packages/typegen/src/util/imports.ts

@@ -10,6 +10,10 @@ import * as extrinsicClasses from '@polkadot/types/extrinsic';
 import * as genericClasses from '@polkadot/types/generic';
 import * as primitiveClasses from '@polkadot/types/primitive';
 
+export interface ModuleTypes {
+  types: Record<string, unknown>;
+}
+
 // these map all the codec and primitive types for import, see the TypeImports below. If
 // we have an unseen type, it is `undefined`/`false`, if we need to import it, it is `true`
 type TypeExist = Record<string, boolean>;
@@ -26,14 +30,14 @@ export interface TypeImports {
   localTypes: TypeExistMap; // `import {} from '../something'`
   primitiveTypes: TypeExist; // `import {} from '@polkadot/types/primitive`
   typesTypes: TypeExist; // `import {} from '@polkadot/types/types`
-  definitions: object; // all definitions
+  definitions: Record<string, ModuleTypes>; // all definitions
   typeToModule: Record<string, string>;
 }
 
 // Maps the types as found to the source location. This is used to generate the
 // imports in the output file, dep-duped and sorted
 /** @internal */
-export function setImports (allDefs: object, imports: TypeImports, types: string[]): void {
+export function setImports (allDefs: Record<string, ModuleTypes>, imports: TypeImports, types: string[]): void {
   const { codecTypes, extrinsicTypes, genericTypes, ignoredTypes, localTypes, primitiveTypes, typesTypes } = imports;
 
   types.forEach((type): void => {
@@ -41,13 +45,13 @@ export function setImports (allDefs: object, imports: TypeImports, types: string
       // do nothing
     } else if (['AnyNumber', 'CallFunction', 'Codec', 'IExtrinsic', 'ITuple'].includes(type)) {
       typesTypes[type] = true;
-    } else if ((codecClasses as any)[type]) {
+    } else if ((codecClasses as Record<string, unknown>)[type]) {
       codecTypes[type] = true;
-    } else if ((extrinsicClasses as any)[type]) {
+    } else if ((extrinsicClasses as Record<string, unknown>)[type]) {
       extrinsicTypes[type] = true;
-    } else if ((genericClasses as any)[type]) {
+    } else if ((genericClasses as Record<string, unknown>)[type]) {
       genericTypes[type] = true;
-    } else if ((primitiveClasses as any)[type] || type === 'Metadata') {
+    } else if ((primitiveClasses as Record<string, unknown>)[type] || type === 'Metadata') {
       primitiveTypes[type] = true;
     } else if (type.includes('<') || type.includes('(') || (type.includes('[') && !type.includes('|'))) {
       // If the type is a bit special (tuple, fixed u8, nested type...), then we
@@ -84,8 +88,8 @@ export function setImports (allDefs: object, imports: TypeImports, types: string
 
 // Create an Imports object, can be pre-filled with `ignoredTypes`
 /** @internal */
-export function createImports (importDefinitions: Record<string, object>, { types }: { types: Record<string, any> } = { types: {} }): TypeImports {
-  const definitions = {} as Record<string, object>;
+export function createImports (importDefinitions: Record<string, Record<string, ModuleTypes>>, { types }: ModuleTypes = { types: {} }): TypeImports {
+  const definitions = {} as Record<string, ModuleTypes>;
   const typeToModule = {} as Record<string, string>;
 
   Object.entries(importDefinitions).forEach(([packagePath, packageDef]): void => {