From b08d91af5d2c67a54f1921aee5640523c09aad22 Mon Sep 17 00:00:00 2001 From: ModulatingForce <116608425+modulatingforce@users.noreply.github.com> Date: Wed, 27 Mar 2024 10:18:13 -0400 Subject: [PATCH] (cont) start runonce --- src/core/botmodules.rs | 260 ++++++++++++++++++++--- src/custom/experimental/experiment003.rs | 9 +- 2 files changed, 237 insertions(+), 32 deletions(-) diff --git a/src/core/botmodules.rs b/src/core/botmodules.rs index 34c6b02..0e6dfc2 100644 --- a/src/core/botmodules.rs +++ b/src/core/botmodules.rs @@ -688,7 +688,8 @@ impl Routine { // pub async fn start(self : &mut Self) -> Result pub async fn start( trg_routine_ar : Arc> - ) -> Result + // ) -> Result +) -> Result>,String> { // [ ] Asyncio Spawn likely around here @@ -718,50 +719,228 @@ impl Routine { // fn innerhelper(self_rw : Arc>) -> Option> { // fn innerhelper(inroutine : &Routine) -> Option> { // fn innerhelper(inroutine : Routine) -> Option> { - fn innerhelper(inroutine : Arc>) -> Option> { + // async fn innerhelper(inroutine : Arc>) -> Option> { + async fn runonce_innerhelper(inroutine : Arc>) -> JoinHandle<()> { - Some( - tokio::spawn(async move { + botlog::trace( + "innerhelper() started", + Some(format!( + "Routine > start() > (In Tokio Spawn)", + )), + Some(&inroutine.read().await.parent_params.msg), + ); + + Log::flush(); + + // Some( + // tokio::spawn(async move { + + // botlog::trace( + // ">> Within Spawn", + // Some(format!( + // "Routine > start() > (In Tokio Spawn)", + // )), + // Some(&inroutine.read().await.parent_params.msg), + // ); + + // Log::flush(); + + + + // // let mut self_wr_lock = self_rw.write().await; + // // let mut remainingiter = self_wr_lock.remaining_iterations.unwrap(); + // let mut remainingiter = inroutine.write().await.remaining_iterations.unwrap_or(0); + + + + // botlog::trace( + // format!( + // "[TRACE][Routine Started] {} in {}", + // inroutine.read().await.name, + // inroutine.read().await.channel.0 + // ) + // .as_str(), + // Some(format!( + // "Routine > start() > (In Tokio Spawn) > {:?}", + // inroutine.read().await.module + // )), + // Some(&inroutine.read().await.parent_params.msg), + // ); + + // Log::flush(); + + // inroutine.write().await.start_time = Some(chrono::offset::Local::now()); + + + // // Loop iteration + // while remainingiter > 1 { + + // // execution body + // inroutine.read().await.loopbody().await; + + // // end of loop iteration + // remainingiter -= 1; + // { + // inroutine.write().await.remaining_iterations = Some(remainingiter); + // inroutine.write().await.complete_iterations += 1; + // } + + // } + + // botlog::trace( + // format!( + // "[TRACE][Routine Completed] {} in {}", + // inroutine.read().await.name, + // inroutine.read().await.channel.0 + // ) + // .as_str(), + // Some(format!( + // "Routine > start() > (In Tokio Spawn) > {:?}", + // inroutine.read().await.module + // )), + // Some(&inroutine.read().await.parent_params.msg), + // ); + + + // Log::flush(); + // })) + + return tokio::spawn(async move { + + botlog::trace( + ">> Within Spawn", + Some(format!( + "Routine > start() > (In Tokio Spawn)", + )), + Some(&inroutine.read().await.parent_params.msg), + ); + + Log::flush(); + + + // botlog::trace( + // &format!( + // ">> Within Spawn - Reamining Iter Eval : {:?}" + // ,inroutine.read().await.remaining_iterations), + // Some(format!( + // "Routine > start() > (In Tokio Spawn)", + // )), + // Some(&inroutine.read().await.parent_params.msg), + // ); + + // Log::flush(); + + botlog::trace( + ">> Within Spawn >> After remaining iter eval", + Some(format!( + "Routine > start() > (In Tokio Spawn)", + )), + Some(&inroutine.read().await.parent_params.msg), + ); + + Log::flush(); + + + botlog::trace( + ">> Within Spawn >> After remaining iter eval 2 ", + Some(format!( + "Routine > start() > (In Tokio Spawn)", + )), + Some(&inroutine.read().await.parent_params.msg), + ); + + Log::flush(); + + + botlog::trace( + ">> Within Spawn >> After remaining iter eval 3 ", + Some(format!( + "Routine > start() > (In Tokio Spawn)", + )), + Some(&inroutine.read().await.parent_params.msg), + ); + + Log::flush(); // let mut self_wr_lock = self_rw.write().await; // let mut remainingiter = self_wr_lock.remaining_iterations.unwrap(); - let mut remainingiter = inroutine.write().await.remaining_iterations.unwrap_or(0); + // let mut remainingiter = inroutine.write().await.remaining_iterations.unwrap_or(0); + // let mut remainingiter = inroutine.read().await.remaining_iterations.unwrap_or(0); + // let mut remainingiter = inroutine.read().await.remaining_iterations.unwrap_or(0); + // async fn setremain(inroutine : Arc> , number : Option) { + // inroutine.write().await.remaining_iterations = number; + // } + // if inroutine.read().await.remaining_iterations.is_none() { + // // inroutine.write().await.remaining_iterations = Some(0); + // // setremain(inroutine.clone(),Some(0)).await; + // } - botlog::trace( - format!( - "[TRACE][Routine Started] {} in {}", - inroutine.read().await.name, - inroutine.read().await.channel.0 - ) - .as_str(), - Some(format!( - "Routine > start() > (In Tokio Spawn) > {:?}", - inroutine.read().await.module - )), - Some(&inroutine.read().await.parent_params.msg), - ); + // botlog::trace( + // format!( + // "[TRACE][Routine Started] {} in {}", + // inroutine.read().await.name, + // inroutine.read().await.channel.0 + // ) + // .as_str(), + // Some(format!( + // "Routine > start() > (In Tokio Spawn) > {:?}", + // inroutine.read().await.module + // )), + // Some(&inroutine.read().await.parent_params.msg), + // ); - inroutine.write().await.start_time = Some(chrono::offset::Local::now()); + // botlog::trace( + // format!( + // "[TRACE][Routine Started] {} in {}", + // inroutine.read().await.name, + // inroutine.read().await.channel.0 + // ) + // .as_str(), + // Some(format!( + // "Routine > start() > (In Tokio Spawn) > {:?}", + // inroutine.read().await.module + // )), + // Some(&inroutine.read().await.parent_params.msg), + // ); + + // Log::flush(); + + // inroutine.write().await.start_time = Some(chrono::offset::Local::now()); + // { + // inroutine.write().await.start_time = Some(chrono::offset::Local::now()); + // } // Loop iteration - while remainingiter > 1 { + // while remainingiter > 1 { + // while inroutine.read().await.remaining_iterations.unwrap_or(0) > 1 { // execution body inroutine.read().await.loopbody().await; // end of loop iteration - remainingiter -= 1; - { - inroutine.write().await.remaining_iterations = Some(remainingiter); - inroutine.write().await.complete_iterations += 1; - } + + // let remain_iter = inroutine.read().await.remaining_iterations.unwrap_or(0); + + // { + // // inroutine.write().await.remaining_iterations = Some(remain_iter - 1); + // setremain(inroutine.clone(),Some(remain_iter - 1)).await; + // } + // { + // inroutine.write().await.complete_iterations += 1; + // } + + // remainingiter -= 1; + // { + // inroutine.write().await.remaining_iterations = Some(remainingiter); + // inroutine.write().await.complete_iterations += 1; + // } - } - + // } + botlog::trace( format!( "[TRACE][Routine Completed] {} in {}", @@ -778,7 +957,10 @@ impl Routine { Log::flush(); - })) + }) + + + } @@ -793,9 +975,17 @@ impl Routine { // let routine = *self_rw_copy.read().await; // self_rw_copy.write().await.join_handle = innerhelper(&routine); // let self_ref = Arc::clone(&trg_routine_ar); - trg_routine_ar.write().await.join_handle = innerhelper(trg_routine_ar.clone()); + // trg_routine_ar.write().await.join_handle = innerhelper(trg_routine_ar.clone()).await; + { + trg_routine_ar.write().await.join_handle = Some(runonce_innerhelper(trg_routine_ar.clone()).await); + } - return Ok("Successfully Started Routine".to_string()); + // if let Some(a) = &trg_routine_ar.read().await.join_handle { + // (*a).await.unwrap(); + // }; + + // return Ok("Successfully Started Routine".to_string()); + return Ok(trg_routine_ar); } @@ -825,6 +1015,16 @@ impl Routine { async fn loopbody(&self) { + botlog::trace( + "loopbody() started", + Some(format!( + "Routine > start() > (During Tokio Spawn) > Execution body", + )), + None, + ); + + Log::flush(); + (self.exec_body)( self.parent_params.clone() ).await; diff --git a/src/custom/experimental/experiment003.rs b/src/custom/experimental/experiment003.rs index 1e25591..76862f6 100644 --- a/src/custom/experimental/experiment003.rs +++ b/src/custom/experimental/experiment003.rs @@ -160,10 +160,15 @@ async fn test3_body(params : ExecBodyParams) { // let rslt = newr_ar.read().await.start().await; + let rsltstr = match rslt { + Ok(_) => "successful".to_string(), + Err(a) => a, + }; + botlog::debug( format!("TEST3_BODY RESULT : {:?}", - rslt + rsltstr ).as_str(), Some("experiment003 > test3_body".to_string()), Some(¶ms.msg), @@ -181,7 +186,7 @@ async fn test3_body(params : ExecBodyParams) { .chat .say_in_reply_to( ¶ms.msg, - format!("Routine Result : {:?}",rslt), + format!("Routine Result : {:?}",rsltstr), params.clone() ).await;