traderinteractive / cronus

     *

     * @return void

     */

    public function removeWithoutExistingProcess()

    {

        $initialVersion = new ObjectID();

        $initalTask = [

            '_id' => 'testId',

            'hosts' => [HOSTNAME => [getmypid() => time() + 60]],

            'version' => $initialVersion,

        ];

        $this->collection->insertOne($initalTask);

        $this->registry->remove($this->getProcess('testId'));

        $this->assertSame(1, $this->collection->count());

        $result = $this->collection->findOne();

        $this->assertSame(['_id' => 'testId', 'hosts' => [HOSTNAME => []], 'version' => $result['version']], $result);

        $this->assertNotSame((string)$initialVersion, (string)$result['version']);

    }

    /**

     * @test

     *

     * @return void

     */

    public function resetUnderflowMinsBeforeExpire()

    {

        $initialVersion = new ObjectID();

        $initalTask = [

            '_id' => 'testId',

            'hosts' => [HOSTNAME => [getmypid() => time() + 60]],

            'version' => $initialVersion,

        ];

        $this->collection->insertOne($initalTask);

        $this->registry->reset($this->getProcess('testId', ~PHP_INT_MAX));

        $this->assertSame(1, $this->collection->count());

        $result = $this->collection->findOne();

        $this->assertSame(

            ['_id' => 'testId', 'hosts' => [HOSTNAME => [getmypid() => 0]], 'version' => $result['version']],

            $result

        );

        $this->assertNotSame((string)$initialVersion, (string)$result['version']);

    }

    /**

     * @test