src/bot_manager.rs

@@ -118,11 +118,7 @@ where
                             script_handler_gen(bot_runner.controller.clone(), handlers.collect())
                                 .await;
                         Some(
-                            spawn_bot_thread(
-                                bot_runner.controller.bot.clone(),
-                                bot_runner.controller.db.clone(),
-                                handler,
-                            )
+                            spawn_bot_thread(bot_runner.controller.clone(), db, handler)
                                 .await
                                 .unwrap(),
                         )
@@ -140,13 +136,12 @@ where
         db: &mut DB,
         plug_handlers: Vec<BotHandler>,
     ) -> BotResult<BotInfo> {
-        let db = db.clone().with_name(bi.name.clone());
+        let mut db = db.clone().with_name(bi.name.clone());
         let controller = BotController::with_db(db.clone(), &bi.token, &bi.script).await?;
 
         let handler = script_handler_gen(controller.clone(), plug_handlers).await;
 
-        let thread =
-            spawn_bot_thread(controller.bot.clone(), controller.db.clone(), handler).await?;
+        let thread = spawn_bot_thread(controller.clone(), &mut db, handler).await?;
 
         let info = BotInfo {
             name: bi.name.clone(),
@@ -179,7 +174,7 @@ pub async fn start_bot(
     db: &mut DB,
     plug_handlers: Vec<BotHandler>,
 ) -> BotResult<BotInfo> {
-    let db = db.clone().with_name(bi.name.clone());
+    let mut db = db.clone().with_name(bi.name.clone());
     let controller = BotController::with_db(db.clone(), &bi.token, &bi.script).await?;
 
     let handler = script_handler(controller.rc.clone());
@@ -190,7 +185,7 @@ pub async fn start_bot(
         .chain(std::iter::once(handler))
         .fold(dptree::entry(), |h, plug| h.branch(plug));
 
-    let thread = spawn_bot_thread(controller.bot.clone(), controller.db.clone(), handler).await?;
+    let thread = spawn_bot_thread(controller.clone(), &mut db, handler).await?;
 
     let info = BotInfo {
         name: bi.name.clone(),
@@ -217,11 +212,11 @@ pub async fn start_bot(
 }
 
 pub async fn spawn_bot_thread(
-    bot: Bot,
-    mut db: DB,
+    bc: BotController,
+    db: &mut DB,
     handler: BotHandler,
 ) -> BotResult<JoinHandle<BotResult<()>>> {
-    let state_mgr = MongodbStorage::from_db(&mut db, Json)
+    let state_mgr = MongodbStorage::from_db(db, Json)
         .await
         .map_err(DbError::from)?;
     let thread = std::thread::spawn(move || -> BotResult<()> {
@@ -232,8 +227,8 @@ pub async fn spawn_bot_thread(
             .build()?;
 
         rt.block_on(
-            Dispatcher::builder(bot, handler)
-                .dependencies(dptree::deps![db, state_mgr])
+            Dispatcher::builder(bc.bot, handler)
+                .dependencies(dptree::deps![bc.db, state_mgr])
                 .build()
                 .dispatch(),
         );

src/main.rs

@@ -108,12 +108,6 @@ pub struct BotController {
     pub runner: Runner,
 }
 
-impl Drop for BotController {
-    fn drop(&mut self) {
-        info!("called drop for BotController");
-    }
-}
-
 unsafe impl Send for BotController {}
 
 const MAIN_BOT_SCRIPT: &str = include_str!(concat!(env!("CARGO_MANIFEST_DIR"), "/mainbot.js"));