% =====================================
% supplies hook specific architecture
% =====================================


:- use_module(library(socket)).  
 %Load the TCP Library
:- use_module(library(unix)).      
:- use_module(library(shell)).      
:- use_module(library(shlib)).        
:- use_module(library(url)).        
:- use_module(library(quintus)).        
%:-ensure_loaded(alarm).
:- dynamic(tty_in/1).
:- dynamic(tty_out/1).
:- volatile(tty_in/1).
:- volatile(tty_out/1).

      
:-use_module(library(threadutil)).        

call_with_time_limit(Goal,Time,_):-
	retractAllProlog(cpuend(_)),
	getCputime(Now),
	Then is Now + Time,
	assert(cpuend(Then)),!,Goal.
%call_with_time_limit(Goal,Time,timed_out):-!.
%getCleanCharsWhitespaceProper(X,X):-!.
	
getCleanCharsWhitespaceProper(X,Z):-string_clean(X,C),!,string_to_list(C,List),!,ltrim(List,Z),!.

string_clean(X,X).

%:-assert((thread_util:open_xterm(T,In,Out):-sigma_server_break(T,In,Out))).


/*
:- redefine_system_predicate(message_hook(_,_,_)).

:- asserta(((user:message_hook(A,B,C) :- sigma_server_message_hook(A,B,C)))).

sigma_server_message_hook(trace_mode(on),B,Lines):-
	catch(thread_self(Id),_,fail),
	'$get_pid'(Pid),
	fmtString(Title, 'SWI-Prolog Thread ~w (pid ~d) interactor', [Id, Pid]),
	tty_in(Stream),
	thread_signal(main,(close(Stream))),
	set_input(Stream),
	set_output(user_output),
	thread_at_exit(thread_signal(main,set_input(Stream))).
*/

save_tty_streams:-current_input(Stream),assert(tty_in(Stream)),current_output(StreamO),assert(tty_out(StreamO)).
:- initialization(save_tty_streams,now).
:- initialization(save_tty_streams,restore_state).

bt(ID):-thread_signal(ID,trace)			.

sigma_server_message_hook(A,B,Lines):-
	'$get_pid'(Pid),
	writeFmt(user_error,'% Sigma ~w (~w): ~w \n',[Pid,B,A]),flush_output(user_error),
	print_message_lines(user_error, '% ', Lines),flush_output(user_error).



sigma_server_break(T,user_input,user_output):-
		writeFmt(user_error,'Switching main thread to sleep mode. \n ~w \n',[T]).