Adapt for pwrtelegram

Author: danog

LICENSE

@@ -1,14 +1,18 @@
 {
-    "name": "zyberspace/telegram-cli-client",
-    "description": "php-client for telegram-cli",
+    "name": "pwrtelegram/telegram-cli-client",
+    "description": "Modified version php-client for telegram-cli used by the PWRTelegram bot API",
     "type": "library",
-    "homepage": "https://github.com/zyberspace/php-telegram-cli-client",
+    "homepage": "https://github.com/pwrtelegram/php-telegram-cli-client",
     "license": "MPL-2.0",
     "authors": [
         {
             "name": "zyberspace",
             "email": "[email protected]"
         }
+        {
+            "name": "Daniil Gentili",
+            "email": "[email protected]"
+        }
     ],
     "require": {
         "php": ">=5.3.0,<6.0.0"

README.md

@@ -9,7 +9,7 @@
  */
 require('vendor/autoload.php');
 
-$telegram = new \Zyberspace\Telegram\Cli\Client('unix:///tmp/tg.sck');
+$telegram = new \Zyberspace\Telegram\Cli\Client();
 
 $discoverShell = new \Zyberspace\DiscoveryShell($telegram, 'telegram', __DIR__ . '/.developer-shell-history');
 $discoverShell->run();

composer.json

@@ -70,6 +70,23 @@ public function msg($peer, $msg)
         return $this->exec('msg ' . $peer . ' ' . $msg);
     }
 
+    /**
+     * Replies tp a text message.
+     *
+     * @param string $id The message id that we're replying to
+     * @param string $msg The message to send, gets escaped with escapeStringArgument()
+     *
+     * @return boolean true on success, false otherwise
+     *
+     * @uses exec()
+     * @uses escapeStringArgument()
+     */
+    public function replymsg($id, $msg)
+    {
+        $msg = $this->escapeStringArgument($msg);
+        
+        return $this->exec('reply ' . $id . ' ' . $msg);
+    }
     /**
      * Sends a text message to several users at once.
      *
@@ -410,4 +427,85 @@ public function sendFile($peer, $path)
 
         return $this->exec('send_file ' . $peer . ' ' . $formattedPath);
     }
+
+
+    /**
+     * Send file to peer and return message id
+     *
+     * @param  string $peer The peer, gets escaped with escapePeer() and escapeshellarg()
+     * @param  string $type The type of the file to be sent, gets escaped with escapePeer() and escapeshellarg()
+     * @param  string $path The file path, gets formatted with formatFileName() and escapeshellarg()
+     * @return array
+     *
+     * @uses exec()
+     * @uses escapePeer()
+     * @uses formatFileName()
+     * @uses escapeshellarg()
+     */
+    public function pwrsendFile($peer, $type, $path, $hash)
+    {
+	$peer = $this->escapePeer($peer);
+/*	$cmd = "msg " . $peer . " " . $hash;
+	$res = shell_exec($GLOBALS["homedir"] . "/tg/bin/telegram-cli --json --permanent-msg-ids -WNRe " . escapeshellarg($cmd) . " 2>&1");
+	foreach (explode("\n", $res) as $line) {
+		if(preg_match('|^{|', $line) && !preg_match('|{"result": "SUCCESS"}|', $line)) $newres = json_decode(preg_replace(array('|^[^{]*{|', "|}[^}]*$|"), array("{", "}"), $line), true); else continue;
+		if($newres["out"] && $newres["text"] == $hash && $newres["from"]["peer_id"] == $GLOBALS["botusername"]) $msgid = $newres["id"];
+	}
+*/
+        $formattedPath = $this->formatFileName($path);
+	$cmd = "send_" . $type . " " . $peer . " " . $formattedPath;
+	$res = shell_exec($GLOBALS["homedir"] . "/tg/bin/telegram-cli --json --permanent-msg-ids -U pwrtelegram -WNRe " . escapeshellarg($cmd) . " 2>&1");
+	$newres = null;
+	$finalres = null;
+	foreach (explode("\n", $res) as $line) {
+		if(preg_match('|^{|', $line) && !preg_match('|{"result": "SUCCESS"}|', $line)) $newres = json_decode(preg_replace(array('|^[^{]*{|', "|}[^}]*$|"), array("{", "}"), $line), true); else continue;
+		if(isset($newres["out"]) && $newres["out"] && isset($newres["media"]["type"]) && $newres["media"]["type"] == $type && isset($newres["from"]["peer_id"]) && $newres["from"]["peer_id"] == $GLOBALS["botusername"]) $finalres = $newres;
+	}
+	return $newres;
+    }
+
+    /**
+     * Download file from message id
+     *
+     * @param  string $type   The file type (document, audio, photo, video, voice)
+     * @param  string $id   The message's id
+     * @return array|boolean
+     *
+     * @uses exec()
+     * @uses escapePeer()
+     */
+    public function getdFile($id, $type)
+    {
+	$res = shell_exec($GLOBALS["homedir"] . "/tg/bin/telegram-cli --json --permanent-msg-ids -WNRe 'load_file $id' 2>&1 | sed 's/[>]//g;/{/!d;/{\"event\": \"download\"/!d;/^\s*$/d;s/^[^{]*{/{/;s/}[^}]*$/}/'");
+	error_log($res);
+	return json_decode($res);
+    }
+    public function getFile($user, $file_id, $type)
+    {
+	$script = escapeshellarg($GLOBALS["pwrhomedir"] . "/lua/download.lua");
+	$res = shell_exec($GLOBALS["homedir"] . "/tg/bin/telegram-cli --json -WNRs " . $script . " --lua-param ".escapeshellarg($user." ".$file_id." ".$type)." 2>&1");
+	foreach(explode("\n", $res) as $line) {
+		if(preg_match('|.*{"event":"download", "result"|', $line)) $res = preg_replace(array('|.*{"event":"download", "result"|', "|}.*|"), array('{"event":"download", "result"', "}"), $line);
+	}
+	return json_decode($res);
+    }
+
+    public function oldgetFile($user, $id, $type)
+    {
+
+        return $this->exec('load_' . $type . ' ' . $id);
+    }
+
+    /**
+     * Get info about current user
+     *
+     * @return array|boolean
+     *
+     * @uses exec()
+     * @uses escapePeer()
+     */
+    public function getSelf()
+    {
+        return $this->exec('get_self');
+    }
 }

