Add serverside list for contacts

.gitignore

@@ -3,6 +3,7 @@
 .php_cs.cache
 .credentials
 .credentials*
+.vscode/
 vendor/
 scripts/
 composer.lock

adapters/OctopushShortcodeAdapter.php

@@ -38,9 +38,9 @@ class OctopushShortcodeAdapter implements AdapterInterface
      * Sender name to use instead of shortcode.
      */
     private $sender;
-    
+
     /**
-     * Octopush SMS type
+     * Octopush SMS type.
      */
     private $sms_type;
 
@@ -49,7 +49,6 @@ class OctopushShortcodeAdapter implements AdapterInterface
      */
     private $api_url = 'https://api.octopush.com/v1/public';
 
-
     /**
      * Adapter constructor, called when instanciated by RaspiSMS.
      *
@@ -64,7 +63,7 @@ class OctopushShortcodeAdapter implements AdapterInterface
         $this->api_key = $this->data['api_key'];
 
         $this->sms_type = self::SMS_TYPE_LOWCOST;
-        if (($this->data['sms_type'] ?? false) && $this->data['sms_type'] === 'premium')
+        if (($this->data['sms_type'] ?? false) && 'premium' === $this->data['sms_type'])
         {
             $this->sms_type = self::SMS_TYPE_PREMIUM;
         }
@@ -234,7 +233,7 @@ class OctopushShortcodeAdapter implements AdapterInterface
 
             $data = [
                 'text' => $text,
-                'recipients' => [['phone_number' => $destination]], 
+                'recipients' => [['phone_number' => $destination]],
                 'sms_type' => $this->sms_type,
                 'purpose' => 'alert',
             ];
@@ -245,12 +244,11 @@ class OctopushShortcodeAdapter implements AdapterInterface
             }
             else
             {
-                $data['with_replies'] = "True";
+                $data['with_replies'] = 'True';
             }
 
             $data = json_encode($data);
 
-
             $endpoint = $this->api_url . '/sms-campaign/send';
 
             $curl = curl_init();
@@ -260,7 +258,7 @@ class OctopushShortcodeAdapter implements AdapterInterface
             curl_setopt($curl, CURLOPT_POST, true);
             curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
             curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
-            
+
             $curl_response = curl_exec($curl);
             $http_code = (int) curl_getinfo($curl, CURLINFO_HTTP_CODE);
             curl_close($curl);
@@ -332,7 +330,7 @@ class OctopushShortcodeAdapter implements AdapterInterface
             {
                 return false;
             }
-            
+
             $headers = [
                 'api-login: ' . $this->login,
                 'api-key: ' . $this->api_key,
@@ -350,7 +348,7 @@ class OctopushShortcodeAdapter implements AdapterInterface
             $http_code = (int) curl_getinfo($curl, CURLINFO_HTTP_CODE);
             curl_close($curl);
 
-            if ($http_code !== 200)
+            if (200 !== $http_code)
             {
                 return false;
             }
@@ -369,14 +367,13 @@ class OctopushShortcodeAdapter implements AdapterInterface
         header('Content-Encoding: none');
         header('Content-Length: 0');
 
-
         $input = file_get_contents('php://input');
         $content = json_decode($input, true);
         if (null === $content)
         {
             return false;
         }
-        
+
         $uid = $content['message_id'] ?? false;
         $status = $content['status'] ?? false;
 
@@ -385,7 +382,6 @@ class OctopushShortcodeAdapter implements AdapterInterface
             return false;
         }
 
-
         switch ($status)
         {
             case 'DELIVERED':
@@ -420,14 +416,14 @@ class OctopushShortcodeAdapter implements AdapterInterface
         header('Connection: close');
         header('Content-Encoding: none');
         header('Content-Length: 0');
-        
+
         $input = file_get_contents('php://input');
         $content = json_decode($input, true);
         if (null === $content)
         {
             $response['error'] = true;
             $response['error_message'] = 'Cannot read input data from callback request.';
-            
+
             return $response;
         }
 

adapters/OctopushVirtualNumberAdapter.php

@@ -35,7 +35,7 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
     private $api_key;
 
     /**
-     * Octopush SMS type
+     * Octopush SMS type.
      */
     private $sms_type;
 
