diff options
| author | Estevan Castilho <tevo@riajuu.net> | 2026-05-28 03:18:52 +0000 |
|---|---|---|
| committer | Estevan Castilho <tevo@riajuu.net> | 2026-05-28 03:18:52 +0000 |
| commit | a5e1d949d2ee8d82991cd48638137bbf57d40652 (patch) | |
| tree | 4cefba58453953f4adcf331ae156950c32e99b1b /lib | |
| parent | 1378202e6b0b51d7d338a1042824860f19fcbc9b (diff) | |
| download | Sakura-a5e1d949d2ee8d82991cd48638137bbf57d40652.tar.gz Sakura-a5e1d949d2ee8d82991cd48638137bbf57d40652.zip | |
No need to take the multigroup name as an argument
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/branch.ml | 2 | ||||
| -rw-r--r-- | lib/ddl/executor.ml | 3 | ||||
| -rw-r--r-- | lib/nt.ml | 13 |
3 files changed, 8 insertions, 10 deletions
diff --git a/lib/branch.ml b/lib/branch.ml index 0b28663..f606d3f 100644 --- a/lib/branch.ml +++ b/lib/branch.ml @@ -96,7 +96,7 @@ module Make (NT : Nt.S) = struct let* mg_val = self#get_mg "create_relation" mg in let* (bh', mg') = NT.create_relation bh mg_val - ~branch_name:name ~mg_name:mg ~name:rel_name ~schema + ~branch_name:name ~name:rel_name ~schema in bh <- bh'; Hashtbl.replace mgs mg mg'; self#sync_tip (); Ok () diff --git a/lib/ddl/executor.ml b/lib/ddl/executor.ml index c61b02e..a47c911 100644 --- a/lib/ddl/executor.ml +++ b/lib/ddl/executor.ml @@ -46,8 +46,7 @@ module Make (NT : Nt.S) = struct Schema.empty schema_pairs in let* _bh, new_mg = - NT.create_relation bh mg - ~branch_name ~mg_name:fqn.mg ~name:fqn.name ~schema + NT.create_relation bh mg ~branch_name ~name:fqn.name ~schema in ctx.branch#set_mg ~name:fqn.mg new_mg; Ok ([ (fqn.mg, new_mg) ], "Relation created: " ^ name) @@ -395,9 +395,9 @@ module Make (B : Backend) = struct open_branch claims name let create_relation (bh : branch_handle) (mg : Management.Multigroup.multigroup) - ~(branch_name : string) ~(mg_name : string) ~(name : string) - ~(schema : Schema.t) : + ~(branch_name : string) ~(name : string) ~(schema : Schema.t) : (branch_handle * Management.Multigroup.multigroup, Condition.t) result = + let mg_name = mg#name in let path = relation_path ~branch_name ~mg_name ~rel_name:name in let rc = Nt_ffi.rnt_register_relation path in if rc <> 0 then Error (Error.handle_error ("register_relation failed: " ^ name)) @@ -551,7 +551,7 @@ module Make (B : Backend) = struct (fun acc (name, schema) -> let* (branch_handle, multigroup) = acc in create_relation branch_handle multigroup - ~branch_name ~mg_name ~name ~schema) + ~branch_name ~name ~schema) (Ok (branch_handle, multigroup)) Prelude.Catalog.catalog_definitions in @@ -598,9 +598,8 @@ module Make (B : Backend) = struct new Management.Multigroup.multigroup ~name:Prelude.Catalog.prelude_mg in - (match seed_prelude ~branch_name:"master" bh mg with - | Ok _ -> Ok () - | Error e -> Error e) + seed_prelude ~branch_name:"master" bh mg + |> Result.map ignore else Ok () in ignore (Nt_ffi.rnt_close_handle (Nt_ffi.nint_to_ptr bh)); @@ -666,7 +665,7 @@ module type S = sig val get_relation : Management.Multigroup.multigroup -> string -> Relation.ephemeral option val create_multigroup : claims -> string -> (branch_handle * Management.Multigroup.multigroup, Condition.t) result - val create_relation : branch_handle -> Management.Multigroup.multigroup -> branch_name:string -> mg_name:string -> name:string -> schema:Schema.t -> (branch_handle * Management.Multigroup.multigroup, Condition.t) result + val create_relation : branch_handle -> Management.Multigroup.multigroup -> branch_name:string -> name:string -> schema:Schema.t -> (branch_handle * Management.Multigroup.multigroup, Condition.t) result val retract_relation : branch_handle -> Management.Multigroup.multigroup -> name:string -> (branch_handle * Management.Multigroup.multigroup, Condition.t) result val clear_relation : branch_handle -> Management.Multigroup.multigroup -> branch_name:string -> mg_name:string -> Relation.relation -> (branch_handle * Management.Multigroup.multigroup, Condition.t) result val register_domain : branch_handle -> Management.Multigroup.multigroup -> Relation.domain -> (branch_handle * Management.Multigroup.multigroup, Condition.t) result |
