Update meta_analysis_api.R

meta_analysis_api.R

@@ -1,27 +1,53 @@
 library(plumber)
-# Load all the meta-analysis packages
+library(jsonlite)
+
+# Load all the meta-analysis packages (as per your original code)
 packages <- c("aggregation", "aides", "altmeta", "amanida", "baggr", "bamdit", "BayesCombo", "bayesmeta", "BayesMultMeta", "bipd", "bnma", "boot.heterogeneity", "boutliers", "brms", "bspmma", "CAMAN", "catmap", "CausalMetaR", "CBnetworkMA", "CIAAWconsensus", "citationchaser", "clubSandwich", "coefa", "CohensdpLibrary", "compute.es", "corrmeta", "CoTiMA", "CPBayes", "crossnma", "crwbmetareg", "dfmeta", "diagmeta", "digitize", "dmetar", "dmetatools", "dosresmeta", "dplyr", "DTAplots", "ecoreg", "effectsize", "effsize", "epiR", "es.dif", "esc", "esci", "estimraw", "estmeansd", "EValue", "EvidenceSynthesis", "extraDistr", "forcats", "forestly", "forestmodel", "forestplot", "forestploter", "forplo", "fsn", "gap", "gemtc", "GENMETA", "getmstatistic", "getspres", "ggplot2", "ggridges", "glue", "GMCM", "harmonicmeanp", "heterometa", "igraph", "jarbes", "joint.Cox", "juicr", "KenSyn", "MAd", "mada", "MBNMAdose", "MBNMAtime", "mc.heterogeneity", "MendelianRandomization", "meta", "meta.shrinkage", "meta4diag", "MetaAnalyser", "metabias", "metaBLUE", "metaBMA", "metabolic", "metabup", "metacart", "metaconfoundr", "metadat", "metaDigitise", "metafor", "metaforest", "metafuse", "metagam", "metaGE", "metagear", "metainc", "MetaIntegration", "MetaIntegrator", "metaLik", "metaMA", "metamedian", "metamicrobiomeR", "metamisc", "metansue", "metap", "metapack", "metaplus", "metapower", "metapro", "metarep", "metaRNASeq", "metaSEM", "metasens", "MetaSKAT", "MetaStan", "MetaSubtract", "metaSurvival", "metatest", "metaumbrella", "MetaUtility", "metavcov", "metaviz", "metawho", "miniMeta", "mixmeta", "MOTE", "multibiasmeta", "multinma", "mvmeta", "MVPBT", "mvtmeta", "netmeta", "NMA", "nmadb", "NMADiagT", "nmaINLA", "NMAoutlier", "nmaplateplot", "nmarank", "nmathresh", "ofGEM", "openxlsx", "OssaNMA", "osfr", "pcnetmeta", "pema", "PerformanceAnalytics", "phacking", "pimeta", "PINMA", "POMADE", "poolr", "PRISMA2020", "PRISMAstatement", "psychmeta", "psymetadata", "PublicationBias", "publipha", "puniform", "ra4bayesmeta", "RandMeta", "rankinma", "ratesci", "RBesT", "RcmdrPlugin.EZR", "RcmdrPlugin.MA", "RcmdrPlugin.RMTCJags", "reappraised", "rema", "remaCor", "revtools", "rjags", "rma.exact", "rmeta", "rnmamod", "RoBMA", "robumeta", "RobustBayesianCopas", "robustmeta", "RobustRankAggreg", "robvis", "RTSA", "SCMA", "selectMeta", "semPlot", "SingleCaseES", "smd", "SPAtest", "ssifs", "stringr", "TFisher", "tidybayes", "tidyverse", "vcmeta", "viscomp", "weightr", "wildmeta", "xmeta")
 
 for (pkg in packages) {
-  suppressWarnings(library(pkg, character.only = TRUE))
+  suppressWarnings(suppressMessages(library(pkg, character.only = TRUE)))
 }
 
 #* @apiTitle Comprehensive Meta-Analysis API
 
-#* Perform meta-analysis based on the selected package
+#* Perform meta-analysis using the selected package and function
 #* @param package The name of the package to use
-#* @param method The method for the analysis
-#* @param data A list containing all necessary data for the analysis
+#* @param function The name of the function within the package to execute
+#* @param params A list containing all necessary parameters for the function
 #* @post /analyze
-function(package, method, data) {
-  # Convert data from JSON to R objects
-  data <- lapply(data, function(x) if(is.character(x)) jsonlite::fromJSON(x) else x)
+function(package, function, params) {
+  # Check if the package is installed
+  if (!requireNamespace(package, quietly = TRUE)) {
+    res <- list(error = paste("Package", package, "is not installed."))
+    return(res)
+  }
+  
+  # Load the package
+  suppressWarnings(suppressMessages(library(package, character.only = TRUE)))
+  
+  # Check if the function exists in the package
+  if (!exists(function, where = asNamespace(package), mode = "function")) {
+    res <- list(error = paste("Function", function, "does not exist in package", package))
+    return(res)
+  }
   
-  # Perform the analysis based on the package
+  # Convert params from JSON to R objects if necessary
+  params <- lapply(params, function(x) {
+    if (is.character(x)) {
+      # Attempt to parse JSON strings
+      parsed <- tryCatch(jsonlite::fromJSON(x), error = function(e) x)
+      return(parsed)
+    } else {
+      return(x)
+    }
+  })
+  
+  # Perform the analysis by calling the specified function with the provided params
   result <- tryCatch({
-    do.call(package, c(list(method = method), data))
+    func <- get(function, envir = asNamespace(package))
+    do.call(func, params)
   }, error = function(e) {
-    list(error = paste("Error in", package, ":", e$message))
+    list(error = paste("Error in", package, "function", function, ":", e$message))
   })
   
   return(result)
@@ -30,4 +56,4 @@ function(package, method, data) {
 #* @plumber
 function(pr) {
   pr$setDebug(TRUE)
-}
+}