Skip to content

Commit

Permalink
fix: imports
Browse files Browse the repository at this point in the history
  • Loading branch information
faustbrian committed Apr 26, 2019
1 parent 15d39da commit ef6a747
Show file tree
Hide file tree
Showing 2 changed files with 17 additions and 9 deletions.
2 changes: 1 addition & 1 deletion packages/core-transaction-pool/src/connection.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ import { dato, Dato } from "@faustbrian/dato";
import assert from "assert";
import { ITransactionsProcessed } from "./interfaces";
import { Memory } from "./memory";
import { SequentialTransaction } from "./sequential-transaction";
import { Processor } from "./processor";
import { SequentialTransaction } from "./sequential-transaction";
import { Storage } from "./storage";
import { WalletManager } from "./wallet-manager";

Expand Down
24 changes: 16 additions & 8 deletions packages/core-transaction-pool/src/memory.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
import assert from "assert";
import { app } from "@arkecosystem/core-container";
import { State } from "@arkecosystem/core-interfaces";
import { Enums, Interfaces, Utils } from "@arkecosystem/crypto";
import assert from "assert";
import { SequentialTransaction } from "./sequential-transaction";
import { State } from "@arkecosystem/core-interfaces";
import { app } from "@arkecosystem/core-container";

export class Memory {
private sequence: number = 0;
Expand Down Expand Up @@ -111,7 +111,11 @@ export class Memory {
return new Set();
}

public remember(SequentialTransaction: SequentialTransaction, maxTransactionAge: number, databaseReady?: boolean): void {
public remember(
SequentialTransaction: SequentialTransaction,
maxTransactionAge: number,
databaseReady?: boolean,
): void {
const transaction: Interfaces.ITransaction = SequentialTransaction.transaction;

assert.strictEqual(this.byId[transaction.id], undefined);
Expand Down Expand Up @@ -155,10 +159,11 @@ export class Memory {

if (type !== Enums.TransactionTypes.TimelockTransfer) {
const maxHeight: number = this.currentHeight() + maxTransactionAge;
if (typeof SequentialTransaction.transaction.data.expiration !== "number" ||
if (
typeof SequentialTransaction.transaction.data.expiration !== "number" ||
SequentialTransaction.transaction.data.expiration === 0 ||
SequentialTransaction.transaction.data.expiration > maxHeight) {

SequentialTransaction.transaction.data.expiration > maxHeight
) {
SequentialTransaction.transaction.data.expiration = maxHeight;
}
this.byExpiration.push(SequentialTransaction);
Expand Down Expand Up @@ -266,6 +271,9 @@ export class Memory {
}

private currentHeight(): number {
return app.resolvePlugin<State.IStateStorage>("state").getLastBlock().data.height;
return app
.resolvePlugin<State.IStateService>("state")
.getStore()
.getLastHeight();
}
}

0 comments on commit ef6a747

Please sign in to comment.