/*    /secure/daemon/events.c
 *    from the Foundation II LPC Library
 *    an event monitoring daemon, for call outs across time
 *    created by Descartes of Borg 950501
 */

#include <lib.h>
#include <save.h>
#include <config.h>
#include <daemons.h>
#include <privs.h>
#include "events.h"

inherit LIB_DAEMON;

private int RebootInterval;
private mapping Events;
private static int InReboot = 0;

static void create() {
    daemon::create();
    SetNoClean(1);
    if( file_exists(SAVE_EVENTS __SAVE_EXTENSION__) )
	unguarded((: restore_object, SAVE_EVENTS :));
    if( !RebootInterval ) RebootInterval = 170;
    if( !Events ) Events = ([]);
    eventSave();
    call_out((: eventPollEvents :), 60);
}

varargs static int eventSave(int ung) {
    if( ung ) {
	unguarded( (: save_object, SAVE_EVENTS :) );
	return 1;
    }
    else return save_object(SAVE_EVENTS);
}

void eventReboot(int x) {
    if( previous_object() && !((int)master()->valid_apply(({ PRIV_ASSIST }))) )
	return;
    if( x < 1 ) x = 1;
    x *= 60;
    message("broadcast", mud_name() + " will reboot in " +
      consolidate(x/60, "a minute") + ".", users());
    if( x < 61 ) call_out( (: eventAnnounceReboot, 10 :), x - 10);
    else {
	int y;

	y = x/60;
	y = ((2*y)/3) * 60;
	call_out( (: eventAnnounceReboot($(y)) :), x - y);
    }
}

static void eventAnnounceReboot(int x) {
    if( x == 10 ) {
	message("broadcast", "Last warning: Reboot in 10 seconds.", users());
	call_out( (: Shutdown :), 10 );
    }
    else if( x < 61 ) {
	message("broadcast", mud_name() + " will reboot in a minute.",
	  users());
	call_out( (: eventAnnounceReboot, 10 :), 50);
    }
    else {
	int y;

	message("broadcast", "Reboot in " + (x/60) + " minutes.", users());
	y = ((2 * (x/60))/3) * 60;
	call_out( (: eventAnnounceReboot($(y)) :), x - y);
    }
}

void eventShutdown() { 
    if( !((int)master()->valid_apply( ({ PRIV_ASSIST }) )) ) return;
    Shutdown();
}

static void Shutdown() {
    message("broadcast", "Shutting down " + mud_name() + " immediately!",
      users());
    map(users(), (: catch($1->cmdQuit()) :));
    shutdown();
}

static void eventPollEvents() {
    int *events;
    int i, x;

    call_out((: eventPollEvents :), 60);
    x = time();
    i = sizeof(events = keys(Events));
    while(i--) {
	if( events[i] <= x ) {
	    object ob;
	    function f;

	    if( !(ob = find_object(Events[events[i]]["creator"]) )
	      && !(ob = load_object(Events[events[i]]["creator"])) ) {
		map_delete(Events, events[i]);
		continue;
	    }
	    f = (: call_other, Events[events[i]]["object"],
	      Events[events[i]]["function"] :);
	    f = bind(f, ob);
	    catch(evaluate(f, Events[events[i]]["args"]...));
	    if( Events[events[i]]["regular"] > 0 )
		Events[x + Events[events[i]]["interval"]] = Events[events[i]];
	    map_delete(Events, events[i]);
	}
    }
    if( (uptime() > RebootInterval*3600) && !InReboot && !DISABLE_REBOOTS) {
	InReboot = 1;
	eventReboot(MINUTES_REBOOT_WARNING);
    }
    eventSave();
}

int SetRebootInterval(int x) {
    int y;

    y = RebootInterval;
    if( x > 1 ) RebootInterval = x;
    if( !eventSave() ) RebootInterval = y;
    return RebootInterval;
}

int GetRebootInterval() { return RebootInterval; }

void AddEvent(string c, string s, string f, mixed *a, int w, int r) {
    mapping NewEvent;
    if( file_name(previous_object()) != SEFUN && file_name(previous_object()) != UPDATE_D) {
	if(EVENTS_LOGGING){
	    unguarded( (: write_file("/log/secure/events",timestamp()+" "+
		  identify(previous_object(-1))+" ILLEGALLY tried to add an event.\n") :) );
	}
	return;
    }
    NewEvent = ([ "object" : s, "function" : f, "args" : a,
      "creator" : c,  "regular" : (r ? w : 0), "interval" : w ]);
    if(EVENTS_LOGGING)
	unguarded( (: write_file("/log/secure/events",timestamp()+
	      identify(previous_object(-1))+" added this event: "+
	      identify($(NewEvent))+"\n") :) );		
    Events[time() + w] = NewEvent;
    eventSave(1);
}

void RemoveEvent(int i){
    if( file_name(previous_object()) != SEFUN ) return;
    if(sizeof(Events[i])){
	map_delete(Events, i);
	eventSave(1);
    }
}

mapping GetEvents() { return copy(Events); }