exception SvnError of string;;
-let mutex = Mutex.create ();;
-
-let to_be_committed = ref [];;
+(* disable for debugging *)
+let prerr_endline _ = ()
let exec_process cmd =
let (stdout, stdin, stderr) as chs = Unix.open_process_full cmd [||] in
exception SvnAnomaly of string
-let stat_classify line =
+let stat_classify line uid =
+ let basedir = (Helm_registry.get "matita.rt_base_dir") ^ "/users/" ^ uid ^ "/" in
let rec aux n acc =
match (line.[n], n) with
- | _, n when n = 7 -> String.sub line 8 ((String.length line) - 8), acc
+ | _, n when n = 7 ->
+ let fn = String.sub line 8 ((String.length line) - 8) in
+ let prefix_len = String.length basedir in
+ let fn_len = String.length fn in
+ if String.sub fn 0 prefix_len = basedir
+ then String.sub fn prefix_len (fn_len - prefix_len), acc
+ else fn, acc
| ' ', _ -> aux (n+1) acc
| 'A',0 -> aux (n+1) (Add::acc)
| 'C',_ when n = 0 || n = 1 -> aux (n+1) (Conflict::acc)
| _ -> raise (SvnAnomaly line)
in aux 0 []
+let count p l =
+ List.length (List.filter p l)
+
+exception Unimplemented
+
+let matita_flag_of_stat fs =
+ if List.mem Conflict fs then MConflict
+ else if List.mem Modified fs then MModified
+ else if List.mem Add fs then MAdd
+ else if List.mem Delete fs then raise Unimplemented
+ else if List.mem NotAdded fs then MUnversioned
+ else MSynchronized
+
let stat_user user =
let rt_dir = Helm_registry.get "matita.rt_base_dir" in
- let repo = Helm_registry.get "matita.weblib" in
+ let _repo = Helm_registry.get "matita.weblib" in
let errno, outlines, errlines = exec_process
("svn stat " ^ rt_dir ^ "/users/" ^ user ^ "/")
let files, anomalies =
List.fold_left (fun (facc,eacc) line ->
try
- (stat_classify line::facc), eacc
+ (stat_classify line user::facc), eacc
with
| SvnAnomaly l -> facc, l::eacc) ([],[]) outlines
in
+ let files =
+ List.map (fun (fname,flags) -> fname,Some (matita_flag_of_stat flags)) files
+ in
+
if errno = 0 then files, anomalies
else raise (SvnError ("Anomalies: " ^ (String.concat "\n" anomalies) ^ "\n\n" ^ (string_of_output outlines errlines)))
;;
(* update and checkout *)
-let up_classify line =
+let up_classify line uid =
+ let basedir = (Helm_registry.get "matita.rt_base_dir") ^ "/users/" ^ uid ^ "/" in
let rec aux n acc =
match (line.[n], n) with
- | _, n when n = 4 -> String.sub line 5 ((String.length line) - 5), acc
+ | _, n when n = 4 ->
+ let fn = String.sub line 5 ((String.length line) - 5) in
+ let prefix_len = String.length basedir in
+ let fn_len = String.length fn in
+ if String.sub fn 0 prefix_len = basedir
+ then String.sub fn prefix_len (fn_len - prefix_len), acc
+ else fn, acc
| ' ', _ -> aux (n+1) acc
| 'A',_ when n = 0 || n = 1 -> aux (n+1) (Add::acc)
| 'C',_ when n = 0 || n = 1 -> aux (n+1) (Conflict::acc)
| _ -> raise (SvnAnomaly line)
in aux 0 []
+let matita_flag_of_update fs =
+ if List.mem Conflict fs then Some MConflict
+ else if List.mem Delete fs then None
+ else if List.mem Merge fs then Some MModified
+ else Some MSynchronized
+
(* this should be executed only for a freshly created user so no CS is needed *)
let checkout user =
let rt_dir = Helm_registry.get "matita.rt_base_dir" in
let repo = Helm_registry.get "matita.weblib" in
- let errno, outlines, errlines = exec_process
- ("svn co " ^ repo ^ " " ^ rt_dir ^ "/users/" ^ user ^ "/")
+ let errno, outlines, errlines =
+ prerr_endline
+ ("svn co --non-interactive " ^ repo ^ " " ^ rt_dir ^ "/users/" ^ user ^ "/");
+ exec_process
+ ("svn co --non-interactive " ^ repo ^ " " ^ rt_dir ^ "/users/" ^ user ^ "/")
in
let files, anomalies =
List.fold_left (fun (facc,eacc) line ->
try
- (up_classify line::facc), eacc
+ (up_classify line user::facc), eacc
with
| SvnAnomaly l -> facc, l::eacc) ([],[]) outlines
in
if errno = 0 then List.map (fun (f,_) -> f,MSynchronized) files
else raise (SvnError (string_of_output outlines errlines))
+(* normalize qualified file name *)
+let normalize_qfn p =
+ (* trim leading "./" *)
+ let p =
+ try
+ if String.sub p 0 2 <> "./" then p
+ else String.sub p 2 (String.length p - 2)
+ with
+ | Invalid_argument _ -> p
+ in
+ (* trim trailing "/" *)
+ try
+ if String.sub p (String.length p - 1) 1 <> "/" then p
+ else String.sub p 0 (String.length p - 1)
+ with
+ | Invalid_argument _ -> p
+
let html_of_library uid ft =
let i = ref 0 in
let newid () = incr i; ("node" ^ string_of_int !i) in
let basedir = (Helm_registry.get "matita.rt_base_dir") ^ "/users/" ^ uid in
+
let branch lpath children =
let id = newid () in
let name = Filename.basename lpath in
let name = if name <> "." then name else "cic:/matita" in
- let lpath =
- try
- if String.sub lpath 0 2 <> "./" then lpath
- else String.sub lpath 2 (String.length lpath - 2)
- with Invalid_argument _ -> lpath
- in
let flag =
try List.assoc lpath ft
with Not_found -> MSynchronized in
let szflag = string_of_matita_flag flag in
- "<span class=\"trigger\" onClick=\"showBranch('" ^ id ^ "','" ^ lpath ^ "/')\">\n" ^
+ "<span class=\"trigger\" onClick=\"showBranch('" ^ id ^ "','" ^ lpath ^ "')\">\n" ^
"<img src=\"treeview/closed.gif\" id=\"I" ^ id ^ "\"/>\n" ^
name ^ " " ^ szflag ^ "<br/></span>\n" ^
"<span class=\"branch\" id=\"" ^ id ^ "\">\n" ^
children ^ "\n</span>"
in
let leaf lpath =
+ let flag =
+ try List.assoc lpath ft
+ with Not_found -> MSynchronized in
+ let szflag = string_of_matita_flag flag in
"<img src=\"treeview/doc.gif\"/>\n" ^
"<a href=\"javascript:void(0)\" onClick=\"selectFile('" ^ lpath ^ "')\" onDblClick=\"dialogBox.callback('" ^ lpath ^ "')\">" ^
- (Filename.basename lpath) ^ "</a><br/>"
+ (Filename.basename lpath) ^ " " ^ szflag ^ "</a><br/>"
in
let rec aux path =
let lpath filename = path ^ "/" ^ filename in
let gpath filename = basedir ^ "/" ^ path ^ "/" ^ filename in
+
+ (* hide hidden dirs ... including svn stuff *)
let dirlist =
List.filter (fun x -> String.sub x 0 1 <> ".")
(Array.to_list (Sys.readdir (basedir ^ "/" ^ path))) in
let subdirs = List.filter (fun x -> Sys.is_directory (gpath x)) dirlist in
+ let subdirs = List.sort String.compare subdirs in
+
+ (* only .ma scripts, hidden files excluded *)
let scripts =
List.filter (fun x ->
try
not (Sys.is_directory (gpath x)) &&
(String.sub x 0 1 <> ".") && (String.sub x i len = ".ma")
with Not_found | Invalid_argument _ -> false) dirlist in
+ let scripts = List.sort String.compare scripts in
let subdirtags =
- String.concat "\n" (List.map (fun x -> aux (lpath x)) subdirs) in
+ String.concat "\n" (List.map (fun x -> aux (normalize_qfn (lpath x ^ "/"))) subdirs) in
let scripttags =
String.concat "\n"
- (List.map (fun x -> leaf (lpath x)) scripts)
+ (List.map (fun x -> leaf (normalize_qfn (lpath x))) scripts)
in
branch path (subdirtags ^ "\n" ^ scripttags)
in
ignore (Sys.command ("rm -rf " ^ to_be_removed))
;;
-(* adds a user to the commit queue; concurrent instances possible, so we
- * enclose the update in a CS
- *)
-let add_user uid =
- Mutex.lock mutex;
- to_be_committed := uid::List.filter (fun x -> x <> uid) !to_be_committed;
- Mutex.unlock mutex;
-;;
-
let update_user user =
let rt_dir = Helm_registry.get "matita.rt_base_dir" in
- let repo = Helm_registry.get "matita.weblib" in
+ let _repo = Helm_registry.get "matita.weblib" in
let errno, outlines, errlines = exec_process
- ("svn up " ^ rt_dir ^ "/users/" ^ user ^ "/")
+ ("svn up --non-interactive " ^ rt_dir ^ "/users/" ^ user ^ "/")
in
let files, anomalies =
List.fold_left (fun (facc,eacc) line ->
try
- (up_classify line::facc), eacc
+ (let fname,flags = up_classify line user in
+ (fname, flags)::facc), eacc
with
| SvnAnomaly l -> facc, l::eacc) ([],[]) outlines
in
- if errno = 0 then files, anomalies
+ let added = count (fun (_,flags) -> List.mem Add flags) files in
+ let conflict = count (fun (_,flags) -> List.mem Conflict flags) files in
+ let del = count (fun (_,flags) -> List.mem Delete flags) files in
+ let upd = count (fun (_,flags) -> List.mem Update flags) files in
+ let merged = count (fun (_,flags) -> List.mem Merge flags) files in
+
+ let files =
+ List.map (fun (fname,flags) -> fname,matita_flag_of_update flags) files
+ in
+
+ if errno = 0 then files, anomalies, (added,conflict,del,upd,merged)
else raise (SvnError (string_of_output outlines errlines))
;;
-(* this function and the next one should only be called by the server itself (or
+let add_files user files =
+ if (List.length files > 0) then
+ (let rt_dir = Helm_registry.get "matita.rt_base_dir" in
+ let _repo = Helm_registry.get "matita.weblib" in
+
+ let files = String.concat " "
+ (List.map ((^) (rt_dir ^ "/users/" ^ user ^ "/")) files) in
+
+ let errno, outlines, errlines =
+ if files <> "" then
+ exec_process ("svn add --non-interactive " ^ files)
+ else 0,[],[]
+ in
+ if errno = 0 then
+ "BEGIN ADD - " ^ user ^ ":\n" ^ (string_of_output outlines errlines) ^ "END ADD - " ^ user ^ "\n\n"
+ else raise (SvnError (string_of_output outlines errlines)))
+ else ("ADD - nothing to do for " ^ user ^ "\n")
+;;
+
+(* this function should only be called by the server itself (or
* the admin) at a scheduled time, so no concurrent instances and no CS needed
* also, svn should already be safe as far as concurrency is concerned *)
-let commit user =
- let rt_dir = Helm_registry.get "matita.rt_base_dir" in
- let repo = Helm_registry.get "matita.weblib" in
-
- let errno, outlines, errlines = exec_process
- ("svn ci --message \"commit by user " ^ user ^ "\" " ^ rt_dir ^ "/users/" ^ user ^ "/")
- in
- if errno = 0 then ()
- else raise (SvnError (string_of_output outlines errlines))
+let commit user files =
+ if (List.length files > 0) then
+ (let rt_dir = Helm_registry.get "matita.rt_base_dir" in
+ let _repo = Helm_registry.get "matita.weblib" in
+
+ let files = String.concat " "
+ (List.map ((^) (rt_dir ^ "/users/" ^ user ^ "/")) files) in
+
+ let errno, outlines, errlines = exec_process
+ ("svn ci --non-interactive --message \"commit by user " ^ user ^ "\" " ^ files)
+ in
+ if errno = 0 then
+ "BEGIN COMMIT - " ^ user ^ ":\n" ^ (string_of_output outlines errlines) ^ "END COMMIT - " ^ user ^ "\n\n"
+ else raise (SvnError (string_of_output outlines errlines)))
+ else ("COMMIT nothing to do for " ^ user ^ "\n")
;;
-let do_global_commit () =
- prerr_endline ("to be committed: " ^ String.concat " " !to_be_committed);
- List.fold_left
- (fun acc u ->
- try
- commit u;
- acc
- with
- | SvnError outstr ->
- prerr_endline outstr;
- u::acc)
- [] (List.rev !to_be_committed)
-;;