funding: setup wallet actor

src/lib.rs

@@ -1,6 +1,8 @@
 mod config;
 pub use config::Config;
 
+pub mod wallet;
+
 pub mod ldk;
 pub use ldk::{start_ldk, LdkConfig};
 pub mod ckb;

src/main.rs

@@ -1,4 +1,5 @@
 use log::{debug, error, info};
+use ractor::Actor;
 use tentacle::multiaddr::Multiaddr;
 use tokio::sync::mpsc;
 use tokio::{select, signal};
@@ -11,6 +12,7 @@ use ckb_pcn_node::ckb::{NetworkActorCommand, NetworkActorMessage};
 use ckb_pcn_node::tasks::{
     cancel_tasks_and_wait_for_completion, new_tokio_cancellation_token, new_tokio_task_tracker,
 };
+use ckb_pcn_node::wallet::WalletActor;
 use ckb_pcn_node::{start_cch, start_ckb, start_ldk, start_rpc, Config};
 
 #[tokio::main]
@@ -29,6 +31,15 @@ pub async fn main() {
     let token = new_tokio_cancellation_token();
     let root_actor = RootActor::start(tracker, token).await;
 
+    let (_wallet_actor, _wallet_handle) = Actor::spawn_linked(
+        Some("wallet actor".to_string()),
+        WalletActor {},
+        (),
+        root_actor.get_cell(),
+    )
+    .await
+    .expect("start wallet actor");
+
     let ckb_command_sender = match config.ckb {
         Some(ckb_config) => {
             const CHANNEL_SIZE: usize = 4000;

src/wallet/mod.rs

@@ -0,0 +1,25 @@
+use ractor::{Actor, ActorProcessingErr, ActorRef};
+
+pub struct WalletActor;
+
+#[derive(Clone, Debug)]
+pub struct WalletState;
+
+#[derive(Clone, Debug)]
+pub struct WalletMessage;
+
+#[ractor::async_trait]
+impl Actor for WalletActor {
+    type Msg = WalletMessage;
+    type State = WalletState;
+    type Arguments = ();
+
+    async fn pre_start(
+        &self,
+        _myself: ActorRef<Self::Msg>,
+        _: (),
+    ) -> Result<Self::State, ActorProcessingErr> {
+        log::debug!("start wallet actor");
+        Ok(WalletState)
+    }
+}