2017-02-11 15:16:57 +01:00
#!/usr/bin/env php
< ? php
2017-02-11 15:30:37 +01:00
/*
Copyright 2016 - 2017 Daniil Gentili
( https :// daniil . it )
This file is part of MadelineProto .
MadelineProto is free software : you can redistribute it and / or modify it under the terms of the GNU Affero General Public License as published by the Free Software Foundation , either version 3 of the License , or ( at your option ) any later version .
MadelineProto is distributed in the hope that it will be useful , but WITHOUT ANY WARRANTY ; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE .
See the GNU Affero General Public License for more details .
You should have received a copy of the GNU General Public License along with MadelineProto .
If not , see < http :// www . gnu . org / licenses />.
*/
2017-02-11 15:16:57 +01:00
require 'vendor/autoload.php' ;
$settings = [];
$MadelineProto = false ;
try {
$MadelineProto = \danog\MadelineProto\Serialization :: deserialize ( 'bot.madeline' );
} catch ( \danog\MadelineProto\Exception $e ) {
}
$uMadelineProto = \danog\MadelineProto\Serialization :: deserialize ( 'pwr.madeline' );
if ( file_exists ( 'token.php' ) && $MadelineProto === false ) {
include_once 'token.php' ;
$MadelineProto = new \danog\MadelineProto\API ( $settings );
$authorization = $MadelineProto -> bot_login ( $token );
\danog\MadelineProto\Logger :: log ([ $authorization ], \danog\MadelineProto\Logger :: NOTICE );
}
if ( $uMadelineProto === false ) {
echo 'Loading MadelineProto...' . PHP_EOL ;
$uMadelineProto = new \danog\MadelineProto\API ([ 'updates' => [ 'handle_updates' => false ]]);
2017-02-11 15:18:18 +01:00
$sentCode = $uMadelineProto -> phone_login ( readline ());
\danog\MadelineProto\Logger :: log ([ $sentCode ], \danog\MadelineProto\Logger :: NOTICE );
echo 'Enter the code you received: ' ;
$code = fgets ( STDIN , ( isset ( $sentCode [ 'type' ][ 'length' ]) ? $sentCode [ 'type' ][ 'length' ] : 5 ) + 1 );
$authorization = $uMadelineProto -> complete_phone_login ( $code );
\danog\MadelineProto\Logger :: log ([ $authorization ], \danog\MadelineProto\Logger :: NOTICE );
if ( $authorization [ '_' ] === 'account.noPassword' ) {
throw new \danog\MadelineProto\Exception ( '2FA is enabled but no password is set!' );
}
if ( $authorization [ '_' ] === 'account.password' ) {
\danog\MadelineProto\Logger :: log ([ '2FA is enabled' ], \danog\MadelineProto\Logger :: NOTICE );
$authorization = $uMadelineProto -> complete_2fa_login ( readline ( 'Please enter your password (hint ' . $authorization [ 'hint' ] . '): ' ));
}
echo 'Serializing MadelineProto to session.madeline...' . PHP_EOL ;
echo 'Wrote ' . \danog\MadelineProto\Serialization :: serialize ( 'session.madeline' , $uMadelineProto ) . ' bytes' . PHP_EOL ;
2017-02-11 15:16:57 +01:00
}
2017-02-11 15:18:18 +01:00
function inputify ( & $stuff )
{
2017-02-11 15:16:57 +01:00
$stuff [ '_' ] = 'input' . ucfirst ( $stuff [ '_' ]);
2017-02-11 15:18:18 +01:00
2017-02-11 15:16:57 +01:00
return $stuff ;
}
2017-02-11 15:18:18 +01:00
function translatetext ( & $value )
{
2017-02-11 15:16:57 +01:00
inputify ( $value );
if ( isset ( $value [ 'entities' ])) {
foreach ( $value [ 'entities' ] as & $entity ) {
2017-02-11 15:18:18 +01:00
if ( $entity [ '_' ] === 'messageEntityMentionName' ) {
inputify ( $entity );
}
2017-02-11 15:16:57 +01:00
}
}
if ( isset ( $value [ 'geo' ])) {
$value [ 'geo_point' ] = inputify ( $value [ 'geo' ]);
}
}
2017-02-11 15:18:18 +01:00
function translate ( & $value , $key )
{
2017-02-11 15:16:57 +01:00
switch ( $value [ '_' ]) {
case 'botInlineResult' :
$value [ '_' ] = 'inputBotInlineResult' ;
translatetext ( $value [ 'send_message' ]);
2017-02-11 15:18:18 +01:00
2017-02-11 15:16:57 +01:00
return $value ;
case 'botInlineMediaResult' :
2017-02-11 15:18:18 +01:00
if ( isset ( $value [ 'game' ])) {
throw new \danog\MadelineProto\RPCErrorException ( 'Games are not supported.' );
}
if ( isset ( $value [ 'photo' ])) {
$value [ '_' ] = 'inputBotInlineResultPhoto' ;
}
if ( isset ( $value [ 'document' ])) {
$value [ '_' ] = 'inputBotInlineResultDocument' ;
}
2017-02-11 15:16:57 +01:00
translatetext ( $value [ 'send_message' ]);
2017-02-11 15:18:18 +01:00
2017-02-11 15:16:57 +01:00
return $value ;
}
}
$offset = 0 ;
$start = " This bot can create a pipeline between inline bots.
To use it , simply type an inline query with the following syntax :
Query | @ ainlinebot : 1 | @ binlinebot : lel | @ inlinebot \ $
This will make an inline query with text \ " Query \" to @ainlinebot, take the first result if it's a text message (entities will be ignored, if it's a media message you will be redirected here), then it will make an inline query to @binlinebot with the text received out of the first bot, select the result that is a text message with the word \" lel \" in it (regexes are supported), and finally pipe it to @inlinebot, fetch all results and return them to you.
Note that the query must be terminated by a \ $
Created by @ danogentili ( @ daniilgentili ) using the daniil . it / MadelineProto PHP MTProto client . " ;
while ( true ) {
$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 ( $updates as $update ) {
$offset = $update [ 'update_id' ] + 1 ; // Just like in the bot API, the offset must be set to the last update_id
switch ( $update [ 'update' ][ '_' ]) {
case 'updateNewMessage' :
var_dump ( $update );
if ( isset ( $update [ 'update' ][ 'message' ][ 'out' ]) && $update [ 'update' ][ 'message' ][ 'out' ]) {
continue ;
}
try {
2017-02-11 15:18:18 +01:00
if ( preg_match ( '|/start|' , $update [ 'update' ][ 'message' ][ 'message' ])) {
2017-02-11 15:16:57 +01:00
$MadelineProto -> messages -> sendMessage ([ 'peer' => $update [ 'update' ][ 'message' ][ 'from_id' ], 'message' => $start , 'reply_to_msg_id' => $update [ 'update' ][ 'message' ][ 'id' ]]);
}
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
$MadelineProto -> messages -> sendMessage ([ 'peer' => '@danogentili' , 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
}
break ;
case 'updateNewChannelMessage' :
if ( isset ( $update [ 'update' ][ 'message' ][ 'out' ]) && $update [ 'update' ][ 'message' ][ 'out' ]) {
continue ;
}
try {
2017-02-11 15:18:18 +01:00
if ( preg_match ( '|/start|' , $update [ 'update' ][ 'message' ][ 'message' ])) {
2017-02-11 15:16:57 +01:00
$MadelineProto -> messages -> sendMessage ([ 'peer' => $update [ 'update' ][ 'message' ][ 'to_id' ], 'message' => $start , 'reply_to_msg_id' => $update [ 'update' ][ 'message' ][ 'id' ]]);
}
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
$MadelineProto -> messages -> sendMessage ([ 'peer' => '@danogentili' , 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
} catch ( \danog\MadelineProto\Exception $e ) {
$MadelineProto -> messages -> sendMessage ([ 'peer' => '@danogentili' , 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
}
break ;
case 'updateBotInlineQuery' :
try {
2017-02-11 15:18:18 +01:00
$sswitch = [ '_' => 'inlineBotSwitchPM' , 'text' => 'FAQ' , 'start_param' => 'lel' ];
if ( $update [ 'update' ][ 'query' ] === '' ) {
$MadelineProto -> messages -> setInlineBotResults ([ 'query_id' => $update [ 'update' ][ 'query_id' ], 'results' => [], 'cache_time' => 0 , 'switch_pm' => $sswitch ]);
} else {
$toset = [ 'query_id' => $update [ 'update' ][ 'query_id' ], 'results' => [], 'cache_time' => 0 , 'private' => true ];
if ( preg_match ( '|\$\s*$|' , $update [ 'update' ][ 'query' ])) {
$exploded = explode ( '|' , preg_replace ( '/\$\s*$/' , '' , $update [ 'update' ][ 'query' ]));
array_walk ( $exploded , function ( & $value , $key ) {
$value = preg_replace ([ '/^\s+/' , '/\s+$/' ], '' , $value );
});
$query = array_shift ( $exploded );
foreach ( $exploded as $current => $botq ) {
$bot = preg_replace ( '|:.*|' , '' , $botq );
if ( $bot === '' || $uMadelineProto -> get_info ( $bot )[ 'bot_api_id' ] === $MadelineProto -> API -> datacenter -> authorization [ 'user' ][ 'id' ]) {
$toset [ 'switch_pm' ] = $sswitch ;
break ;
}
$select = preg_replace ( '|' . $bot . ':|' , '' , $botq );
$results = $uMadelineProto -> messages -> getInlineBotResults ([ 'bot' => $bot , 'peer' => $update [ 'update' ][ 'user_id' ], 'query' => $query , 'offset' => $offset ]);
if ( isset ( $results [ 'switch_pm' ])) {
$toset [ 'switch_pm' ] = $results [ 'switch_pm' ];
break ;
2017-02-11 15:16:57 +01:00
}
2017-02-11 15:18:18 +01:00
$toset [ 'gallery' ] = $results [ 'gallery' ];
$toset [ 'results' ] = [];
if ( is_numeric ( $select )) {
$toset [ 'results' ][ 0 ] = $results [ 'results' ][ $select - 1 ];
} elseif ( $select === '' ) {
$toset [ 'results' ] = $results [ 'results' ];
} else {
foreach ( $results [ 'results' ] as $result ) {
if ( isset ( $result [ 'send_message' ][ 'message' ]) && preg_match ( '|' . $select . '|' , $result [ 'send_message' ][ 'message' ])) {
$toset [ 'results' ][ 0 ] = $result ;
}
}
}
if ( ! isset ( $toset [ 'results' ][ 0 ])) {
$toset [ 'results' ] = $results [ 'results' ];
}
if ( count ( $exploded ) - 1 === $current || ! isset ( $toset [ 'results' ][ 0 ][ 'send_message' ][ 'message' ])) {
break ;
}
$query = $toset [ 'results' ][ 0 ][ 'send_message' ][ 'message' ];
2017-02-11 15:16:57 +01:00
}
}
2017-02-11 15:18:18 +01:00
if ( empty ( $toset [ 'results' ])) {
$toset [ 'switch_pm' ] = $sswitch ;
} else {
array_walk ( $toset [ 'results' ], 'translate' );
}
$MadelineProto -> messages -> setInlineBotResults ( $toset );
2017-02-11 15:16:57 +01:00
}
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
$MadelineProto -> messages -> sendMessage ([ 'peer' => '@danogentili' , 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
try {
2017-02-11 15:18:18 +01:00
$MadelineProto -> messages -> sendMessage ([ 'peer' => $update [ 'update' ][ 'user_id' ], 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
2017-02-11 15:16:57 +01:00
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
2017-02-11 15:18:18 +01:00
} catch ( \danog\MadelineProto\Exception $e ) {
}
2017-02-11 15:16:57 +01:00
try {
2017-02-11 15:18:18 +01:00
$toset [ 'switch_pm' ] = $sswitch ;
$MadelineProto -> messages -> setInlineBotResults ( $toset );
2017-02-11 15:16:57 +01:00
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
2017-02-11 15:18:18 +01:00
} catch ( \danog\MadelineProto\Exception $e ) {
}
2017-02-11 15:16:57 +01:00
} catch ( \danog\MadelineProto\Exception $e ) {
$MadelineProto -> messages -> sendMessage ([ 'peer' => '@danogentili' , 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
try {
2017-02-11 15:18:18 +01:00
$MadelineProto -> messages -> sendMessage ([ 'peer' => $update [ 'update' ][ 'user_id' ], 'message' => $e -> getCode () . ': ' . $e -> getMessage () . PHP_EOL . $e -> getTraceAsString ()]);
2017-02-11 15:16:57 +01:00
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
2017-02-11 15:18:18 +01:00
} catch ( \danog\MadelineProto\Exception $e ) {
}
2017-02-11 15:16:57 +01:00
try {
2017-02-11 15:18:18 +01:00
$toset [ 'switch_pm' ] = $sswitch ;
$MadelineProto -> messages -> setInlineBotResults ( $toset );
2017-02-11 15:16:57 +01:00
} catch ( \danog\MadelineProto\RPCErrorException $e ) {
2017-02-11 15:18:18 +01:00
} catch ( \danog\MadelineProto\Exception $e ) {
}
2017-02-11 15:16:57 +01:00
}
}
}
\danog\MadelineProto\Serialization :: serialize ( 'bot.madeline' , $MadelineProto );
\danog\MadelineProto\Serialization :: serialize ( 'pwr.madeline' , $uMadelineProto );
}