♻️ Unable CCU sending when receiving chain is syncing

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

framework-plugins/lisk-framework-chain-connector-plugin/test/unit/ccu_handler.spec.ts

@@ -775,6 +775,7 @@ describe('CCUHandler', () => {
 			receivingChainAPIClientMock.postTransaction.mockResolvedValue({
 				transactionId: cryptography.utils.hash(Buffer.from('txID')).toString('hex'),
 			});
+			receivingChainAPIClientMock.getNodeInfo.mockResolvedValue({ syncing: false });
 			jest.spyOn(initArgs.logger as Logger, 'info');
 
 			const { activeValidatorsUpdate, certificateThreshold } = calculateActiveValidatorsUpdate(
@@ -813,6 +814,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'));