-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add ISMP into the RegionX runtime (#56)
* Add ISMP into the RegionX runtime * compiles * implement proxy module * runtime apis * fix node * inherent * fix * fix message
- Loading branch information
Showing
9 changed files
with
1,423 additions
and
1,165 deletions.
There are no files selected for viewing
Large diffs are not rendered by default.
Oops, something went wrong.
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,100 @@ | ||
| use crate::{AccountId, Ismp, IsmpParachain, ParachainInfo, Runtime, RuntimeEvent, Timestamp}; | ||
| use frame_support::pallet_prelude::Get; | ||
| use frame_system::EnsureRoot; | ||
| use ismp::{ | ||
| error::Error, | ||
| host::StateMachine, | ||
| module::IsmpModule, | ||
| prelude::Vec, | ||
| router::{IsmpRouter, Post, Request, Response, Timeout}, | ||
| }; | ||
| use ismp_parachain::ParachainConsensusClient; | ||
| use pallet_ismp::{dispatcher::FeeMetadata, primitives::ModuleId}; | ||
| use scale_info::prelude::boxed::Box; | ||
|
|
||
| pub struct HostStateMachine; | ||
| impl Get<StateMachine> for HostStateMachine { | ||
| fn get() -> StateMachine { | ||
| StateMachine::Kusama(ParachainInfo::get().into()) | ||
| } | ||
| } | ||
|
|
||
| pub struct Coprocessor; | ||
|
|
||
| impl Get<Option<StateMachine>> for Coprocessor { | ||
| fn get() -> Option<StateMachine> { | ||
| Some(HostStateMachine::get()) | ||
| } | ||
| } | ||
|
|
||
| impl ismp_parachain::Config for Runtime { | ||
| type RuntimeEvent = RuntimeEvent; | ||
| } | ||
|
|
||
| impl pallet_ismp::Config for Runtime { | ||
| type RuntimeEvent = RuntimeEvent; | ||
| const INDEXING_PREFIX: &'static [u8] = b"ISMP"; | ||
| type AdminOrigin = EnsureRoot<AccountId>; | ||
| type HostStateMachine = HostStateMachine; | ||
| type Coprocessor = Coprocessor; | ||
| type TimeProvider = Timestamp; | ||
| type Router = Router; | ||
| type ConsensusClients = (ParachainConsensusClient<Runtime, IsmpParachain>,); | ||
| type WeightInfo = (); | ||
| type WeightProvider = (); | ||
| } | ||
|
|
||
| #[derive(Default)] | ||
| pub struct ProxyModule; | ||
|
|
||
| impl IsmpModule for ProxyModule { | ||
| fn on_accept(&self, _request: Post) -> Result<(), Error> { | ||
| // we don't support any incoming post requests. | ||
| Err(Error::CannotHandleMessage) | ||
| } | ||
|
|
||
| fn on_response(&self, response: Response) -> Result<(), Error> { | ||
| if response.dest_chain() != HostStateMachine::get() { | ||
| let meta = FeeMetadata { origin: [0u8; 32].into(), fee: Default::default() }; | ||
| return Ismp::dispatch_response(response, meta); | ||
| } | ||
|
|
||
| let request = &response.request(); | ||
| let from = match &request { | ||
| Request::Post(post) => &post.from, | ||
| Request::Get(get) => &get.from, | ||
| }; | ||
|
|
||
| let pallet_id = ModuleId::from_bytes(from) | ||
| .map_err(|err| Error::ImplementationSpecific(err.to_string()))?; | ||
| match pallet_id { | ||
| // TODO: route to regions pallet | ||
| _ => Err(Error::ImplementationSpecific("Destination module not found".to_string())), | ||
| } | ||
| } | ||
|
|
||
| fn on_timeout(&self, timeout: Timeout) -> Result<(), Error> { | ||
| let from = match &timeout { | ||
| Timeout::Request(Request::Post(post)) => &post.from, | ||
| Timeout::Request(Request::Get(get)) => &get.from, | ||
| Timeout::Response(res) => &res.post.to, | ||
| }; | ||
|
|
||
| let pallet_id = ModuleId::from_bytes(from) | ||
| .map_err(|err| Error::ImplementationSpecific(err.to_string()))?; | ||
| match pallet_id { | ||
| // TODO: route to regions pallet | ||
| // instead of returning an error, do nothing. The timeout is for a connected chain. | ||
| _ => Ok(()), | ||
| } | ||
| } | ||
| } | ||
|
|
||
| #[derive(Default)] | ||
| pub struct Router; | ||
|
|
||
| impl IsmpRouter for Router { | ||
| fn module_for_id(&self, _bytes: Vec<u8>) -> Result<Box<dyn IsmpModule>, Error> { | ||
| Ok(Box::new(ProxyModule::default())) | ||
| } | ||
| } |
Oops, something went wrong.