X-Git-Url: http://matita.cs.unibo.it/gitweb/?a=blobdiff_plain;f=matitaB%2Fmatita%2Fmatitadaemon.ml;h=95ff43b17f852704fec42989414cda56a10cfca7;hb=fd05d5ee6ec6b74a88f1b6f25319760b4c05ba7c;hp=06b465b13687243cd726888c238c8353069128b8;hpb=d0d2ebcf0ad48c38dcd69142f5e080e987fc5536;p=helm.git diff --git a/matitaB/matita/matitadaemon.ml b/matitaB/matita/matitadaemon.ml index 06b465b13..95ff43b17 100644 --- a/matitaB/matita/matitadaemon.ml +++ b/matitaB/matita/matitadaemon.ml @@ -89,11 +89,11 @@ let output_status s = let markup = if is_loc then (match depth, pos with - | 0, 0 -> "" ^ (render_switch sw) ^ "" + | 0, 0 -> "" ^ (render_switch sw) ^ "" | 0, _ -> - Printf.sprintf "|%d: %s" pos (render_switch sw) + Printf.sprintf "|%d: %s" pos (render_switch sw) | 1, pos when Stack.head_tag s#stack = `BranchTag -> - Printf.sprintf "|%d : %s" pos (render_switch sw) + Printf.sprintf "|%d : %s" pos (render_switch sw) | _ -> render_switch sw) else render_switch sw in @@ -107,29 +107,14 @@ let output_status s = "" ^ markup ^ txt0 ^ "" ^ acc in - let res = "" ^ + "" ^ (Stack.fold ~env:(render_sequent true) ~cont:(render_sequent false) ~todo:(render_sequent false) "" s#stack) ^ "" - in (* prerr_endline ("sending metasenv:\n" ^ res); res *) ;; -(* let html_of_status s = - let _,_,metasenv,subst,_ = s#obj in - let txt = List.fold_left - (fun acc (nmeta,_ as meta) -> - let txt0 = snd (ApplyTransformation.ntxt_of_cic_sequent - ~metasenv ~subst ~map_unicode_to_tex:false 80 s meta) - in - prerr_endline ("### txt0 = " ^ txt0); - ("Goal ?" ^ (string_of_int nmeta) ^ "\n" ^ txt0)::acc) - [] metasenv - in - String.concat "\n\n" txt -;; *) - let html_of_matita s = let patt1 = Str.regexp "\005" in let patt2 = Str.regexp "\006" in @@ -215,8 +200,10 @@ let retrieve (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = with Librarian.NoRootFor _ | Librarian.FileNotFound _ -> "",[] in include_paths := incpaths; - let status = MatitaAuthentication.get_status sid in - MatitaAuthentication.set_status sid (status#set_baseuri baseuri); + let status = (MatitaAuthentication.get_status sid)#set_baseuri baseuri in + let history = [status] in + MatitaAuthentication.set_status sid status; + MatitaAuthentication.set_history sid history; cgi # set_header ~cache:`No_cache ~content_type:"text/xml; charset=\"utf-8\"" @@ -246,6 +233,7 @@ let advance0 sid text = let interpr = GrafiteDisambiguate.get_interpr st#disambiguate_db in let outstr = ref "" in ignore (SmallLexer.mk_small_printer interpr outstr stringbuf); + prerr_endline ("baseuri after advance = " ^ st#baseuri); (* prerr_endline ("parser output: " ^ !outstr); *) MatitaAuthentication.set_status sid st; parsed_len, @@ -295,7 +283,8 @@ let login (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = if pw = userpw then begin - let _ = MatitaFilesystem.html_of_library uid in + let ft = MatitaAuthentication.read_ft uid in + let _ = MatitaFilesystem.html_of_library uid ft in let sid = MatitaAuthentication.create_session uid in (* let cookie = Netcgi.Cookie.make "session" (Uuidm.to_string sid) in cgi#set_header ~set_cookies:[cookie] (); *) @@ -356,24 +345,33 @@ let save (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = assert (cgi#arguments <> []); let locked = cgi#argument_value "locked" in let unlocked = cgi#argument_value "unlocked" in - let filename = libdir uid ^ "/" ^ (cgi # argument_value "file") in + let dir = cgi#argument_value "dir" in + let rel_filename = cgi # argument_value "file" in + let filename = libdir uid ^ "/" ^ rel_filename in let force = bool_of_string (cgi#argument_value "force") in if ((not force) && (Sys.file_exists filename)) then raise File_already_exists; - let oc = open_out filename in - output_string oc (locked ^ unlocked); - close_out oc; - if MatitaEngine.eos status unlocked then + if dir = "true" then + Unix.mkdir filename 0o744 + else begin - (* prerr_endline ("serializing proof objects..."); *) - GrafiteTypes.Serializer.serialize - ~baseuri:(NUri.uri_of_string status#baseuri) status; - (* prerr_endline ("adding to the commit queue..."); *) - MatitaFilesystem.add_user uid; - (* prerr_endline ("done."); *) + let oc = open_out filename in + output_string oc (locked ^ unlocked); + close_out oc; + if MatitaEngine.eos status unlocked then + begin + (* prerr_endline ("serializing proof objects..."); *) + GrafiteTypes.Serializer.serialize + ~baseuri:(NUri.uri_of_string status#baseuri) status; + (* prerr_endline ("adding to the commit queue..."); *) + MatitaFilesystem.add_user uid; + (* prerr_endline ("done."); *) + end; end; + MatitaAuthentication.set_file_flag uid + [rel_filename, Some MatitaFilesystem.MModified]; cgi # set_header ~cache:`No_cache ~content_type:"text/xml; charset=\"utf-8\"" @@ -387,7 +385,10 @@ let save (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = ~status:`Internal_server_error ~cache:`No_cache ~content_type:"text/xml; charset=\"utf-8\"" - ()); + () + | e -> + let estr = Printexc.to_string e in + cgi#out_channel#output_string ("" ^ estr ^ "")); cgi#out_channel#commit_work() ;; @@ -395,13 +396,57 @@ let initiate_commit (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = let cgi = Netcgi1_compat.Netcgi_types.of_compat_activation cgi in let env = cgi#environment in (try - let errors = MatitaFilesystem.do_global_commit () in - prerr_endline ("commit errors: " ^ (String.concat " " errors)); + let errors,out = MatitaFilesystem.do_global_commit () in cgi # set_header ~cache:`No_cache ~content_type:"text/xml; charset=\"utf-8\"" (); - cgi#out_channel#output_string "ok" + cgi#out_channel#output_string ""; + cgi#out_channel#output_string "ok"; + cgi#out_channel#output_string "
" ^ out ^ "
"; + cgi#out_channel#output_string "
" + with + | Not_found _ -> + cgi # set_header + ~status:`Internal_server_error + ~cache:`No_cache + ~content_type:"text/xml; charset=\"utf-8\"" + ()); + cgi#out_channel#commit_work() +;; + +let svn_update (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = + let cgi = Netcgi1_compat.Netcgi_types.of_compat_activation cgi in + let env = cgi#environment in + let sid = Uuidm.of_string (Netcgi.Cookie.value (env#cookie "session")) in + let sid = HExtlib.unopt sid in + let uid = MatitaAuthentication.user_of_session sid in + (try + let files,anomalies,(added,conflict,del,upd,merged) = + MatitaFilesystem.update_user uid + in + let anomalies = String.concat "\n" anomalies in + let details = Printf.sprintf + ("%d new files\n"^^ + "%d deleted files\n"^^ + "%d updated files\n"^^ + "%d merged files\n"^^ + "%d conflicting files\n\n" ^^ + "Anomalies:\n%s") added del upd merged conflict anomalies + in + prerr_endline ("update details:\n" ^ details); + let details = + Netencoding.Html.encode ~in_enc:`Enc_utf8 ~prefer_name:false () details + in + MatitaAuthentication.set_file_flag uid files; + cgi # set_header + ~cache:`No_cache + ~content_type:"text/xml; charset=\"utf-8\"" + (); + cgi#out_channel#output_string ""; + cgi#out_channel#output_string "ok"; + cgi#out_channel#output_string ("
" ^ details ^ "
"); + cgi#out_channel#output_string "
"; with | Not_found _ -> cgi # set_header @@ -508,6 +553,43 @@ let gotoBottom (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = cgi#out_channel#commit_work() ;; +let gotoTop (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = + let cgi = Netcgi1_compat.Netcgi_types.of_compat_activation cgi in + let env = cgi#environment in + prerr_endline "executing goto Top"; + (try + let sid = Uuidm.of_string (Netcgi.Cookie.value (env#cookie "session")) in + let sid = HExtlib.unopt sid in + (* + cgi # set_header + ~cache:`No_cache + ~content_type:"text/xml; charset=\"utf-8\"" + (); + *) + let status = MatitaAuthentication.get_status sid in + let uid = MatitaAuthentication.user_of_session sid in + let baseuri = status#baseuri in + let new_status = new MatitaEngine.status (Some uid) baseuri in + prerr_endline "gototop prima della time travel"; + NCicLibrary.time_travel new_status; + prerr_endline "gototop dopo della time travel"; + let new_history = [new_status] in + MatitaAuthentication.set_history sid new_history; + MatitaAuthentication.set_status sid new_status; + NCicLibrary.time_travel new_status; + cgi # set_header + ~cache:`No_cache + ~content_type:"text/xml; charset=\"utf-8\"" + (); + cgi#out_channel#output_string "ok" + with _ -> + (cgi#set_header ~status:`Internal_server_error + ~cache:`No_cache + ~content_type:"text/xml; charset=\"utf-8\"" (); + cgi#out_channel#output_string "ok")); + cgi#out_channel#commit_work() +;; + let retract (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = let cgi = Netcgi1_compat.Netcgi_types.of_compat_activation cgi in let env = cgi#environment in @@ -527,9 +609,12 @@ let retract (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = history, status | [_] -> (prerr_endline "singleton";failwith "retract") | _ -> (prerr_endline "nil"; assert false) in + prerr_endline ("prima della time travel"); NCicLibrary.time_travel new_status; + prerr_endline ("dopo della time travel"); MatitaAuthentication.set_history sid new_history; MatitaAuthentication.set_status sid new_status; + prerr_endline ("baseuri after retract = " ^ new_status#baseuri); let body = output_status new_status in cgi # set_header ~cache:`No_cache @@ -557,7 +642,8 @@ let viewLib (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = *) let uid = MatitaAuthentication.user_of_session sid in - let html = MatitaFilesystem.html_of_library uid in + let ft = MatitaAuthentication.read_ft uid in + let html = MatitaFilesystem.html_of_library uid ft in cgi # set_header ~cache:`No_cache ~content_type:"text/html; charset=\"utf-8\"" @@ -570,6 +656,14 @@ let viewLib (cgi : Netcgi1_compat.Netcgi_types.cgi_activation) = "\n" ^ "\n" ^ *) html (* ^ "\n" *) ); + + let files,anomalies = MatitaFilesystem.stat_user uid in + let changed = HExtlib.filter_map + (fun (n,fl) -> if (List.mem MatitaFilesystem.Modified fl) then Some n else None) files + in + let changed = String.concat "\n" changed in + let anomalies = String.concat "\n" anomalies in + prerr_endline ("Changed:\n" ^ changed ^ "\n\nAnomalies:\n" ^ anomalies); cgi#out_channel#commit_work() ;; @@ -644,6 +738,13 @@ let start() = dyn_translator = (fun _ -> ""); (* not needed *) dyn_accept_all_conditionals = false; } in + let goto_top = + { Nethttpd_services.dyn_handler = (fun _ -> gotoTop); + dyn_activation = Nethttpd_services.std_activation `Std_activation_buffered; + dyn_uri = None; (* not needed *) + dyn_translator = (fun _ -> ""); (* not needed *) + dyn_accept_all_conditionals = false; + } in let retrieve = { Nethttpd_services.dyn_handler = (fun _ -> retrieve); dyn_activation = Nethttpd_services.std_activation `Std_activation_buffered; @@ -700,12 +801,21 @@ let start() = dyn_translator = (fun _ -> ""); (* not needed *) dyn_accept_all_conditionals = false; } in + let do_update = + { Nethttpd_services.dyn_handler = (fun _ -> svn_update); + dyn_activation = Nethttpd_services.std_activation `Std_activation_buffered; + dyn_uri = None; (* not needed *) + dyn_translator = (fun _ -> ""); (* not needed *) + dyn_accept_all_conditionals = false; + } in + let nethttpd_factory = Nethttpd_plex.nethttpd_factory ~handlers:[ "advance", do_advance ; "retract", do_retract ; "bottom", goto_bottom + ; "top", goto_top ; "open", retrieve ; "register", do_register ; "login", do_login @@ -713,7 +823,8 @@ let start() = ; "reset", do_resetlib ; "viewlib", do_viewlib ; "save", do_save - ; "commit", do_commit] + ; "commit", do_commit + ; "update", do_update] () in MatitaInit.initialize_all (); MatitaAuthentication.deserialize ();