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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
module H = Ldp.Http
module Foaf = Rdf.Foaf
module G = Rdf.Graph
open Lwt.Infix
type profile = G.graph
type workspace = {
ws_title : string ;
ws_iri : Iri.t ;
ws_triples : Rdf.Term.triple list ;
}
module type S =
sig
val get_profile : Iri.t -> (profile, Ldp.Types.error) result Lwt.t
val webid : profile -> Iri.t
val inbox : profile -> Iri.t option
val workspaces : ?typ:Iri.t -> profile -> workspace list
val storages : profile -> Iri.t list
val name : profile -> string
val pim : profile -> Rdf.Pim.from
val preferences_ws : profile -> workspace list
val private_ws : profile -> workspace list
val public_ws : profile -> workspace list
val shared_ws : profile -> workspace list
val master_ws : profile -> workspace list
end
module Make (H: Ldp.Http.Http) =
struct
let primary_topic profile =
let iri = profile.G.name() in
match G.iri_objects_of profile
~sub: (Rdf.Term.Iri iri)
~pred: Foaf.primaryTopic
with
[] ->
Ldp.Types.error
(Ldp.Types.Missing_pred_iri (iri, Foaf.primaryTopic))
| webid :: _ ->
webid
let webid = primary_topic
let get_profile iri =
match%lwt H.get_rdf_graph iri with
| Error e -> Lwt.return (Error e)
| Ok g ->
let%lwt webid =
try Lwt.return (primary_topic g)
with e -> Lwt.fail e
in
let f sub acc pred =
let sub = Rdf.Term.Iri sub in
let objs = G.iri_objects_of g ~sub ~pred in
objs @ acc
in
let to_load_preds =
[ Rdf.Owl.sameAs ; Rdf.Rdfs.seeAlso ; Rdf.Pim.preferencesFile ]
in
let to_load = List.fold_left (f iri) [] to_load_preds in
let to_load = List.fold_left (f webid) to_load to_load_preds in
let load iri =
let g = Rdf.Graph.open_graph iri in
try%lwt H.get_rdf_graph_exn ~g iri
with Ldp.Types.Error e ->
H.dbg (Ldp.Types.string_of_error e) >>= fun () ->
Lwt.return g
in
let%lwt graphs = Lwt_list.map_p load to_load in
List.iter (Rdf.Graph.merge g) graphs ;
Lwt.return_ok g
let workspaces ?typ profile =
let webid = primary_topic profile in
let ws = G.iri_objects_of profile
~sub:(Rdf.Term.Iri webid) ~pred: Rdf.Pim.workspace
in
let ws =
match typ with
None -> ws
| Some typ ->
let pred ws =
profile.G.exists ~sub: (Rdf.Term.Iri ws)
~pred:Rdf.Rdf_.type_ ~obj:(Rdf.Term.Iri typ) ()
in
List.filter pred ws
in
let f acc ws =
match profile.G.objects_of
~sub: (Rdf.Term.Iri ws) ~pred: Rdf.Dc.title
with
(Rdf.Term.Literal lit) :: _ ->
{ ws_title = lit.Rdf.Term.lit_value ;
ws_iri = ws ;
ws_triples = profile.G.find ~sub: (Rdf.Term.Iri ws) () ;
} :: acc
| _ ->
acc
in
List.fold_left f [] ws
let inbox profile =
let sub = Rdf.Term.Iri (primary_topic profile) in
match Rdf.Graph.iri_objects_of profile
~sub ~pred: Rdf.Solid.inbox
with
[] -> None
| iri :: _ -> Some iri
let storages profile =
let sub = Rdf.Term.Iri (primary_topic profile) in
Rdf.Graph.iri_objects_of profile
~sub ~pred: Rdf.Pim.storage
let name profile =
let sub = Rdf.Term.Iri (primary_topic profile) in
let l = profile.Rdf.Graph.objects_of
~sub ~pred: Rdf.Foaf.name
in
let rec iter = function
[] -> Iri.to_string (profile.Rdf.Graph.name())
| (Rdf.Term.Literal l) :: _ -> l.Rdf.Term.lit_value
| _ :: q -> iter q
in
iter l
let pim profile =
let sub = Rdf.Term.Iri (primary_topic profile) in
new Rdf.Pim.from ~sub profile
let preferences_ws = workspaces ~typ: Rdf.Pim.c_PreferencesWorkspace
let private_ws = workspaces ~typ: Rdf.Pim.c_PrivateWorkspace
let public_ws = workspaces ~typ: Rdf.Pim.c_PublicWorkspace
let shared_ws = workspaces ~typ: Rdf.Pim.c_SharedWorkspace
let master_ws = workspaces ~typ: Rdf.Pim.c_MasterWorkspace
end