|
@@ -13,7 +13,7 @@ use std::{
|
|
|
};
|
|
|
|
|
|
use btlib::{bterr, crypto::Creds, error::StringError, BlockPath, Result};
|
|
|
-use btmsg::{DeserCallback, MsgCallback, Receiver, Replier, Transmitter};
|
|
|
+use bttp::{DeserCallback, MsgCallback, Receiver, Replier, Transmitter};
|
|
|
use btserde::{field_helpers::smart_ptr, from_slice, to_vec, write_to};
|
|
|
use serde::{de::DeserializeOwned, Deserialize, Serialize};
|
|
|
use tokio::{
|
|
@@ -385,7 +385,7 @@ impl RuntimeCallback {
|
|
|
impl MsgCallback for RuntimeCallback {
|
|
|
type Arg<'de> = WireMsg<'de>;
|
|
|
type CallFut<'de> = impl 'de + Future<Output = Result<()>>;
|
|
|
- fn call<'de>(&'de self, arg: btmsg::MsgReceived<Self::Arg<'de>>) -> Self::CallFut<'de> {
|
|
|
+ fn call<'de>(&'de self, arg: bttp::MsgReceived<Self::Arg<'de>>) -> Self::CallFut<'de> {
|
|
|
async move {
|
|
|
let (_, body, replier) = arg.into_parts();
|
|
|
if body.to.path() == self.rt.path() {
|
|
@@ -477,11 +477,11 @@ struct WireMsg<'a> {
|
|
|
payload: &'a [u8],
|
|
|
}
|
|
|
|
|
|
-impl<'a> btmsg::CallMsg<'a> for WireMsg<'a> {
|
|
|
+impl<'a> bttp::CallMsg<'a> for WireMsg<'a> {
|
|
|
type Reply<'r> = WireReply<'r>;
|
|
|
}
|
|
|
|
|
|
-impl<'a> btmsg::SendMsg<'a> for WireMsg<'a> {}
|
|
|
+impl<'a> bttp::SendMsg<'a> for WireMsg<'a> {}
|
|
|
|
|
|
#[derive(Serialize, Deserialize)]
|
|
|
enum WireReply<'a> {
|
|
@@ -656,7 +656,7 @@ mod tests {
|
|
|
log::BuilderExt,
|
|
|
};
|
|
|
use btlib_tests::TEST_STORE;
|
|
|
- use btmsg::BlockAddr;
|
|
|
+ use bttp::BlockAddr;
|
|
|
use btserde::to_vec;
|
|
|
use ctor::ctor;
|
|
|
use lazy_static::lazy_static;
|