Fix pool workers

Author: sebastijankuzner

tests/functional/resync/source/pool-worker.ts

@@ -34,10 +34,13 @@ export class PoolWorker implements Contracts.TransactionPool.Worker {
 	}
 
 	public async getTransactions(options: Contracts.TransactionPool.GetBatchOptions): Promise<Contracts.TransactionPool.GetBatchResult> {
-		return {
+		const result =  {
 			remaining: 0,
 			transactions: (await this.poolQuery.getFromHighestPriority().all()).map((transaction) => transaction.toData()),
 		}
+
+		this.transactionPoolMempool.flush();
+		return result;
 	}
 
 	public async removeTransaction(address: string, hash: string): Promise<void> {

tests/functional/resync/source/worker.ts

@@ -1,6 +1,7 @@
+import type { Contracts } from "@mainsail/contracts";
+
 import { Identifiers } from "@mainsail/constants";
 import { inject, injectable, tagged } from "@mainsail/container";
-import type { Contracts } from "@mainsail/contracts";
 
 @injectable()
 export class Worker implements Contracts.Crypto.WorkerScriptHandler {

tests/functional/transaction-pool-api/source/pool-worker.ts

@@ -34,10 +34,13 @@ export class PoolWorker implements Contracts.TransactionPool.Worker {
 	}
 
 	public async getTransactions(options: Contracts.TransactionPool.GetBatchOptions): Promise<Contracts.TransactionPool.GetBatchResult> {
-		return {
+		const result =  {
 			remaining: 0,
 			transactions: (await this.poolQuery.getFromHighestPriority().all()).map((transaction) => transaction.toData()),
 		}
+
+		this.transactionPoolMempool.flush();
+		return result;
 	}
 
 	public async removeTransaction(address: string, hash: string): Promise<void> {