aljaz/sphinx-key
1
1
Fork 0
mirror of https://github.com/stakwork/sphinx-key.git synced 2025-12-18 07:44:21 +01:00
Code Issues Packages Projects Releases Wiki Activity

dummy peer in root handler

Browse Source
This commit is contained in:
Evan Feenstra
2022-06-06 14:54:18 -07:00
parent 8ec7b6c87e
commit 3b4771241c
2 changed files with 30 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@@ -64,7 +64,7 @@ nightly
In this new esp-rs repo, find the path to your `riscv32-esp-elf-gcc` binary within the `.embuild` dir:
`export CC=/Users/evanfeenstra/code/sphinx-key/sphinx-key/signer/.embuild/espressif/tools/riscv32-esp-elf/esp-2021r2-patch3-8.4.0/riscv32-esp-elf/bin/riscv32-esp-elf-gcc`
`export CC=/Users/evanfeenstra/code/sphinx-key/sphinx-key/sphinx-key/.embuild/espressif/tools/riscv32-esp-elf/esp-2021r2-patch3-8.4.0/riscv32-esp-elf/bin/riscv32-esp-elf-gcc`
### get std features of vls:

37
signer/src/lib.rs
View File

@@ -6,6 +6,7 @@ use vls_protocol::serde_bolt::WireString;
use vls_protocol_signer::lightning_signer;
use vls_protocol_signer::vls_protocol;
pub use vls_protocol::model::PubKey;
pub use vls_protocol_signer::handler::{Handler, RootHandler};
pub struct InitResponse {
@@ -40,8 +41,34 @@ pub fn init(bytes: Vec<u8>) -> anyhow::Result<InitResponse> {
})
}
pub fn handle(_root_handler: &RootHandler, _bytes: Vec<u8>) -> anyhow::Result<Vec<u8>> {
Ok(Vec::new())
pub fn handle(
root_handler: &RootHandler,
bytes: Vec<u8>,
dummy_peer: PubKey,
) -> anyhow::Result<Vec<u8>> {
let mut md = MsgDriver::new(bytes);
let (sequence, dbid) = read_serial_request_header(&mut md).expect("read request header");
let mut message = msgs::read(&mut md).expect("message read failed");
// Override the peerid when it is passed in certain messages
match message {
Message::NewChannel(ref mut m) => m.node_id = dummy_peer.clone(),
Message::ClientHsmFd(ref mut m) => m.peer_id = dummy_peer.clone(),
Message::GetChannelBasepoints(ref mut m) => m.node_id = dummy_peer.clone(),
Message::SignCommitmentTx(ref mut m) => m.peer_id = dummy_peer.clone(),
_ => {}
};
let reply = if dbid > 0 {
let handler = root_handler.for_new_client(0, dummy_peer.clone(), dbid);
handler.handle(message).expect("handle")
} else {
root_handler.handle(message).expect("handle")
};
let mut out_md = MsgDriver::new_empty();
write_serial_response_header(&mut out_md, sequence).expect("write reply header");
msgs::write_vec(&mut out_md, reply.as_vec()).expect("write reply");
Ok(out_md.bytes())
}
pub fn parse_ping_and_form_response(msg_bytes: Vec<u8>) -> Vec<u8> {
@@ -59,12 +86,6 @@ pub fn parse_ping_and_form_response(msg_bytes: Vec<u8>) -> Vec<u8> {
md.bytes()
}
// pub fn say_hi() {
// let persister: Arc<dyn Persist> = Arc::new(DummyPersister);
// println!("Hello, world!");
// }
fn from_wire_string(s: &WireString) -> String {
String::from_utf8(s.0.to_vec()).expect("malformed string")
}