Skip to content

Commit

Permalink
clean up some unit tests
Browse files Browse the repository at this point in the history
  • Loading branch information
jerryfan01234 committed Aug 28, 2024
1 parent c9e4411 commit 8f8400c
Show file tree
Hide file tree
Showing 3 changed files with 35 additions and 63 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,13 @@ import {
} from '@dydxprotocol-indexer/postgres/build/__tests__/helpers/constants';
import Big from 'big.js';

const defaultWallet = {
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
};

describe('transfers-controller#V4', () => {
beforeAll(async () => {
await dbHelpers.migrate();
Expand All @@ -53,12 +60,7 @@ describe('transfers-controller#V4', () => {
createdAt: testConstants.createdDateTime.toISO(),
createdAtHeight: testConstants.createdHeight,
};
await WalletTable.create({
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
});
await WalletTable.create(defaultWallet);
await Promise.all([
TransferTable.create(testConstants.defaultTransfer),
TransferTable.create(transfer2),
Expand Down Expand Up @@ -179,12 +181,7 @@ describe('transfers-controller#V4', () => {
createdAt: testConstants.createdDateTime.toISO(),
createdAtHeight: testConstants.createdHeight,
};
await WalletTable.create({
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
});
await WalletTable.create(defaultWallet);
await Promise.all([
TransferTable.create(testConstants.defaultTransfer),
TransferTable.create(transfer2),
Expand Down Expand Up @@ -462,12 +459,7 @@ describe('transfers-controller#V4', () => {
createdAt: testConstants.createdDateTime.toISO(),
createdAtHeight: testConstants.createdHeight,
};
await WalletTable.create({
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
});
await WalletTable.create(defaultWallet);
await Promise.all([
TransferTable.create(testConstants.defaultTransfer),
TransferTable.create(transfer2),
Expand Down Expand Up @@ -588,12 +580,7 @@ describe('transfers-controller#V4', () => {
createdAt: testConstants.createdDateTime.toISO(),
createdAtHeight: testConstants.createdHeight,
};
await WalletTable.create({
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
});
await WalletTable.create(defaultWallet);
await Promise.all([
TransferTable.create(testConstants.defaultTransfer),
TransferTable.create(transfer2),
Expand Down Expand Up @@ -743,12 +730,7 @@ describe('transfers-controller#V4', () => {
createdAt: testConstants.createdDateTime.toISO(),
createdAtHeight: testConstants.createdHeight,
};
await WalletTable.create({
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
});
await WalletTable.create(defaultWallet);
await Promise.all([
TransferTable.create(testConstants.defaultTransfer),
TransferTable.create(transfer2),
Expand Down Expand Up @@ -831,12 +813,7 @@ describe('transfers-controller#V4', () => {
createdAt: createdDateTime.toISO(),
createdAtHeight: createdHeight,
};
await WalletTable.create({
address: testConstants.defaultWalletAddress,
totalTradingRewards: '0',
totalVolume: '0',
isWhitelistAffiliate: false,
});
await WalletTable.create(defaultWallet);
await Promise.all([
TransferTable.create(transferFromNonParent),
TransferTable.create(transferToNonParent),
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ import {
defaultTime,
defaultTradingRewardsEvent,
defaultTxHash,
defaultWalletAddress,
} from '../helpers/constants';
import { updateBlockCache } from '../../src/caches/block-cache';
import { createPostgresFunctions } from '../../src/helpers/postgres/postgres-functions';
Expand All @@ -38,6 +39,13 @@ import { intToSerializedInt } from '../helpers/conversion-helpers';

const defaultTransactionIndex: number = -2; // end block

const defaultWallet = {
address: defaultWalletAddress,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(0),
totalVolume: '0',
isWhitelistAffiliate: false,
};

describe('tradingRewardHandler', () => {
beforeAll(async () => {
await dbHelpers.migrate();
Expand Down Expand Up @@ -171,11 +179,10 @@ describe('tradingRewardHandler', () => {
const wallet: WalletFromDatabase | undefined = await WalletTable.findById(
testConstants.defaultWallet.address,
);

expect(wallet).toEqual({
address: testConstants.defaultWallet.address,
...defaultWallet,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(1_000_000_000),
totalVolume: '0',
isWhitelistAffiliate: false,
});
});

Expand All @@ -197,21 +204,17 @@ describe('tradingRewardHandler', () => {
});

await WalletTable.update({
address: testConstants.defaultWallet.address,
...defaultWallet,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(1_000_000_000),
totalVolume: '0',
isWhitelistAffiliate: false,
});

await onMessage(kafkaMessage);
const wallet: WalletFromDatabase | undefined = await WalletTable.findById(
testConstants.defaultWallet.address,
);
expect(wallet).toEqual({
address: testConstants.defaultWallet.address,
...defaultWallet,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(2_000_000_000),
totalVolume: '0',
isWhitelistAffiliate: false,
});
});
});
Expand Down
28 changes: 10 additions & 18 deletions indexer/services/ender/__tests__/handlers/transfer-handler.test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,13 @@ import {
import { updateBlockCache } from '../../src/caches/block-cache';
import { createPostgresFunctions } from '../../src/helpers/postgres/postgres-functions';

const defaultWallet = {
address: defaultWalletAddress,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(0),
totalVolume: '0',
isWhitelistAffiliate: false,
};

describe('transferHandler', () => {
beforeAll(async () => {
await dbHelpers.migrate();
Expand Down Expand Up @@ -303,12 +310,7 @@ describe('transferHandler', () => {
const wallet: WalletFromDatabase | undefined = await WalletTable.findById(
defaultWalletAddress,
);
expect(wallet).toEqual({
address: defaultWalletAddress,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(0),
totalVolume: '0',
isWhitelistAffiliate: false,
});
expect(wallet).toEqual(defaultWallet);
});

it('creates new deposit for previously non-existent subaccount', async () => {
Expand Down Expand Up @@ -357,12 +359,7 @@ describe('transferHandler', () => {
defaultRecipientSubaccountId,
);
expect(newRecipientSubaccount).toBeDefined();
expect(wallet).toEqual({
address: defaultWalletAddress,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(0),
totalVolume: '0',
isWhitelistAffiliate: false,
});
expect(wallet).toEqual(defaultWallet);
});

it('creates new withdrawal for existing subaccount', async () => {
Expand Down Expand Up @@ -412,12 +409,7 @@ describe('transferHandler', () => {
const wallet: WalletFromDatabase | undefined = await WalletTable.findById(
defaultWalletAddress,
);
expect(wallet).toEqual({
address: defaultWalletAddress,
totalTradingRewards: testConversionHelpers.denomToHumanReadableConversion(0),
totalVolume: '0',
isWhitelistAffiliate: false,
});
expect(wallet).toEqual(defaultWallet);
});

it('creates new transfer and the recipient subaccount', async () => {
Expand Down

0 comments on commit 8f8400c

Please sign in to comment.