get updates

[abbas980301]

First, thank you for this awesome project !
how can i Handling updates?
I tried this link
https://github.com/danog/MadelineProto#handling-updates
but i can't understand it! that return me duplicate updates in loop.
How can i remove updates from get_updates after process updates?

[danog]

You must increment the offset like with the bot API.

[abbas980301]

thanks.
after that ( increment the offset ) old updates will remove?

[danog]

@shakibonline Yep, exactly like in the bot API

[abbas980301]

I use this code

$offset = 0;
while (1) {

    $updates = $MadelineProto->API->get_updates(['offset' => $offset, 'limit' => 10, 'timeout' => 1]); // Just like in the bot API, you can specify an offset, a limit and a timeout
    echo "\n\n";
    echo "===============[update]===========\n";
    echo json_encode($updates);
    echo "\n\n";

    foreach ($updates as $update) {
        $offset = $update['update_id']; // Just like in the bot API, the offset must be set to the last update_id
        // Parse $update['update'], that is an object of type Update
        if ($update['update']['_'] == 'updateNewMessage') {
            $messages_AffectedMessages = $MadelineProto->messages->readMessageContents(['id' => [$update['update']['message']['id']],]);
        }
    }
}

but it it didn't mark as read messages! what is wrong??

[danog]

@shakibonline Of course not, you aren't using the offset properly. Read the bot API documentation or take a look at the examples in the repo.

[abbas980301]

what about this one?

        $offset = 0;
        while (true) {
        $updates = $MadelineProto->API->get_updates(['offset' => $offset, 'limit' => 50, 'timeout' => 1]); // Just like in the bot API, you can specify an offset, a limit and a timeout
        foreach ($updates as $update) {
            $offset = $update['update_id']; // Just like in the bot API, the offset must be set to the last update_id
            // Parse $update['update'], that is an object of type Update
        }
        var_dump($updates);
        }

is it true?

ps : i should store last offset for next run time?

[abbas980301]

what is this error on running ( before load env & setting )

    An error getting response of method updates.getChannelDifference: WARNING: Wrong length was read (should've read 4, read 0)! in Connection on line 174. Retrying...

[danog]

is it true?

Nope, please check the official bot API documentation.

ps : i should store last offset for next run time?

Nope, please check the official bot API documentation.

what is this error on running

It sometimes happens, ignore it.

[abbas980301]

thanks for answers.

Nope, please check the official bot API documentation.

did you mean this page?
http://daniil.it/MadelineProto/

[danog]

Nope, Google "telegram bot API documentation"

[Amirjan]

Hi @danog
Is it possible get updates near real time?

[danog]

Yes, use callbacks.
You must run $MadelineProto->get_updates_difference() in a loop to get updates with the callback.

[Amirjan]

I implement it:

function onNewChannelMessage($update){
file_put_contents('ChannelMessage.txt',print_r($update,true) , FILE_APPEND);
}

function onNewMessage($update){
file_put_contents('NewMessage.txt',print_r($update,true) , FILE_APPEND);
}

$MadelineProto->eventManager()->bind('NewChannelMessage', 'onNewChannelMessage');
$MadelineProto->eventManager()->bind('NewMessage', 'onNewMessage');

while(true){
$MadelineProto->get_updates_difference();
}

[vahidvdn]

You must run $MadelineProto->get_updates_difference() in a loop to get updates with the callback

@danog Hi. How did you implement non-blocking in php?

[danog]

I use pthreads for multithreading, but to enable it a ZTS version of PHP must be installed, along with the pthreads extension.

[nicorac]

@Amirjan: I'm trying to use your sample code:
#67 (comment)

but the line
$MadelineProto->eventManager()->bind('NewChannelMessage', 'onNewChannelMessage');

throws an exception:
PHP Fatal error: Uncaught danog\MadelineProto\TL\Exception: Could not find method: eventManager in madelineProto/src/danog/MadelineProto/TL/TL.php:357

I've also searched for "eventManager" in the whole source tree unsuccessfully.
Where is it supposed to be defined?

[danog]

@Amirjan is clearly using a custom event manager, a pull request would be nice :3

[Amirjan]

@nicorac I implement it with my custom event manager
If dear @danog allows it, I will publish it here

[danog]

@Amirjan Sure, send a pr!

[Cojad]

@Amirjan, your event manager looks so awesome!

[Amirjan]

ApiEventsManager.php:

listeners[$event][] = $callback; } public function fire($event, array $parameters) { if (!empty($this->listeners[$event])) { foreach ($this->listeners[$event] as $listener) { call_user_func_array($listener, $parameters); } } } } ?>

in MTProto.php:

protected $eventManager;

public function __construct($settings = []){

......
$this->should_serialize = true;
$this->eventManager = new ApiEventsManager();
}

public function eventManager()
{
    return $this->eventManager;
}

/MTProtoTools/UpdateHandler.php
public function get_updates_update_handler($update)
{
if (!$this->settings['updates']['handle_updates']) {
return;
}
switch ($update['_']) {
case 'updateNewChannelMessage':
$this->eventManager()->fire('NewChannelMessage',[$update]);
break;
case 'updateNewMessage':
if (isset($update['message']['out']) && $update['message']['out']) {
break;
}
$this->eventManager()->fire('NewMessage',[$update]);
break;
}
$this->eventManager()->fire('onUpdate',[$update]);
$this->updates[$this->updates_key++] = $update;
$this->should_serialize = true;
}