Bugfixes to magnaluna, dialog fetching and phone calls

magna.php

@@ -80,24 +80,58 @@ if ($MadelineProto === false) {
 \danog\MadelineProto\Logger::log(['hey'], \danog\MadelineProto\Logger::FATAL_ERROR);
 
 $message = (getenv('TRAVIS_COMMIT') == '') ? 'I iz works always (io laborare sembre) (yo lavorar siempre) (mi labori ĉiam) (я всегда работать) (Ik werkuh altijd) (Ngimbonga ngaso sonke isikhathi ukusebenza)' : ('Travis ci tests in progress: commit '.getenv('TRAVIS_COMMIT').', job '.getenv('TRAVIS_JOB_NUMBER').', PHP version: '.getenv('TRAVIS_PHP_VERSION'));
+if (!isset($MadelineProto->programmed_call)) $MadelineProto->programmed_call = [];
 
 echo 'Serializing MadelineProto to session.madeline...'.PHP_EOL; echo 'Wrote '.\danog\MadelineProto\Serialization::serialize('session.madeline', $MadelineProto).' bytes'.PHP_EOL;
 /*
 $m = new \danog\MadelineProto\API($settings);
 $m->import_authorization($MadelineProto->export_authorization());
 */
+$times = [];
 $calls = [];
 $users = [];
     $offset = 0;
     while (1) {
         $updates = $MadelineProto->API->get_updates(['offset' => $offset, 'limit' => 50, 'timeout' => 0]); // Just like in the bot API, you can specify an offset, a limit and a timeout
+        foreach ($MadelineProto->programmed_call as $key => $pair) {
+            list($user, $time) = $pair;
+            if ($time < time()) {
+                if (!isset($calls[$user])) {
+                    try {
+                            include 'songs.php';
+                            $call = $MadelineProto->request_call($user);
+                            $call->configuration['enable_NS'] = false;
+                            $call->configuration['enable_AGC'] = false;
+                            $call->configuration['enable_AEC'] = false;
+                            $call->configuration['shared_config'] = [
+                                'audio_init_bitrate' => 70 * 1000,
+                                'audio_max_bitrate'  => 100 * 1000,
+                                'audio_min_bitrate'  => 15 * 1000,
+                                //'audio_bitrate_step_decr' => 0,
+                                //'audio_bitrate_step_incr' => 2000,
+                            ];
+                            $call->parseConfig();
+                            $calls[$call->getOtherID()] = $call;
+                            $times[$call->getOtherID()] = [time(), $MadelineProto->messages->sendMessage(['peer' => $call->getOtherID(), 'message' => 'Total running calls: '.count($calls).PHP_EOL.PHP_EOL.$call->getDebugString()])['id']];
+                            $call->playOnHold($songs);
+
+                    } catch (\danog\MadelineProto\RPCErrorException $e) {
+echo $e;
+                    }
+                }
+                unset($MadelineProto->programmed_call[$key]);
+            }
+        }
         foreach ($calls as $key => $call) {
             if ($call->getCallState() === \danog\MadelineProto\VoIP::CALL_STATE_ENDED) {
-                try {
-                    //$MadelineProto->messages->sendMessage(['peer' => $call->getOtherID(), 'message' => 'Emojis: '.implode('', $call->getVisualization())]);
-                } catch (\danog\MadelineProto\RPCErrorException $e) {
-                }
                 unset($calls[$key]);
+            } else if ($times[$call->getOtherID()][0] < time()) {
+                $times[$call->getOtherID()][0] += 10;
+                try {
+                    $MadelineProto->messages->editMessage(['id' => $times[$call->getOtherID()][1], 'peer' => $call->getOtherID(), 'message' => 'Total running calls: '.count($calls).PHP_EOL.PHP_EOL.$call->getDebugString()]);
+                } catch (\danog\MadelineProto\RPCErrorException $e) {
+echo $e;
+                }
             }
         }
         foreach ($updates as $update) {
@@ -111,7 +145,27 @@ $users = [];
                     }
 
                     try {
-                        if (isset($update['update']['message']['message']) && $update['update']['message']['message'] !== '') {
+                        if (!isset($users[$update['update']['message']['from_id']]) ||isset($update['update']['message']['message']) && $update['update']['message']['message'] === '/start') {
+                            $users[$update['update']['message']['from_id']] = true;
+                            $update['update']['message']['message'] = '/call';
+                            $MadelineProto->messages->sendMessage(['peer' => $update['update']['message']['from_id'], 'message' => "Hi, I'm @magnaluna the webradio.
+
+Call _me_ to listen to some **awesome** music, or send /call to make _me_ call _you_ (don't forget to disable call privacy settings!).
+
+You can also program a phone call with /program:
+
+/program 29 August 2018 - call me the 29th of august 2018
+/program +1 hour 30 minutes - call me in one hour and thirty minutes
+/program next Thursday - call me next Thursday at midnight
+
+Send /start to see this message again.
+
+I also provide advanced stats during calls!
+
+I'm a userbot powered by @MadelineProto, created by @danogentili.
+Propic art by @magnaluna on deviantart.", 'parse_mode' => 'Markdown']);
+                        }
+                        if (!isset($calls[$update['update']['message']['from_id']]) && isset($update['update']['message']['message']) && $update['update']['message']['message'] === '/call') {
                             include 'songs.php';
                             $call = $MadelineProto->request_call($update['update']['message']['from_id']);
                             $call->configuration['enable_NS'] = false;
@@ -126,20 +180,29 @@ $users = [];
                             ];
                             $call->parseConfig();
                             $calls[$call->getOtherID()] = $call;
+                            $times[$call->getOtherID()] = [time(), $MadelineProto->messages->sendMessage(['peer' => $call->getOtherID(), 'message' => 'Total running calls: '.count($calls).PHP_EOL.PHP_EOL.$call->getDebugString()])['id']];
+
+
                             $call->playOnHold($songs);
                         }
-
+                        if (isset($update['update']['message']['message']) && strpos($update['update']['message']['message'], '/program') === 0) {
-                        if (!isset($users[$update['update']['message']['from_id']])) {
+                            $time = strtotime(str_replace('/program ', '', $update['update']['message']['message']));
-                            $users[$update['update']['message']['from_id']] = true;
+                            if ($time === false) {
-                            $MadelineProto->messages->sendMessage(['peer' => $update['update']['message']['from_id'], 'message' => "Hi, I'm @magnaluna the webradio.
+                                $MadelineProto->messages->sendMessage(['peer' => $update['update']['message']['from_id'], 'message' => "Invalid time provided"]);
-
+                            } else {
-Call _me_ to listen to some **awesome** music, or send /call to make _me_ call _you_ (don't forget to disable call privacy settings!).
+                                $MadelineProto->programmed_call[]= [$update['update']['message']['from_id'], $time];
-
+                                $MadelineProto->messages->sendMessage(['peer' => $update['update']['message']['from_id'], 'message' => "OK"]);
-I'm a userbot powered by @MadelineProto, created by @danogentili.
+                            }
-Propic art by @magnaluna on deviantart.", 'parse_mode' => 'Markdown']);
                         }
                     } catch (\danog\MadelineProto\RPCErrorException $e) {
+                        try {
+                            if (strpos($e->rpc, 'FLOOD_WAIT_') === 0) $MadelineProto->programmed_call[]= [$update['update']['message']['from_id'], time()+1+str_replace('FLOOD_WAIT_', '', $e->rpc)];
+                            $MadelineProto->messages->sendMessage(['peer' => $update['update']['message']['from_id'], 'message' => (string) $e]);
+                        } catch (\danog\MadelineProto\RPCErrorException $e) {
+                        }
+                        echo $e;
                     } catch (\danog\MadelineProto\Exception $e) {
+                        echo $e;
                     }
                     break;
                 case 'updatePhoneCall':
@@ -160,6 +223,9 @@ Propic art by @magnaluna on deviantart.", 'parse_mode' => 'Markdown']);
                         echo 'DID NOT ACCEPT A CALL';
                     }
                     $calls[$update['update']['phone_call']->getOtherID()] = $update['update']['phone_call'];
+                    try {
+                        $times[$update['update']['phone_call']->getOtherID()] = [time(), $MadelineProto->messages->sendMessage(['peer' => $update['update']['phone_call']->getOtherID(), 'message' => 'Total running calls: '.count($calls).PHP_EOL.PHP_EOL.$update['update']['phone_call']->getDebugString()])['id']];
+                    } catch (\danog\MadelineProto\RPCErrorException $e) { ; }
                     $update['update']['phone_call']->playOnHold($songs);
                 }
 

src/danog/MadelineProto/VoIP/AuthKeyHandler.php

@@ -89,7 +89,7 @@ trait AuthKeyHandler
             }
             if ($e->rpc === 'CALL_ALREADY_DECLINED') {
                 \danog\MadelineProto\Logger::log(['Call '.$call['id'].' already declined']);
-                $this->discard_call($call['id']);
+                $this->discard_call($call['id'], 'phoneCallDiscardReasonHangup');
                 //$this->calls[$call['id']]->discard();
 
                 return false;

src/danog/MadelineProto/Wrappers/DialogHandler.php

@@ -34,7 +34,7 @@ trait DialogHandler
             $this->dialog_params['count'] += count($res['dialogs']);
             $this->dialog_params['offset_date'] = end($res['messages'])['date'];
             $this->dialog_params['offset_peer'] = end($res['dialogs'])['peer'];
-            $this->dialog_params['offset_id'] = end($res['messages'])['id'];
+            $this->dialog_params['offset_id'] = end($res['messages'])['id'] & 4294967296;
             if (!isset($res['count'])) {
                 break;
             }