Skip to content

Commit

Permalink
[TelegramBridge] Add new bridge (#1175)
Browse files Browse the repository at this point in the history
  • Loading branch information
VerifiedJoseph authored and logmanoriginal committed Jun 19, 2019
1 parent 91e73b0 commit 1989252
Showing 1 changed file with 265 additions and 0 deletions.
265 changes: 265 additions & 0 deletions bridges/TelegramBridge.php
Original file line number Diff line number Diff line change
@@ -0,0 +1,265 @@
<?php
class TelegramBridge extends BridgeAbstract {
const NAME = 'Telegram Bridge';
const URI = 'https://t.me';
const DESCRIPTION = 'Returns newest post from a public Telegram channel';
const MAINTAINER = 'VerifiedJoseph';
const PARAMETERS = array(array(
'username' => array(
'name' => 'Username',
'type' => 'text',
'exampleValue' => '@telegram',
)
)
);

const CACHE_TIMEOUT = 900; // 15 mins

private $feedName = '';
private $enclosures = array();
private $itemTitle = '';

private $backgroundImageRegex = "/background-image:url\('(.*)'\)/";

public function collectData() {

$html = getSimpleHTMLDOM($this->getURI())
or returnServerError('Could not request: ' . $this->getURI());

$channelTitle = htmlspecialchars_decode(
$html->find('div.tgme_channel_info_header_title span', 0)->plaintext,
ENT_QUOTES
);
$this->feedName = $channelTitle . ' (@' . $this->processUsername() . ')';

foreach($html->find('div.tgme_widget_message_wrap.js-widget_message_wrap') as $index => $messageDiv) {
$this->itemTitle = '';
$this->enclosures = array();
$item = array();

$item['uri'] = $this->processUri($messageDiv);
$item['content'] = $this->processContent($messageDiv);
$item['title'] = $this->itemTitle;
$item['timestamp'] = $this->processDate($messageDiv);
$item['enclosures'] = $this->enclosures;

$this->items[] = $item;
}
$this->items = array_reverse($this->items);
}

public function getURI() {

if (!is_null($this->getInput('username'))) {
return self::URI . '/s/' . $this->processUsername();
}

return parent::getURI();
}

public function getName() {

if (!empty($this->feedName)) {
return $this->feedName . ' - Telegram';
}

return parent::getName();
}

private function processUsername() {

if (substr($this->getInput('username'), 0, 1) === '@') {
return substr($this->getInput('username'), 1);
}

return $this->getInput('username');
}

private function processUri($messageDiv) {
return $messageDiv->find('a.tgme_widget_message_date', 0)->href;
}

private function processContent($messageDiv) {
$message = '';

if ($messageDiv->find('div.tgme_widget_message_forwarded_from', 0)) {
$message = $messageDiv->find('div.tgme_widget_message_forwarded_from', 0)->innertext . '<br><br>';
}

if ($messageDiv->find('a.tgme_widget_message_reply', 0)) {
$message = $this->processReply($messageDiv);
}

if ($messageDiv->find('div.tgme_widget_message_sticker_wrap', 0)) {
$message .= $this->processSticker($messageDiv);
}

if ($messageDiv->find('div.tgme_widget_message_poll', 0)) {
$message .= $this->processPoll($messageDiv);
}

if ($messageDiv->find('video', 0)) {
$message .= $this->processVideo($messageDiv);
}

if ($messageDiv->find('a.tgme_widget_message_photo_wrap', 0)) {
$message .= $this->processPhoto($messageDiv);
}

if ($messageDiv->find('div.tgme_widget_message_text.js-message_text', 0)) {
$message .= $messageDiv->find('div.tgme_widget_message_text.js-message_text', 0);

$this->itemTitle = $this->ellipsisTitle(
$messageDiv->find('div.tgme_widget_message_text.js-message_text', 0)->plaintext
);
}

if ($messageDiv->find('a.tgme_widget_message_link_preview', 0)) {
$message .= $this->processLinkPreview($messageDiv);
}

return $message;
}

private function processReply($messageDiv) {

$reply = $messageDiv->find('a.tgme_widget_message_reply', 0);

return <<<EOD
<blockquote>{$reply->find('span.tgme_widget_message_author_name', 0)->plaintext}<br>
{$reply->find('div.tgme_widget_message_text', 0)->innertext}
<a href="{$reply->href}">{$reply->href}</a></blockquote><hr>
EOD;
}

private function processSticker($messageDiv) {

if (empty($this->itemTitle)) {
$this->itemTitle = '@' . $this->processUsername() . ' posted a sticker';
}

$stickerDiv = $messageDiv->find('div.tgme_widget_message_sticker_wrap', 0);

preg_match($this->backgroundImageRegex, $stickerDiv->find('i', 0)->style, $sticker);

$this->enclosures[] = $sticker[1];

return <<<EOD
<a href="{$stickerDiv->children(0)->herf}"><img src="{$sticker[1]}"></a>
EOD;
}

private function processPoll($messageDiv) {

$poll = $messageDiv->find('div.tgme_widget_message_poll', 0);

$title = $poll->find('div.tgme_widget_message_poll_question', 0)->plaintext;
$type = $poll->find('div.tgme_widget_message_poll_type', 0)->plaintext;

if (empty($this->itemTitle)) {
$this->itemTitle = $title;
}

$pollOptions = '<ul>';

foreach ($poll->find('div.tgme_widget_message_poll_option') as $option) {
$pollOptions .= '<li>' . $option->children(0)->plaintext . ' - ' .
$option->find('div.tgme_widget_message_poll_option_text', 0)->plaintext . '</li>';
}
$pollOptions .= '</ul>';

return <<<EOD
{$title}<br><small>$type</small><br>{$pollOptions}
EOD;
}

private function processLinkPreview($messageDiv) {

$image = '';
$title = '';
$site = '';
$description = '';

$preview = $messageDiv->find('a.tgme_widget_message_link_preview', 0);

if (trim($preview->innertext) === '') {
return '';
}

if($preview->find('i', 0) &&
preg_match($this->backgroundImageRegex, $preview->find('i', 0)->style, $photo)) {

$image = '<img src="' . $photo[1] . '"/>';
$this->enclosures[] = $photo[1];
}

if ($preview->find('div.link_preview_title', 0)) {
$title = $preview->find('div.link_preview_title', 0)->plaintext;
}

if ($preview->find('div.link_preview_site_name', 0)) {
$site = $preview->find('div.link_preview_site_name', 0)->plaintext;
}

if ($preview->find('div.link_preview_description', 0)) {
$description = $preview->find('div.link_preview_description', 0)->plaintext;
}

return <<<EOD
<blockquote><a href="{$preview->href}">$image</a><br><a href="{$preview->href}">
{$title} - {$site}</a><br>{$description}</blockquote>
EOD;
}

private function processVideo($messageDiv) {

if (empty($this->itemTitle)) {
$this->itemTitle = '@' . $this->processUsername() . ' posted a video';
}

preg_match($this->backgroundImageRegex, $messageDiv->find('i.tgme_widget_message_video_thumb', 0)->style, $photo);

$this->enclosures[] = $photo[1];

return <<<EOD
<video controls="" poster="{$photo[1]}" preload="none">
<source src="{$messageDiv->find('video', 0)->src}" type="video/mp4">
</video>
EOD;
}

private function processPhoto($messageDiv) {

if (empty($this->itemTitle)) {
$this->itemTitle = '@' . $this->processUsername() . ' posted a photo';
}

$photos = '';

foreach ($messageDiv->find('a.tgme_widget_message_photo_wrap') as $photoWrap) {
preg_match($this->backgroundImageRegex, $photoWrap->style, $photo);

$this->enclosures[] = $photo[1];

$photos .= <<<EOD
<a href="{$photoWrap->href}"><img src="{$photo[1]}"/></a><br>
EOD;
}
return $photos;
}

private function processDate($messageDiv) {
return $messageDiv->find('time', 0)->datetime;
}

private function ellipsisTitle($text) {

$length = 100;

if (strlen($text) > $length) {
$text = explode('<br>', wordwrap($text, $length, '<br>'));
return $text[0] . '...';
}
return $text;
}
}

0 comments on commit 1989252

Please sign in to comment.