@@ -45,11 +45,10 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
     private $api_url = 'https://api.octopush.com/v1/public';
 
     /**
-     * Octopush phone number
+     * Octopush phone number.
      */
     private $number;
 
-
     /**
      * Adapter constructor, called when instanciated by RaspiSMS.
      *
@@ -65,7 +64,7 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
         $this->number = $this->data['number'];
 
         $this->sms_type = self::SMS_TYPE_LOWCOST;
-        if (($this->data['sms_type'] ?? false) && $this->data['sms_type'] === 'premium')
+        if (($this->data['sms_type'] ?? false) && 'premium' === $this->data['sms_type'])
         {
             $this->sms_type = self::SMS_TYPE_PREMIUM;
         }
@@ -118,7 +117,6 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
                 Envoi de SMS avec un numéro virtuel en utilisant <a target="_blank" href="https://www.octopush.com/">Octopush</a>. Pour trouver vos clés API Octopush <a target="_blank" href="' . $credentials_url . '">cliquez ici.</a><br/>
                 Pour plus d\'information sur l\'utilisation de ce téléphone, reportez-vous à <a href="https://documentation.raspisms.fr/users/adapters/octopush_virtual_number.html" target="_blank">la documentation sur les téléphones "Octopush Numéro Virtuel".</a>
             ';
-
     }
 
     /**
@@ -154,7 +152,7 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
                 'description' => 'Type de SMS à employer coté Octopush, rentrez "low cost" ou "premium" selon le type de SMS que vous souhaitez employer. Laissez vide pour utiliser par défaut des SMS low cost.',
                 'required' => false,
             ],
-       ];
+        ];
     }
 
     /**
@@ -233,16 +231,15 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
 
             $data = [
                 'text' => $text,
-                'recipients' => [['phone_number' => $destination]], 
+                'recipients' => [['phone_number' => $destination]],
                 'sms_type' => $this->sms_type,
                 'purpose' => 'alert',
                 'sender' => $this->number,
-                'with_replies' => "True",
+                'with_replies' => 'True',
             ];
 
             $data = json_encode($data);
 
-
             $endpoint = $this->api_url . '/sms-campaign/send';
 
             $curl = curl_init();
@@ -252,7 +249,7 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
             curl_setopt($curl, CURLOPT_POST, true);
             curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
             curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
-            
+
             $curl_response = curl_exec($curl);
             $http_code = (int) curl_getinfo($curl, CURLINFO_HTTP_CODE);
             curl_close($curl);
@@ -325,7 +322,7 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
             {
                 return false;
             }
-            
+
             $headers = [
                 'api-login: ' . $this->login,
                 'api-key: ' . $this->api_key,
@@ -343,7 +340,7 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
             $http_code = (int) curl_getinfo($curl, CURLINFO_HTTP_CODE);
             curl_close($curl);
 
-            if ($http_code !== 200)
+            if (200 !== $http_code)
             {
                 return false;
             }
@@ -362,14 +359,13 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
         header('Content-Encoding: none');
         header('Content-Length: 0');
 
-
         $input = file_get_contents('php://input');
         $content = json_decode($input, true);
         if (null === $content)
         {
             return false;
         }
-        
+
         $uid = $content['message_id'] ?? false;
         $status = $content['status'] ?? false;
 
@@ -378,7 +374,6 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
             return false;
         }
 
-
         switch ($status)
         {
             case 'DELIVERED':
@@ -413,14 +408,14 @@ class OctopushVirtualNumberAdapter implements AdapterInterface
         header('Connection: close');
         header('Content-Encoding: none');
         header('Content-Length: 0');
-        
+
         $input = file_get_contents('php://input');
         $content = json_decode($input, true);
         if (null === $content)
         {
             $response['error'] = true;
             $response['error_message'] = 'Cannot read input data from callback request.';
-            
+
             return $response;
         }
 

controllers/internals/Call.php

@@ -136,7 +136,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Call
         {
             $this->model = $this->model ?? new \models\Call($this->bdd);
 

controllers/internals/Command.php

@@ -150,7 +150,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Command
         {
             $this->model = $this->model ?? new \models\Command($this->bdd);
 

controllers/internals/ConditionalGroup.php

@@ -134,7 +134,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\ConditionalGroup
         {
             $this->model = $this->model ?? new \models\ConditionalGroup($this->bdd);
 

controllers/internals/Contact.php

@@ -15,6 +15,23 @@ namespace controllers\internals;
     {
         protected $model;
 
+        /**
+         * @param int     $id_user        : User id
+         * @param ?int    $limit          : Number of entry to return
+         * @param ?int    $offset         : Number of entry to avoid
+         * @param ?string $search         : String to search for
+         * @param ?array  $search_columns : List of columns to search on
+         * @param ?string $order_column   : Name of the column to order by
+         * @param bool    $order_desc     : Should result be ordered DESC, if false order ASC
+         * @param bool    $count          : Should the query only count results
+         *
+         * @return array : Entries list
+         */
+        public function datatable_list_for_user(int $id_user, ?int $limit = null, ?int $offset = null, ?string $search = null, ?array $search_columns = [], ?string $order_column = null, bool $order_desc = false, $count = false)
+        {
+            return $this->get_model()->datatable_list_for_user($id_user, $limit, $offset, $search, $search_columns, $order_column, $order_desc, $count);
+        }
+        
         /**
          * Return a contact for a user by a number.
          *
@@ -351,7 +368,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Contact
         {
             $this->model = $this->model ?? new \models\Contact($this->bdd);
 

controllers/internals/Event.php

@@ -74,7 +74,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Event
         {
             $this->model = $this->model ?? new \models\Event($this->bdd);
 

controllers/internals/Group.php

@@ -130,7 +130,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Group
         {
             $this->model = $this->model ?? new \models\Group($this->bdd);
 

controllers/internals/Media.php

@@ -313,7 +313,7 @@ class Media extends StandardController
     /**
      * Get the model for the Controller.
      */
