♻️ Unable CCU sending when receiving chain is syncing

LiskArchive · Mar 12, 2024 · aea9020 · aea9020
1 parent 7126fdf
commit aea9020
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/framework-plugins/lisk-framework-chain-connector-plugin/src/ccu_handler.ts b/framework-plugins/lisk-framework-chain-connector-plugin/src/ccu_handler.ts
@@ -277,6 +277,10 @@ export class CCUHandler {
 		if (!this._db.privateKey) {
 			throw new Error('There is no key enabled to submit CCU.');
 		}
+		const { syncing } = await this._receivingChainAPIClient.getNodeInfo();
+		if (syncing) {
+			throw new Error('Receiving node is syncing.');
+		}
 		const relayerPublicKey = cryptography.ed.getPublicKeyFromPrivateKey(this._db.privateKey);
 		const targetCommand = this._isReceivingChainMainchain
 			? COMMAND_NAME_SUBMIT_MAINCHAIN_CCU

diff --git a/framework-plugins/lisk-framework-chain-connector-plugin/test/unit/ccu_handler.spec.ts b/framework-plugins/lisk-framework-chain-connector-plugin/test/unit/ccu_handler.spec.ts
@@ -813,6 +813,13 @@ describe('CCUHandler', () => {
 			);
 		});
 
+		it('should throw error when receiving chain is syncing', async () => {
+			receivingChainAPIClientMock.getNodeInfo.mockResolvedValue({ syncing: true });
+			await expect(ccuHandler['submitCCU'](ccuParams, 'txID')).rejects.toThrow(
+				'Receiving node is syncing.',
+			);
+		});
+
 		it('should return undefined when the tx id is equal to last sent CCU', async () => {
 			ccuTx.sign(config.receivingChainID as Buffer, Buffer.from(privateKey, 'hex'));
 			const result = await ccuHandler['submitCCU'](ccuParams, ccuTx.id.toString('hex'));