Method and system for blockchain service orchestration

A system comprising:

• an input/output interface to receive a request for a business transaction as an input to orchestrate one or more services of a business operation within one or more blockchain platforms using an orchestration engine;
• a memory in communication with the one or more hardware processors, wherein the one or more hardware processors are configured to execute programmed instructions stored in the memory to;
• identify a configuration associated with each of the one or more services, wherein the configuration provides an operational need of the business that is executed one of (a) parallelly or (b) sequentially from a service pool;
• generate a service packet instance for each of the one or more services based on the identified configuration, wherein the service packet instance includes one or more flows within or across the one or more blockchain platforms;
• stamp the generated service packet instance with a unique hash, wherein the unique hash comprises a Service-ID of the service packet, collection of one or more business unique fields for world state acted upon, data and time of service invocation, a unique ID of a user who has initiated the business transaction and a random byte generated during generation of the unique hash;
• analyze the stamped service packet instance to identify at least one of (a) an asynchronous service packet instance, or (b) a synchronous service packet instance;
• determine a nature of processing of the identified asynchronous service packet instance, and the synchronous service packet instance, wherein the nature of processing includes a sequential processing and a parallel processing from the service pool, wherein in the sequential processing of the synchronous service packet instance, a primary thread proceeds to process the service packet by invoking one service worker after the other, and wherein in the parallel processing of the synchronous service packet instance, the primary thread spawns parallel threads of each flow,
• wherein in the sequential processing of the asynchronous service packet instance, the service packet instance is published to a pool and one or more service workers pick the service packet and processes the flow sequentially to put it back into the pool, and wherein in the parallel processing of the asynchronous service packet instance, the service packet instance is published to the pool and the one or more service workers pick the service packet and processes the flows in parallel to put it back in the pool;
• invoke each of the one or more flows of the service packet instance to stamp with a flow hash, wherein the flow hash of each flow is linked with the unique hash of the generated service packet instance;
• generate a ledger hash, wherein the ledger hash comprising a service hash, a business unique parameter hash, and a block-hash, wherein the service hash is generated for each of service request which is linked to hash of the business transaction request generated for the business transaction, wherein the business unique parameter hash is generated for one or more business parameters used for the one or more services, and wherein the block-hash is generated by at least one of the one or more blockchain platforms;
• form a hash-tree to link the generated ledger hash, the flow hash, and the unique hash of the service packet instance, wherein the hash-tree is created to trace transactions impacting ledger data within or across the one or more blockchain platforms, and wherein the hash-tree establishes a pseudo-relation between the one or more services by mapping hashes enabling traceability within or across the one or more blockchain platforms, tracking execution status and retrieving the ledger data based on the hashes embedded within the ledger;
• execute the one or more flows within the one or more blockchain platforms based on the determined nature of processing to receive one or more responses based on the flow executions;
• and
• assess the received one or more responses to construct a final response, wherein the final response includes a commit, a roll back, or a reversal of the transaction within the one or more blockchain platforms, thereby
• orchestrating the business operation within or across blockchain platforms without impacting blockchain protocol layer.

One or more non-transitory machine-readable information storage mediums comprising one or more instructions which when executed by one or more hardware processors cause:

• receiving, via an input/output interface, a request for a business transaction as an input to orchestrate one or more services of a business operation within one or more blockchain platforms;
• identifying a configuration associated with each of the one or more services, wherein the configuration provides an operational need of the business that is executed one of (a) parallelly, or (b) sequentially from a service pool;
• generating a service packet instance for each of the one or more services based on the identified configuration, wherein the service packet instance includes one or more flows within the one or more blockchain platforms;
• stamping the generated service packet instance with a unique hash, wherein the unique hash comprises a Service-ID of the service packet, collection of one or more business unique fields for world state acted upon, data and time of service invocation, a unique ID of a user who has initiated the business transaction and a random byte generated during generation of the unique hash;
• analyzing the stamped service packet instance to identify at least one of (a) an asynchronous service packet instance, or (b) a synchronous service packet instance;
• determining a nature of processing of the identified asynchronous service packet instance, and the synchronous service packet instance, wherein the nature of processing includes a sequential processing and a parallel processing from the service pool, wherein in the sequential processing of the synchronous service packet instance, a primary thread proceeds to process the service packet by invoking one service worker after the other, and wherein in the parallel processing of the synchronous service packet instance, the primary thread spawns parallel threads of each flow,
• wherein in the sequential processing of the asynchronous service packet instance, the service packet instance is published to a pool and one or more service workers pick the service packet and processes the flow sequentially to put it back into the pool, and wherein in the parallel processing of the asynchronous service packet instance, the service packet instance is published to the pool and the one or more service workers pick the service packet and processes the flows in parallel to put it back in the pool;
• invoking each of the one or more flows of the service packet instance to stamp with a flow hash, wherein the flow hash of each flow is linked with the unique hash of the generated service packet instance;
• generating a ledger hash, wherein the ledger hash comprising a service hash, a business unique parameter hash, and a block-hash;
• forming a hash-tree to link the generated ledger hash, the flow hash, and the unique hash of the service packet instance, wherein the hash-tree is created to trace transactions impacting ledger data within or across the one or more blockchain platforms, and wherein the hash-tree establishes a pseudo-relation between the one or more services by mapping hashes enabling traceability within or across the one or more blockchain platforms, tracking execution status and retrieving the ledger data based on the hashes embedded within the ledger;
• executing the one or more flows within or across the one or more blockchain platforms based on the determined nature of processing to receive one or more responses based on the flow executions;
• and
• assessing the received one or more responses to construct a final response, wherein the final response includes a commit, a roll back, or a reversal of the transaction within the one or more blockchain platforms, thereby
• orchestrating the business operation within or across blockchain platforms without impacting blockchain protocol layer.