1: <?php
 2: 
 3: namespace Budabot\Core;
 4: 
 5: /**
 6:  * @Instance
 7:  */
 8: class Timer {
 9:     /**
10:      * @internal
11:      * Array of waiting timer events.
12:      */
13:     private $timerEvents = array();
14: 
15:     public function executeTimerEvents() {
16:         // execute timer events
17:         $time = time();
18:         while (count($this->timerEvents) > 0 && $this->timerEvents[0]->time <= $time) {
19:             $timerEvent = array_shift($this->timerEvents);
20:             $timerEvent->callCallback();
21:         }
22:     }
23: 
24:     /**
25:      * Calls given callback asynchronously after $delay seconds.
26:      *
27:      * The callback has following signature:
28:      * <code>
29:      * function callback(...)
30:      * </code>
31:      *  * ... - optional values which are same as given as arguments to this method.
32:      *
33:      * Example usage:
34:      * <code>
35:      * $this->util->callLater(5, function($message) {
36:      *     print $message;
37:      * }, 'Hello World');
38:      * </code>
39:      * Prints 'Hello World' after 5 seconds.
40:      *
41:      * @param integer  $delay time in seconds to delay the call
42:      * @param callback $callback callback which is called after timeout
43:      * @internal param $ ... any additional parameters are passed to the callback
44:      * @return TimerEvent
45:      */
46:     public function callLater($delay, $callback) {
47:         $additionalArgs = func_get_args();
48:         array_shift($additionalArgs); // remove $delay
49:         array_shift($additionalArgs); // remove $callback
50:         return $this->addTimerEvent($delay, $callback, $additionalArgs);
51:     }
52: 
53:     /**
54:      * @internal
55:      */
56:     public function abortEvent($event) {
57:         $key = array_search($event, $this->timerEvents, true);
58:         if ($key !== false) {
59:             unset($this->timerEvents[$key]);
60:             $this->sortEventsByTime();
61:         }
62:     }
63: 
64:     /**
65:      * @internal
66:      */
67:     public function restartEvent($event) {
68:         $event->time = intval($event->delay) + time();
69:         $this->sortEventsByTime();
70:     }
71: 
72:     /**
73:      * Adds new timer event.
74:      * $callback will be called with arguments $args array after $delay seconds.
75:      */
76:     private function addTimerEvent($delay, $callback, $args) {
77:         $event = new TimerEvent(time() + $delay, $delay, $callback, $args);
78:         $this->timerEvents []= $event;
79:         $this->sortEventsByTime();
80:         return $event;
81:     }
82: 
83:     private function sortEventsByTime() {
84:         usort($this->timerEvents, function($a, $b) {
85:             if ($a->time == $b->time) {
86:                 return 0;
87:             }
88:             return ($a->time < $b->time) ? -1 : 1;
89:         });
90:     }
91: }
92: