From 9864303110f59ebaf3a7427aa285fee44673ad16 Mon Sep 17 00:00:00 2001
From: "tengqiu.huang" <tengqiu.huang@compass.com>
Date: Sun, 15 Sep 2024 22:30:09 +0800
Subject: [PATCH] enhacne: add lock print

---
 robyn_api/robynapi_enpoints.R | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/robyn_api/robynapi_enpoints.R b/robyn_api/robynapi_enpoints.R
index 8e11f64ca..fd37a6f8c 100644
--- a/robyn_api/robynapi_enpoints.R
+++ b/robyn_api/robynapi_enpoints.R
@@ -108,7 +108,9 @@ convert_dates_to_Date <- function(json_data) {
 #* transform InputCollect from API
 transform_InputCollect <- function(InputCollect) {
   promise({
+    sink("Transforming InputCollect Start...")
     lock(mutex)
+    sink("Transforming InputCollect Locking...")
     InputCollect <- jsonlite::fromJSON(InputCollect) %>% convert_dates_to_Date()
 
     # list > tibble
@@ -135,7 +137,9 @@ transform_InputCollect <- function(InputCollect) {
 
     # Add class name which is used as a checker in Robyn
     class(InputCollect) <- c("robyn_inputs", "list")
+    sink("Transforming InputCollect UnLocking...")
     unlock(mutex)
+    sink("Transforming InputCollect Complete...")
     return(InputCollect)
   })
 }
@@ -143,7 +147,9 @@ transform_InputCollect <- function(InputCollect) {
 #* transform OutputCollect from API
 transform_OutputCollect <- function(OutputCollect, select_model = FALSE) {
   promise({
+    sink("Transforming OutputCollect Start...")
     lock(mutex)
+    sink("Transforming OutputCollect Locking...")
     OutputCollect <- jsonlite::fromJSON(OutputCollect)
     # Add class name which is used as a checker in Robyn
     class(OutputCollect) <- c("robyn_outputs", "list")
@@ -178,7 +184,9 @@ transform_OutputCollect <- function(OutputCollect, select_model = FALSE) {
           as_tibble() %>%
           mutate(across(where(is.character), as.factor))
     }
+    sink("Transforming OutputCollect UnLocking...")
     unlock(mutex)
+    sink("Transforming OutputCollect Complete...")
     return(OutputCollect)
   })