#104 support DSD inheritance for SDMXDataFlows document

DESCRIPTION

@@ -1,6 +1,6 @@
 Package: rsdmx
 Version: 0.5-5
-Date: 2016-07-23
+Date: 2016-08-02
 Title: Tools for Reading SDMX Data and Metadata
 Authors@R: c(
   person("Emmanuel", "Blondel", role = c("aut", "cre"), email = "emmanuel.blondel1@gmail.com"),

R/Class-SDMXDataFlow.R

@@ -41,7 +41,8 @@ setClass("SDMXDataFlow",
            #elements
            Name = "list", #at least one
            Description = "list", #optional
-           dsdRef = "character"
+           dsdRef = "character",
+           dsd = "SDMXDataStructureDefinition_OR_NULL"
          ),
          prototype = list(
            #attributes
@@ -64,7 +65,8 @@ setClass("SDMXDataFlow",
              en = "dataflow description",
              fr = "description du dataflow"
            ),
-           dsdRef = "someId"
+           dsdRef = "someId",
+           dsd = NULL
          ),
          validity = function(object){
 

R/SDMXDataFlow-methods.R

@@ -161,6 +161,7 @@ SDMXDataFlow <- function(xmlObj, namespaces){
             #elements,
             Name = flowNames,
             Description = flowDescriptions,
-            dsdRef = dsdRef
+            dsdRef = dsdRef,
+            dsd = NULL
   )
 }

R/readSDMX.R

@@ -337,16 +337,21 @@ readSDMX <- function(file = NULL, isURL = TRUE,
   }
 
   #attempt to get DSD in case of helper method
-  if(buildRequest && resource == "data" && dsd){
+  if(buildRequest && resource %in% c("data","dataflow") && dsd){
 
-    if(providerId %in% c("ESTAT", "ISTAT", "WBG_WITS")){
+    if(resource == "data" && providerId %in% c("ESTAT", "ISTAT", "WBG_WITS")){
       if(verbose) message("-> Attempt to fetch DSD ref from dataflow description")
       flow <- readSDMX(providerId = providerId, resource = "dataflow",
                       resourceId = flowRef, verbose = TRUE)
       dsdRef <- slot(slot(flow, "dataflows")[[1]],"dsdRef")
       rm(flow)
     }else{
-      dsdRef <- slot(obj,"dsdRef")
+      dsdRef <- NULL
+      if(resource == "data"){
+        dsdRef <- slot(obj, "dsdRef")
+      }else if(resource=="dataflow"){
+        dsdRef <- lapply(slot(obj,"dataflows"), slot,"dsdRef")
+      }
       if(!is.null(dsdRef)){
         if(verbose) message(paste0("-> DSD ref identified in dataset = '", dsdRef, "'"))
         if(verbose) message("-> Attempt to fetch & bind DSD to dataset")
@@ -356,14 +361,29 @@ readSDMX <- function(file = NULL, isURL = TRUE,
         if(verbose) message("-> Attempt to fetch & bind DSD to dataset using 'flowRef'")
       }
     }
-
-    dsdObj <- readSDMX(providerId = providerId, resource = "datastructure",
+
+    #fetch DSD
+    dsdObj <- NULL
+    if(resource == "data"){
+      dsdObj <- readSDMX(providerId = providerId, resource = "datastructure",
                        resourceId = dsdRef, verbose = verbose)
-    if(is.null(dsdObj)){
-      if(verbose) message("-> Impossible to fetch DSD")
-    }else{
-      if(verbose) message("-> DSD fetched and associated to dataset!")
-      slot(obj, "dsd") <- dsdObj
+      if(is.null(dsdObj)){
+        if(verbose) message(sprintf("-> Impossible to fetch DSD for dataset %s", flowRef))
+      }else{
+        if(verbose) message("-> DSD fetched and associated to dataset!")
+        slot(obj, "dsd") <- dsdObj
+      }
+    }else if(resource == "dataflow"){
+      dsdObj <- lapply(1:length(dsdRef), function(x){
+        flowDsd <- readSDMX(providerId = providerId, resource = "datastructure",
+                 resourceId = dsdRef[[x]], verbose = verbose)
+        if(is.null(flowDsd)){
+          if(verbose) message(sprintf("-> Impossible to fetch DSD for dataflow %s",resourceId))
+        }else{
+          if(verbose) message("-> DSD fetched and associated to dataflow!")
+          slot(slot(obj,"dataflows")[[x]],"dsd") <<- flowDsd
+        }
+      })
     }
   }
 

R/rsdmx.R

@@ -17,7 +17,7 @@
 #'    Type: \tab Package\cr
 #'    Version
 #'    : \tab 0.5-5\cr
-#'    Date: \tab 2016-07-23\cr
+#'    Date: \tab 2016-08-02\cr
 #'    License: \tab GPL(>=2.0)\cr
 #'    LazyLoad: \tab yes\cr
 #'  }

man/rsdmx.Rd

@@ -18,7 +18,7 @@ currently focuses on the SDMX XML standard format (SDMX-ML).
    Type: \tab Package\cr
    Version
    : \tab 0.5-5\cr
-   Date: \tab 2016-07-23\cr
+   Date: \tab 2016-08-02\cr
    License: \tab GPL(>=2.0)\cr
    LazyLoad: \tab yes\cr
  }

tests/testthat/test_DataFlows.R

@@ -28,4 +28,5 @@ test_that("DataFlows - 2.1",{
   expect_equal(flow.df[1, "version"], "1.0")
   expect_equal(flow.df[1, "urn"], "urn:sdmx:org.sdmx.infomodel.datastructure.Dataflow=MYORG:DS-001(1.0)")
   expect_equal(flow.df[1, "dsdRef"], "DSD_DS-001")
+  expect_equal(flow.df[1, "dsd"], NULL)
 })