- Add the new Item model

app/models/item/Item.php

@@ -0,0 +1,59 @@
+<?php
+
+namespace modl;
+
+class Item extends ModlModel {
+    public $server;
+    public $jid;
+    public $name;
+    public $node;
+    public $updated;
+    public $subscription;
+    public $num;
+    
+    public function __construct() {
+        $this->_struct = '
+        {
+            "server" : 
+                {"type":"string", "size":128, "mandatory":true, "key":true },
+            "jid" : 
+                {"type":"string", "size":128, "mandatory":true, "key":true },
+            "node" : 
+                {"type":"string", "size":128, "mandatory":true, "key":true },
+            "name" : 
+                {"type":"string", "size":128 },
+            "updated" : 
+                {"type":"date"}
+        }';
+        
+        parent::__construct();
+    }
+
+    public function set($item, $from) {
+        $this->server = $from;
+        $this->node   = (string)$item->attributes()->node;
+        $this->jid    = (string)$item->attributes()->jid;
+        if($this->jid == null)
+            $this->jid = $this->node;
+        $this->name   = (string)$item->attributes()->name;
+        $this->updated  = date('Y-m-d H:i:s');
+    }
+    
+    public function getName() {
+        /*if($this->name == '')
+            return $this->node;
+        else
+            return $this->name;*/
+        if($this->name != null)
+            return $this->name;
+        elseif($this->node != null)
+            return $this->node;
+        else
+            return $this->jid;
+    }
+}
+
+class Server extends ModlModel {
+    public $server;
+    public $number;
+}

app/models/item/ItemDAO.php

@@ -0,0 +1,156 @@
+<?php
+
+namespace modl;
+
+class ItemDAO extends ModlSQL { 
+    function set(Item $item) {
+        $this->_sql = '
+            update item
+            set name   = :name,
+                updated = :updated
+            where server = :server
+                and jid  = :jid
+                and node = :node';
+        
+        $this->prepare(
+            'Item', 
+            array(
+                'name'   => $item->name,
+                'updated'=> $item->updated,
+                'server' => $item->server,
+                'jid'    => $item->jid,
+                'node'   => $item->node
+            )
+        );
+        
+        $this->run('Item');
+        
+        if(!$this->_effective) {
+            $this->_sql = '
+                insert into item
+                (server,
+                node,
+                jid,
+                name,
+                updated
+                )
+                values(
+                    :server,
+                    :node,
+                    :jid,
+                    :name,
+                    :updated
+                    )';
+            
+            $this->prepare(
+                'Item', 
+                array(
+                    'name'   => $item->name,
+                    'updated'=> $item->updated,
+                    'server' => $item->server,
+                    'jid'    => $item->jid,
+                    'node'   => $item->node
+                )
+            );
+            
+            $this->run('Item');
+        }
+    }
+    
+    function getServers() {
+        $this->_sql = '
+            select server, count(node) as number 
+            from item
+            where node not like :node
+            group by server
+            order by number desc';
+            
+        $this->prepare(
+            'Item',
+            array(
+                'node' => 'urn:xmpp:microblog:0:comments%'
+            )
+        );
+            
+        return $this->run('Server'); 
+    }
+    
+    function getItems($server) {
+        
+        $this->_sql = '
+            select * from item
+            left outer join (
+                select node, count(node) as num from postn
+                where jid = :server
+                group by node) as p
+            on p.node = item.node
+            left outer join (select server, node, subscription from subscription where jid = :node) 
+                as s on s.server = item.server 
+                and s.node = item.node
+            where item.server= :server
+            order by name, item.node
+            ';
+            
+        $this->prepare(
+            'Item',
+            array(
+                // Dirty hack, using node param to inject the session key
+                'node' => $this->_user,
+                'server' => $server
+            )
+        );
+            
+        return $this->run('Item'); 
+    }
+
+    function deleteItems($server) {
+        $this->_sql = '
+            delete from item
+            where server= :server';
+            
+        $this->prepare(
+            'Item',
+            array(
+                'server' => $server
+            )
+        );
+            
+        return $this->run('Item'); 
+    }
+
+    function deleteItem($server, $item) {
+        $this->_sql = '
+            delete from item
+            where server = :server
+                and node = :node';
+            
+        $this->prepare(
+            'Item',
+            array(
+                'server' => $server,
+                'node' => $item
+            )
+        );
+            
+        return $this->run('Item'); 
+    }
+    
+    function getItem($server, $item) {
+        /*$this->_sql = '
+            select * from node
+            where 
+                node = :node
+                and server = :server';
+        
+        $this->prepare(
+            'Item', 
+            array(
+                'node' => $item,
+                'server' => $server
+            )
+        );
+        
+        return $this->run('Item', 'item');*/
+        return null;
+    }
+}