movim/app/MessageBuffer.php

<?php

namespace App;

use Illuminate\Database\Capsule\Manager as DB;

use App\Message;

class MessageBuffer
{
    protected static $instance;
    private $_models = null;
    private $_calls = null;

    public static function getInstance()
    {
        if (!isset(self::$instance)) {
            self::$instance = new self();
        }

        return self::$instance;
    }

    public function __construct()
    {
        //global $loop;

        $this->_models = collect();
        $this->_calls = collect();

        /*$loop->addPeriodicTimer(0.5, function () {
            $this->save();
        });*/
    }

    public function save()
    {
        if ($this->_models->count() > 0) {
            try {
                DB::beginTransaction();

                // We delete all the presences that might already be there
                $table = DB::table('messages');
                $first = $this->_models->first();
                $table = $table->where([
                    ['user_id', $first['user_id']],
                    ['jidfrom', $first['jidfrom']],
                    ['id', $first['id']],
                ]);

                $this->_models->skip(1)->each(function ($message) use ($table) {
                    $table->orWhere([
                        ['user_id', $message['user_id']],
                        ['jidfrom', $message['jidfrom']],
                        ['id', $message['id']],
                    ]);
                });
                $table->delete();

                \Utils::debug('INSERT '.$this->_models->count());
                Message::insert($this->_models->toArray());
                DB::commit();
            } catch (\Exception $e) {
                DB::rollback();
            }

            $this->_models = collect();
        }

        if ($this->_calls->isNotEmpty()) {
            $this->_calls->each(function ($call) {
                $call();
            });
            $this->_calls = collect();
        }
    }

    public function append(Message $message, $call)
    {
        //if (empty($message->mid)) {
            $this->_models[$message->user_id.$message->jidfrom.$message->id] = $message->toRawArray();
            $this->_calls->push($call);
        /*} else {
            $message->save();
            $call();
        }*/
    }
}