test: Add test code for serializatoin and deserialization of the plan from JSON

Author: s-minoo

plan/src/data_type.rs

@@ -22,13 +22,13 @@ pub type RcRefCellPlan<T> = Rc<RefCell<Plan<T>>>;
 pub const DEFAULT_FRAGMENT: &'static str = "default";
 // Plan states in unit structs
 
-#[derive(Clone, Serialize, Deserialize)]
+#[derive(Clone, Serialize, Deserialize, PartialEq)]
 pub struct PlanEdge {
     pub fragment:  String,
     pub direction: EdgeDirection,
 }
 
-#[derive(Debug, Clone, Serialize, Deserialize)]
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
 pub enum EdgeDirection {
     Left,
     Right,

plan/src/lib.rs

@@ -226,6 +226,7 @@ mod tests {
     use std::collections::{HashMap, HashSet};
 
     use operator::{Iterator, Projection, Rename, Source};
+    use petgraph::algo::is_isomorphic_matching;
     use states::Processed;
 
     use super::*;
@@ -299,4 +300,38 @@ mod tests {
 
         Ok(())
     }
+
+    #[test]
+    fn test_plan_serialization() -> Result<(), PlanError> {
+        let plan = generate_dummy_processed_plan()?;
+        plan.non_empty_plan_check()?;
+
+        let plan_json_string = plan.to_json_string().map_err(|_| {
+            PlanError::GenericError(format!(
+                "Something went wrong while serializing to json: {:?}",
+                plan
+            ))
+        })?;
+
+        let plan_serialized: DiGraphOperators =
+            serde_json::from_str(&plan_json_string)
+                .map_err(|err| PlanError::GenericError(err.to_string()))?;
+
+        let node_match_fn = |node1: &PlanNode, node2: &PlanNode| -> bool {
+            node1.operator == node2.operator
+        };
+
+        let edge_match_fn =
+            |edge1: &PlanEdge, edge2: &PlanEdge| -> bool { edge1 == edge2 };
+
+        let plan_graph: &DiGraphOperators = &plan.graph.borrow_mut();
+        assert!(is_isomorphic_matching(
+            plan_graph,
+            &plan_serialized,
+            node_match_fn,
+            edge_match_fn,
+        ));
+
+        Ok(())
+    }
 }

resources/csv-testcases/RMLTC0002a-CSV/mapping.ttl

@@ -1,30 +1,28 @@
-@prefix rr: <http://www.w3.org/ns/r2rml#> .
-@prefix foaf: <http://xmlns.com/foaf/0.1/> .
-@prefix ex: <http://example.com/> .
-@prefix xsd: <http://www.w3.org/2001/XMLSchema#> .
-@prefix rml: <http://semweb.mmlab.be/ns/rml#> .
-@prefix ql: <http://semweb.mmlab.be/ns/ql#> .
-@base <http://example.com/base/> .
+@prefix faldo: <http://biohackathon.org/resource/faldo#>.
+@prefix rr: <http://www.w3.org/ns/r2rml#>.
+@prefix foaf: <http://xmlns.com/foaf/0.1/>.
+@prefix ex: <http://example.com/>.
+@prefix xsd: <http://www.w3.org/2001/XMLSchema#>.
+@prefix rml: <http://semweb.mmlab.be/ns/rml#>.
+@prefix ql: <http://semweb.mmlab.be/ns/ql#>.
 
 <TriplesMap1> a rr:TriplesMap;
-    
-  rml:logicalSource [ 
+  rml:logicalSource [
     rml:source "student.csv";
-    rml:referenceFormulation ql:CSV
+    rml:referenceFormulation ql:CSV;
   ];
-
-  rr:subjectMap [ 
+  rr:subjectMap [
     rr:template "http://example.com/{ID}/{Name}";
-    rr:class foaf:Person 
+    rr:class foaf:Person;
   ];
-
-  rr:predicateObjectMap [ 
-    rr:predicate ex:id ; 
-    rr:objectMap [ rml:reference "ID" ]
+  rr:predicateObjectMap [
+    rr:predicate ex:id;
+    rr:objectMap [ rml:reference "ID" ];
   ];
-
-  rr:predicateObjectMap [ 
-    rr:predicate foaf:name ; 
-    rr:objectMap [ rml:reference "Name" ]
+  rr:predicateObjectMap [
+    rr:predicate foaf:name;
+    rr:objectMap [ rml:reference "Name" ];
   ].
 
+
+