{"app.R": "library(shiny)\nlibrary(bslib)\nlibrary(DBI)\nlibrary(dplyr)\n\nsource(\"db.R\")\nsource(\"ui.R\")\nsource(\"server.R\")\n\nshinyApp(ui = ui, server = server)", "db.R": "library(DBI)\nlibrary(dplyr)\n\n# Function to connect to PostgreSQL\nget_db_connection <- function() {\n con <- dbConnect(\n RPostgres::Postgres(),\n dbname = Sys.getenv('PG_DATABASE'),\n host = Sys.getenv('PG_HOST'),\n port = Sys.getenv('PG_PORT'),\n user = Sys.getenv('PG_USER'),\n password = Sys.getenv('PG_PASSWORD')\n )\n return(con)\n}\n\n# Function to get failed jobs\nget_failed_jobs <- function(con) {\n query <- \"SELECT \n id,\n job_name,\n status,\n error_message,\n created_at,\n updated_at\n FROM jobs \n WHERE status = 'failed'\n ORDER BY updated_at DESC\"\n \n result <- dbGetQuery(con, query)\n return(result)\n}\n\n# Function to rerun a job\nrerun_job <- function(con, job_id) {\n query <- sprintf(\n \"INSERT INTO jobs (job_name, status, parent_job_id)\n SELECT job_name, 'pending', %d\n FROM jobs\n WHERE id = %d\n RETURNING id\",\n job_id, job_id\n )\n \n new_job_id <- dbGetQuery(con, query)$id\n return(new_job_id)\n}", "server.R": "library(bslib)\nlibrary(DT)\nsource('db.R')\nlibrary(shiny)\nlibrary(dplyr)\n\nserver <- function(input, output, session) {\n # Reactive value to store connection\n con <- reactiveVal()\n \n # Initialize connection when app starts\n observe({\n con(get_db_connection())\n })\n \n # Clean up connection when app closes\n onStop(function() {\n if (!is.null(con())) {\n dbDisconnect(con())\n }\n })\n \n # Reactive to get failed jobs\n failed_jobs <- eventReactive(input$refresh, {\n req(con())\n get_failed_jobs(con())\n }, ignoreNULL = FALSE)\n \n # Render the table of failed jobs\n output$failedJobsTable <- renderDT({\n jobs <- failed_jobs()\n \n DT::datatable(\n jobs,\n selection = 'single',\n options = list(\n pageLength = 10,\n order = list(list(4, 'desc')), # Sort by updated_at by default\n dom = 'Bfrtip'\n ),\n rownames = FALSE\n ) %>%\n DT::formatDate(\n columns = c('created_at', 'updated_at'),\n method = 'toLocaleString'\n )\n })\n \n # Handle rerun button clicks\n observeEvent(input$failedJobsTable_rows_selected, {\n req(input$failedJobsTable_rows_selected)\n \n selected_row <- input$failedJobsTable_rows_selected\n job_id <- failed_jobs()[selected_row, 'id']\n \n # Create modal dialog for confirmation\n showModal(modalDialog(\n title = \"Confirm Job Rerun\",\n \"Are you sure you want to rerun this job?\",\n footer = tagList(\n input_task_button(\"confirmRerun\", \"Yes, Rerun\", type = \"warning\"),\n modalButton(\"Cancel\")\n )\n ))\n })\n \n # Handle confirmation of job rerun\n observeEvent(input$confirmRerun, {\n req(input$failedJobsTable_rows_selected)\n \n selected_row <- input$failedJobsTable_rows_selected\n job_id <- failed_jobs()[selected_row, 'id']\n \n # Rerun the job\n tryCatch({\n new_job_id <- rerun_job(con(), job_id)\n showNotification(\n sprintf(\"Successfully created new job %d\", new_job_id),\n type = \"message\"\n )\n }, error = function(e) {\n showNotification(\n sprintf(\"Error creating new job: %s\", e$message),\n type = \"error\"\n )\n })\n \n removeModal()\n updateTaskButton(session, \"refresh\", state = \"ready\")\n })\n \n # Display last updated time\n output$lastUpdated <- renderText({\n input$refresh\n paste(\"Last updated:\", format(Sys.time(), \"%Y-%m-%d %H:%M:%S\"))\n })\n}", "ui.R": "library(DT)\nlibrary(shiny)\nlibrary(bslib)\n\nui <- page_sidebar(\n title = \"Job Monitor\",\n \n sidebar = sidebar(\n title = \"Controls\",\n input_task_button(\"refresh\", \"Refresh Jobs\", icon = bsicons::bs_icon(\"arrow-clockwise\")),\n hr(),\n textOutput(\"lastUpdated\")\n ),\n \n layout_column_wrap(\n width = 1,\n card(\n card_header(\"Failed Jobs\"),\n card_body(\n DTOutput(\"failedJobsTable\")\n )\n )\n )\n)", "install.R": "install.packages('DBI')\ninstall.packages('DT')\ninstall.packages('bslib')\ninstall.packages('dplyr')\ninstall.packages('shiny')", "startApp.R": "\nlibrary(shiny)\noptions(shiny.host = '0.0.0.0')\noptions(shiny.port = 80)\nrunApp('app.R')\n"}