diff options
Diffstat (limited to 'lib/management/multigroup.ml')
| -rw-r--r-- | lib/management/multigroup.ml | 32 |
1 files changed, 12 insertions, 20 deletions
diff --git a/lib/management/multigroup.ml b/lib/management/multigroup.ml index b908302..2882afa 100644 --- a/lib/management/multigroup.ml +++ b/lib/management/multigroup.ml @@ -2,13 +2,11 @@ to content-addressed relation values. The multigroup object owns the B+ tree pointer and advances it when relations change. *) - class multigroup ~name:(init_name : Conventions.Name.t) = object (_self) val name : Conventions.Name.t = init_name val relations : Relation.relation BatMap.String.t = BatMap.String.empty val timestamp : float = Unix.gettimeofday () - method name = name method relations = relations method timestamp = timestamp @@ -19,21 +17,19 @@ class multigroup ~name:(init_name : Conventions.Name.t) = method has_relation rel_name = BatMap.String.mem rel_name relations method add_relation (rel : Relation.relation) = - {< relations = BatMap.String.add rel#name rel relations >} + {<relations = BatMap.String.add rel#name rel relations>} - method remove_relation rel_name = - {< relations = BatMap.String.remove rel_name relations >} + method remove_relation rel_name = {<relations = BatMap.String.remove rel_name relations>} method update_relation (rel : Relation.relation) = - if not (BatMap.String.mem rel#name relations) then {< >} - else {< relations = BatMap.String.add rel#name rel relations >} + if not (BatMap.String.mem rel#name relations) then {<>} + else {<relations = BatMap.String.add rel#name rel relations>} method serialize () : Storable.Multigroup.t = - { - Storable.Multigroup.name = name; - relations = BatMap.String.bindings relations |> List.map snd |> List.map (fun r -> r#serialize ()); - } -end + { Storable.Multigroup.name; + relations= + BatMap.String.bindings relations |> List.map snd |> List.map (fun r -> r#serialize ()) } + end let deserialize (bytes : bytes) : (multigroup, string) result = (* Reconstruct a multigroup from its persisted payload. @@ -48,19 +44,15 @@ let deserialize (bytes : bytes) : (multigroup, string) result = (fun mg rel -> let relation = new Relation.stored - ~name:rel.Storable.Relation.name - ~schema:rel.schema - ~constraints:None - ~cardinality:Conventions.Cardinality.AlephZero - ~lineage:None - ~provenance:None - ~membership_criteria:(fun _ -> true) + ~name:rel.Storable.Relation.name ~schema:rel.schema ~constraints:None + ~cardinality:Conventions.Cardinality.AlephZero ~lineage:None ~provenance:None + ~membership_criteria:(fun _ -> true ) in let relation = if rel.tree_pointer = "" then relation else relation#set_tree_pointer (Some rel.tree_pointer) in - mg#add_relation (relation :> Relation.relation)) + mg#add_relation (relation :> Relation.relation) ) db stored.relations in Ok db |