-    protected function get_model(): \descartes\Model
+    protected function get_model(): \models\Media
     {
         $this->model = $this->model ?? new \models\Media($this->bdd);
 

controllers/internals/Phone.php

@@ -166,7 +166,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Phone
         {
             $this->model = $this->model ?? new \models\Phone($this->bdd);
 

controllers/internals/Quota.php

@@ -288,7 +288,7 @@ class Quota extends StandardController
     /**
      * Get the model for the Controller.
      */
-    protected function get_model(): \descartes\Model
+    protected function get_model(): \models\Quota
     {
         $this->model = $this->model ?? new \models\Quota($this->bdd);
 

controllers/internals/Received.php

@@ -15,6 +15,26 @@ namespace controllers\internals;
     {
         protected $model;
 
+        /**
+         * Return the list of entries for a user.
+         *
+         * @param int     $id_user        : User id
+         * @param ?int    $limit          : Number of entry to return
+         * @param ?int    $offset         : Number of entry to avoid
+         * @param ?string $search         : String to search for
+         * @param ?array  $search_columns : List of columns to search on
+         * @param ?string $order_column   : Name of the column to order by
+         * @param bool    $order_desc     : Should result be ordered DESC, if false order ASC
+         * @param bool    $count          : Should the query only count results
+         * @param bool    $unread         : Should only unread messages be returned
+         *
+         * @return array : Entrys list
+         */
+        public function datatable_list_for_user(int $id_user, ?int $limit = null, ?int $offset = null, ?string $search = null, ?array $search_columns = [], ?string $order_column = null, bool $order_desc = false, bool $count = false, bool $unread = false)
+        {
+            return $this->get_model()->datatable_list_for_user($id_user, $limit, $offset, $search, $search_columns, $order_column, $order_desc, $count, $unread);
+        }
+
         /**
          * Return the list of unread messages for a user.
          *
@@ -355,7 +375,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Received
         {
             $this->model = $this->model ?? new \models\Received($this->bdd);
 

controllers/internals/Scheduled.php

@@ -544,7 +544,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Scheduled
         {
             $this->model = $this->model ?? new \models\Scheduled($this->bdd);
 

controllers/internals/Sended.php

@@ -14,17 +14,18 @@ namespace controllers\internals;
     class Sended extends StandardController
     {
         protected $model;
-        
+
         /**
-         * Return the list of entries for a user.
+         * @param int     $id_user        : User id
+         * @param ?int    $limit          : Number of entry to return
+         * @param ?int    $offset         : Number of entry to avoid
+         * @param ?string $search         : String to search for
+         * @param ?array  $search_columns : List of columns to search on
+         * @param ?string $order_column   : Name of the column to order by
+         * @param bool    $order_desc     : Should result be ordered DESC, if false order ASC
+         * @param bool    $count          : Should the query only count results
          *
-         * @param int  $id_user  : User id
-         * @param ?int $limit : Number of entry to return
-         * @param ?int $offset     : Number of entry to avoid
-         * @param ?string $search : String to search for
-         * @param ?array $orders : How to order results
-         *
-         * @return array : Entrys list
+         * @return array : Entries list
          */
         public function datatable_list_for_user(int $id_user, ?int $limit = null, ?int $offset = null, ?string $search = null, ?array $search_columns = [], ?string $order_column = null, bool $order_desc = false, $count = false)
         {
@@ -305,7 +306,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Sended
         {
             $this->model = $this->model ?? new \models\Sended($this->bdd);
 

controllers/internals/Setting.php

@@ -89,7 +89,7 @@ namespace controllers\internals;
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\Setting
         {
             $this->model = $this->model ?? new \models\Setting($this->bdd);
 

controllers/internals/SmsStop.php

@@ -64,24 +64,25 @@ namespace controllers\internals;
             return $this->get_model()->get_by_number_for_user($id_user, $number);
         }
 
+        /**
+         * Parse a string to check if its a SMS stop.
+         *
+         * @param string $str : The string to check
+         *
+         * @return bool : true if sms stop, false else
+         */
+        public function check_for_stop(string $str)
+        {
+            return 'stop' == trim(mb_strtolower($str));
+        }
+
         /**
          * Get the model for the Controller.
          */
-        protected function get_model(): \descartes\Model
+        protected function get_model(): \models\SmsStop
         {
             $this->model = $this->model ?? new \models\SmsStop($this->bdd);
 
             return $this->model;
         }
-
-        /**
-         * Parse a string to check if its a SMS stop
-         *
-         * @param string $str : The string to check
-         * @return bool : true if sms stop, false else
-         */
-        public function check_for_stop (string $str)
-        {
-            return trim(mb_strtolower($str)) == 'stop';
-        }
     }

controllers/internals/StandardController.php

@@ -137,6 +137,8 @@ namespace controllers\internals;
 
         /**
          * Get the model for the Controller.
+         * 
+         * @return \models\StandardModel
          */
-        abstract protected function get_model(): \descartes\Model;
+        abstract protected function get_model();
     }

controllers/internals/Webhook.php

@@ -146,7 +146,7 @@ class Webhook extends StandardController
     /**
      * Get the model for the Controller.
      */
-    protected function get_model(): \descartes\Model
+    protected function get_model(): \models\Webhook
     {
         $this->model = $this->model ?? new \models\Webhook($this->bdd);
 

controllers/publics/Account.php

@@ -204,10 +204,11 @@ namespace controllers\publics;
 
             return $this->redirect(\descartes\Router::url('Connect', 'login'));
         }
-        
+
         /**
-         * Allow to stop impersonating a user
-         * @param mixed     $csrf
+         * Allow to stop impersonating a user.
+         *
+         * @param mixed $csrf
          */
         public function stop_impersonate()
         {
@@ -223,6 +224,7 @@ namespace controllers\publics;
             $_SESSION = $old_session;
 
             \FlashMessage\FlashMessage::push('success', 'Vous n\'incarnez plus l\'utilisateur ' . $user_email . '.');
+
             return $this->redirect(\descartes\Router::url('Dashboard', 'show'));
         }
     }

controllers/publics/Connect.php

@@ -164,5 +164,4 @@ namespace controllers\publics;
 
             return $this->redirect(\descartes\Router::url('Connect', 'login'));
         }
-        
     }

controllers/publics/Contact.php

@@ -45,19 +45,43 @@ namespace controllers\publics;
             return $this->render('contact/list');
         }
 
