Start to move the Post table to Eloquent

8 years ago · 97c8991653
6 changed files with 670 additions and 5 deletions
--- a/app/Message.php
+++ b/app/Message.php
@ -127,11 +127,11 @@ class Message extends Model
                //$pd = new \Modl\PresenceDAO;
                //$p = $pd->getMyPresenceRoom($this->jidfrom);

-                if (is_object($p)
+                /*if (is_object($p)
                && strpos($this->body, $p->resource) !== false
                && $this->resource != $p->resource) {
                    $this->quoted = true;
-                }
+                }*/
            }

            if ($stanza->html) {
--- a/app/Post.php
+++ b/app/Post.php
@ -0,0 +1,577 @@
+<?php
+
+namespace App;
+
+use Respect\Validation\Validator;
+
+use Movim\Picture;
+use Movim\User;
+
+use Illuminate\Database\Eloquent\Model;
+
+class Post extends Model
+{
+    protected $guarded = [];
+    private $titleLimit = 200;
+
+    private function extractContent($contents)
+    {
+        $content = '';
+
+        foreach($contents as $c) {
+            switch($c->attributes()->type) {
+                case 'html':
+                case 'xhtml':
+                    $dom = new \DOMDocument('1.0', 'utf-8');
+                    $import = @dom_import_simplexml($c->children());
+                    if ($import == null) {
+                        $import = dom_import_simplexml($c);
+                    }
+                    $element = $dom->importNode($import, true);
+                    $dom->appendChild($element);
+                    return (string)$dom->saveHTML();
+                    break;
+                case 'text':
+                    if (trim($c) != '') {
+                        $this->contentraw = trim($c);
+                    }
+                    break;
+                default :
+                    $content = (string)$c;
+                    break;
+            }
+        }
+
+        return $content;
+    }
+
+    private function extractTitle($titles)
+    {
+        $title = '';
+        foreach($titles as $t) {
+            switch($t->attributes()->type) {
+                case 'html':
+                case 'xhtml':
+                    $title = strip_tags((string)$t->children()->asXML());
+                    break;
+                case 'text':
+                    if (trim($t) != '') {
+                        $title = trim($t);
+                    }
+                    break;
+                default :
+                    $title = (string)$t;
+                    break;
+            }
+        }
+
+        return $title;
+    }
+
+    public function set($item, $from, $delay = false, $node = false)
+    {
+        $entry = ($item->item) ? $item->item : $item;
+
+        if ($from != '') {
+            $this->server = $from;
+        }
+
+        $this->node = ($node) ? $node : (string)$item->attributes()->node;
+
+        $this->nodeid = (string)$entry->attributes()->id;
+
+        if ($entry->entry->id)
+            $this->nodeid = (string)$entry->entry->id;
+
+        // Get some informations on the author
+        if ($entry->entry->author->name)
+            $this->aname = (string)$entry->entry->author->name;
+        if ($entry->entry->author->uri)
+            $this->aid = substr((string)$entry->entry->author->uri, 5);
+        if ($entry->entry->author->email)
+            $this->aemail = (string)$entry->entry->author->email;
+
+        // Non standard support
+        if ($entry->entry->source && $entry->entry->source->author->name)
+            $this->aname = (string)$entry->entry->source->author->name;
+        if ($entry->entry->source && $entry->entry->source->author->uri)
+            $this->aid = substr((string)$entry->entry->source->author->uri, 5);
+
+        $this->title = $this->extractTitle($entry->entry->title);
+
+        // Content
+        $summary = ($entry->entry->summary && (string)$entry->entry->summary != '')
+            ? '<p class="summary">'.(string)$entry->entry->summary.'</p>'
+            : null;
+
+        if ($entry->entry && $entry->entry->content) {
+            $content = $this->extractContent($entry->entry->content);
+        } elseif ($summary == '') {
+            $content = __('');
+        } else {
+            $content = '';
+        }
+
+        $content = $summary.$content;
+
+        $this->updated = ($entry->entry->updated)
+            ? (string)$entry->entry->updated
+            : gmdate(SQL::SQL_DATE);
+
+        if ($entry->entry->published) {
+            $this->published = (string)$entry->entry->published;
+        } elseif ($entry->entry->updated) {
+            $this->published = (string)$entry->entry->updated;
+        } else {
+            $this->published = gmdate(SQL::SQL_DATE);
+        }
+
+        if ($delay) $this->delay = $delay;
+
+        // Tags parsing
+        /*if ($entry->entry->category) {
+            $td = new \Modl\TagDAO;
+            $td->delete($this->nodeid);
+
+            if ($entry->entry->category->count() == 1
+            && isset($entry->entry->category->attributes()->term)) {
+                $tag = new \Modl\Tag;
+                $tag->nodeid = $this->nodeid;
+                $tag->tag    = strtolower((string)$entry->entry->category->attributes()->term);
+                $td->set($tag);
+
+                if ($tag->tag == 'nsfw') $this->nsfw = true;
+            } else {
+                foreach($entry->entry->category as $cat) {
+                    $tag = new \Modl\Tag;
+                    $tag->nodeid = $this->nodeid;
+                    $tag->tag    = strtolower((string)$cat->attributes()->term);
+                    $td->set($tag);
+
+                    if ($tag->tag == 'nsfw') $this->nsfw = true;
+                }
+            }
+        }*/
+
+        if (current(explode('.', $this->server)) == 'nsfw') $this->nsfw = true;
+
+        if (!isset($this->commentserver)) {
+            $this->commentserver = $this->server;
+        }
+
+        $this->content = trim($content);
+        $this->contentcleaned = purifyHTML(html_entity_decode($this->content));
+
+        // We fill empty aid
+        if ($this->isMicroblog() && empty($this->aid)) {
+            $this->aid = $this->server;
+        }
+
+        // We check if this is a reply
+        if ($entry->entry->{'in-reply-to'}) {
+            $href = (string)$entry->entry->{'in-reply-to'}->attributes()->href;
+            $arr = explode(';', $href);
+            $reply = [
+                'server' => substr($arr[0], 5, -1),
+                'node'   => substr($arr[1], 5),
+                'nodeid' => substr($arr[2], 5)
+            ];
+
+            $this->reply = $reply;
+        }
+
+        $extra = false;
+        // We try to extract a picture
+        $xml = \simplexml_load_string('<div>'.$this->contentcleaned.'</div>');
+        if ($xml) {
+            $results = $xml->xpath('//img/@src');
+
+            if (is_array($results) && !empty($results)) {
+                $extra = (string)$results[0];
+
+                $this->picture = protectPicture($extra);
+                $this->setAttachments($entry->entry->link, $extra);
+            } else {
+                $results = $xml->xpath('//video/@poster');
+                if (is_array($results) && !empty($results)) {
+                    $extra = (string)$results[0];
+
+                    $this->picture = $extra;
+                    $this->setAttachments($entry->entry->link, $extra);
+                }
+            }
+
+            $results = $xml->xpath('//a');
+            if (is_array($results) && !empty($results)) {
+                foreach($results as $link) {
+                    $link->addAttribute('target', '_blank');
+                }
+            }
+        }
+
+        $this->setAttachments($entry->entry->link, $extra);
+
+        if ($this->isComment()) {
+            /*$pd = new \Modl\PostnDAO;
+            $p = $pd->getParent($this->server, substr($this->node, 30));
+            if ($p) {
+                $this->parentserver = $p->server;
+                $this->parentnode   = $p->node;
+                $this->parentnodeid = $p->nodeid;
+            }*/
+        }
+    }
+
+    private function setAttachments($links, $extra = false)
+    {
+        $l = [];
+
+        foreach($links as $attachment) {
+            $enc = [];
+            $enc = (array)$attachment->attributes();
+            $enc = $enc['@attributes'];
+            array_push($l, $enc);
+
+            if ($this->picture == null
+            && isset($enc['type'])
+            && typeIsPicture($enc['type'])
+            /*&& isSmallPicture($enc['href'])*/) {
+                $this->picture = protectPicture($enc['href']);
+            }
+
+            if ($enc['rel'] == 'alternate'
+            && Validator::url()->validate($enc['href'])) $this->open = true;
+
+            if ((string)$attachment->attributes()->title == 'comments') {
+                $url = parse_url(urldecode((string)$attachment->attributes()->href));
+
+                if ($url) {
+                    $this->commentserver = $url['path'];
+                    $this->commentnodeid = substr($url['query'], 36);
+                }
+            }
+        }
+
+        if ($extra) {
+            array_push(
+                $l,
+                [
+                    'rel' => 'enclosure',
+                    'href' => $extra,
+                    'type' => 'picture'
+                ]);
+        }
+
+        if (!empty($l)) {
+            $this->links = $l;
+        }
+    }
+
+    public function getAttachments()
+    {
+        $attachments = null;
+        $this->openlink = null;
+
+        if (isset($this->links)) {
+            $links = $this->links;
+            $attachments = [
+                'pictures' => [],
+                'files' => [],
+                'links' => []
+            ];
+
+            foreach($links as $l) {
+                // If the href is not a valid URL we skip
+                if (!Validator::url()->validate($l['href'])) continue;
+
+                // Prepare the switch
+                $rel = isset($l['rel']) ? $l['rel'] : null;
+                switch($rel) {
+                    case 'enclosure':
+                        if (typeIsPicture($l['type'])) {
+                            array_push($attachments['pictures'], $l);
+                        } elseif ($l['type'] != 'picture') {
+                            array_push($attachments['files'], $l);
+                        }
+                        break;
+
+                    case 'related':
+                        if (preg_match('%(?:youtube(?:-nocookie)?\.com/(?:[^/]+/.+/|(?:v|e(?:mbed)?)/|.*[?&]v=)|youtu\.be/)([^"&?/ ]{11})%i', $l['href'], $match)) {
+                            $this->youtube = $match[1];
+                        }
+
+                        array_push(
+                            $attachments['links'],
+                            [
+                                'href' => $l['href'],
+                                'url'  => parse_url($l['href']),
+                                'title'=> (isset($l['title'])) ? $l['title'] : false,
+                                'rel'  => 'related',
+                                'description' => (isset($l['description'])) ? $l['description'] : false,
+                                'logo' => (isset($l['logo'])) ? $l['logo'] : false
+                            ]
+                        );
+                        break;
+
+                    case 'alternate':
+                    default:
+                        $this->openlink = $l['href'];
+                        if (!$this->isMicroblog()) {
+                            array_push(
+                                $attachments['links'],
+                                [
+                                    'href' => $l['href'],
+                                    'url'  => parse_url($l['href']),
+                                    'rel'  => 'alternate'
+                                ]
+                            );
+                        }
+                        break;
+                }
+            }
+        }
+
+        if (empty($attachments['pictures'])) unset($attachments['pictures']);
+        if (empty($attachments['files']))    unset($attachments['files']);
+        if (empty($attachments['links']))    unset($attachments['links']);
+
+        return $attachments;
+    }
+
+    public function getAttachment()
+    {
+        $attachments = $this->getAttachments();
+
+        if (array_key_exists('links', $attachments)) {
+            foreach($attachments['links'] as $attachment) {
+                if (in_array($attachment['rel'], ['enclosure', 'related'])) {
+                    return $attachment;
+                }
+            }
+        }
+
+        unset($attachments['links']);
+
+        foreach($attachments as $key => $group) {
+            foreach($group as $attachment) {
+                if (in_array($attachment['rel'], ['enclosure', 'related'])) {
+                    return $attachment;
+                }
+            }
+        }
+    }
+
+    public function getPicture()
+    {
+        return $this->picture;
+    }
+
+    public function getYoutube()
+    {
+        return $this->youtube;
+    }
+
+    public function getPlace()
+    {
+        return (isset($this->lat, $this->lon) && $this->lat != '' && $this->lon != '');
+    }
+
+    /*public function getLogo()
+    {
+        $p = new Picture;
+        return $p->get($this->server.$this->node, 50);
+    }*/
+
+    public function getUUID()
+    {
+        if (substr($this->nodeid, 10) == 'urn:uuid:') {
+            return $this->nodeid;
+        }
+
+        return 'urn:uuid:'.generateUUID($this->nodeid);
+    }
+
+    public function getRef()
+    {
+        return 'xmpp:'.$this->server.'?;node='.$this->node.';item='.$this->nodeid;
+    }
+
+    // Works only for the microblog posts
+    /*public function getParent()
+    {
+        $pd = new PostnDAO;
+        return $pd->get($this->parentserver, $this->parentnode, $this->parentnodeid);
+    }*/
+
+    public function isMine($force = false)
+    {
+        if ($force) {
+            return ($this->aid == \App\User::me()->id);
+        }
+
+        return ($this->aid == \App\User::me()->id
+            || $this->server == \App\User::me()->id);
+    }
+
+    /*public function isPublic()
+    {
+        return ($this->open);
+    }*/
+
+    public function isMicroblog()
+    {
+        return ($this->node == "urn:xmpp:microblog:0");
+    }
+
+    public function isEditable()
+    {
+        return ($this->contentraw != null || $this->links != null);
+    }
+
+    public function isShort()
+    {
+        return (strlen($this->contentcleaned) < 700);
+    }
+
+    public function isBrief()
+    {
+        return ($this->content == '' && strlen($this->title) < $this->titleLimit);
+    }
+
+    public function isNSFW()
+    {
+        return $this->nsfw;
+    }
+
+    public function isReply()
+    {
+        return isset($this->reply);
+    }
+
+    public function isLike()
+    {
+        return ($this->contentraw == '♥' || $this->title == '♥');
+    }
+
+    public function isRTL()
+    {
+        return (isRTL($this->contentraw) || isRTL($this->title));
+    }
+
+    public function isComment()
+    {
+        return (substr($this->node, 0, 30) == 'urn:xmpp:microblog:0:comments/');
+    }
+
+    public function hasCommentsNode()
+    {
+        return (isset($this->commentserver)
+             && isset($this->commentnodeid));
+    }
+
+    public function getSummary()
+    {
+        if ($this->isBrief()) {
+            return truncate(html_entity_decode($this->title), 140);
+        }
+
+        return truncate(stripTags(html_entity_decode($this->contentcleaned)), 140);
+    }
+
+    public function getTitle()
+    {
+        return (isset($this->title)
+            && strlen($this->title) >= $this->titleLimit)
+            ? __('post.default_title')
+            : $this->title;
+    }
+
+    public function getContent()
+    {
+        return (strlen($this->title) >= $this->titleLimit)
+            ? nl2br(addUrls(addHashtagsLinks($this->title)))
+            : $this->contentcleaned;
+    }
+
+    public function getReply()
+    {
+        if (!$this->reply) return;
+
+        $reply = $this->reply;
+        $pd = new \Modl\PostnDAO;
+        return $pd->get($reply['server'], $reply['node'], $reply['nodeid']);
+    }
+
+    public function getPublicUrl()
+    {
+        return $this->openlink;
+    }
+
+    public function getComments()
+    {
+        /*$pd = new \Modl\PostnDAO;
+        $comments = $pd->getComments($this);
+        return $comments ? $comments : [];*/
+    }
+
+    public function countComments()
+    {
+        /*$pd = new \Modl\PostnDAO;
+        return $pd->countComments($this->commentserver, $this->commentnodeid);*/
+        return 0;
+    }
+
+    public function countLikes()
+    {
+        /*$pd = new \Modl\PostnDAO;
+        return $pd->countLikes($this->commentserver, $this->commentnodeid);*/
+        return 0;
+    }
+
+    public function isLiked()
+    {
+        /*$pd = new \Modl\PostnDAO;
+        return $pd->isLiked($this->commentserver, $this->commentnodeid);*/
+        return false;
+    }
+
+    /*public function countReplies()
+    {
+        $pd = new \Modl\PostnDAO;
+        return $pd->countReplies([
+            'server'    => $this->server,
+            'node'      => $this->node,
+            'nodeid'    => $this->nodeid
+        ]);
+    }*/
+
+    /*public function getTags()
+    {
+        $td = new \Modl\TagDAO;
+        $tags = $td->getTags($this->nodeid);
+        if (is_array($tags)) {
+            return array_map(function($tag) { return $tag->tag; }, $tags);
+        }
+    }
+
+    public function getTagsImploded()
+    {
+        $tags = $this->getTags();
+        if (is_array($tags)) {
+            return implode(', ', $tags);
+        }
+    }*/
+
+    /*public function getNext()
+    {
+        $pd = new PostnDAO;
+        return $pd->getNext($this->server, $this->node, $this->nodeid);
+    }
+
+    public function getPrevious()
+    {
+        $pd = new PostnDAO;
+        return $pd->getPrevious($this->server, $this->node, $this->nodeid);
+    }*/
+}
+
--- a/app/widgets/ContactData/ContactData.php
+++ b/app/widgets/ContactData/ContactData.php
@ -22,7 +22,6 @@ class ContactData extends \Movim\Widget\Base
    {
        $view = $this->tpl();

-        $subscriptions = $id->getSharedItems($jid);
        $view->assign('message', $this->user->messages()
                                        ->where(function ($query) use ($jid) {
                                            $query->where('jidfrom', $jid)
@ -30,7 +29,8 @@ class ContactData extends \Movim\Widget\Base
                                        })
                                        ->orderBy('published', 'desc')
                                        ->first());
-        $view->assign('subscriptions', $subscriptions ? $subscriptions : []);
+        $view->assign('subscriptions', \App\Subscription::where('jid', $jid)
+            ->where('public', true)->get());
        $view->assign('contact', App\Contact::firstOrNew(['id' => $jid]));
        $view->assign('roster', App\User::me()->session->contacts->where('jid', $jid)->first());

--- a/database/migrations/20180402112838_create_subscriptions_table.php
+++ b/database/migrations/20180402112838_create_subscriptions_table.php
@ -11,7 +11,6 @@ class CreateSubscriptionsTable extends Migration
            $table->string('jid', 64);
            $table->string('server', 64);
            $table->string('node', 192);
-            //$table->string('subscription', 16);
            $table->string('subid', 128)->nullable();
            $table->string('title', 128)->nullable();
            $table->boolean('public')->default(false);
--- a/database/migrations/20180402145559_create_posts_table.php
+++ b/database/migrations/20180402145559_create_posts_table.php
@ -0,0 +1,51 @@
+<?php
+
+use Movim\Migration;
+use Illuminate\Database\Schema\Blueprint;
+
+class CreatePostsTable extends Migration
+{
+    public function up()
+    {
+        $this->schema->create('posts', function(Blueprint $table) {
+            $table->increments('id');
+            $table->string('server', 64);
+            $table->string('node', 256);
+            $table->string('nodeid', 192);
+            $table->string('aname', 128)->nullable();
+            $table->string('aid', 64)->nullable();
+            $table->string('aemail', 64)->nullable();
+
+            $table->text('title')->nullable();
+            $table->text('content')->nullable();
+            $table->text('contentraw')->nullable();
+            $table->text('contentcleaned')->nullable();
+
+            $table->string('commentserver', 64)->nullable();
+            $table->string('commentnodeid', 96)->nullable();
+            $table->string('parentorigin', 64)->nullable();
+            $table->string('parentnode', 96)->nullable();
+            $table->string('parentnodeid', 96)->nullable();
+
+            $table->boolean('open')->default(false);
+            $table->boolean('nsfw')->default(false);
+
+            $table->datetime('published')->nullable();
+            $table->datetime('updated')->nullable();
+            $table->datetime('delay')->nullable();
+            $table->text('reply')->nullable();
+            $table->text('links')->nullable();
+            $table->text('picture')->nullable();
+
+            $table->timestamps();
+
+            $table->unique(['server', 'node', 'nodeid']);
+        });
+    }
+
+    public function down()
+    {
+        $this->schema->drop('posts');
+    }
+}
+
--- a/database/migrations/20180402145603_create_tags_table.php
+++ b/database/migrations/20180402145603_create_tags_table.php
@ -0,0 +1,38 @@
+<?php
+
+use Movim\Migration;
+use Illuminate\Database\Schema\Blueprint;
+
+class CreateTagsTable extends Migration
+{
+    public function up()
+    {
+        $this->schema->create('tags', function(Blueprint $table) {
+            $table->increments('id');
+            $table->string('title', 32);
+
+            $table->timestamps();
+        });
+
+        $this->schema->create('post_tag', function(Blueprint $table) {
+            $table->integer('post_id')->unsigned();
+            $table->integer('tag_id')->unsigned();
+
+            $table->foreign('post_id')->references('id')
+                  ->on('posts')->onDelete('cascade');
+            $table->foreign('tag_id')->references('id')
+                  ->on('tags')->onDelete('cascade');
+
+            $table->timestamps();
+
+            $table->unique(['post_id', 'tag_id']);
+        });
+    }
+
+    public function down()
+    {
+        $this->schema->drop('post_tag');
+        $this->schema->drop('tags');
+    }
+}
+