aboutsummaryrefslogtreecommitdiffstats
path: root/lib/management/physical.ml
diff options
context:
space:
mode:
authorEstevan Castilho <tevo@riajuu.net>2026-05-27 23:24:12 +0000
committerGitHub <noreply@github.com>2026-05-27 23:24:12 +0000
commit9dc0391443ca16bf1ab3114d002aad83872f8a73 (patch)
treee4f78a2533e5e633b733c1ea21d0159aeca79b75 /lib/management/physical.ml
parentf9097a0562ea8b40d40a19059578a9280b945de4 (diff)
downloadSakura-9dc0391443ca16bf1ab3114d002aad83872f8a73.tar.gz
Sakura-9dc0391443ca16bf1ab3114d002aad83872f8a73.zip
Improve the error handling situation (#71)
* Sketches of a condition system * `Condition.condition` -> `Condition.t` * Migrate `NT` over * Migrate `Branch` over * Migrate `Sublanguage` et al. over * Migrate the PRL over * Migrate the DRL over * Migrate the DML over * Have `Qualified_name.try_parse` return a `Condition.t` * Migrate the DDL over * Migrate the VCL over * Migrate the SCL over * Migrate the ICL over * Migrate the parsers over * Just inherit the errors from NT and the sublanguages * Migrate `Management.Physical` over * Migrate `Configuration` over * Migrate `Management.Branch` over * Migrate `Transport` over * Migrate `System` over * Migrate `Server` over * Include messages on on all conditions * A prettier stringifier
Diffstat (limited to '')
-rw-r--r--lib/management/physical.ml58
1 files changed, 31 insertions, 27 deletions
diff --git a/lib/management/physical.ml b/lib/management/physical.ml
index 0f26bca..7c6f6b2 100644
--- a/lib/management/physical.ml
+++ b/lib/management/physical.ml
@@ -12,38 +12,37 @@ module type BACKEND = sig
include Configuration.CONFIGURABLE
type connection
- type error
- val connect : configuration -> (connection, error) result
+ val connect : configuration -> (connection, Condition.t) result
(** Connect to the storage backend *)
val disconnect : connection -> unit
(** Disconnect from the backend *)
- val get : connection -> Conventions.Hash.t -> (bytes option, error) result
+ val get : connection -> Conventions.Hash.t -> (bytes option, Condition.t) result
(** Get a value by its hash. Returns None if not found. *)
- val put : connection -> Conventions.Hash.t -> bytes -> (unit, error) result
+ val put : connection -> Conventions.Hash.t -> bytes -> (unit, Condition.t) result
(** Store a value at its hash *)
- val exists : connection -> Conventions.Hash.t -> (bool, error) result
+ val exists : connection -> Conventions.Hash.t -> (bool, Condition.t) result
(** Check if a hash exists *)
- val begin_transaction : connection -> (unit, error) result
+ val begin_transaction : connection -> (unit, Condition.t) result
(** Begin a transaction *)
- val commit : connection -> (unit, error) result
+ val commit : connection -> (unit, Condition.t) result
(** Commit a transaction *)
- val rollback : connection -> (unit, error) result
+ val rollback : connection -> (unit, Condition.t) result
(** Rollback a transaction *)
val get_many :
- connection -> Conventions.Hash.t list -> (bytes option list, error) result
+ connection -> Conventions.Hash.t list -> (bytes option list, Condition.t) result
(** Batch get multiple values *)
val put_many :
- connection -> (Conventions.Hash.t * bytes) list -> (unit, error) result
+ connection -> (Conventions.Hash.t * bytes) list -> (unit, Condition.t) result
(** Batch put multiple values *)
end
@@ -52,43 +51,41 @@ module type S = sig
include Configuration.CONFIGURABLE
type t
- type error
- val create : configuration -> (t, error) result
+ val create : configuration -> (t, Condition.t) result
(** Create a storage instance from a backend connection *)
val close : t -> unit
(** Close the storage *)
val store_attribute :
- t -> Conventions.AbstractValue.t -> (Conventions.Hash.t, error) result
+ t -> Conventions.AbstractValue.t -> (Conventions.Hash.t, Condition.t) result
(** Store an attribute value, returns its hash *)
val load_attribute :
t ->
Conventions.Hash.t ->
- (Conventions.AbstractValue.t option, error) result
+ (Conventions.AbstractValue.t option, Condition.t) result
(** Load an attribute value by hash *)
- val store_raw : t -> Conventions.Hash.t -> bytes -> (unit, error) result
+ val store_raw : t -> Conventions.Hash.t -> bytes -> (unit, Condition.t) result
(** Store raw bytes at a hash *)
- val load_raw : t -> Conventions.Hash.t -> (bytes option, error) result
+ val load_raw : t -> Conventions.Hash.t -> (bytes option, Condition.t) result
(** Load raw bytes by hash *)
- val exists : t -> Conventions.Hash.t -> (bool, error) result
+ val exists : t -> Conventions.Hash.t -> (bool, Condition.t) result
(** Check if a hash exists *)
- val with_transaction : t -> (unit -> ('a, error) result) -> ('a, error) result
+ val with_transaction : t -> (unit -> ('a, Condition.t) result) -> ('a, Condition.t) result
(** Execute a function within a transaction *)
end
(** Functor to create storage operations from a backend *)
module Make (B : BACKEND) :
- S with type error = B.error and type configuration = B.configuration = struct
+ S with type configuration = B.configuration = struct
type configuration = B.configuration
type t = B.connection
- type error = B.error
let parse = B.parse
let create config = B.connect config
@@ -123,7 +120,7 @@ end
(** In-memory backend for testing and development *)
module MemoryBackend :
- BACKEND with type error = string and type configuration = unit = struct
+ BACKEND with type configuration = unit = struct
type configuration = unit
type connection = {
@@ -132,15 +129,22 @@ module MemoryBackend :
mutable transaction_buffer : (string * bytes) list;
}
- type error = string
+ module Error = struct
+ open Condition
+ (* TODO: more structure *)
+ let parse_error msg = condition "parse-error" msg empty
+ let already_in_transaction = condition "already-in-transaction" "Already inside a transaction" empty
+ let not_in_transaction = condition "not-in-transaction" "Not inside a transaction" empty
+ end
let parse sexp =
match sexp with
| Sexplib.Sexp.List [] -> Ok ()
| _ ->
Error
- (Printf.sprintf "memory backend takes no configuration, got: %s"
- (Sexplib.Sexp.to_string sexp))
+ (Error.parse_error
+ (Printf.sprintf "memory backend takes no configuration, got: %s"
+ (Sexplib.Sexp.to_string sexp)))
let connect () =
Ok
@@ -166,7 +170,7 @@ module MemoryBackend :
let exists conn hash = Ok (Hashtbl.mem conn.data hash)
let begin_transaction conn =
- if conn.in_transaction then Error "Already in transaction"
+ if conn.in_transaction then Error Error.already_in_transaction
else begin
conn.in_transaction <- true;
conn.transaction_buffer <- [];
@@ -174,7 +178,7 @@ module MemoryBackend :
end
let commit conn =
- if not conn.in_transaction then Error "Not in transaction"
+ if not conn.in_transaction then Error Error.not_in_transaction
else begin
List.iter
(fun (hash, value) -> Hashtbl.replace conn.data hash value)
@@ -185,7 +189,7 @@ module MemoryBackend :
end
let rollback conn =
- if not conn.in_transaction then Error "Not in transaction"
+ if not conn.in_transaction then Error Error.not_in_transaction
else begin
conn.in_transaction <- false;
conn.transaction_buffer <- [];