···

       
2
       
 
       
open Eio.Std

     

       
3
       
 
       
module API = Schema.Storage.MakeRPC (Capnp_rpc)

     

       
4
       
 
       


     

       
5
       
-
       
let pp_file ppf file =

     

       
6
       
-
       
  let e = Capability.problem file in

     

       
7
       
-
       
  Fmt.pf ppf "[%a:%a]" Capnp_rpc.Capability.pp file

     

       
8
       
-
       
    Fmt.(option Capnp_rpc.Exception.pp)

     

       
9
       
-
       
    e

     

       
10
       
-
       


     

       
11
       
 
       
module Storage :

     

       
12
       
 
       
  Bellairs.Storage

     

       
13
       
 
       
    with type file = API.Client.File.t Capability.t

     
···

       
84
       
 
       
  let client = Capnp_rpc_unix.Vat.import_exn client_vat uri in

     

       
85
       
 
       
  Capnp_rpc_unix.with_cap_exn client f

     

       
86
       
 
       


     

       
87
       
-
       
let pp_entry ppf entry =

     

       
88
       
-
       
  Fmt.pf ppf "%s:%a" entry.Storage.name pp_file entry.file

     

       
89
       
 
       


     

       
90
       
 
       
let ls net uri =

     

       
91
       
 
       
  connect net uri @@ fun dir ->

     
···

       
96
       
 
       


     

       
97
       
 
       
let create net uri name =

     

       
98
       
 
       
  connect net uri @@ fun dir ->

     

       
99
       
-
       
  let file = Storage.create dir name in

     

       
100
       
-
       
  Fmt.pr "Created file '%s': %a\n" name pp_file file

     

       
101
       
 
       


     

       
102
       
 
       
let open_file net uri name =

     

       
103
       
 
       
  connect net uri @@ fun dir ->

     

       
104
       
-
       
  let file = Storage.open_ dir name in

     

       
105
       
-
       
  Fmt.pr "Opened file '%s': %a\n" name pp_file file

     

       
106
       
 
       


     

       
107
       
 
       
let delete net uri name =

     

       
108
       
 
       
  connect net uri @@ fun dir ->

     

       
109
       
 
       
  Storage.delete dir name;

     

       
110
       
-
       
  Fmt.pr "Deleted file '%s'\n" name

     

       
111
       
 
       


     

       
112
       
 
       
let size net uri name =

     

       
113
       
 
       
  connect net uri @@ fun dir ->

     

···

       
2
       
 
       
open Eio.Std

     

       
3
       
 
       
module API = Schema.Storage.MakeRPC (Capnp_rpc)

     

       
4
       
 
       


     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
5
       
 
       
module Storage :

     

       
6
       
 
       
  Bellairs.Storage

     

       
7
       
 
       
    with type file = API.Client.File.t Capability.t

     
···

       
78
       
 
       
  let client = Capnp_rpc_unix.Vat.import_exn client_vat uri in

     

       
79
       
 
       
  Capnp_rpc_unix.with_cap_exn client f

     

       
80
       
 
       


     

       
81
       
+
       
let pp_name ppf name = Fmt.pf ppf "%a" Fmt.(styled `Bold string) name

     

       
82
       
+
       
let pp_entry ppf entry = pp_name ppf entry.Storage.name

     

       
83
       
 
       


     

       
84
       
 
       
let ls net uri =

     

       
85
       
 
       
  connect net uri @@ fun dir ->

     
···

       
90
       
 
       


     

       
91
       
 
       
let create net uri name =

     

       
92
       
 
       
  connect net uri @@ fun dir ->

     

       
93
       
+
       
  let _file = Storage.create dir name in

     

       
94
       
+
       
  Fmt.pr "Created file '%a'\n" pp_name name

     

       
95
       
 
       


     

       
96
       
 
       
let open_file net uri name =

     

       
97
       
 
       
  connect net uri @@ fun dir ->

     

       
98
       
+
       
  let _file = Storage.open_ dir name in

     

       
99
       
+
       
  Fmt.pr "Opened file <raw>\n"

     

       
100
       
 
       


     

       
101
       
 
       
let delete net uri name =

     

       
102
       
 
       
  connect net uri @@ fun dir ->

     

       
103
       
 
       
  Storage.delete dir name;

     

       
104
       
+
       
  Fmt.pr "Deleted file '%a'\n" pp_name name

     

       
105
       
 
       


     

       
106
       
 
       
let size net uri name =

     

       
107
       
 
       
  connect net uri @@ fun dir ->

     

···

       
1
       
-
       
(* TODO: put the real implementation here -- for now it's just an in-memory database *)

     

       
0
       
 
       

     

       
2
       
 
       


     

       
3
       
 
       
type file = { content : string; size : int64 }

     

       
4
       
 
       
type dir = (string, file) Hashtbl.t

     

···

       
1
       
+
       
(* TODO: put the real implementation here -- for now it's just an

     

       
2
       
+
       
   in-memory database *)

     

       
3
       
 
       


     

       
4
       
 
       
type file = { content : string; size : int64 }

     

       
5
       
 
       
type dir = (string, file) Hashtbl.t