Working version of JSON2RDF converter

Author: bharath181

Cargo.lock

@@ -4,8 +4,8 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
+oxrdf = "0.1.7"
 petgraph = "0.6.5"
-rio_api = "0.8.4"
-rio_turtle = "0.8.4"
+
 serde = "1.0.203"
 serde_json = "1.0.117"

Cargo.toml

@@ -1,11 +1,13 @@
+use oxrdf::{LiteralRef, NamedNodeRef, TermRef, TripleRef};
 use petgraph::graph::{Graph, NodeIndex};
 use petgraph::visit::EdgeRef;
-use rio_api::formatter::TriplesFormatter;
-use rio_api::model::{NamedNode, Triple};
-use rio_turtle::NTriplesFormatter;
+// use rio_api::formatter::TriplesFormatter;
+// use rio_api::model::{NamedNode, Triple};
+// use rio_turtle::NTriplesFormatter;
 use serde_json::Value;
-use std::fs::File;
-use std::io::BufReader;
+use std::fmt::format;
+use std::fs::{read, File};
+use std::io::{BufReader, Write};
 
 fn json_to_graph(value: &Value, graph: &mut Graph<String, String>, parent: Option<NodeIndex>) {
     match value {
@@ -15,6 +17,10 @@ fn json_to_graph(value: &Value, graph: &mut Graph<String, String>, parent: Optio
                 if let Some(parent_index) = parent {
                     graph.add_edge(parent_index, node, "".to_string());
                 }
+                // let node = graph.add_node("".to_string());
+                // if let Some(parent_index) = parent {
+                //     graph.add_edge(parent_index, node, key.to_string());
+                // }
                 json_to_graph(val, graph, Some(node));
             }
         }
@@ -27,6 +33,9 @@ fn json_to_graph(value: &Value, graph: &mut Graph<String, String>, parent: Optio
             let node = graph.add_node(value.to_string());
             if let Some(parent_index) = parent {
                 graph.add_edge(parent_index, node, "".to_string());
+                // let node = graph.add_node("".to_string());
+                // if let Some(parent_index) = parent {
+                //     graph.add_edge(parent_index, node, value.to_string());
             }
         }
     }
@@ -35,9 +44,25 @@ fn json_to_graph(value: &Value, graph: &mut Graph<String, String>, parent: Optio
 fn graph_to_ttl(graph: &mut Graph<String, String>, file_path: &str) {
     let mut file = File::create(file_path);
 
-    let mut formatter = NTriplesFormatter::new(Vec::default());
+    let mut triples_graph = oxrdf::Graph::default();
 
-    for edge in graph.edge_references() {}
+    for edge in graph.edge_references() {
+        let val = format!("http://www.decisym.ai/data#{}", &graph[edge.source()]);
+
+        let subject_triple = NamedNodeRef::new(val.as_str()).unwrap();
+
+        let predicate_triple = NamedNodeRef::new("http://www.w3.org/1999/02/22-rdf-syntax-ns#type");
+
+        let object_triples = TermRef::Literal(LiteralRef::new_simple_literal(
+            graph[edge.target()].as_str(),
+        ));
+
+        let rdf_triple = TripleRef::new(subject_triple, predicate_triple.unwrap(), object_triples);
+
+        triples_graph.insert(rdf_triple);
+    }
+
+    writeln!(file.unwrap(), "{}", triples_graph.to_string()).unwrap();
 }
 
 fn main() -> serde_json::Result<()> {
@@ -50,5 +75,15 @@ fn main() -> serde_json::Result<()> {
 
     json_to_graph(&json_value, &mut graph, None);
 
+    // for edge in graph.edge_references() {
+    //     println!("{:?}", graph[edge.source()]);
+    //     println!("{:?}", graph[edge.target()]);
+
+    //     println!("------------")
+    //     //println!("{:?}", edge.id());
+    // }
+
+    graph_to_ttl(&mut graph, "/home/bharath/test.ttl");
+
     Ok(())
 }