Context Done & Timeout

src/Context.php

@@ -3,6 +3,7 @@
 
 use Packaged\Config\ConfigProviderInterface;
 use Packaged\Config\Provider\ConfigProvider;
+use Packaged\Context\Events\ContextDoneEvent;
 use Packaged\Event\Channel\Channel;
 use Packaged\Helpers\System;
 use Packaged\Http\Cookies\CookieJar;
@@ -25,13 +26,18 @@ class Context implements ContextAware
   const ENV_STAGE = 'stage';
   const ENV_PROD = 'prod';
 
+  const DONE_DESTRUCT = 1;
+  const DONE_MANUAL = 2;
+  const DONE_TIMEOUT = 3;
+
   protected $_projectRoot;
   protected $_env;
   protected $_cfg;
   protected $_meta;
   protected $_routeData;
 
   private $_id;
+  private $_done;
   private $_events;
   private $_request;
   private $_cookieJar;
@@ -253,4 +259,47 @@ public function hasContext(): bool
     return true;
   }
 
+  public function withTimeout(int $duration)
+  {
+    new ContextTimeout($this, $duration);
+    return $this;
+  }
+
+  /**
+   * Mark the context as done, and trigger the done event
+   *
+   * @param $reason
+   *
+   * @return bool
+   * @throws \Exception
+   */
+  public function done($reason = ContextDoneEvent::RSN_TRIGGER)
+  {
+    if($this->_done === null)
+    {
+      $this->_done = $reason;
+      $this->events()->trigger(new ContextDoneEvent($reason));
+    }
+    return true;
+  }
+
+  public function isDone(): bool
+  {
+    return $this->_done !== null;
+  }
+
+  public function __destruct()
+  {
+    if($this->_events && !$this->_done)
+    {
+      try
+      {
+        $this->done(ContextDoneEvent::RSN_DESTRUCT);
+      }
+      catch(\Exception $e)
+      {
+      }
+    }
+  }
+
 }

src/ContextTimeout.php

@@ -0,0 +1,52 @@
+<?php
+namespace Packaged\Context;
+
+use Packaged\Context\Events\ContextDoneEvent;
+use Packaged\Context\Events\ContextTimeoutEvent;
+
+class ContextTimeout
+{
+  private $_ctx;
+  private $_duration;
+  private $_expiry;
+
+  public function __construct(Context $context, $duration = 30)
+  {
+    $this->_ctx = $context;
+    $this->_ctx->events()->listen(ContextDoneEvent::TYPE, [$this, 'onComplete']);
+    $this->_duration = $duration;
+    $this->_expiry = time() + $duration;
+    register_tick_function([$this, 'onTick']);
+  }
+
+  protected function _tick()
+  {
+    if($this->_expiry <= time())
+    {
+      $this->_ctx->events()->trigger(new ContextTimeoutEvent($this->_duration, time()));
+      $this->_ctx->done(ContextDoneEvent::RSN_TIMEOUT);
+      $this->_shutdown();
+    }
+  }
+
+  public function onTick()
+  {
+    $this->_tick();
+  }
+
+  public function onComplete()
+  {
+    $this->_shutdown();;
+  }
+
+  protected function _shutdown()
+  {
+    unregister_tick_function([$this, 'tick']);
+  }
+
+  public function __destruct()
+  {
+    $this->_shutdown();
+  }
+
+}

src/Events/ContextDoneEvent.php

@@ -0,0 +1,31 @@
+<?php
+namespace Packaged\Context\Events;
+
+use Packaged\Event\Events\AbstractEvent;
+
+class ContextDoneEvent extends AbstractEvent
+{
+  const RSN_DESTRUCT = 1;
+  const RSN_TRIGGER = 2;
+  const RSN_TIMEOUT = 3;
+
+  const TYPE = 'context.done';
+
+  private $_reason;
+
+  public function __construct($reason)
+  {
+    parent::__construct();
+    $this->_reason = $reason;
+  }
+
+  public function getType()
+  {
+    return static::TYPE;
+  }
+
+  public function reason()
+  {
+    return $this->_reason;
+  }
+}

src/Events/ContextTimeoutEvent.php

@@ -0,0 +1,33 @@
+<?php
+namespace Packaged\Context\Events;
+
+use Packaged\Event\Events\AbstractEvent;
+
+class ContextTimeoutEvent extends AbstractEvent
+{
+  const TYPE = 'context.timeout';
+  private $_expiryTime;
+  private $_duration;
+
+  public function __construct($duration, $expiryTime)
+  {
+    parent::__construct();
+    $this->_duration = $duration;
+    $this->_expiryTime = $expiryTime;
+  }
+
+  public function getType()
+  {
+    return static::TYPE;
+  }
+
+  public function getDuration()
+  {
+    return $this->_duration;
+  }
+
+  public function getExpiryTime()
+  {
+    return $this->_expiryTime;
+  }
+}