1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
#!/usr/bin/env perl
use v5.18;
use autodie;
use utf8;
use File::Spec;
use JSON;
use JSONLD;
use Attean;
use open ':std', ':encoding(UTF-8)';
package MyJSONLD {
use v5.14;
use autodie;
use Moo;
use Attean::RDF;
extends 'JSONLD';
use namespace::clean;
sub default_graph {
return iri('http://attean.example.org/default-graph');
}
sub add_quad {
my $self = shift;
my $triple = shift;
my $ds = shift;
$ds->add_quad($triple);
}
sub new_dataset {
my $self = shift;
my $store = Attean->get_store('Memory')->new();
return $store;
}
sub new_triple {
my $self = shift;
foreach my $v (@_) {
Carp::confess "not a term object" unless (ref($v));
}
return triple(@_);
}
sub new_quad {
my $self = shift;
foreach my $v (@_) {
Carp::confess "not a term object: $v" unless (ref($v));
}
return quad(@_);
}
sub new_graphname {
my $self = shift;
my $value = shift;
if ($value =~ /^_:(.+)$/) {
$value = 'tag:gwilliams@cpan.org,2019-12:JSONLD:skolem:' . $1;
}
return $self->new_iri($value);
}
sub new_iri {
my $self = shift;
return iri(shift);
}
sub new_blank {
my $self = shift;
return blank(@_);
}
sub new_lang_literal {
my $self = shift;
my $value = shift;
my $lang = shift;
return langliteral($value, $lang);
}
sub new_dt_literal {
my $self = shift;
my $value = shift;
my $dt = shift;
return dtliteral($value, $dt);
}
}
my $data;
my $base;
my $j = JSON->new->pretty(1)->canonical(1)->allow_nonref(1);
while (scalar(@ARGV) and $ARGV[0] =~ /^-(\w+)$/) {
my $flag = $1;
shift;
if ($flag eq 'v') {
$JSONLD::debug = 1;
}
}
if (scalar(@ARGV)) {
my $file = shift;
open(my $fh, '<:utf8', $file);
$data = $j->decode(do { local($/); <$fh> });
$base = 'file://' . File::Spec->rel2abs($file);
} else {
$data = $j->decode(do { local($/); <> });
$base = 'http://base.example.org/';
}
my $jld = MyJSONLD->new(base_iri => IRI->new($base));
my $default_graph = $jld->default_graph();
my $iter = eval {
my $qiter = $jld->to_rdf($data)->get_quads()->materialize();
my $iter = Attean::CodeIterator->new(generator => sub {
my $q = $qiter->next;
return unless ($q);
if ($q->graph->equals($default_graph)) {
return $q->as_triple;
} else {
return $q;
}
}, item_type => 'Attean::API::TripleOrQuad')->materialize;
};
if ($@) {
die $@;
}
my $ser = Attean->get_serializer('nquads')->new();
$ser->serialize_iter_to_io(\*STDOUT, $iter);
|