discovery-shell.php

@@ -7,7 +7,6 @@
  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
  */
 namespace Zyberspace\Telegram\Cli;
-
 /**
  * Raw part of the php-client for telegram-cli.
  * Takes care of the socket-connection and some helper-methods.
@@ -47,7 +46,11 @@ public function __construct($remoteSocket)
     {
         $this->_fp = stream_socket_client($remoteSocket);
         if ($this->_fp === false) {
-            throw new ClientException('Could not connect to socket "' . $remoteSocket . '"');
+            shell_exec("pkill telegram-cli; rm /tmp/tg.sck; " . $GLOBALS["homedir"] . "/tg/bin/telegram-cli --json --permanent-msg-ids -dWS /tmp/tg.sck&");
+            $this->_fp = stream_socket_client($remoteSocket);
+            if ($this->_fp === false) {
+                throw new ClientException('Could not connect to socket "' . $remoteSocket . '"');
+            }
         }
     }
 
@@ -69,10 +72,11 @@ public function __destruct()
     public function exec($command)
     {
         $command = implode(' ', func_get_args());
-
         fwrite($this->_fp, str_replace("\n", '\n', $command) . PHP_EOL);
 
         $answer = fgets($this->_fp); //"ANSWER $bytes" or false if an error occurred
+
+
         if (is_string($answer)) {
             if (substr($answer, 0, 7) === 'ANSWER ') {
                 $bytes = ((int) substr($answer, 7)) + 1; //+1 because the json-return seems to miss one byte
@@ -87,8 +91,8 @@ public function exec($command)
                         $bytesRead = strlen($jsonString);
                     } while ($bytesRead < $bytes);
 
-                    $json = json_decode($jsonString);
 
+                    $json = json_decode($jsonString);
                     if (!isset($json->error)) {
                         //Reset error-message and error-code
                         $this->_errorMessage = null;
@@ -156,6 +160,13 @@ public function escapePeer($peer)
     {
         return str_replace(' ', '_', $peer);
     }
+    public function escapeUsername($username)
+    {
+        $peer = $this->exec('resolve_username ' . $username);
+        if(!isset($peer->print_name) || $peer->print_name == "") return false;
+	$peer = $peer->print_name;
+        return str_replace(' ', '_', $peer);
+    }
 
     /**
      * Takes a list of peers and turns it into a format needed by the most commands that handle multiple peers.