feat(ethexe/rpc): implement rpc methods

core/Cargo.toml

@@ -50,4 +50,10 @@ numerated = { workspace = true, features = ["mock"] }
 [features]
 default = []
 strict = []
-std = ["serde/std", "dep:impl-serde", "wasmparser/std", "gear-core-errors/serde"]
+std = [
+    "serde/std",
+    "dep:impl-serde",
+    "wasmparser/std",
+    "gear-core-errors/serde",
+    "gprimitives/serde",
+]

core/src/buffer.rs

@@ -29,12 +29,15 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 /// Limited len vector.
 /// `T` is data type.
 /// `E` is overflow error type.
 /// `N` is max len which a vector can have.
 #[derive(Clone, Default, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo)]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct LimitedVec<T, E, const N: usize>(Vec<T>, PhantomData<E>);
 
 /// Formatter for [`LimitedVec`] will print to precision of 8 by default, to print the whole data, use `{:+}`.

core/src/memory.rs

@@ -38,6 +38,8 @@ use scale_info::{
     scale::{self, Decode, Encode, EncodeLike, Input, Output},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 /// Interval in wasm program memory.
 #[derive(Clone, Copy, Eq, PartialEq, Encode, Decode)]
@@ -111,6 +113,7 @@ pub type PageBufInner = LimitedVec<u8, IntoPageBufError, { GearPage::SIZE as usi
 
 /// Buffer for gear page data.
 #[derive(Clone, PartialEq, Eq, TypeInfo)]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct PageBuf(PageBufInner);
 
 // These traits are implemented intentionally by hand to achieve two goals:

core/src/message/common.rs

@@ -29,6 +29,8 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 /// An entity that is used for interaction between actors.
 /// Can transfer value and executes by programs in corresponding function: init, handle or handle_reply.
@@ -179,6 +181,7 @@ impl Message {
     TypeInfo,
     derive_more::From,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub enum MessageDetails {
     /// Reply details.
     Reply(ReplyDetails),
@@ -228,6 +231,7 @@ impl MessageDetails {
 #[derive(
     Clone, Copy, Default, Debug, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct ReplyDetails {
     /// Message id, this message replies on.
     to: MessageId,
@@ -261,6 +265,7 @@ impl ReplyDetails {
 #[derive(
     Clone, Copy, Default, Debug, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct SignalDetails {
     /// Message id, which issues signal.
     to: MessageId,

core/src/message/context.rs

@@ -33,6 +33,8 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 use super::{DispatchKind, IncomingDispatch, Packet};
 
@@ -144,6 +146,7 @@ impl ContextOutcome {
 
 /// Store of previous message execution context.
 #[derive(Clone, Default, Debug, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo)]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct ContextStore {
     outgoing: BTreeMap<u32, Option<Payload>>,
     reply: Option<Payload>,

core/src/message/mod.rs

@@ -49,6 +49,8 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 /// Max payload size which one message can have (8 MiB).
 pub const MAX_PAYLOAD_SIZE: usize = 8 * 1024 * 1024;
@@ -60,6 +62,7 @@ const _: () = assert!(MAX_PAYLOAD_SIZE <= u32::MAX as usize);
 #[derive(
     Clone, Copy, Default, Debug, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct PayloadSizeError;
 
 impl From<PayloadSizeError> for &str {
@@ -113,6 +116,7 @@ pub enum MessageWaitedType {
 #[derive(
     Copy, Clone, Default, Debug, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub enum DispatchKind {
     /// Initialization.
     Init,

core/src/pages.rs

@@ -26,6 +26,8 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 pub use numerated::{self, num_traits};
 
@@ -195,6 +197,7 @@ impl<const SIZE: u32> PartialOrd<PagesAmount<SIZE>> for Page<SIZE> {
     Default,
     derive_more::Into,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct Page<const SIZE: u32>(u32);
 
 impl<const SIZE: u32> Page<SIZE> {

core/src/program.rs

@@ -30,6 +30,8 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 /// Program in different states in storage.
 #[derive(Clone, Debug, Decode, Encode, PartialEq, Eq, TypeInfo)]
@@ -124,6 +126,7 @@ pub enum ProgramState {
 
 /// Struct defines infix of memory pages storage.
 #[derive(Clone, Copy, Debug, Default, Decode, Encode, PartialEq, Eq, TypeInfo)]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct MemoryInfix(u32);
 
 impl MemoryInfix {

core/src/reservation.rs

@@ -28,6 +28,8 @@ use scale_info::{
     scale::{Decode, Encode},
     TypeInfo,
 };
+#[cfg(feature = "std")]
+use serde::Serialize;
 
 /// An unchangeable wrapper over u64 value, which is required
 /// to be used as a "view-only" reservations nonce in a message
@@ -40,6 +42,7 @@ use scale_info::{
 #[derive(
     Clone, Copy, Default, Debug, Eq, Hash, Ord, PartialEq, PartialOrd, Decode, Encode, TypeInfo,
 )]
+#[cfg_attr(feature = "std", derive(Serialize))]
 pub struct ReservationNonce(u64);
 
 impl From<&InnerNonce> for ReservationNonce {

ethexe/common/src/lib.rs

@@ -32,6 +32,7 @@ pub use gprimitives;
 
 use gprimitives::ActorId;
 use parity_scale_codec::{Decode, Encode};
+use serde::Serialize;
 
 #[derive(Clone, Debug, Encode, Decode)]
 pub enum BlockEvent {
@@ -61,7 +62,7 @@ impl From<wvara::Event> for BlockEvent {
     }
 }
 
-#[derive(Clone, Debug, Encode, Decode)]
+#[derive(Clone, Debug, Encode, Decode, Serialize)]
 pub enum BlockRequestEvent {
     Router(router::RequestEvent),
     Mirror {

ethexe/common/src/mirror.rs

@@ -20,6 +20,7 @@ use alloc::vec::Vec;
 use gear_core::message::ReplyCode;
 use gprimitives::{ActorId, MessageId, H256};
 use parity_scale_codec::{Decode, Encode};
+use serde::Serialize;
 
 /* Events section */
 
@@ -104,7 +105,7 @@ impl Event {
     }
 }
 
-#[derive(Clone, Debug, Encode, Decode)]
+#[derive(Clone, Debug, Encode, Decode, Serialize)]
 pub enum RequestEvent {
     ExecutableBalanceTopUpRequested {
         value: u128,

ethexe/common/src/router.rs

@@ -20,6 +20,7 @@ use alloc::vec::Vec;
 use gear_core::message::{Message, ReplyDetails};
 use gprimitives::{ActorId, CodeId, MessageId, H256};
 use parity_scale_codec::{Decode, Encode};
+use serde::Serialize;
 
 /* Storage related structures */
 
@@ -141,7 +142,7 @@ impl Event {
     }
 }
 
-#[derive(Clone, Debug, Encode, Decode, PartialEq, Eq)]
+#[derive(Clone, Debug, Encode, Decode, PartialEq, Eq, Serialize)]
 pub enum RequestEvent {
     BaseWeightChanged {
         base_weight: u64,

ethexe/common/src/wvara.rs

@@ -18,6 +18,7 @@
 
 use gprimitives::{ActorId, U256};
 use parity_scale_codec::{Decode, Encode};
+use serde::Serialize;
 
 /* Events section */
 
@@ -44,7 +45,7 @@ impl Event {
     }
 }
 
-#[derive(Clone, Debug, Encode, Decode)]
+#[derive(Clone, Debug, Encode, Decode, Serialize)]
 pub enum RequestEvent {
     Transfer {
         /// Never router, wvara or zero address.

ethexe/rpc/Cargo.toml

@@ -13,7 +13,7 @@ repository.workspace = true
 tokio = { workspace = true }
 anyhow.workspace = true
 futures.workspace = true
-gprimitives.workspace = true
+gprimitives = { workspace = true, features = ["serde"] }
 ethexe-db.workspace = true
 ethexe-processor.workspace = true
 jsonrpsee = { version = "0.24", features = ["server", "macros"] }
@@ -23,5 +23,7 @@ log.workspace = true
 parity-scale-codec.workspace = true
 hex.workspace = true
 ethexe-common.workspace = true
+ethexe-runtime-common.workspace = true
 sp-core = { workspace = true, features = ["serde"] }
 gear-core = { workspace = true, features = ["std"] }
+serde.workspace = true

ethexe/rpc/src/errors.rs

@@ -0,0 +1,13 @@
+use jsonrpsee::types::ErrorObject;
+
+pub fn db_err(err: &'static str) -> ErrorObject<'static> {
+    ErrorObject::owned(8000, "Database error", Some(err))
+}
+
+pub fn runtime_err(err: anyhow::Error) -> ErrorObject<'static> {
+    ErrorObject::owned(8000, "Runtime error", Some(format!("{err}")))
+}
+
+pub fn internal() -> ErrorObject<'static> {
+    ErrorObject::owned(8000, "Internal error", None::<&str>)
+}