+
         /**
          * Return contacts as json.
          */
         public function list_json()
         {
-            $entities = $this->internal_contact->list_for_user($_SESSION['user']['id']);
+            $draw = (int) ($_GET['draw'] ?? false);
+
+            $columns = [
+                0 => 'name',
+                1 => 'number',
+                2 => 'created_at',
+                3 => 'updated_at',
+            ];
+
+            $search = $_GET['search']['value'] ?? null;
+            $order_column = $columns[$_GET['order'][0]['column']] ?? null;
+            $order_desc = ($_GET['order'][0]['dir'] ?? 'asc') == 'desc' ? true : false;
+            $offset = (int) ($_GET['start'] ?? 0);
+            $limit = (int) ($_GET['length'] ?? 25);
+
+            $entities = $this->internal_contact->datatable_list_for_user($_SESSION['user']['id'], $limit, $offset, $search, $columns, $order_column, $order_desc);
+            $count_entities = $this->internal_contact->datatable_list_for_user($_SESSION['user']['id'], $limit, $offset, $search, $columns, $order_column, $order_desc, true);
             foreach ($entities as &$entity)
             {
                 $entity['number_formatted'] = \controllers\internals\Tool::phone_link($entity['number']);
             }
 
+            $records_total = $this->internal_contact->count_for_user($_SESSION['user']['id']);
+
             header('Content-Type: application/json');
-            echo json_encode(['data' => $entities]);
+            echo json_encode([
+                'draw' => $draw,
+                'recordsTotal' => $records_total,
+                'recordsFiltered' => $count_entities,
+                'data' => $entities,
+            ]);
         }
 
         /**

controllers/publics/Received.php

@@ -47,11 +47,31 @@ namespace controllers\publics;
         }
 
         /**
-         * Return received as json.
+         * Return receiveds as json.
+         *
+         * @param bool $unread : Should we only search for unread messages
          */
