LaravelRUS / GitterBot

    /**

     * @param GitterRoom $room

     */

    public function syncMessages(GitterRoom $room)

    {

        /** @var CircleProgress $circle */

        $this->output->writeln('Fetching...');

        $room->getMessages()

            // Fetch all messages

            ->fetch(function (GitterMessage $message, Controls $controls) {

                $this->messageRemember($message, $controls);

            })

            ->then(function () use ($room) {

                $this->syncLatestMessages($room);

            });

    }

    /**

     * @param GitterMessage $gitterMessage

            ->first();

        if ($lastMessage) {

            $loop->addTimer($timeout, function () use ($gitter, $lastMessage) {

                $gitter->getMessages($lastMessage->gitter_id, GitterRoom::MESSAGE_FETCH_ASC)

                    ->fetch(function (GitterMessage $message, Controls $controls) {

                        $this->onMessage($message);

                        $controls->next();

                    })

                    ->then(function () use ($gitter) {

                        $this->warn('Connection...');

                        $this->listen($gitter);

                    });

            });

        } else {

            $this->listen($gitter);

        }