Proyectos de Subversion LeadersLinked - Services

Rev

Rev 685 | Rev 688 | Ir a la última revisión | | Comparar con el anterior | Ultima modificación | Ver Log |

Rev Autor Línea Nro. Línea
1 efrain 1
<?php
2
 
3
declare(strict_types=1);
4
 
5
namespace LeadersLinked\Controller;
6
 
7
use Laminas\Db\Adapter\AdapterInterface;
8
 
9
use Laminas\Mvc\Controller\AbstractActionController;
10
use Laminas\Log\LoggerInterface;
11
use Laminas\View\Model\ViewModel;
12
 
13
use LeadersLinked\Library\Functions;
14
use LeadersLinked\Mapper\UserMapper;
15
 
16
use LeadersLinked\Model\User;
17
 
18
use LeadersLinked\Mapper\UserBlockedMapper;
19
 
20
use LeadersLinked\Mapper\CompanyMapper;
21
use LeadersLinked\Mapper\CompanyUserMapper;
307 www 22
use LeadersLinked\Mapper\ConversationMapper;
23
use LeadersLinked\Mapper\MessageMapper;
24
use LeadersLinked\Model\Conversation;
1 efrain 25
use LeadersLinked\Library\Image;
26
use Laminas\View\Model\JsonModel;
307 www 27
use LeadersLinked\Form\InMail\SendForm;
28
use LeadersLinked\Model\Message;
29
use LeadersLinked\Model\VideoConvert;
30
use LeadersLinked\Mapper\VideoConvertMapper;
1 efrain 31
use Laminas\Mvc\I18n\Translator;
199 efrain 32
use LeadersLinked\Mapper\AbuseReportMapper;
33
use LeadersLinked\Model\AbuseReport;
345 www 34
use LeadersLinked\Library\Storage;
1 efrain 35
 
