From 7ba7558c0031a391c60db8adbc6144ca00734709 Mon Sep 17 00:00:00 2001
From: cmdoret <cyril.mattheydoret@gmail.com>
Date: Wed, 23 Oct 2024 02:27:29 +0200
Subject: [PATCH] fix: always exclude blank nodes

---
 fuzon/src/lib.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/fuzon/src/lib.rs b/fuzon/src/lib.rs
index 0ad24dc..3804ecc 100644
--- a/fuzon/src/lib.rs
+++ b/fuzon/src/lib.rs
@@ -11,6 +11,7 @@ use std::{
 use anyhow::Result;
 use lazy_static::lazy_static;
 use oxrdfio::{RdfFormat, RdfParser};
+use oxrdf::Subject;
 use postcard;
 use reqwest::{blocking::Client, Url};
 use serde::{Deserialize, Serialize};
@@ -164,8 +165,10 @@ pub fn gather_terms(readers: Vec<(impl BufRead, RdfFormat)>) -> impl Iterator<It
     let mut terms = Vec::new();
     for (reader, format) in readers {
         let parser = RdfParser::from_format(format).for_reader(reader);
+        // Drop blank nodes and filter by common annotation properties
         let mut out = parser
             .map(|t| t.expect("Error parsing RDF"))
+            .filter(|t| if let Subject::NamedNode(_) = t.subject {true} else {false})
             .filter(|t| ANNOTATIONS.contains(t.predicate.as_str()))
             .map(|t| Term {
                 uri: t.subject.to_string(),