-        public function list_json()
+        public function list_json(bool $unread = false)
         {
-            $entities = $this->internal_received->list_for_user($_SESSION['user']['id']);
+            $draw = (int) ($_GET['draw'] ?? false);
+
+            $columns = [
+                0 => 'searchable_origin',
+                1 => 'phone_name',
+                2 => 'text',
+                3 => 'at',
+                4 => 'status',
+                5 => 'command',
+            ];
+
+            $search = $_GET['search']['value'] ?? null;
+            $order_column = $columns[$_GET['order'][0]['column']] ?? null;
+            $order_desc = ($_GET['order'][0]['dir'] ?? 'asc') == 'desc' ? true : false;
+            $offset = (int) ($_GET['start'] ?? 0);
+            $limit = (int) ($_GET['length'] ?? 25);
+
+            $entities = $this->internal_received->datatable_list_for_user($_SESSION['user']['id'], $limit, $offset, $search, $columns, $order_column, $order_desc, false, $unread);
+            $count_entities = $this->internal_received->datatable_list_for_user($_SESSION['user']['id'], $limit, $offset, $search, $columns, $order_column, $order_desc, true, $unread);
             foreach ($entities as &$entity)
             {
                 $entity['origin_formatted'] = \controllers\internals\Tool::phone_link($entity['origin']);
@@ -61,8 +81,15 @@ namespace controllers\publics;
                 }
             }
 
+            $records_total = $this->internal_received->count_for_user($_SESSION['user']['id']);
+
             header('Content-Type: application/json');
