Align Data.Raw decoding with Substrate (32-bytes) (#3573)

* Align Data.Raw decoding with Substrate (32-bytes)

* CHANGELOG

* Encoding test updates

* provider.disconnect

* Adjust provider tests

* Unique connection URLs

* Dangling tests

* detectOpenHandles

* Additional

* Remove rx test (catered for by Promise wrap)

* Additional cleanups to tests

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

@@ -12,10 +12,16 @@ import { RpcCore } from '.';
 describe('Cached Observables', (): void => {
   const registry = new TypeRegistry();
   let rpc: RpcCore & RpcInterface;
+  let provider: MockProvider;
   const keyring = createTestPairs();
 
   beforeEach((): void => {
-    rpc = new RpcCore('123', registry, new MockProvider(registry)) as (RpcCore & RpcInterface);
+    provider = new MockProvider(registry);
+    rpc = new RpcCore('123', registry, provider) as (RpcCore & RpcInterface);
+  });
+
+  afterEach(async () => {
+    await provider.disconnect();
   });
 
   it('creates a single observable for subscriptions (multiple calls)', (): void => {

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

@@ -16,8 +16,9 @@ describe('Api', (): void => {
     ).toThrow(/Expected Provider/);
   });
 
-  it('allows for the definition of user RPCs', (): void => {
-    const rpc = new RpcCore('567', registry, new MockProvider(registry), {
+  it('allows for the definition of user RPCs', async () => {
+    const provider = new MockProvider(registry);
+    const rpc = new RpcCore('567', registry, provider, {
       testing: {
         foo: {
           description: 'foo',
@@ -42,5 +43,7 @@ describe('Api', (): void => {
       section: 'testing',
       type: 'Balance'
     });
+
+    await provider.disconnect();
   });
 });

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

@@ -13,9 +13,15 @@ import { RpcCore } from '.';
 describe('replay', (): void => {
   const registry = new TypeRegistry();
   let rpc: RpcCore & RpcInterface;
+  let provider: MockProvider;
 
   beforeEach((): void => {
-    rpc = new RpcCore('653', registry, new MockProvider(registry)) as (RpcCore & RpcInterface);
+    provider = new MockProvider(registry);
+    rpc = new RpcCore('653', registry, provider) as (RpcCore & RpcInterface);
+  });
+
+  afterEach(async () => {
+    await provider.disconnect();
   });
 
   it('subscribes via the rpc section', (done): void => {

packages/rpc-core/src/util/drr.spec.ts

@@ -6,28 +6,39 @@ import { of, timer } from '@polkadot/x-rxjs';
 import { drr } from '.';
 
 describe('drr', (): void => {
+  beforeEach((): void => {
+    jest.setTimeout(15000);
+  });
+
   it('should not fire twice the same value', (done): void => {
     let count = 0;
 
-    of(1, 1).pipe(drr()).subscribe((): void => { ++count; });
+    const sub = of(1, 1).pipe(drr({ delay: 500 })).subscribe((): void => { ++count; });
 
     setTimeout((): void => {
       expect(count).toBe(1);
-      done();
+      sub.unsubscribe();
+
+      setTimeout(done, 2000);
     }, 50);
   });
 
   it('should be a ReplaySubject(1)', (done): void => {
-    const obs = timer(0, 100).pipe(drr()); // Starts at 0, increments every 100ms
+    const obs = timer(0, 100).pipe(drr({ delay: 500 })); // Starts at 0, increments every 100ms
 
-    obs.subscribe(); // Fire the observable
+    const sub = obs.subscribe(); // Fire the observable
 
     // Subscribe another time after some time, i.e. after the observable has fired
     setTimeout((): void => {
-      obs.subscribe((value): void => {
+      const sub = obs.subscribe((value): void => {
         expect(value > 1).toBe(true);
-        done();
+
+        setTimeout(done, 2000);
       });
+
+      sub.unsubscribe();
     }, 500);
+
+    sub.unsubscribe();
   });
 });