The Staking API Service is a critical component of the Babylon Phase-1 system, focused on serving information about the state of the network and receiving unbonding requests for further processing. The API can be utilised by user facing applications, such as staking dApps.
This architecture is centered around a message-driven approach, utilizing RabbitMQ queues for inter-service communication. Such a design facilitates high concurrency and enhances fault tolerance by allowing for horizontal scaling and leveraging RabbitMQ's message retry features. The primary infrastructure components include:
- MongoDB
- RabbitMQ
- Redis cache (Work In Progress)
- Asynchronous Communication: Enables decoupled, non-blocking inter-service interactions, aside from the unbonding pipeline which follows a different interaction pattern.
- Fault Tolerance: Utilizes RabbitMQ's message retry mechanism for resilience against transient failures.
- Horizontal Scalability: Supports increasing system capacity by adding more processing nodes as demand grows.
For more detailed rules applied to message processing, refer to the queue handler documentation.
The standard staking path encompasses user-initiated staking through CLI/UI, followed by waiting for the staking period (timelock) to expire.
- Transaction Submission: User-submitted staking transactions are confirmed and picked up by the indexer after receiving sufficient Bitcoin block confirmations.
- Event Queuing: The indexer sends
ActiveStakingEvent
messages to the Active Event Queue for the staking API service to process. - Processing and State Management: The staking API service executes statistical calculations,
data transformation, and staking state management, inserting records into the
timelock_queue
collection. - Timelock Expiry Monitoring: A dedicated service monitors the
timelock_queue
for records with expired Bitcoin Staking timelocks and signals the staking API service to update the staking delegation status tounbonded
. This status displays to the user that the staking transaction is ready for withdrawal.
The early unbonding path enables users to on-demand unlock their staked Bitcoin before the timelock of the staking transaction expires.
- Signature Submission: Via the UI/CLI, users can initiate an early unbonding action, which involves generating an unbonding transaction and creating a signature for it, both of which are forwarded to the staking API service.
- Signature Verification and Storage: The staking API service validates the signature against the unbonding transaction and stores it for further processing by the unbonding pipeline.
- Committee Co-Signing: The unbonding pipeline collects additional signatures from the covenant committee and submits the unbonding transaction to the Bitcoin network.
- Transaction Detection: The unbonding transaction is detected by the staking-indexer once it receives a sufficient number of confirmations and a corresponding unbonding event is placed into the RabbitMQ queue.
- Processing and State Management: Similar to the standard path, the staking API service
handles statistical updates, adjusts the staking state, and inserts a record into the
timelock_queue
. - Finalization: The expire-service processes items from the
timelock_queue
in MongoDB and emits an expired event to RabbitMQ for the staking-api-service to process. This marks completed staking transactions asunbonded
. This status displays to the user that the staking transaction is ready for withdrawal.
- Docker
- Go
- Clone the repository:
git clone git@github.com:babylonchain/staking-api-service.git
- Run the service:
make run-local
OR, you can run as a docker container
make start-staking-api-service
- Open your browser and navigate to
http://localhost
to see the api server running.
The service only contains integration tests so far, run below:
make tests
- Make sure the interfaces such as the
DBClient
is up to date - Install
mockery
: https://vektra.github.io/mockery/latest/ - Run
make generate-mock-interface
Feel free to submit a pull request or open an issue.