-            echo json_encode(['data' => $entities]);
+            echo json_encode([
+                'draw' => $draw,
+                'recordsTotal' => $records_total,
+                'recordsFiltered' => $count_entities,
+                'data' => $entities,
+            ]);
         }
 
         /**
@@ -73,25 +100,6 @@ namespace controllers\publics;
             $this->render('received/list', ['is_unread' => true]);
         }
 
-        /**
-         * Return unred received as json.
-         */
-        public function list_unread_json()
-        {
-            $entities = $this->internal_received->list_unread_for_user($_SESSION['user']['id']);
-            foreach ($entities as &$entity)
-            {
-                $entity['origin_formatted'] = \controllers\internals\Tool::phone_link($entity['origin']);
-                if ($entity['mms'])
-                {
-                    $entity['medias'] = $this->internal_media->gets_for_received($entity['id']);
-                }
-            }
-
-            header('Content-Type: application/json');
-            echo json_encode(['data' => $entities]);
-        }
-
         /**
          * Mark messages as.
          *

controllers/publics/Sended.php

@@ -53,8 +53,7 @@ namespace controllers\publics;
          */
         public function list_json()
         {
-
-            $draw = (int)($_GET['draw'] ?? false);
+            $draw = (int) ($_GET['draw'] ?? false);
 
             $columns = [
                 0 => 'phone_name',

controllers/publics/User.php

@@ -410,13 +410,13 @@ class User extends \descartes\Controller
         return $this->redirect(\descartes\Router::url('User', 'list'));
     }
 
-
     /**
-     * Allow an admin to impersonate a user
+     * Allow an admin to impersonate a user.
+     *
      * @param mixed     $csrf
      * @param array int $_GET['user_ids'] : Ids of users to impersonate, the array should actually contain one id only, we keep use of array for simpler compatibility in UI
      */
-    public function impersonate ($csrf)
+    public function impersonate($csrf)
     {
         if (!$this->verify_csrf($csrf))
         {
@@ -425,7 +425,7 @@ class User extends \descartes\Controller
             return $this->redirect(\descartes\Router::url('User', 'list'));
         }
 
-        if (count($_GET['user_ids']) != 1)
+        if (1 != count($_GET['user_ids']))
         {
             \FlashMessage\FlashMessage::push('danger', 'Vous devez séléctionner un et un seul utilisateur à incarner !');
 
@@ -460,17 +460,17 @@ class User extends \descartes\Controller
 
         $user['settings'] = $settings;
 
-        //Save old session to get it back later 
+        //Save old session to get it back later
         $old_session = $_SESSION;
         $_SESSION = [
-            'old_session' => $old_session, 
+            'old_session' => $old_session,
             'impersonate' => true,
             'connect' => true,
             'user' => $user,
         ];
 
         \FlashMessage\FlashMessage::push('success', 'Vous incarnez désormais l\'utilisateur ' . $user['email'] . '.');
+
         return $this->redirect(\descartes\Router::url('Dashboard', 'show'));
     }
-    
 }

models/Contact.php

@@ -13,6 +13,65 @@ namespace models;
 
     class Contact extends StandardModel
     {
+        /**
+         * Return a list of sended messages for a user.
+         * Add a column contact_name and phone_name when available.
+         *
+         * @param int  $id_user : user id
+         * @param ?int $limit   : Number of entry to return or null
+         * @param ?int $offset  : Number of entry to ignore or null
+         *
+         * @return array
+         */
+        public function datatable_list_for_user(int $id_user, ?int $limit = null, ?int $offset = null, ?string $search = null, ?array $search_columns = [], ?string $order_column = null, bool $order_desc = false, ?bool $count = false)
+        {
+            $params = [
+                'id_user' => $id_user,
+            ];
+
+            $query = $count ? 'SELECT COUNT(*) as nb' : 'SELECT * ';
+            $query .= '
+                FROM (
+                    SELECT * FROM contact
+                    WHERE id_user = :id_user
+                ) as results
+            ';
+
+            if ($search && $search_columns)
+            {
+                $like_search = '%' . str_replace(['\\', '%', '_'], ['\\\\', '\%', '\_'], $search) . '%';
+                $params[':like_search'] = $like_search;
+
+                $query .= ' WHERE (0';
+
+                foreach ($search_columns as $column)
+                {
+                    $query .= ' OR ' . $column . ' LIKE :like_search';
+                }
+
+                $query .= ')';
+            }
+
+            if ($order_column)
+            {
+                $query .= ' ORDER BY ' . $order_column . ($order_desc ? ' DESC' : ' ASC');
+            }
+
+            if (null !== $limit && !$count)
+            {
+                $limit = (int) $limit;
+
+                $query .= ' LIMIT ' . $limit;
+                if (null !== $offset)
+                {
+                    $offset = (int) $offset;
+                    $query .= ' OFFSET ' . $offset;
+                }
+            }
+
+            return $count ? $this->_run_query($query, $params)[0]['nb'] ?? 0 : $this->_run_query($query, $params);
+        }
+
         /**
          * Return a contact by his number for a user.
          *

models/Received.php

@@ -20,29 +20,60 @@ namespace models;
         const STATUS_READ = 'read';
 
         /**
-         * Return a list of received messages for a user.
-         * Add a column contact_name and phone_name when available.
+         * @param int     $id_user        : User id
+         * @param ?int    $limit          : Number of entry to return
+         * @param ?int    $offset         : Number of entry to avoid
+         * @param ?string $search         : String to search for
+         * @param ?array  $search_columns : List of columns to search on
+         * @param ?string $order_column   : Name of the column to order by
+         * @param bool    $order_desc     : Should result be ordered DESC, if false order ASC
+         * @param bool    $count          : Should the query only count results
+         * @param bool    $unread         : Should only unread messages be returned
          *
-         * @param int  $id_user : user id
-         * @param ?int $limit   : Number of entry to return or null
-         * @param ?int $offset  : Number of entry to ignore or null
-         *
-         * @return array
+         * @return array : Entrys list
          */
-        public function list_for_user(int $id_user, $limit, $offset)
+        public function datatable_list_for_user(int $id_user, ?int $limit = null, ?int $offset = null, ?string $search = null, ?array $search_columns = [], ?string $order_column = null, bool $order_desc = false, bool $count = false, bool $unread = false)
         {
-            $query = '
-                SELECT received.*, contact.name as contact_name, phone.name as phone_name
-                FROM received
-                LEFT JOIN contact
-                ON contact.number = received.origin
-                AND contact.id_user = received.id_user
-                LEFT JOIN phone
-                ON phone.id = received.id_phone
-                WHERE received.id_user = :id_user
-            ';
+            $params = [
+                'id_user' => $id_user,
+            ];
 
-            if (null !== $limit)
+            $query = $count ? 'SELECT COUNT(*) as nb' : 'SELECT * ';
+            $query .= '
+                FROM (
+                    SELECT received.*, contact.name as contact_name, phone.name as phone_name, IF(contact.name IS NULL, received.origin, CONCAT(received.origin, " (", contact.name, ")")) as searchable_origin
+                    FROM received
+                    LEFT JOIN contact
+                    ON contact.number = received.origin
+                    AND contact.id_user = received.id_user
+                    LEFT JOIN phone
+                    ON phone.id = received.id_phone
+                    WHERE received.id_user = :id_user
+                    ' . ($unread ? ' AND received.status = \'unread\'' : '') . '
+                ) as results
+';
+
+            if ($search && $search_columns)
+            {
+                $like_search = '%' . str_replace(['\\', '%', '_'], ['\\\\', '\%', '\_'], $search) . '%';
+                $params[':like_search'] = $like_search;
+
+                $query .= ' WHERE (0';
+
+                foreach ($search_columns as $column)
+                {
+                    $query .= ' OR ' . $column . ' LIKE :like_search';
+                }
+
+                $query .= ')';
+            }
+
+            if ($order_column)
+            {
+                $query .= ' ORDER BY ' . $order_column . ($order_desc ? ' DESC' : ' ASC');
+            }
+
+            if (null !== $limit && !$count)
             {
                 $limit = (int) $limit;
 
@@ -54,11 +85,7 @@ namespace models;
                 }
             }
 
-            $params = [
-                'id_user' => $id_user,
-            ];
-
-            return $this->_run_query($query, $params);
+            return $count ? $this->_run_query($query, $params)[0]['nb'] ?? 0 : $this->_run_query($query, $params);
         }
 
         /**

models/Sended.php

@@ -48,15 +48,15 @@ namespace models;
                     ON phone.id = sended.id_phone
                     WHERE sended.id_user = :id_user
                 ) as results
-';
+            ';
 
             if ($search && $search_columns)
             {
                 $like_search = '%' . str_replace(['\\', '%', '_'], ['\\\\', '\%', '\_'], $search) . '%';
                 $params[':like_search'] = $like_search;
-                
+
                 $query .= ' WHERE (0';
-                    
+
                 foreach ($search_columns as $column)
                 {
                     $query .= ' OR ' . $column . ' LIKE :like_search';
@@ -82,7 +82,7 @@ namespace models;
                 }
             }
 
-            return ($count ? $this->_run_query($query, $params)[0]['nb'] ?? 0 : $this->_run_query($query, $params)) ;
+            return $count ? $this->_run_query($query, $params)[0]['nb'] ?? 0 : $this->_run_query($query, $params);
         }
 
         /**

routes.php

@@ -93,9 +93,11 @@
 
         'Received' => [
             'list' => '/received/',
-            'list_json' => '/received/json/',
+            'list_json' => [
+                '/received/json/',
+                '/received/json/{unread}/',
+            ],
             'list_unread' => '/unread/',
-            'list_unread_json' => '/unread/json/',
             'mark_as' => '/mark/{status}/{csrf}/',
             'delete' => '/received/delete/{csrf}/',
             'popup' => '/received/popup/',

templates/contact/list.php

@@ -186,11 +186,12 @@ jQuery(document).ready(function()
         "language": {
             "url": HTTP_PWD + "/assets/js/datatables/french.json",
         },
+        "orderMulti": false,
         "columnDefs": [{
             'targets': 'checkcolumn',
             'orderable': false,
         }],
-
+        "serverSide": true,
         "ajax": {
             'url': '<?php echo \descartes\Router::url('Contact', 'list_json'); ?>',
             'dataSrc': 'data',

templates/received/list.php

@@ -83,13 +83,14 @@ jQuery(document).ready(function ()
         "language": {
             "url": HTTP_PWD + "/assets/js/datatables/french.json",
         },
+        "orderMulti": false,
         "columnDefs": [{
             'targets': 'checkcolumn',
             'orderable': false,
         }],
-
+        "serverSide": true,
         "ajax": {
-            'url': '<?php echo $is_unread ? \descartes\Router::url('Received', 'list_unread_json') : \descartes\Router::url('Received', 'list_json'); ?>',
+            'url': '<?php echo $is_unread ? \descartes\Router::url('Received', 'list_json', ['unread' => true]) : \descartes\Router::url('Received', 'list_json'); ?>',
             'dataSrc': 'data',
         },
         "columns" : [

templates/sended/list.php

@@ -73,6 +73,7 @@ jQuery(document).ready(function ()
         "language": {
             "url": HTTP_PWD + "/assets/js/datatables/french.json",
         },
+        "orderMulti": false,
         "columnDefs": [{
             'targets': 'checkcolumn',
             'orderable': false,

templates/smsstop/list.php

@@ -40,7 +40,7 @@
                                         <thead>
                                             <tr>
                                                 <th>Numéro</th>
-                                                <?php if ($_SESSION['user']['admin']) { ?>
+                                                <?php if ($_SESSION['user']['admin'] ?? false) { ?>
                                                     <th class="checkcolumn"><input type="checkbox" id="check-all"/></th>
                                                 <?php } ?>
                                             </tr>
@@ -50,7 +50,7 @@
                                     </table>
                                 </div>
                                 <div>
-                                    <?php if ($_SESSION['user']['admin']) { ?>
+                                    <?php if ($_SESSION['user']['admin'] ?? false) { ?>
                                         <div class="text-right col-xs-12 no-padding">
                                             <strong>Action pour la séléction :</strong>
                                             <button class="btn btn-default btn-confirm" type="submit" formaction="<?php echo \descartes\Router::url('SmsStop', 'delete', ['csrf' => $_SESSION['csrf']]); ?>"><span class="fa fa-trash-o"></span> Supprimer</button>
@@ -74,11 +74,11 @@ jQuery(document).ready(function ()
         "language": {
             "url": HTTP_PWD + "/assets/js/datatables/french.json",
         },
+        "orderMulti": false,
         "columnDefs": [{
             'targets': 'checkcolumn',
             'orderable': false,
         }],
-
         "ajax": {
             'url': '<?php echo \descartes\Router::url('SmsStop', 'list_json'); ?>',
             'dataSrc': 'data',
@@ -86,13 +86,15 @@ jQuery(document).ready(function ()
         "columns" : [
             {
                 data: 'number_formatted',
-            },
-            {
+            }
+            <?php if ($_SESSION['user']['admin'] ?? false) { ?>
+            ,{
                 data: 'id',
                 render: function (data, type, row, meta) {
                     return '<input name="ids[]" type="checkbox" value="' + data + '">';
                 },
             },
+            <?php } ?>
         ],
         "deferRender": true
     });