36
class InMailController extends AbstractActionController
37
{
38
    /**
39
     *
40
     * @var \Laminas\Db\Adapter\AdapterInterface
41
     */
42
    private $adapter;
582 ariadna 43
 
1 efrain 44
    /**
45
     *
46
     * @var \LeadersLinked\Cache\CacheInterface
47
     */
48
    private $cache;
582 ariadna 49
 
50
 
1 efrain 51
    /**
52
     *
53
     * @var \Laminas\Log\LoggerInterface
54
     */
55
    private $logger;
582 ariadna 56
 
1 efrain 57
    /**
58
     *
59
     * @var array
60
     */
61
    private $config;
582 ariadna 62
 
63
 
1 efrain 64
    /**
65
     *
66
     * @var \Laminas\Mvc\I18n\Translator
67
     */
68
    private $translator;
582 ariadna 69
 
70
 
1 efrain 71
    /**
72
     *
73
     * @param \Laminas\Db\Adapter\AdapterInterface $adapter
74
     * @param \LeadersLinked\Cache\CacheInterface $cache
75
     * @param \Laminas\Log\LoggerInterface LoggerInterface $logger
76
     * @param array $config
77
     * @param \Laminas\Mvc\I18n\Translator $translator
78
     */
79
    public function __construct($adapter, $cache, $logger, $config, $translator)
80
    {
81
        $this->adapter      = $adapter;
82
        $this->cache        = $cache;
83
        $this->logger       = $logger;
84
        $this->config       = $config;
85
        $this->translator   = $translator;
86
    }
87
 
88
    /**
667 stevensc 89
     * Genera el listado de conversaciones del usuario actual
1 efrain 90
     *
667 stevensc 91
     * Endpoint: GET /inmail
1 efrain 92
     *
667 stevensc 93
     * Parámetros de ruta:
94
     * - id: UUID del usuario o empresa para seleccionar automáticamente (opcional)
95
     *
96
     * Respuesta exitosa:
1 efrain 97
     * [
667 stevensc 98
     *   success: true,
99
     *   data: [
100
     *     [
101
     *       uuid: UUID del usuario/empresa con quien se tiene la conversación,
102
     *       name: nombre del usuario/empresa,
103
     *       image: URL de la imagen del usuario/empresa,
104
     *       profile: URL del perfil del usuario/empresa,
105
     *       last_message: tiempo transcurrido del último mensaje,
307 www 106
     *       count_unread: cantidad de mensajes sin leer,
667 stevensc 107
     *       messages_link: URL para recuperar los mensajes,
108
     *       send_link: URL para enviar mensaje,
109
     *       selected: 0 = no seleccionado, 1 = seleccionado,
110
     *       delete_link: URL para eliminar la conversación
307 www 111
     *     ]
667 stevensc 112
     *   ]
113
     * ]
1 efrain 114
     *
667 stevensc 115
     * Respuesta de error:
116
     * [
117
     *   success: false,
118
     *   data: mensaje de error
119
     * ]
1 efrain 120
     *
121
     * @return \Laminas\View\Model\JsonModel
122
     */
123
    public function indexAction()
124
    {
125
        $request = $this->getRequest();
667 stevensc 126
 
127
        // Verificar que la petición sea GET
128
        if (!$request->isGet()) {
129
            return new JsonModel([
130
                'success' => false,
131
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
132
            ]);
133
        }
307 www 134
 
667 stevensc 135
        // Obtener el usuario actual autenticado
136
        $currentUserPlugin = $this->plugin('currentUserPlugin');
137
        $currentUser = $currentUserPlugin->getUser();
307 www 138
 
667 stevensc 139
        // Obtener la fecha actual de la base de datos para cálculos de tiempo
140
        $userMapper = UserMapper::getInstance($this->adapter);
141
        $now = $userMapper->getDatebaseNow();
1 efrain 142
 
667 stevensc 143
        // Obtener IDs de usuarios que el usuario actual ha bloqueado
144
        $userBlockedMapper = UserBlockedMapper::getInstance($this->adapter);
145
        $user_blocked_ids = $userBlockedMapper->fetchAllBlockedReturnIds($currentUser->id);
199 efrain 146
 
667 stevensc 147
        // Obtener IDs de usuarios que han bloqueado al usuario actual
148
        $user_blocked_me_ids = $userBlockedMapper->fetchAllUserBlockMeReturnIds($currentUser->id);
1 efrain 149
 
667 stevensc 150
        $conversationMapper = ConversationMapper::getInstance($this->adapter);
151
        $messageMapper = MessageMapper::getInstance($this->adapter);
152
        $conversations = [];
153
        $selected_user_id = 0;
307 www 154
 
667 stevensc 155
        $records = $conversationMapper->fetchAllByUserId($currentUser->id);
681 stevensc 156
 
157
        $id = $this->params()->fromRoute('id');
667 stevensc 158
 
673 stevensc 159
        foreach ($records as $record) {
667 stevensc 160
            // Omitir conversaciones que ya fueron procesadas como seleccionadas
161
            if ($selected_user_id) {
162
                if ($record->sender_id == $currentUser->id && $record->receiver_id == $selected_user_id) {
163
                    continue;
1 efrain 164
                }
667 stevensc 165
                if ($record->receiver_id == $currentUser->id && $record->sender_id == $selected_user_id) {
166
                    continue;
582 ariadna 167
                }
667 stevensc 168
            }
1 efrain 169
 
667 stevensc 170
            if ($record->sender_id == $currentUser->id) {
171
                $user = $userMapper->fetchOne($record->receiver_id);
172
            }
173
            if ($record->receiver_id == $currentUser->id) {
174
                $user = $userMapper->fetchOne($record->sender_id);
175
 
176
                // Omitir usuarios bloqueados
177
                if (in_array($user->id, $user_blocked_ids) || in_array($user->id, $user_blocked_me_ids)) {
178
                    continue;
582 ariadna 179
                }
667 stevensc 180
            }
1 efrain 181
 
667 stevensc 182
            $timeElapsedString = '';
183
            $unread = $messageMapper->fetchCountUnreadMessagesByConversationIdAndReceiverId(
184
                $record->id,
185
                $currentUser->id
186
            );
187
            $lastMessage = $messageMapper->fetchLastMessagesByConversationIdAndReceiverId(
188
                $record->id,
189
                $currentUser->id
190
            );
1 efrain 191
 
667 stevensc 192
            if ($lastMessage) {
193
                $timeElapsedString = $this->timeAgo($lastMessage, $now);
582 ariadna 194
            }
1 efrain 195
 
667 stevensc 196
            array_push($conversations, [
197
                'uuid' => $user->uuid,
198
                'name' => trim($user->first_name . ' ' . $user->last_name),
199
                'image' => $this->url()->fromRoute('storage', [
200
                    'type' => 'user',
201
                    'code' => $user->uuid,
202
                    'filename' => $user->image
203
                ], ['force_canonical' => true]),
204
                'profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
205
                'last_message' => $timeElapsedString,
206
                'count_unread' => $unread,
683 stevensc 207
                'selected' => 0,
208
                'messages_link' => $this->url()->fromRoute('inmail/messages', ['uuid' => $user->uuid]),
209
                'send_link' => $this->url()->fromRoute('inmail/messages/send', ['uuid' => $user->uuid]),
210
                'delete_link' => $this->url()->fromRoute('inmail/messages/delete', ['uuid' => $user->uuid]),
667 stevensc 211
            ]);
212
        }
1 efrain 213
 
667 stevensc 214
        // Ordenar por: seleccionados primero, luego por fecha del último mensaje
215
        usort($conversations, function ($a, $b) {
216
            if ($a['selected'] == $b['selected']) {
217
                if ($a['last_message'] == $b['last_message']) {
218
                    return 0;
582 ariadna 219
                } else {
667 stevensc 220
                    return $a['last_message'] < $b['last_message'] ? -1 : 1;
582 ariadna 221
                }
667 stevensc 222
            } else {
223
                return $a['selected'] < $b['selected'] ? -1 : 1;
224
            }
225
        });
1 efrain 226
 
667 stevensc 227
        return new JsonModel([
228
            'success' => true,
229
            'data' => $conversations
230
        ]);
1 efrain 231
    }
307 www 232
 
233
    /**
666 stevensc 234
     * Recupera los mensajes de una conversación específica entre usuarios
235
     *
685 stevensc 236
     * Endpoint: GET /inmail/messages/:uuid
666 stevensc 237
     *
238
     * Parámetros de consulta:
239
     * - page: número de página para paginación (opcional, por defecto 0)
240
     *
241
     * Respuesta exitosa:
307 www 242
     * [
243
     *   success: true,
666 stevensc 244
     *   data: [
245
     *     [
246
     *       uuid: UUID del mensaje,
247
     *       sender_name: nombre del remitente,
248
     *       sender_image: URL de la imagen del remitente,
249
     *       sender_profile: URL del perfil del remitente,
250
     *       receiver_name: nombre del destinatario,
251
     *       receiver_image: URL de la imagen del destinatario,
252
     *       receiver_profile: URL del perfil del destinatario,
253
     *       side: 'left' (mensaje propio) | 'right' (mensaje recibido),
254
     *       message: contenido del mensaje,
255
     *       type: 'text' | 'image' | 'video' | 'document',
256
     *       filename: URL del archivo adjunto (si existe),
257
     *       date: tiempo transcurrido desde el envío,
258
     *       url_abuse_report: URL para reportar abuso (solo mensajes recibidos)
259
     *     ]
260
     *   ],
261
     *   pagination: información de paginación
262
     * ]
263
     *
264
     * Respuesta de error:
307 www 265
     * [
666 stevensc 266
     *   success: false,
267
     *   data: mensaje de error
307 www 268
     * ]
666 stevensc 269
     *
307 www 270
     * @return \Laminas\View\Model\JsonModel
271
     */
677 stevensc 272
    public function getMessagesAction()
1 efrain 273
    {
274
        $request = $this->getRequest();
666 stevensc 275
 
276
        // Verificar que la petición sea GET
277
        if (!$request->isGet()) {
278
            return new JsonModel([
279
                'success' => false,
280
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
281
            ]);
282
        }
283
 
284
        // Obtener parámetros de la petición
285
        $page = intval($this->params()->fromQuery('page', 0), 10);
683 stevensc 286
        $uuid = $this->params()->fromRoute('uuid');
666 stevensc 287
 
685 stevensc 288
        // Validar que se proporcione el UUID del usuario
683 stevensc 289
        if (!$uuid) {
666 stevensc 290
            return new JsonModel([
291
                'success' => false,
292
                'data' => 'ERROR_PARAMETERS_ARE_INVALID'
293
            ]);
294
        }
307 www 295
 
666 stevensc 296
        // Obtener el usuario actual autenticado
297
        $currentUserPlugin = $this->plugin('currentUserPlugin');
298
        $currentUser = $currentUserPlugin->getUser();
582 ariadna 299
 
666 stevensc 300
        // Obtener la fecha actual de la base de datos para cálculos de tiempo
301
        $userMapper = UserMapper::getInstance($this->adapter);
302
        $now = $userMapper->getDatebaseNow();
307 www 303
 
666 stevensc 304
        // Buscar el usuario destinatario por UUID
683 stevensc 305
        $user = $userMapper->fetchOneByUuid($uuid);
666 stevensc 306
        if (!$user) {
307
            return new JsonModel([
308
                'success' => false,
309
                'data' => 'ERROR_REQUEST_IS_INVALID'
310
            ]);
311
        }
307 www 312
 
666 stevensc 313
        // Obtener IDs de mensajes reportados por el usuario actual
314
        $abuseReportMapper = AbuseReportMapper::getInstance($this->adapter);
315
        $abuse_report_message_ids = $abuseReportMapper->fetchAllDataByUserReportingIdAndTypeReturnIds(
316
            $currentUser->id,
317
            AbuseReport::TYPE_INMAIL_MESSAGE
318
        );
307 www 319
 
666 stevensc 320
        $conversationMapper = ConversationMapper::getInstance($this->adapter);
321
        $messageMapper = MessageMapper::getInstance($this->adapter);
322
 
323
        // Buscar la conversación entre los dos usuarios
324
        $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
325
 
326
        $messages = [];
327
 
328
        if ($conversation) {
329
            // Obtener mensajes paginados de la conversación
330
            $records = $messageMapper->getAllMessagesPaginatorByConversationId($conversation->id, $page);
582 ariadna 331
 
666 stevensc 332
            foreach ($records as $record) {
333
                // Calcular tiempo transcurrido desde el envío del mensaje
334
                $timeElapsedString = $this->timeAgo($record->added_on, $now);
307 www 335
 
666 stevensc 336
                if ($record->sender_id == $currentUser->id) {
337
                    array_push($messages, [
338
                        'uuid' => $record->uuid,
339
                        'sender_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
340
                        'sender_image' => $this->url()->fromRoute('storage', [
341
                            'type' => 'user',
342
                            'filename' => $currentUser->image,
343
                            'code' => $currentUser->uuid
344
                        ], ['force_canonical' => true]),
345
                        'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
346
                        'receiver_name' => trim($user->first_name . ' ' . $user->last_name),
347
                        'receiver_image' => $this->url()->fromRoute('storage', [
348
                            'type' => 'user',
349
                            'filename' => $user->image,
350
                            'code' => $user->uuid
351
                        ], ['force_canonical' => true]),
352
                        'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
353
                        'side' => 'left', // Mensaje propio (lado izquierdo)
354
                        'message' => $record->message,
355
                        'type' => $record->type,
356
                        'filename' => $record->filename ? $this->url()->fromRoute('storage', [
357
                            'type' => 'message',
358
                            'filename' => $record->filename,
359
                            'code' => $record->uuid
360
                        ], ['force_canonical' => true]) : '',
361
                        'date' => $timeElapsedString,
362
                        'url_abuse_report' => '', // No se puede reportar mensajes propios
363
                    ]);
364
                }
365
                else {
366
                    // Verificar si el mensaje ha sido reportado por abuso
367
                    if (in_array($record->id, $abuse_report_message_ids)) {
368
                        // Mensaje reportado - mostrar mensaje de contenido reportado
369
                        array_push($messages, [
370
                            'uuid' => $record->uuid,
371
                            'sender_name' => trim($user->first_name . ' ' . $user->last_name),
372
                            'sender_image' => $this->url()->fromRoute('storage', [
373
                                'type' => 'user',
374
                                'filename' => $user->image,
375
                                'code' => $user->uuid
376
                            ], ['force_canonical' => true]),
377
                            'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
378
                            'receiver_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
379
                            'receiver_image' => $this->url()->fromRoute('storage', [
380
                                'type' => 'user',
381
                                'filename' => $currentUser->image,
382
                                'code' => $user->uuid
383
                            ], ['force_canonical' => true]),
384
                            'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
385
                            'side' => 'right', // Mensaje recibido (lado derecho)
386
                            'message' => 'LABEL_ABUSE_CONTENT_REPORTED',
387
                            'type' => Message::TYPE_TEXT,
388
                            'filename' => '',
389
                            'date' => $timeElapsedString,
390
                            'url_abuse_report' => '', // Ya no se puede reportar
391
                        ]);
392
                    } else {
393
                        // Mensaje normal - generar URL para reportar abuso
394
                        $url_abuse_report = $this->url()->fromRoute('helpers/abuse-report', [
395
                            'type' => 'message',
396
                            'id' => $record->uuid
397
                        ], ['force_canonical' => true]);
582 ariadna 398
 
307 www 399
                        array_push($messages, [
400
                            'uuid' => $record->uuid,
666 stevensc 401
                            'sender_name' => trim($user->first_name . ' ' . $user->last_name),
402
                            'sender_image' => $this->url()->fromRoute('storage', [
403
                                'type' => 'user',
404
                                'filename' => $user->image,
405
                                'code' => $user->uuid
406
                            ], ['force_canonical' => true]),
407
                            'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
408
                            'receiver_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
409
                            'receiver_image' => $this->url()->fromRoute('storage', [
410
                                'type' => 'user',
411
                                'filename' => $currentUser->image,
412
                                'code' => $user->uuid
413
                            ], ['force_canonical' => true]),
414
                            'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
415
                            'side' => 'right', // Mensaje recibido (lado derecho)
307 www 416
                            'message' => $record->message,
417
                            'type' => $record->type,
666 stevensc 418
                            'filename' => $record->filename ? $this->url()->fromRoute('storage', [
419
                                'type' => 'message',
420
                                'filename' => $record->filename,
421
                                'code' => $record->uuid
422
                            ], ['force_canonical' => true]) : '',
307 www 423
                            'date' => $timeElapsedString,
666 stevensc 424
                            'url_abuse_report' => $url_abuse_report,
307 www 425
                        ]);
582 ariadna 426
 
666 stevensc 427
                        // Marcar el mensaje como leído
307 www 428
                        $messageMapper->markAsRead($record->id);
261 efrain 429
                    }
307 www 430
                }
1 efrain 431
            }
307 www 432
 
433
            return new JsonModel([
434
                'success' => true,
435
                'data' => $messages,
666 stevensc 436
                'pagination' => $records->getPages()
307 www 437
            ]);
1 efrain 438
        }
666 stevensc 439
 
440
        return new JsonModel([
441
            'success' => true,
442
            'data' => $messages,
443
            'pagination' => 1
444
        ]);
1 efrain 445
    }
307 www 446
 
447
    /**
589 ariadna 448
     * Envía un mensaje InMail a un usuario específico
307 www 449
     *
685 stevensc 450
     * Endpoint: POST /inmail/messages/send/:uuid
589 ariadna 451
     *
452
     * Parámetros requeridos:
453
     * - message: texto plano del mensaje
454
     *
455
     * Parámetros opcionales:
456
     * - file: archivo adjunto (jpg, jpeg, png, mp4, webm, mpeg, pdf)
457
     *
458
     * @return JsonModel
307 www 459
     */
460
    public function sendMessageAction()
1 efrain 461
    {
589 ariadna 462
        // Verificar que la petición sea POST
1 efrain 463
        $request = $this->getRequest();
589 ariadna 464
        if (!$request->isPost()) {
465
            return new JsonModel([
466
                'success' => false,
467
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
468
            ]);
469
        }
307 www 470
 
589 ariadna 471
        // Obtener el usuario actual
472
        $currentUserPlugin = $this->plugin('currentUserPlugin');
473
        $currentUser = $currentUserPlugin->getUser();
307 www 474
 
589 ariadna 475
        // Obtener la fecha actual de la base de datos
476
        $userMapper = UserMapper::getInstance($this->adapter);
477
        $now = $userMapper->getDatebaseNow();
582 ariadna 478
 
589 ariadna 479
        // Validar el ID del destinatario
684 stevensc 480
        $uuid = $this->params()->fromRoute('uuid');
481
        if (!$uuid) {
589 ariadna 482
            return new JsonModel([
483
                'success' => false,
484
                'data' => 'ERROR_PARAMETERS_ARE_INVALID'
485
            ]);
486
        }
307 www 487
 
589 ariadna 488
        // Buscar el usuario destinatario
684 stevensc 489
        $user = $userMapper->fetchOneByUuidAndNetworkId($uuid, $currentUser->network_id);
589 ariadna 490
        if (!$user) {
491
            return new JsonModel([
492
                'success' => false,
493
                'data' => 'ERROR_REQUEST_IS_INVALID'
494
            ]);
495
        }
307 www 496
 
589 ariadna 497
        // Combinar datos POST y archivos
498
        $data = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
307 www 499
 
589 ariadna 500
        // Si se envía un archivo sin error, usar su nombre como mensaje
501
        if (!empty($data['file']) && empty($data['file']['error'])) {
502
            $data['message'] = $data['file']['name'];
503
        }
307 www 504
 
589 ariadna 505
        // Validar los datos del formulario
506
        $form = new SendForm();
507
        $form->setData($data);
582 ariadna 508
 
589 ariadna 509
        if (!$form->isValid()) {
510
            // Si el formulario no es válido, devolver los errores
511
            $messages = [];
512
            $form_messages = (array) $form->getMessages();
513
            foreach ($form_messages as $fieldname => $field_messages) {
514
                $messages[$fieldname] = array_values($field_messages);
307 www 515
            }
589 ariadna 516
            return new JsonModel([
517
                'success' => false,
518
                'data' => $messages
519
            ]);
520
        }
582 ariadna 521
 
589 ariadna 522
        // Obtener los datos validados
523
        $dataPost = (array) $form->getData();
307 www 524
 
589 ariadna 525
        // Buscar o crear la conversación
526
        $conversationMapper = ConversationMapper::getInstance($this->adapter);
527
        $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
307 www 528
 
589 ariadna 529
        if ($conversation) {
530
            // Actualizar estado de la conversación existente
531
            $conversation->receiver_status = Conversation::STATUS_NORMAL;
532
            $conversation->sender_status = Conversation::STATUS_NORMAL;
307 www 533
 
589 ariadna 534
            if (!$conversationMapper->update($conversation)) {
535
                return new JsonModel([
536
                    'success' => false,
537
                    'data' => $conversationMapper->getError()
538
                ]);
539
            }
540
        } else {
541
            // Crear nueva conversación
542
            $conversation = new Conversation();
543
            $conversation->sender_id = $currentUser->id;
544
            $conversation->sender_status = Conversation::STATUS_NORMAL;
545
            $conversation->receiver_id = $user->id;
546
            $conversation->receiver_status = Conversation::STATUS_NORMAL;
582 ariadna 547
 
589 ariadna 548
            if (!$conversationMapper->insert($conversation)) {
549
                return new JsonModel([
550
                    'success' => false,
551
                    'data' => $conversationMapper->getError()
552
                ]);
553
            }
554
        }
307 www 555
 
589 ariadna 556
        // Procesar archivo adjunto si existe
557
        $files = $this->getRequest()->getFiles()->toArray();
558
        $type = Message::TYPE_TEXT;
559
        $message_tmp_filename = '';
560
        $message_filename = '';
307 www 561
 
589 ariadna 562
        if (isset($files['file']) && empty($files['file']['error'])) {
563
            $message_tmp_filename = $files['file']['tmp_name'];
564
            $message_filename = \LeadersLinked\Library\Functions::normalizeStringFilename($files['file']['name']);
307 www 565
 
589 ariadna 566
            // Determinar el tipo de archivo
567
            $mime_type = mime_content_type($message_tmp_filename);
568
            if ($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {
569
                $type = Storage::FILE_TYPE_IMAGE;
570
            } else if ($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {
571
                $type = Storage::FILE_TYPE_VIDEO;
572
            } else if ($mime_type == 'application/pdf') {
573
                $type = Storage::FILE_TYPE_DOCUMENT;
574
            }
575
        }
307 www 576
 
589 ariadna 577
        // Crear y guardar el mensaje
578
        $message = new Message();
579
        $message->conversation_id = $conversation->id;
580
        $message->read = Message::NO;
581
        $message->message = $type == Message::TYPE_TEXT ? $dataPost['message'] : '';
582
        $message->receiver_id = $user->id;
583
        $message->receiver_status = Message::STATUS_NORMAL;
584
        $message->sender_id = $currentUser->id;
585
        $message->sender_status = Message::STATUS_NORMAL;
586
        $message->type = $type;
307 www 587
 
589 ariadna 588
        $messageMapper = MessageMapper::getInstance($this->adapter);
589
        if (!$messageMapper->insert($message)) {
590
            return new JsonModel([
591
                'success' => false,
592
                'data' => $messageMapper->getError()
593
            ]);
594
        }
307 www 595
 
589 ariadna 596
        // Procesar archivo adjunto si existe
597
        if ($message_filename) {
598
            $storage = new Storage();
599
            $storage->setAdapter($this->adapter);
600
            $storage->setLogger($this->logger);
601
            $storage->setTranslator($this->translator);
307 www 602
 
589 ariadna 603
            if (!$storage->uploadMessageFile($message_tmp_filename, $message_filename, $message->uuid)) {
604
                return new JsonModel([
605
                    'success' => false,
606
                    'data' => $storage->getError()
607
                ]);
608
            }
307 www 609
 
589 ariadna 610
            $message->filename = $message_filename;
611
            if (!$messageMapper->update($message)) {
1 efrain 612
                return new JsonModel([
589 ariadna 613
                    'success' => false,
614
                    'data' => $messageMapper->getError()
1 efrain 615
                ]);
616
            }
617
        }
589 ariadna 618
 
619
        // Preparar respuesta exitosa
620
        $filename = '';
621
        if ($message->filename) {
622
            $filename = $this->url()->fromRoute('storage', [
623
                'type' => 'message',
624
                'filename' => $message->filename,
625
                'code' => $message->uuid
626
            ], ['force_canonical' => true]);
627
        }
628
 
629
        // Actualizar última actividad del usuario
630
        $userMapper->updateLastActivity($currentUser->id);
631
 
632
        // Devolver respuesta exitosa con datos del mensaje
633
        return new JsonModel([
634
            'success' => true,
635
            'data' => [
636
                'sender_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
637
                'sender_image' => $this->url()->fromRoute('storage', [
638
                    'type' => 'user',
639
                    'filename' => $currentUser->image,
640
                    'code' => $currentUser->uuid
641
                ], ['force_canonical' => true]),
642
                'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
643
                'receiver_name' => trim($user->first_name . ' ' . $user->last_name),
644
                'receiver_image' => $this->url()->fromRoute('storage', [
645
                    'type' => 'user',
646
                    'filename' => $user->image,
647
                    'code' => $user->uuid
648
                ], ['force_canonical' => true]),
649
                'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
650
                'side' => 'left',
651
                'message' => $message->message,
652
                'type' => $message->type,
653
                'filename' => $filename,
654
                'date' => $this->timeAgo($now, $now),
655
            ]
656
        ]);
1 efrain 657
    }
307 www 658
 
659
    /**
660
     *
661
     * @param string $timestamp
662
     * @param string $now
663
     * @return string
664
     */
665
    private function timeAgo($timestamp, $now = '')
666
    {
582 ariadna 667
 
307 www 668
        if ($now) {
669
            $datetime1 = \DateTime::createFromFormat('Y-m-d H:i:s', $now);
1 efrain 670
        } else {
307 www 671
            $now = date('Y-m-d H:i:s');
672
            $datetime1 = date_create($now);
1 efrain 673
        }
307 www 674
        $datetime2 = date_create($timestamp);
582 ariadna 675
 
307 www 676
        $diff = date_diff($datetime1, $datetime2);
677
        $timemsg = '';
678
        if ($diff->y > 0) {
582 ariadna 679
            $timemsg = $diff->y . ' ' . ($diff->y > 1 ? $this->translator->translate('LABEL_YEARS_SMALL')  : $this->translator->translate('LABEL_YEAR_SMALL'));
307 www 680
        } else if ($diff->m > 0) {
582 ariadna 681
            $timemsg = $diff->m  . ' ' . ($diff->m > 1 ? $this->translator->translate('LABEL_MONTHS_SMALL')  : $this->translator->translate('LABEL_MONTH_SMALL'));
307 www 682
        } else if ($diff->d > 0) {
582 ariadna 683
            $timemsg = $diff->d . ' ' . ($diff->d > 1 ? $this->translator->translate('LABEL_DAYS_SMALL')  : $this->translator->translate('LABEL_DAY_SMALL'));
307 www 684
        } else if ($diff->h > 0) {
582 ariadna 685
            $timemsg = $diff->h  . ' ' . ($diff->h > 1 ? $this->translator->translate('LABEL_HOURS_SMALL')  : $this->translator->translate('LABEL_HOUR_SMALL'));
307 www 686
        } else if ($diff->i > 0) {
582 ariadna 687
            $timemsg = $diff->i  . ' ' . ($diff->i > 1 ? $this->translator->translate('LABEL_MINUTES_SMALL')  : $this->translator->translate('LABEL_MINUTE_SMALL'));
307 www 688
        } else if ($diff->s > 0) {
582 ariadna 689
            $timemsg = $diff->s  . ' ' . ($diff->s > 1 ? $this->translator->translate('LABEL_SECONDS_SMALL')  : $this->translator->translate('LABEL_SECOND_SMALL'));
307 www 690
        }
691
        if (!$timemsg) {
582 ariadna 692
            $timemsg = $this->translator->translate('LABEL_NOW');
307 www 693
        } else {
582 ariadna 694
            $timemsg = $this->translator->translate('LABEL_AGO_SMALL') . ' ' . $timemsg . '';
307 www 695
        }
696
        return $timemsg;
1 efrain 697
    }
307 www 698
 
685 stevensc 699
    /**
700
     * Elimina una conversación de mensajes
701
     *
702
     * Endpoint: POST /inmail/messages/delete/:uuid
703
     *
704
     * Respuesta exitosa:
705
     * [
706
     *   success: true,
707
     *   data: "LABEL_CONVERSATION_WAS_DELETED"
708
     * ]
709
     *
710
     * Respuesta de error:
711
     * [
712
     *   success: false,
713
     *   data: mensaje de error
714
     * ]
715
     *
716
     * @return \Laminas\View\Model\JsonModel
717
     */
684 stevensc 718
    public function deleteMessageAction()
1 efrain 719
    {
720
        $request = $this->getRequest();
721
        if ($request->isPost()) {
722
            $currentUserPlugin = $this->plugin('currentUserPlugin');
723
            $currentUser = $currentUserPlugin->getUser();
582 ariadna 724
 
684 stevensc 725
            $uuid = $this->params()->fromRoute('uuid');
726
            if (!$uuid) {
1 efrain 727
                return new JsonModel([
728
                    'success' => false,
729
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID'
730
                ]);
731
            }
582 ariadna 732
 
307 www 733
            $userMapper = UserMapper::getInstance($this->adapter);
684 stevensc 734
            $user = $userMapper->fetchOneByUuid($uuid);
1 efrain 735
            if (!$user) {
736
                return new JsonModel([
737
                    'success' => false,
738
                    'data' => 'ERROR_REQUEST_IS_INVALID'
739
                ]);
740
            }
582 ariadna 741
 
307 www 742
            $conversationMapper = ConversationMapper::getInstance($this->adapter);
743
            $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
582 ariadna 744
 
745
 
307 www 746
            if ($conversation) {
582 ariadna 747
 
307 www 748
                if ($conversation->sender_id == $currentUser->id && $conversation->receiver_id == $user->id) {
749
                    $conversation->sender_status = Conversation::STATUS_DELETED;
750
                    if ($conversationMapper->update($conversation)) {
751
                        $response = [
752
                            'success' => true,
753
                            'data' => 'LABEL_CONVERSATION_WAS_DELETED'
754
                        ];
755
                    } else {
582 ariadna 756
 
757
 
307 www 758
                        $response = [
759
                            'success' => false,
760
                            'data' => $conversationMapper->getError()
761
                        ];
291 www 762
                    }
307 www 763
                }
582 ariadna 764
 
307 www 765
                if ($conversation->receiver_id == $currentUser->id && $conversation->sender_id == $user->id) {
766
                    $conversation->receiver_status = Conversation::STATUS_DELETED;
767
                    if ($conversationMapper->update($conversation)) {
768
                        $response = [
769
                            'success' => true,
770
                            'data' => 'LABEL_CONVERSATION_WAS_DELETED'
771
                        ];
291 www 772
                    } else {
582 ariadna 773
 
774
 
307 www 775
                        $response = [
776
                            'success' => false,
777
                            'data' => $conversationMapper->getError()
778
                        ];
1 efrain 779
                    }
780
                }
582 ariadna 781
 
307 www 782
                return new JsonModel($response);
1 efrain 783
            } else {
307 www 784
                $response = [
785
                    'success' => false,
786
                    'data' => 'ERROR_CONVERSATION_NOT_FOUND'
787
                ];
1 efrain 788
            }
582 ariadna 789
 
307 www 790
            return new JsonModel($response);
1 efrain 791
        } else {
307 www 792
            $response = [
1 efrain 793
                'success' => false,
794
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
307 www 795
            ];
1 efrain 796
        }
582 ariadna 797
 
307 www 798
        return new JsonModel($response);
1 efrain 799
    }
800
}