Purge data in explorer based on a parameter

Dockerfile

@@ -16,6 +16,8 @@ WORKDIR $EXPLORER_APP_PATH
 
 COPY . .
 
+RUN sed -i -e 's/http:/https:/' /etc/apk/repositories
+
 # install required dependencies by NPM packages:
 # current dependencies are: python, make, g++
 RUN apk add --no-cache --virtual npm-deps python3 make g++ curl bash && \
@@ -25,7 +27,7 @@ RUN apk add --no-cache --virtual npm-deps python3 make g++ curl bash && \
     rm -r /root/.cache
 
 # install node-prune (https://github.com/tj/node-prune)
-RUN curl -sfL https://install.goreleaser.com/github.com/tj/node-prune.sh | bash -s -- -b /usr/local/bin
+RUN curl -sf https://gobinaries.com/tj/node-prune | sh
 
 # install NPM dependencies
 RUN npm install && npm run build && npm prune --production

app/persistence/fabric/CRUDService.ts

@@ -237,6 +237,42 @@ export class CRUDService {
 		return false;
 	}
 
+	/**
+	 *
+	 * @param network_name
+	 * @param channel_genesis_hash
+	 * @param blockCount
+	 * @returns
+	 * @memberof CRUDService
+	 */
+	async deleteBlock(network_name, channel_genesis_hash, blockCount) {
+		const count: any = await this.sql.getRowsBySQlCase(
+			' select count(*) as count from blocks  where channel_genesis_hash=$1 and network_name = $2 ',
+			[channel_genesis_hash, network_name]
+		);
+
+		const rowCount: number = count.count;
+		var rowsToDelete: number = 0;
+		if (rowCount > blockCount) {
+			rowsToDelete = rowCount - blockCount;
+		}
+
+		if (rowsToDelete > 0) {
+			await this.sql.updateBySql(
+				`delete from transactions where blockid in ( select blocknum from blocks where channel_genesis_hash=$1 and network_name = $2 order by blocknum limit $3) `,
+				[channel_genesis_hash, network_name, rowsToDelete]
+			);
+
+			await this.sql.updateBySql(
+				`delete from blocks where id in ( select id from blocks where channel_genesis_hash=$1 and network_name = $2 order by blocknum limit $3) `,
+				[channel_genesis_hash, network_name, rowsToDelete]
+			);
+
+			return true;
+		}
+		return false;
+	}
+
 	/* eslint-enable */
 
 	/**

app/platform/fabric/sync/SyncPlatform.ts

@@ -37,6 +37,7 @@ export class SyncPlatform {
 	syncService: any;
 	blocksSyncTime: number;
 	network_config: Record<string, any>;
+	blockCount: number;
 
 	/**
 	 * Creates an instance of SyncPlatform.
@@ -54,6 +55,7 @@ export class SyncPlatform {
 		this.syncService = new SyncServices(this, this.persistence);
 		this.blocksSyncTime = 60000;
 		this.network_config = null;
+		this.blockCount = 1000;
 	}
 
 	/**
@@ -86,6 +88,8 @@ export class SyncPlatform {
 			this.network_name = args[1];
 		}
 
+		this.blockCount = network_configs[this.network_id].blockCount;
+
 		logger.info(explorerError.MESSAGE_1002, this.network_id, this.network_name);
 
 		logger.debug('Blocks synch interval time >> %s', this.blocksSyncTime);
@@ -119,7 +123,7 @@ export class SyncPlatform {
 		 */
 		// During initial sync-up phase, disable discovery request
 		(function validateMissingBlocks(sync: SyncPlatform, noDiscovery: boolean) {
-			sync.isChannelEventHubConnected(noDiscovery);
+			sync.isChannelEventHubConnected(noDiscovery, sync.blockCount);
 			setTimeout(validateMissingBlocks, sync.blocksSyncTime, sync, false);
 		})(this, true);
 
@@ -134,12 +138,19 @@ export class SyncPlatform {
 	 *
 	 * @memberof SyncPlatform
 	 */
-	async isChannelEventHubConnected(noDiscovery: boolean) {
+	async isChannelEventHubConnected(noDiscovery: boolean, blockCount: number) {
 		for (const channel_name of this.client.getChannels()) {
 			// Validate channel event is connected
-			const status = this.eventHub.isChannelEventHubConnected(channel_name);
+			const status: boolean = this.eventHub.isChannelEventHubConnected(
+				channel_name
+			);
 			if (status) {
-				await this.syncService.syncBlocks(this.client, channel_name, noDiscovery);
+				await this.syncService.syncBlocks(
+					this.client,
+					channel_name,
+					noDiscovery,
+					blockCount
+				);
 			} else {
 				// Channel client is not connected then it will reconnect
 				this.eventHub.connectChannelEventHub(channel_name);

app/platform/fabric/sync/SyncService.ts

@@ -356,7 +356,7 @@ export class SyncServices {
 			.saveChaincodPeerRef(network_id, chaincode_peer_row);
 	}
 
-	async syncBlocks(client, channel_name, noDiscovery) {
+	async syncBlocks(client, channel_name, noDiscovery, blockCount) {
 		const network_id = client.getNetworkId();
 
 		// Get channel information from ledger
@@ -399,6 +399,12 @@ export class SyncServices {
 		} else {
 			logger.debug('Missing blocks not found for %s', channel_name);
 		}
+
+		const successDeleteBlock = await this.persistence
+			.getCrudService()
+			.deleteBlock(network_id, channel_genesis_hash, blockCount);
+		logger.info('result of DeleteBlock ', successDeleteBlock);
+
 		const index = this.synchInProcess.indexOf(synch_key);
 		this.synchInProcess.splice(index, 1);
 		logger.info(`syncBlocks: Finish >> ${synch_key}`);

examples/net1/config.json

@@ -2,7 +2,8 @@
 	"network-configs": {
 		"test-network": {
 			"name": "Test Network",
-			"profile": "./connection-profile/test-network.json"
+			"profile": "./connection-profile/test-network.json",
+			"blockCount": "5"
 		}
 	},
 	"license": "Apache-2.0"