2 files changed, 27 insertions, 0 deletions
diff --git a/lib/kernel/Storage.ml b/lib/kernel/Storage.ml
new file mode 100644
index 0000000..952b306
--- /dev/null
+++ b/lib/kernel/Storage.ml
@@ -0,0 +1,22 @@
+module Make (S : Abstract.Storage.STORAGE) = struct
+  let finish tx = function
+    | Ok value ->
+       let open Utilities.Result in
+       let* () = S.commit tx in
+       Ok value
+    | Error condition ->
+       let _ = S.abort tx in
+       Error condition
+
+  let with_transaction connection body =
+    let open Utilities.Result in
+    let* tx = S.start connection in
+    body tx |> finish tx
+
+  let store_blob tx blob =
+    let open Utilities.Result in
+    let address = Concepts.Hash.hash_of_blob blob in
+    let* () = S.put tx address blob in
+    Ok address
+
+end
diff --git a/lib/kernel/Storage.mli b/lib/kernel/Storage.mli
new file mode 100644
index 0000000..3ef1ffc
--- /dev/null
+++ b/lib/kernel/Storage.mli
@@ -0,0 +1,5 @@
+module Make : functor (S : Abstract.Storage.STORAGE) -> sig
+  val finish : S.transaction -> ('a, Concepts.Condition.condition) result -> ('a, Concepts.Condition.condition) result
+  val with_transaction : S.connection -> (S.transaction -> ('a, Concepts.Condition.condition) result) -> ('a, Concepts.Condition.condition) result
+  val store_blob : S.transaction -> Concepts.Representation.blob -> (Concepts.Hash.hash, Concepts.Condition.condition) result
+end