dev/test_dev/test_mod_nav_process_PipelineA_Process1.R

In samWieczorek/Magellan: A Pipeline Manager

library(highcharter)
library(shinyjs)
library(DT)
library(tibble)
library(QFeatures)
library(crayon)
library(Magellan)

options(shiny.fullstacktrace = TRUE)

setwd('~/GitHub/Magellan/dev/test_dev')

dirpath <- '../../R'
for (l in list.files(path = dirpath, pattern = ".R", recursive = TRUE))
  source(file.path(dirpath, l), local=TRUE)$value

dirpath <- 'example_modules'
for (l in list.files(path = dirpath, pattern = ".R", recursive = TRUE))
  source(file.path(dirpath, l), local=TRUE)$value

#--------------------------------------------


mod_test_process_ui <- function(id){
  ns <- NS(id)
  tagList(
    fluidRow(
      column(width=2, actionButton(ns('simReset'), 
                                   'Remote reset', 
                                   style='background-color: lightgrey;')),
      column(width=2, actionButton(ns('simEnabled'), 
                                   'Remote enable/disable', 
                                   style='background-color: lightgrey;')),
      column(width=2, actionButton(ns('simSkipped'), 
                                   'Remote is.skipped', 
                                   style='background-color: lightgrey;'))
    ),
    hr(),
    uiOutput(ns('UI')),
    wellPanel(title = 'foo',
              tagList(
                h3('Valler'),
                uiOutput(ns('show_Debug_Infos'))
              )
    )
  )
}


mod_test_process_server <- function(id){
  moduleServer(id, function(input, output, session) {
    ns <- session$ns
     
    rv <- reactiveValues(
      dataIn = QFeatures::feat1,
      dataOut = NULL
    )
    
    observe({
      source(file.path('example_modules', 'mod_PipelineA_Process1.R'), local=TRUE)$value
      
      rv$dataOut <- mod_nav_process_server(id = 'PipelineA_Process1',
                                           dataIn = reactive({rv$dataIn}),
                                           remoteReset = reactive({input$simReset}),
                                           is.skipped = reactive({input$simSkipped%%2 != 0}),
                                           is.enabled = reactive({input$simEnabled%%2 == 0})
                                           )
      
      
      observeEvent(rv$dataOut$dataOut()$trigger, {
        print(names(rv$dataOut$dataOut()$value))
      })
    }, priority=1000)
    
    
    output$UI <- renderUI({
      mod_nav_process_ui(ns('PipelineA_Process1'))
    })
    
    
    
    #--------------------------------------------------------------------
    
    output$show_Debug_Infos <- renderUI({
      fluidRow(
        column(width=2,
               tags$b(h4(style = 'color: blue;', "Data In")),
               uiOutput(ns('show_rv_dataIn'))),
        column(width=2,
               tags$b(h4(style = 'color: blue;', "Data Out")),
               uiOutput(ns('show_rv_dataOut')))
      )
    })
    
    ###########---------------------------#################
    output$show_rv_dataIn <- renderUI({
      lapply(names(rv$dataIn), function(x){tags$p(x)})
    })
    
    output$show_rv_dataOut <- renderUI({
      lapply(names(rv$dataOut$dataOut()$value), function(x){tags$p(x)})
    })
    
  })
}


#----------------------------------------------------------------------
ui <- fluidPage(
  mod_test_process_ui('test_mod_process')
)


#----------------------------------------------------------------------
server <- function(input, output){
  mod_test_process_server('test_mod_process')
}
shinyApp(ui, server)


# shinyApp(ui = mod_test_process_ui('test_mod_process'),
#          server = mod_test_process_server('test_mod_process'))