mirror of
https://github.com/danog/MadelineProto.git
synced 2025-01-11 09:48:17 +01:00
293 lines
11 KiB
PHP
293 lines
11 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
/**
|
|
* MyTelegramOrgWrapper module.
|
|
*
|
|
* 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/>.
|
|
*
|
|
* @author Daniil Gentili <daniil@daniil.it>
|
|
* @copyright 2016-2023 Daniil Gentili <daniil@daniil.it>
|
|
* @license https://opensource.org/licenses/AGPL-3.0 AGPLv3
|
|
* @link https://docs.madelineproto.xyz MadelineProto documentation
|
|
*/
|
|
|
|
namespace danog\MadelineProto;
|
|
|
|
use Amp\Http\Client\Cookie\LocalCookieJar;
|
|
use Amp\Http\Client\Request;
|
|
|
|
/**
|
|
* Wrapper for my.telegram.org.
|
|
*/
|
|
final class MyTelegramOrgWrapper
|
|
{
|
|
/**
|
|
* Whether we're logged in.
|
|
*/
|
|
private bool $logged = false;
|
|
/**
|
|
* Login hash.
|
|
*/
|
|
private string $hash = '';
|
|
/**
|
|
* Phone number.
|
|
*/
|
|
private string $number = '';
|
|
/**
|
|
* Creation hash.
|
|
*/
|
|
private string $creation_hash = '';
|
|
/**
|
|
* Settings.
|
|
*
|
|
*/
|
|
private Settings $settings;
|
|
/**
|
|
* Datacenter instance.
|
|
*/
|
|
private DoHWrapper $datacenter;
|
|
/**
|
|
* Cooke jar.
|
|
*
|
|
*/
|
|
private ?LocalCookieJar $jar = null;
|
|
/**
|
|
* Endpoint.
|
|
*/
|
|
private const MY_TELEGRAM_URL = 'https://my.telegram.org';
|
|
/**
|
|
* Sleep function.
|
|
*/
|
|
public function __sleep(): array
|
|
{
|
|
return ['logged', 'hash', 'number', 'creation_hash', 'settings', 'async', 'jar'];
|
|
}
|
|
/**
|
|
* Constructor.
|
|
*/
|
|
public function __construct(SettingsAbstract $settings)
|
|
{
|
|
if (!$settings instanceof Settings) {
|
|
$settings = new Settings;
|
|
$settings->merge($this->settings);
|
|
}
|
|
$this->settings = $settings;
|
|
$this->__wakeup();
|
|
}
|
|
/**
|
|
* Wakeup function.
|
|
*/
|
|
public function __wakeup(): void
|
|
{
|
|
if (!$this->jar || !$this->jar instanceof LocalCookieJar) {
|
|
$this->jar = new LocalCookieJar();
|
|
}
|
|
$this->datacenter = new DoHWrapper(
|
|
$this->settings->getConnection(),
|
|
new class(new Logger($this->settings->getLogger())) implements LoggerGetter {
|
|
public function __construct(private Logger $logger)
|
|
{
|
|
}
|
|
public function getLogger(): Logger
|
|
{
|
|
return $this->logger;
|
|
}
|
|
},
|
|
$this->jar
|
|
);
|
|
}
|
|
/**
|
|
* Login.
|
|
*
|
|
* @param string $number Phone number
|
|
*/
|
|
public function login(string $number): void
|
|
{
|
|
$this->number = $number;
|
|
$request = new Request(self::MY_TELEGRAM_URL.'/auth/send_password', 'POST');
|
|
$request->setBody(\http_build_query(['phone' => $number]));
|
|
$request->setHeaders($this->getHeaders('origin'));
|
|
$response = $this->datacenter->HTTPClient->request($request);
|
|
$result = $response->getBody()->buffer();
|
|
$resulta = \json_decode($result, true);
|
|
if (!isset($resulta['random_hash'])) {
|
|
throw new Exception($result);
|
|
}
|
|
$this->hash = $resulta['random_hash'];
|
|
}
|
|
/**
|
|
* Complete login.
|
|
*
|
|
* @param string $password Password
|
|
*/
|
|
public function completeLogin(string $password)
|
|
{
|
|
if ($this->logged) {
|
|
throw new Exception('Already logged in!');
|
|
}
|
|
$request = new Request(self::MY_TELEGRAM_URL.'/auth/login', 'POST');
|
|
$request->setBody(\http_build_query(['phone' => $this->number, 'random_hash' => $this->hash, 'password' => $password]));
|
|
$request->setHeaders($this->getHeaders('origin'));
|
|
$request->setHeader('user-agent', 'Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.8.1.13) Gecko/20080311 Firefox/2.0.0.13');
|
|
$response = $this->datacenter->HTTPClient->request($request);
|
|
$result = $response->getBody()->buffer();
|
|
switch ($result) {
|
|
case 'true':
|
|
//Logger::log(['Login OK'], Logger::VERBOSE);
|
|
break;
|
|
default:
|
|
throw new Exception($result);
|
|
}
|
|
return $this->logged = true;
|
|
}
|
|
/**
|
|
* Whether we are logged in.
|
|
*/
|
|
public function loggedIn(): bool
|
|
{
|
|
return $this->logged;
|
|
}
|
|
/**
|
|
* Check if an app was already created.
|
|
*/
|
|
public function hasApp()
|
|
{
|
|
if (!$this->logged) {
|
|
throw new Exception('Not logged in!');
|
|
}
|
|
$request = new Request(self::MY_TELEGRAM_URL.'/apps');
|
|
$request->setHeaders($this->getHeaders('refer'));
|
|
$response = $this->datacenter->HTTPClient->request($request);
|
|
$result = $response->getBody()->buffer();
|
|
$title = \explode('</title>', \explode('<title>', $result)[1])[0];
|
|
switch ($title) {
|
|
case 'App configuration':
|
|
return true;
|
|
case 'Create new application':
|
|
$this->creation_hash = \explode('"/>', \explode('<input type="hidden" name="hash" value="', $result)[1])[0];
|
|
return false;
|
|
}
|
|
$this->logged = false;
|
|
throw new Exception($title);
|
|
}
|
|
/**
|
|
* Get the currently created app.
|
|
*/
|
|
public function getApp()
|
|
{
|
|
if (!$this->logged) {
|
|
throw new Exception('Not logged in!');
|
|
}
|
|
$request = new Request(self::MY_TELEGRAM_URL.'/apps');
|
|
$request->setHeaders($this->getHeaders('refer'));
|
|
$response = $this->datacenter->HTTPClient->request($request);
|
|
$result = $response->getBody()->buffer();
|
|
$cose = \explode('<label for="app_id" class="col-md-4 text-right control-label">App api_id:</label>
|
|
<div class="col-md-7">
|
|
<span class="form-control input-xlarge uneditable-input" onclick="this.select();"><strong>', $result);
|
|
$asd = \explode('</strong></span>', $cose[1]);
|
|
$api_id = $asd[0];
|
|
$cose = \explode('<label for="app_hash" class="col-md-4 text-right control-label">App api_hash:</label>
|
|
<div class="col-md-7">
|
|
<span class="form-control input-xlarge uneditable-input" onclick="this.select();">', $result);
|
|
$asd = \explode('</span>', $cose[1]);
|
|
$api_hash = $asd[0];
|
|
return ['api_id' => (int) $api_id, 'api_hash' => $api_hash];
|
|
}
|
|
/**
|
|
* Create an app.
|
|
*
|
|
* @param array $settings App parameters
|
|
*/
|
|
public function createApp(array $settings)
|
|
{
|
|
if (!$this->logged) {
|
|
throw new Exception('Not logged in!');
|
|
}
|
|
if ($this->hasApp()) {
|
|
throw new Exception('The app was already created!');
|
|
}
|
|
$request = new Request(self::MY_TELEGRAM_URL.'/apps/create', 'POST');
|
|
$request->setHeaders($this->getHeaders('app'));
|
|
$request->setBody(\http_build_query(['hash' => $this->creation_hash, 'app_title' => $settings['app_title'], 'app_shortname' => $settings['app_shortname'], 'app_url' => $settings['app_url'], 'app_platform' => $settings['app_platform'], 'app_desc' => $settings['app_desc']]));
|
|
$response = $this->datacenter->HTTPClient->request($request);
|
|
$result = $response->getBody()->buffer();
|
|
if ($result) {
|
|
throw new Exception(\html_entity_decode($result));
|
|
}
|
|
$request = new Request(self::MY_TELEGRAM_URL.'/apps');
|
|
$request->setHeaders($this->getHeaders('refer'));
|
|
$response = $this->datacenter->HTTPClient->request($request);
|
|
$result = $response->getBody()->buffer();
|
|
$title = \explode('</title>', \explode('<title>', $result)[1])[0];
|
|
if ($title === 'Create new application') {
|
|
$this->creation_hash = \explode('"/>', \explode('<input type="hidden" name="hash" value="', $result)[1])[0];
|
|
throw new Exception('App creation failed');
|
|
}
|
|
$cose = \explode('<label for="app_id" class="col-md-4 text-right control-label">App api_id:</label>
|
|
<div class="col-md-7">
|
|
<span class="form-control input-xlarge uneditable-input" onclick="this.select();"><strong>', $result);
|
|
$asd = \explode('</strong></span>', $cose['1']);
|
|
$api_id = $asd['0'];
|
|
$cose = \explode('<label for="app_hash" class="col-md-4 text-right control-label">App api_hash:</label>
|
|
<div class="col-md-7">
|
|
<span class="form-control input-xlarge uneditable-input" onclick="this.select();">', $result);
|
|
$asd = \explode('</span>', $cose['1']);
|
|
$api_hash = $asd['0'];
|
|
return ['api_id' => (int) $api_id, 'api_hash' => $api_hash];
|
|
}
|
|
/**
|
|
* Function for generating curl request headers.
|
|
*
|
|
* @param string $httpType Origin
|
|
*/
|
|
private function getHeaders(string $httpType): array
|
|
{
|
|
// Common header flags.
|
|
$headers = [];
|
|
$headers[] = 'Dnt: 1';
|
|
$headers[] = 'Connection: keep-alive';
|
|
$headers[] = 'Accept-Language: it-IT,it;q=0.8,en-US;q=0.6,en;q=0.4';
|
|
$headers[] = 'User-Agent: Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/57.0.2987.133 Safari/537.36';
|
|
// Add additional headers based on the type of request.
|
|
switch ($httpType) {
|
|
case 'origin':
|
|
$headers[] = 'Origin: '.self::MY_TELEGRAM_URL;
|
|
//$headers[] = 'Accept-Encoding: gzip, deflate, br';
|
|
$headers[] = 'Content-Type: application/x-www-form-urlencoded; charset=UTF-8';
|
|
$headers[] = 'Accept: application/json, text/javascript, */*; q=0.01';
|
|
$headers[] = 'Referer: '.self::MY_TELEGRAM_URL.'/auth';
|
|
$headers[] = 'X-Requested-With: XMLHttpRequest';
|
|
break;
|
|
case 'refer':
|
|
//$headers[] = 'Accept-Encoding: gzip, deflate, sdch, br';
|
|
$headers[] = 'Upgrade-Insecure-Requests: 1';
|
|
$headers[] = 'Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8';
|
|
$headers[] = 'Referer: '.self::MY_TELEGRAM_URL;
|
|
$headers[] = 'Cache-Control: max-age=0';
|
|
break;
|
|
case 'app':
|
|
$headers[] = 'Origin: '.self::MY_TELEGRAM_URL;
|
|
//$headers[] = 'Accept-Encoding: gzip, deflate, br';
|
|
$headers[] = 'Content-Type: application/x-www-form-urlencoded; charset=UTF-8';
|
|
$headers[] = 'Accept: */*';
|
|
$headers[] = 'Referer: '.self::MY_TELEGRAM_URL.'/apps';
|
|
$headers[] = 'X-Requested-With: XMLHttpRequest';
|
|
break;
|
|
}
|
|
$final_headers = [];
|
|
foreach ($headers as $header) {
|
|
[$key, $value] = \explode(':', $header, 2);
|
|
$final_headers[\trim($key)] = \trim($value);
|
|
}
|
|
return $final_headers;
|
|
}
|
|
}
|