1:   2:   3:   4:   5:   6:   7:   8:   9:  10:  11:  12:  13:  14:  15:  16:  17:  18:  19:  20:  21:  22:  23:  24:  25:  26:  27:  28:  29:  30:  31:  32:  33:  34:  35:  36:  37:  38:  39:  40:  41:  42:  43:  44:  45:  46:  47:  48:  49:  50:  51:  52:  53:  54:  55:  56:  57:  58:  59:  60:  61:  62:  63:  64:  65:  66:  67:  68:  69:  70:  71:  72:  73:  74:  75:  76:  77:  78:  79:  80:  81:  82:  83:  84:  85:  86:  87:  88:  89:  90:  91:  92:  93:  94:  95:  96:  97:  98:  99: 100: 101: 102: 103: 104: 105: 106: 107: 108: 

<?php
/**
 * @author stev leibelt <artodeto@bazzline.net>
 * @since: 2015-09-10
 */
namespace Net\Bazzline\Component\Database\FileStorage\Writer;

use Net\Bazzline\Component\Csv\Writer\WriterForPhp5Dot3;
use Net\Bazzline\Component\Lock\FileHandlerLock;
use Net\Bazzline\Component\Toolbox\Process\Experiment;
use RuntimeException;

/**
 * Class LockableWriterForPhp5Dot3

 *
 * @package Net\Bazzline\Component\Database\FileStorage\Writer
 */
class LockableWriterForPhp5Dot3 extends WriterForPhp5Dot3 implements LockableWriterInterface
{
    /** @var Experiment */
    private $experiment;

    /** @var FileHandlerLock */
    private $lock;

    /**
     * @param Experiment $experiment
     */
    public function injectExperiment(Experiment $experiment)
    {
        $this->experiment = $experiment;

        if ($this->lock instanceof FileHandlerLock) {
            $this->setupExperiment($this->lock, $this->experiment);
        }
    }

    /**
     * @param FileHandlerLock $lock
     */
    public function injectLock(FileHandlerLock $lock)
    {
        $this->lock = $lock;

        if ($this->experiment instanceof Experiment) {
            $this->setupExperiment($this->lock, $this->experiment);
        }
    }

    /**
     * @throws RuntimeException
     */
    public function acquireLock()
    {
        $this->bindLock($this->lock);
        $this->experiment->andTryIt();
    }

    /**
     * @return bool
     */
    public function isLocked()
    {
        return $this->lock->isLocked();
    }

    /**
     * @throws RuntimeException
     */
    public function releaseLock()
    {
        $this->lock->release();
    }

    /**
     * @param FileHandlerLock $lock
     */
    private function bindLock(FileHandlerLock $lock)
    {
        $lock->setResource($this->getFileHandler());
    }

    /**
     * @param FileHandlerLock $lock
     * @param Experiment $experiment
     */
    private function setupExperiment(FileHandlerLock $lock, Experiment $experiment)
    {
        $onFailure  = function () use ($lock) {
            $lock->acquire();
        };
        $onSuccess  = function () {};
        $trial      = function () use ($lock) {
            try {
                $lock->acquire();
                $wasSuccessful = true;
            } catch (RuntimeException $exception) {
                $wasSuccessful = false;
            }

            return $wasSuccessful;
        };

        $experiment->prepareNewExperiment($trial, 3, 300, $onSuccess, $onFailure);
    }
}