fixup! test(e2e): hoist some utils out of rewards test

Author: mkazlauskas

packages/e2e/test/wallet/SingleAddressWallet/delegation-rewards.test.ts

@@ -5,7 +5,7 @@ import { TestWallet, getWallet } from '../../../src';
 import { assertTxIsValid, waitForWalletStateSettle } from '../../../../wallet/test/util';
 import { filter, firstValueFrom } from 'rxjs';
 import { logger } from '@cardano-sdk/util-dev';
-import { requestCoins, submitAndConfirm, transferCoins, waitForEpoch } from '../util';
+import { requestCoins, runningAgainstLocalNetwork, submitAndConfirm, transferCoins, waitForEpoch } from '../util';
 
 // Verify environment.
 export const env = envalid.cleanEnv(process.env, {
@@ -58,12 +58,7 @@ describe('delegation rewards', () => {
   });
 
   it('will receive rewards for delegated tADA and can spend them', async () => {
-    const { epochLength, slotLength } = await providers.networkInfoProvider.genesisParameters();
-
-    const estimatedTestDurationInEpochs = 4;
-    const localNetworkEpochDuration = 1000 * 0.2;
-    const estimatedTestDuration = epochLength * slotLength * estimatedTestDurationInEpochs;
-    if (estimatedTestDuration > localNetworkEpochDuration * estimatedTestDurationInEpochs) {
+    if (!(await runningAgainstLocalNetwork())) {
       return logger.fatal(
         "Skipping test 'will receive rewards for delegated tADA' as it should only run with a fast test network"
       );

packages/e2e/test/wallet/util.ts

@@ -19,7 +19,8 @@ import {
 } from 'rxjs';
 import { ObservableWallet, SignedTx, buildTx } from '@cardano-sdk/wallet';
 import { assertTxIsValid } from '../../../wallet/test/util';
-import { faucetProviderFactory } from '../../src';
+import { env } from './environment';
+import { faucetProviderFactory, networkInfoProviderFactory } from '../../src';
 import { logger } from '@cardano-sdk/util-dev';
 import sortBy from 'lodash/sortBy';
 
@@ -121,12 +122,12 @@ export const requestCoins = async ({ coins, wallet }: RequestCoinsProps) => {
   const [{ address }] = await firstValueFrom(wallet.addresses$);
   logger.info(`Address ${address.toString()} will be funded with ${coins} tLovelace.`);
 
-  const env = envalid.cleanEnv(process.env, {
+  const { FAUCET_PROVIDER, FAUCET_PROVIDER_PARAMS } = envalid.cleanEnv(process.env, {
     FAUCET_PROVIDER: envalid.str(),
     FAUCET_PROVIDER_PARAMS: envalid.json({ default: {} })
   });
 
-  const faucetProvider = await faucetProviderFactory.create(env.FAUCET_PROVIDER, env.FAUCET_PROVIDER_PARAMS, logger);
+  const faucetProvider = await faucetProviderFactory.create(FAUCET_PROVIDER, FAUCET_PROVIDER_PARAMS, logger);
   await faucetProvider.start();
   const healthCheck = await faucetProvider.healthCheck();
   if (!healthCheck.ok) throw new Error('Faucet provider could not be started.');
@@ -176,3 +177,20 @@ export const waitForEpoch = (wallet: Pick<ObservableWallet, 'currentEpoch$'>, wa
     )
   );
 };
+
+export const runningAgainstLocalNetwork = async () => {
+  const networkInfoProvider = await networkInfoProviderFactory.create(
+    env.NETWORK_INFO_PROVIDER,
+    env.NETWORK_INFO_PROVIDER_PARAMS,
+    logger
+  );
+  const { epochLength, slotLength } = await networkInfoProvider.genesisParameters();
+
+  const estimatedTestDurationInEpochs = 4;
+  const localNetworkEpochDuration = 1000 * 0.2;
+  const estimatedTestDuration = epochLength * slotLength * estimatedTestDurationInEpochs;
+  if (estimatedTestDuration > localNetworkEpochDuration * estimatedTestDurationInEpochs) {
+    return false;
+  }
+  return true;
+};