Added check for bids for the neighbourhood during publish start (#2662)

* Added check for bids for the neighbourhood during publish start

* Updated code for handling errors

src/commands/protocols/publish/sender/publish-schedule-messages-command.js

@@ -1,4 +1,5 @@
 import ProtocolScheduleMessagesCommand from '../../common/protocol-schedule-messages-command.js';
+import Command from '../../../command.js';
 import { OPERATION_ID_STATUS, ERROR_TYPE } from '../../../../constants/constants.js';
 
 class PublishScheduleMessagesCommand extends ProtocolScheduleMessagesCommand {
@@ -10,6 +11,105 @@ class PublishScheduleMessagesCommand extends ProtocolScheduleMessagesCommand {
         this.errorType = ERROR_TYPE.PUBLISH.PUBLISH_START_ERROR;
     }
 
+    async execute(command) {
+        const {
+            operationId,
+            keyword,
+            leftoverNodes,
+            numberOfFoundNodes,
+            blockchain,
+            minAckResponses,
+            hashFunctionId,
+            assertionId,
+            tokenId,
+            contract,
+        } = command.data;
+        let isValid = true;
+        // perform check only first time not for every batch
+        if (leftoverNodes === numberOfFoundNodes) {
+            isValid = await this.validateBidsForNeighbourhood(
+                blockchain,
+                contract,
+                tokenId,
+                keyword,
+                hashFunctionId,
+                assertionId,
+                leftoverNodes,
+                minAckResponses,
+                operationId,
+            );
+        }
+        if (isValid) {
+            return super.execute(command);
+        }
+        return Command.empty();
+    }
+
+    async validateBidsForNeighbourhood(
+        blockchain,
+        contract,
+        tokenId,
+        keyword,
+        hashFunctionId,
+        assertionId,
+        nodes,
+        minAckResponses,
+        operationId,
+    ) {
+        const agreementId = await this.serviceAgreementService.generateId(
+            blockchain,
+            contract,
+            tokenId,
+            keyword,
+            hashFunctionId,
+        );
+
+        const agreementData = await this.blockchainModuleManager.getAgreementData(
+            blockchain,
+            agreementId,
+        );
+
+        const r0 = await this.blockchainModuleManager.getR0(blockchain);
+
+        const blockchainAssertionSize = await this.blockchainModuleManager.getAssertionSize(
+            blockchain,
+            assertionId,
+        );
+
+        const divisor = this.blockchainModuleManager
+            .toBigNumber(blockchain, r0)
+            .mul(Number(agreementData.epochsNumber))
+            .mul(blockchainAssertionSize);
+
+        const serviceAgreementBid = this.blockchainModuleManager
+            .toBigNumber(blockchain, agreementData.tokenAmount)
+            .add(agreementData.updateTokenAmount)
+            .mul(1024)
+            .div(divisor)
+            .add(1); // add 1 wei because of the precision loss
+
+        let validBids = 0;
+
+        nodes.forEach((node) => {
+            const askNumber = this.blockchainModuleManager.convertToWei(blockchain, node.ask);
+
+            const ask = this.blockchainModuleManager.toBigNumber(blockchain, askNumber);
+
+            if (ask.lte(serviceAgreementBid)) {
+                validBids += 1;
+            }
+        });
+        if (validBids < minAckResponses) {
+            await this.operationService.markOperationAsFailed(
+                operationId,
+                'Unable to start publish, not enough nodes in neighbourhood satisfy the bid.',
+                ERROR_TYPE.PUBLISH.PUBLISH_START_ERROR,
+            );
+            return false;
+        }
+        return true;
+    }
+
     /**
      * Builds default publishScheduleMessagesCommand
      * @param map