Skip to content

Commit

Permalink
Fix server backend tests
Browse files Browse the repository at this point in the history
  • Loading branch information
samoht committed Jul 29, 2012
1 parent 0d2897a commit f565f11
Show file tree
Hide file tree
Showing 6 changed files with 25 additions and 15 deletions.
4 changes: 1 addition & 3 deletions src/client.ml
Expand Up @@ -1441,9 +1441,7 @@ let upload upload repo =
Filename.copy upload.descr upload_descr; Filename.copy upload.descr upload_descr;
Filename.copy upload.archive upload_archives; Filename.copy upload.archive upload_archives;
Repositories.upload repo; Repositories.upload repo;
Filename.remove upload_opam; Dirname.rmdir (Path.R.package upload_repo nv)
Filename.remove upload_descr;
Filename.remove upload_archives


(* Return the transitive closure of dependencies *) (* Return the transitive closure of dependencies *)
let get_transitive_dependencies t names = let get_transitive_dependencies t names =
Expand Down
3 changes: 3 additions & 0 deletions src/path.ml
Expand Up @@ -19,6 +19,7 @@ open Utils
let log fmt = Globals.log "PATH" fmt let log fmt = Globals.log "PATH" fmt


let available_packages dir = let available_packages dir =
log "available_packages %s" (Dirname.to_string dir);
let files = Filename.list dir in let files = Filename.list dir in
let files = List.filter (fun f -> Filename.check_suffix f ".opam") files in let files = List.filter (fun f -> Filename.check_suffix f ".opam") files in
List.fold_left (fun set file -> List.fold_left (fun set file ->
Expand All @@ -30,6 +31,7 @@ let available_packages dir =
) NV.Set.empty files ) NV.Set.empty files


let available_compilers dir = let available_compilers dir =
log "available_compilers %s" (Dirname.to_string dir);
if Dirname.exists dir then ( if Dirname.exists dir then (
let files = Filename.list dir in let files = Filename.list dir in
let files = List.filter (fun f -> Filename.check_suffix f ".comp") files in let files = List.filter (fun f -> Filename.check_suffix f ".comp") files in
Expand Down Expand Up @@ -160,6 +162,7 @@ module R = struct
let packages_dir t = t / "packages" let packages_dir t = t / "packages"


let available_packages t = let available_packages t =
log "available_packages %s" (Dirname.to_string t);
let all = Dirname.list (packages_dir t) in let all = Dirname.list (packages_dir t) in
let basenames = List.map Dirname.basename all in let basenames = List.map Dirname.basename all in
NV.Set.of_list (List.map (Basename.to_string |> NV.of_string) basenames) NV.Set.of_list (List.map (Basename.to_string |> NV.of_string) basenames)
Expand Down
12 changes: 6 additions & 6 deletions src/repo/server/daemon.ml
Expand Up @@ -27,17 +27,17 @@ type t = {
available: NV.Set.t available: NV.Set.t
} }


let load_root () =
Path.R.of_dirname (Dirname.of_string !Globals.root_path)

let init () = let init () =
log "init server state"; let t = load_root () in
let t = Path.R.of_dirname (Dirname.cwd ()) in log "init server state (%s)" (Dirname.to_string (Path.R.root t));
Dirname.mkdir (Path.R.packages_dir t); Dirname.mkdir (Path.R.packages_dir t);
Dirname.mkdir (Path.R.compilers_dir t); Dirname.mkdir (Path.R.compilers_dir t);
Dirname.mkdir (Path.R.archives_dir t); Dirname.mkdir (Path.R.archives_dir t);
Dirname.mkdir (Key.hashes_dir t) Dirname.mkdir (Key.hashes_dir t)


let load_root () =
Path.R.of_dirname (Dirname.cwd ())

let load_state () = let load_state () =
let root = load_root () in let root = load_root () in
let available = Path.R.available_packages root in let available = Path.R.available_packages root in
Expand Down Expand Up @@ -69,7 +69,7 @@ let process_request id = function
else else
Error "Wrong API version" Error "Wrong API version"
| GetList -> | GetList ->
log "GetList"; log "GetList %s" !Globals.root_path;
let t = load_state () in let t = load_state () in
let l = NV.Set.fold (fun nv l -> let l = NV.Set.fold (fun nv l ->
(N.to_string (NV.name nv), V.to_string (NV.version nv)) :: l (N.to_string (NV.name nv), V.to_string (NV.version nv)) :: l
Expand Down
13 changes: 8 additions & 5 deletions src/repo/server/init.ml
Expand Up @@ -6,9 +6,12 @@ let _ =
exit 1 exit 1
) )


open Types

let t = Path.R.of_dirname (Dirname.cwd ())

let () = let () =
Run.mkdir "opam"; Dirname.mkdir (Path.R.archives_dir t);
Run.mkdir "descr"; Dirname.mkdir (Path.R.compilers_dir t);
Run.mkdir "archives"; Dirname.mkdir (Path.R.packages_dir t)
Run.mkdir "compilers";
Run.mkdir "keys"
1 change: 1 addition & 0 deletions src/repo/server/server.ml
Expand Up @@ -71,6 +71,7 @@ let init_server () =
Unix.setsockopt socket Unix.SO_REUSEADDR true ; Unix.setsockopt socket Unix.SO_REUSEADDR true ;
Unix.bind socket addr; Unix.bind socket addr;
Unix.listen socket 10; Unix.listen socket 10;
Run.mkdir !Globals.root_path;
socket socket


let run_server () = let run_server () =
Expand Down
7 changes: 6 additions & 1 deletion tests/Makefile
Expand Up @@ -83,11 +83,13 @@ $(BINARIES_): $(BUILDS)
binaries: $(BINARIES_) binaries: $(BINARIES_)


init: init:
ifneq ($(REPOKIND), server)
rm -rf $(OPAM_REPO) rm -rf $(OPAM_REPO)
mkdir -p $(OPAM_REPO) mkdir -p $(OPAM_REPO)
mkdir $(OPAM_REPO)/opam mkdir $(OPAM_REPO)/opam
mkdir $(OPAM_REPO)/descr mkdir $(OPAM_REPO)/descr
mkdir $(OPAM_REPO)/compilers mkdir $(OPAM_REPO)/compilers
endif
ifeq ($(REPOKIND), git) ifeq ($(REPOKIND), git)
mkdir $(OPAM_REPO)/url mkdir $(OPAM_REPO)/url
cd $(OPAM_REPO) && git init && \ cd $(OPAM_REPO) && git init && \
Expand Down Expand Up @@ -245,4 +247,7 @@ clean:
rm -f $(ARCHIVES) rm -f $(ARCHIVES)


fresh: fresh:
rm -rf $(OPAM_ROOT) $(OPAM_REPO) $(BIN) rm -rf $(OPAM_ROOT) $(BIN)
ifneq ($(REPOKIND), server)
rm -rf $(OPAM_REPO)
endif

0 comments on commit f565f11

Please sign in to comment.