System and method for registering subscribable states in blockchain
Methods, systems, and apparatus, including computer programs encoded on computer storage media, for registering subscribable states in blockchain are provided. One of the methods includes: obtaining a request for registering a workflow comprising one or more states; generating a blockchain contract comprising the workflow; and deploying the blockchain contract in a blockchain, wherein the deployed blockchain contract is executable to update a current state of the workflow among the one or more states.
1. A computer-implemented method, comprising:
obtaining, by one or more servers, a request for registering a workflow;
deploying in a blockchain, by the one or more servers, a blockchain contract comprising the workflow, wherein the deployed blockchain contract is executable to update a current state of the workflow among one or more states of the workflow; and
creating, by the one or more servers, one or more local states of a state machine off the blockchain, the created one or more local states respectively mapped to the one or more states of the workflow in the blockchain.
2. The method of claim 1 , further comprising:
determining, by the one or more servers, the current state by obtaining information in one or more blocks of the blockchain;
updating, by the one or more servers, the state machine based on the determined current state;
determining, by the one or more servers, that the updated state machine corresponds to one of the one or more local states, wherein the one local state of the state machine is mapped to the current state; and
transmitting, by the one or more servers, a notification to a subscriber subscribing to the current state.
3. The method of claim 2 , wherein:
the notification comprises a message indicating the current state and a result returned from completion of a preceding state of the current state.
4. The method of claim 1 , wherein:
the one or more local states are configured in a cycle; and
the cycle starts with a starting local state of the one or more local states, passes through each of the one or more local states once in one direction till an ending local state, and returns to the starting local state.
5. The method of claim 4 , wherein:
the one or more states are configured in a different cycle; and
the different cycle starts with a starting state of the one or more states, passes through each of the one or more states once in one direction till an ending state, and returns to the starting state.
6. The method of claim 5 , wherein:
each of the one or more states is triggered by completion of a preceding state in the different cycle; and
the starting local state is mapped to the starting state.
7. The method of claim 5 , further comprising:
executing the blockchain contract to initiate the current state to be the starting state.
8. The method of claim 5 , further comprising:
obtaining a request for deactivating one of the one or more states; and
in response to the request for deactivating the one state, shortcutting one of the one or more local states from the cycle, and storing to the blockchain a blockchain transaction for shortcutting the one state from the different cycle, wherein the one local state of the state machine is mapped to one state in the blockchain.
9. The method of claim 8 , further comprising:
obtaining a request for reactivating the one state; and
in response to the request for reactivating the one state, restoring the one local state in the cycle, and storing to the blockchain a blockchain transaction for restoring the one state in the different cycle.
10. The method of claim 1 , wherein:
one of the one or more states is configurable by a subscriber to comprise one or more sub-states.
11. The method of claim 10 , wherein:
the one or more sub-states form a cycle;
the one or more states are public to all subscribers to the one or more states; and
the one or more sub-states are private to the subscriber.
12. The method of claim 1 , wherein:
obtaining the request for registering a workflow comprises obtaining a request for registering a state group comprising the one or more states corresponding to the workflow.
13. The method of claim 12 , further comprising:
obtaining a request for ceasing notification of the state group; and
in response to the request for ceasing notification of the state group, ceasing notification of the state group to all subscribers subscribing to any of the one or more states.
14. The method of claim 13 , further comprising:
obtaining a request for resuming notification of the state group; and
in response to the request for resuming notification of the state group, resuming notification of the state group to the all subscribers.
15. A non-transitory computer-readable storage medium storing instructions executable by one or more processors, wherein execution of the instructions causes the one or more processors to perform operations comprising:
obtaining a request for registering a workflow;
deploying in a blockchain a blockchain contract comprising the workflow, wherein the deployed blockchain contract is executable to update a current state of the workflow among one or more states of the workflow; and
creating one or more local states of a state machine off the blockchain, the created one or more local states respectively mapped to the one or more states of the workflow in the blockchain.
16. The non-transitory computer-readable storage medium of claim 15 , wherein the operations further comprise:
determining the current state by obtaining information in one or more blocks of the blockchain;
updating the state machine based on the determined current state;
determining that the updated state machine corresponds to one of the one or more local states, wherein the one local state of the state machine is mapped to the current state; and
transmitting a notification to a subscriber subscribing to the current state.
17. The non-transitory computer-readable storage medium of claim 15 , wherein:
the one or more local states are configured in a cycle; and
the cycle starts with a starting local state of the one or more local states, passes through each of the one or more local states once in one direction till an ending local state, and returns to the starting local state.
18. The non-transitory computer-readable storage medium of claim 17 , wherein:
the one or more states are configured in a different cycle; and
the different cycle starts with a starting state of the one or more states, passes through each of the one or more states once in one direction till an ending state, and returns to the starting state.
19. The non-transitory computer-readable storage medium of claim 18 , wherein:
each of the one or more states is triggered by completion of a preceding state in the different cycle; and
the starting local state is mapped to the starting state.
20. A system comprising one or more processors and one or more non-transitory computer-readable memories coupled to the one or more processors, the one or more non-transitory computer-readable memories configured with instructions executable by the one or more processors to cause the system to perform operations comprising:
obtaining a request for registering a workflow;
deploying in a blockchain a blockchain contract comprising the workflow, wherein the deployed blockchain contract is executable to update a current state of the workflow among one or more states of the workflow; and
creating one or more local states of a state machine off the blockchain, the created one or more local states respectively mapped to the one or more states of the workflow in the blockchain.