kakserpom / phpdaemon

PHPDaemon/Examples/MongoNode.php

<?php
namespace PHPDaemon\Examples;

/**
 * @package    Applications
 * @subpackage MongoNode
 *
 * @author     Vasily Zorin <maintainer@daemon.io>
 */
class MongoNode extends \PHPDaemon\Core\AppInstance
{

    public $db; // MongoClient
    public $cache; // MemcacheClient
    public $LockClient; // LockClient
    public $cursor; // Tailable cursor
    public $timer;
    protected $inited = false;

    /**
     * Constructor.
     * @return void
     */
    public function init()
    {
        $this->db = \PHPDaemon\Clients\Mongo\Pool::getInstance($this->config->mongoclientname->value);
        $this->cache = \PHPDaemon\Clients\Memcache\Pool::getInstance($this->config->memcacheclientname->value);
        if (!isset($this->config->limitinstances)) {
            $this->log('missing \'limitInstances\' directive');
        }
    }

    /**
     * Called when the worker is ready to go.
     * @return void
     */
    public function onReady()
    {
        if ($this->config->enable->value) {
            $this->timer = setTimeout(function ($timer) {

The parameter $timer is not used and could be removed.

                $this->touchCursor();
            }, 0.3e6);
        }
    }

    public function touchCursor()
    {
        if (!$this->cursor) {
            if (!$this->inited) {
                $this->inited = true;

                $this->cache->get('_rp',
                    function ($answer) {
                        $this->inited = false;
                        $e = explode(' ', $answer->result);

                        if (isset($e[1])) {
                            $ts = new \MongoTimestamp((int)$e[0], (int)$e[1]);
                        } else {
                            $ts = new \MongoTimestamp(0, 0);
                        }

                        if (\PHPDaemon\Core\Daemon::$config->logevents->value) {

This code seems to be duplicated across your project.

The property logevents does not seem to exist in PHPDaemon\Config\_Object.

                            \PHPDaemon\Core\Daemon::log('MongoNode: replication point - ' . $answer->result . ' (' . \PHPDaemon\Core\Debug::dump($ts) . ')');
                        }

                        $this->initSlave($ts);
                    }
                );
            }
        } elseif (!$this->cursor->session->busy) {
            if ($this->cursor->lastOpId !== null) {
                $this->cache->set('_rp', $this->cursor->lastOpId);
                $this->cursor->lastOpId = null;
            }

            try {
                $this->cursor->getMore();
            } catch (\PHPDaemon\Clients\Mongo\ConnectionFinished $e) {
                $this->cursor = false;
            }
        }
    }

    /**
     * Initializes slave session.
     * @param object Object.
     * @param \MongoTimestamp $point
     * @return void
     */
    public function initSlave($point)
    {
        $this->db->{'local.oplog.$main'}->find(

        /**
         * @param \MongoTimestamp $cursor
         */
            function ($cursor) {
                $this->cursor = $cursor;
                $cursor->state = 1;

The property state does not seem to exist in MongoTimestamp.

                $cursor->lastOpId = null;

The property lastOpId does not seem to exist in MongoTimestamp.

                foreach ($cursor->items as $k => &$item) {

The property items does not seem to exist in MongoTimestamp.

                    if (\PHPDaemon\Core\Daemon::$config->logevents->value) {

This code seems to be duplicated across your project.

The property logevents does not seem to exist in PHPDaemon\Config\_Object.

                        \PHPDaemon\Core\Daemon::log(get_class($this) . ': caught oplog-record with ts = (' . \PHPDaemon\Core\Debug::dump($item['ts']) . ')');
                    }

                    $cursor->lastOpId = $item['ts'];

                    if ($item['op'] === 'i') {
                        $this->cacheObject($item['o']);
                    } elseif ($item['op'] === 'd') {
                        $this->deleteObject($item['o']);
                    } elseif ($item['op'] === 'u') {
                        if (
                            isset($item['b'])
                            && ($item['b'] === false)
                        ) {
                            $item['o']['_id'] = $item['o2']['_id'];
                            $this->cacheObject($item['o']);
                        } else {
                            $cursor->appInstance->{$item['ns']}->findOne(

The property appInstance does not seem to exist in MongoTimestamp.

                            /**
                             * @param \MongoTimestamp $item
                             */
                                function ($item) {
                                    $this->cacheObject($item);
                                },
                                ['where' => ['_id' => $item['o2']['_id']]]
                            );
                        }
                    }

                    unset($cursor->items[$k]);
                }
            }, [
                'tailable' => true,
                'sort' => ['$natural' => 1],
                'snapshot' => 1,
                'where' => [
                    'ts' => [
                        '$gt' => $point
                    ],
                    '$exists' => [
                        '_key' => true
                    ]
                ],
                'parse_oplog' => true,
            ]
        );
    }

    /**
     * Method called when object received.
     * @param object Object.
     * @return void
     */
    public function cacheObject($o)
    {
        if (\PHPDaemon\Core\Daemon::$config->logevents->value) {

This code seems to be duplicated across your project.

The property logevents does not seem to exist in PHPDaemon\Config\_Object.

            \PHPDaemon\Core\Daemon::log(__METHOD__ . '(' . json_encode($o) . ')');
        }

        if (isset($o['_key'])) {
            $this->cache->set($o['_key'], bson_encode($o));
            $this->cache->set('_id.' . ((string)$o['_id']), $o['_key']);
        }

        if (isset($o['_ev'])) {
            $o['name'] = $o['_ev'];

            if (\PHPDaemon\Core\Daemon::$config->logevents->value) {
                \PHPDaemon\Core\Daemon::log('MongoNode send event ' . $o['name']);
            }
        }
    }

    /**
     * Method called when object deleted.
     * @param object Object.
     * @return void
     */
    public function deleteObject($o)
    {
        if (\PHPDaemon\Core\Daemon::$config->logevents->value) {

This code seems to be duplicated across your project.

The property logevents does not seem to exist in PHPDaemon\Config\_Object.

            \PHPDaemon\Core\Daemon::log(__METHOD__ . '(' . json_encode($o) . ')');
        }

        $this->cache->get('_id.' . ((string)$o['_id']),
            function ($mc) use ($o) {
                if (is_string($m->result)) {
                    $mc->delete($m->result);

The variable $m does not exist. Did you forget to declare it?

                    $mc->delete('_id.' . $o['_id']);
                }
            }
        );
    }

    /**
     * Setting default config options
     * Overriden from AppInstance::getConfigDefaults
     * @return array|false
     */
    protected function getConfigDefaults()
    {
        return [
            'mongoclientname' => '',
            'memcacheclientname' => '',
        ];
    }
}