Proyectos de Subversion LeadersLinked - Services

Rev

Rev 688 | Rev 690 | 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
                'send_link' => $this->url()->fromRoute('inmail/messages/send', ['uuid' => $user->uuid]),
667 stevensc 209
            ]);
210
        }
1 efrain 211
 
667 stevensc 212
        // Ordenar por: seleccionados primero, luego por fecha del último mensaje
213
        usort($conversations, function ($a, $b) {
214
            if ($a['selected'] == $b['selected']) {
215
                if ($a['last_message'] == $b['last_message']) {
216
                    return 0;
582 ariadna 217
                } else {
667 stevensc 218
                    return $a['last_message'] < $b['last_message'] ? -1 : 1;
582 ariadna 219
                }
667 stevensc 220
            } else {
221
                return $a['selected'] < $b['selected'] ? -1 : 1;
222
            }
223
        });
1 efrain 224
 
667 stevensc 225
        return new JsonModel([
226
            'success' => true,
227
            'data' => $conversations
228
        ]);
1 efrain 229
    }
307 www 230
 
231
    /**
666 stevensc 232
     * Recupera los mensajes de una conversación específica entre usuarios
233
     *
685 stevensc 234
     * Endpoint: GET /inmail/messages/:uuid
666 stevensc 235
     *
236
     * Parámetros de consulta:
237
     * - page: número de página para paginación (opcional, por defecto 0)
238
     *
239
     * Respuesta exitosa:
307 www 240
     * [
241
     *   success: true,
666 stevensc 242
     *   data: [
243
     *     [
244
     *       uuid: UUID del mensaje,
245
     *       sender_name: nombre del remitente,
246
     *       sender_image: URL de la imagen del remitente,
247
     *       sender_profile: URL del perfil del remitente,
248
     *       receiver_name: nombre del destinatario,
249
     *       receiver_image: URL de la imagen del destinatario,
250
     *       receiver_profile: URL del perfil del destinatario,
251
     *       side: 'left' (mensaje propio) | 'right' (mensaje recibido),
252
     *       message: contenido del mensaje,
253
     *       type: 'text' | 'image' | 'video' | 'document',
254
     *       filename: URL del archivo adjunto (si existe),
255
     *       date: tiempo transcurrido desde el envío,
256
     *       url_abuse_report: URL para reportar abuso (solo mensajes recibidos)
257
     *     ]
258
     *   ],
259
     *   pagination: información de paginación
260
     * ]
261
     *
262
     * Respuesta de error:
307 www 263
     * [
666 stevensc 264
     *   success: false,
265
     *   data: mensaje de error
307 www 266
     * ]
666 stevensc 267
     *
307 www 268
     * @return \Laminas\View\Model\JsonModel
269
     */
677 stevensc 270
    public function getMessagesAction()
1 efrain 271
    {
272
        $request = $this->getRequest();
666 stevensc 273
 
274
        // Verificar que la petición sea GET
275
        if (!$request->isGet()) {
276
            return new JsonModel([
277
                'success' => false,
278
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
279
            ]);
280
        }
281
 
282
        // Obtener parámetros de la petición
283
        $page = intval($this->params()->fromQuery('page', 0), 10);
683 stevensc 284
        $uuid = $this->params()->fromRoute('uuid');
666 stevensc 285
 
685 stevensc 286
        // Validar que se proporcione el UUID del usuario
683 stevensc 287
        if (!$uuid) {
666 stevensc 288
            return new JsonModel([
289
                'success' => false,
290
                'data' => 'ERROR_PARAMETERS_ARE_INVALID'
291
            ]);
292
        }
307 www 293
 
666 stevensc 294
        // Obtener el usuario actual autenticado
295
        $currentUserPlugin = $this->plugin('currentUserPlugin');
296
        $currentUser = $currentUserPlugin->getUser();
582 ariadna 297
 
666 stevensc 298
        // Obtener la fecha actual de la base de datos para cálculos de tiempo
299
        $userMapper = UserMapper::getInstance($this->adapter);
300
        $now = $userMapper->getDatebaseNow();
307 www 301
 
666 stevensc 302
        // Buscar el usuario destinatario por UUID
683 stevensc 303
        $user = $userMapper->fetchOneByUuid($uuid);
666 stevensc 304
        if (!$user) {
305
            return new JsonModel([
306
                'success' => false,
307
                'data' => 'ERROR_REQUEST_IS_INVALID'
308
            ]);
309
        }
307 www 310
 
666 stevensc 311
        // Obtener IDs de mensajes reportados por el usuario actual
312
        $abuseReportMapper = AbuseReportMapper::getInstance($this->adapter);
313
        $abuse_report_message_ids = $abuseReportMapper->fetchAllDataByUserReportingIdAndTypeReturnIds(
314
            $currentUser->id,
315
            AbuseReport::TYPE_INMAIL_MESSAGE
316
        );
307 www 317
 
666 stevensc 318
        $conversationMapper = ConversationMapper::getInstance($this->adapter);
319
        $messageMapper = MessageMapper::getInstance($this->adapter);
320
 
321
        // Buscar la conversación entre los dos usuarios
322
        $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
323
 
324
        $messages = [];
325
 
326
        if ($conversation) {
327
            // Obtener mensajes paginados de la conversación
328
            $records = $messageMapper->getAllMessagesPaginatorByConversationId($conversation->id, $page);
582 ariadna 329
 
666 stevensc 330
            foreach ($records as $record) {
331
                // Calcular tiempo transcurrido desde el envío del mensaje
332
                $timeElapsedString = $this->timeAgo($record->added_on, $now);
307 www 333
 
666 stevensc 334
                if ($record->sender_id == $currentUser->id) {
335
                    array_push($messages, [
336
                        'uuid' => $record->uuid,
337
                        'sender_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
338
                        'sender_image' => $this->url()->fromRoute('storage', [
339
                            'type' => 'user',
340
                            'filename' => $currentUser->image,
341
                            'code' => $currentUser->uuid
342
                        ], ['force_canonical' => true]),
343
                        'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
344
                        'receiver_name' => trim($user->first_name . ' ' . $user->last_name),
345
                        'receiver_image' => $this->url()->fromRoute('storage', [
346
                            'type' => 'user',
347
                            'filename' => $user->image,
348
                            'code' => $user->uuid
349
                        ], ['force_canonical' => true]),
350
                        'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
351
                        'side' => 'left', // Mensaje propio (lado izquierdo)
352
                        'message' => $record->message,
353
                        'type' => $record->type,
354
                        'filename' => $record->filename ? $this->url()->fromRoute('storage', [
355
                            'type' => 'message',
356
                            'filename' => $record->filename,
357
                            'code' => $record->uuid
358
                        ], ['force_canonical' => true]) : '',
359
                        'date' => $timeElapsedString,
360
                        'url_abuse_report' => '', // No se puede reportar mensajes propios
361
                    ]);
362
                }
363
                else {
364
                    // Verificar si el mensaje ha sido reportado por abuso
365
                    if (in_array($record->id, $abuse_report_message_ids)) {
366
                        // Mensaje reportado - mostrar mensaje de contenido reportado
367
                        array_push($messages, [
368
                            'uuid' => $record->uuid,
369
                            'sender_name' => trim($user->first_name . ' ' . $user->last_name),
370
                            'sender_image' => $this->url()->fromRoute('storage', [
371
                                'type' => 'user',
372
                                'filename' => $user->image,
373
                                'code' => $user->uuid
374
                            ], ['force_canonical' => true]),
375
                            'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
376
                            'receiver_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
377
                            'receiver_image' => $this->url()->fromRoute('storage', [
378
                                'type' => 'user',
379
                                'filename' => $currentUser->image,
380
                                'code' => $user->uuid
381
                            ], ['force_canonical' => true]),
382
                            'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
383
                            'side' => 'right', // Mensaje recibido (lado derecho)
384
                            'message' => 'LABEL_ABUSE_CONTENT_REPORTED',
385
                            'type' => Message::TYPE_TEXT,
386
                            'filename' => '',
387
                            'date' => $timeElapsedString,
388
                            'url_abuse_report' => '', // Ya no se puede reportar
389
                        ]);
390
                    } else {
391
                        // Mensaje normal - generar URL para reportar abuso
392
                        $url_abuse_report = $this->url()->fromRoute('helpers/abuse-report', [
393
                            'type' => 'message',
394
                            'id' => $record->uuid
395
                        ], ['force_canonical' => true]);
582 ariadna 396
 
307 www 397
                        array_push($messages, [
398
                            'uuid' => $record->uuid,
666 stevensc 399
                            'sender_name' => trim($user->first_name . ' ' . $user->last_name),
400
                            'sender_image' => $this->url()->fromRoute('storage', [
401
                                'type' => 'user',
402
                                'filename' => $user->image,
403
                                'code' => $user->uuid
404
                            ], ['force_canonical' => true]),
405
                            'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
406
                            'receiver_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
407
                            'receiver_image' => $this->url()->fromRoute('storage', [
408
                                'type' => 'user',
409
                                'filename' => $currentUser->image,
410
                                'code' => $user->uuid
411
                            ], ['force_canonical' => true]),
412
                            'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
413
                            'side' => 'right', // Mensaje recibido (lado derecho)
307 www 414
                            'message' => $record->message,
415
                            'type' => $record->type,
666 stevensc 416
                            'filename' => $record->filename ? $this->url()->fromRoute('storage', [
417
                                'type' => 'message',
418
                                'filename' => $record->filename,
419
                                'code' => $record->uuid
420
                            ], ['force_canonical' => true]) : '',
307 www 421
                            'date' => $timeElapsedString,
666 stevensc 422
                            'url_abuse_report' => $url_abuse_report,
307 www 423
                        ]);
582 ariadna 424
 
666 stevensc 425
                        // Marcar el mensaje como leído
307 www 426
                        $messageMapper->markAsRead($record->id);
261 efrain 427
                    }
307 www 428
                }
1 efrain 429
            }
307 www 430
 
431
            return new JsonModel([
432
                'success' => true,
433
                'data' => $messages,
666 stevensc 434
                'pagination' => $records->getPages()
307 www 435
            ]);
1 efrain 436
        }
666 stevensc 437
 
438
        return new JsonModel([
439
            'success' => true,
440
            'data' => $messages,
441
            'pagination' => 1
442
        ]);
1 efrain 443
    }
307 www 444
 
445
    /**
589 ariadna 446
     * Envía un mensaje InMail a un usuario específico
307 www 447
     *
685 stevensc 448
     * Endpoint: POST /inmail/messages/send/:uuid
589 ariadna 449
     *
450
     * Parámetros requeridos:
451
     * - message: texto plano del mensaje
452
     *
453
     * Parámetros opcionales:
454
     * - file: archivo adjunto (jpg, jpeg, png, mp4, webm, mpeg, pdf)
455
     *
456
     * @return JsonModel
307 www 457
     */
458
    public function sendMessageAction()
1 efrain 459
    {
589 ariadna 460
        // Verificar que la petición sea POST
1 efrain 461
        $request = $this->getRequest();
589 ariadna 462
        if (!$request->isPost()) {
463
            return new JsonModel([
464
                'success' => false,
465
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
466
            ]);
467
        }
307 www 468
 
589 ariadna 469
        // Obtener el usuario actual
470
        $currentUserPlugin = $this->plugin('currentUserPlugin');
471
        $currentUser = $currentUserPlugin->getUser();
307 www 472
 
589 ariadna 473
        // Obtener la fecha actual de la base de datos
474
        $userMapper = UserMapper::getInstance($this->adapter);
475
        $now = $userMapper->getDatebaseNow();
582 ariadna 476
 
589 ariadna 477
        // Validar el ID del destinatario
684 stevensc 478
        $uuid = $this->params()->fromRoute('uuid');
479
        if (!$uuid) {
589 ariadna 480
            return new JsonModel([
481
                'success' => false,
482
                'data' => 'ERROR_PARAMETERS_ARE_INVALID'
483
            ]);
484
        }
307 www 485
 
589 ariadna 486
        // Buscar el usuario destinatario
684 stevensc 487
        $user = $userMapper->fetchOneByUuidAndNetworkId($uuid, $currentUser->network_id);
589 ariadna 488
        if (!$user) {
489
            return new JsonModel([
490
                'success' => false,
491
                'data' => 'ERROR_REQUEST_IS_INVALID'
492
            ]);
493
        }
307 www 494
 
589 ariadna 495
        // Combinar datos POST y archivos
496
        $data = array_merge($request->getPost()->toArray(), $request->getFiles()->toArray());
307 www 497
 
589 ariadna 498
        // Si se envía un archivo sin error, usar su nombre como mensaje
499
        if (!empty($data['file']) && empty($data['file']['error'])) {
500
            $data['message'] = $data['file']['name'];
501
        }
307 www 502
 
589 ariadna 503
        // Validar los datos del formulario
504
        $form = new SendForm();
505
        $form->setData($data);
582 ariadna 506
 
589 ariadna 507
        if (!$form->isValid()) {
508
            // Si el formulario no es válido, devolver los errores
509
            $messages = [];
510
            $form_messages = (array) $form->getMessages();
511
            foreach ($form_messages as $fieldname => $field_messages) {
512
                $messages[$fieldname] = array_values($field_messages);
307 www 513
            }
589 ariadna 514
            return new JsonModel([
515
                'success' => false,
516
                'data' => $messages
517
            ]);
518
        }
582 ariadna 519
 
589 ariadna 520
        // Obtener los datos validados
521
        $dataPost = (array) $form->getData();
307 www 522
 
589 ariadna 523
        // Buscar o crear la conversación
524
        $conversationMapper = ConversationMapper::getInstance($this->adapter);
525
        $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
307 www 526
 
589 ariadna 527
        if ($conversation) {
528
            // Actualizar estado de la conversación existente
529
            $conversation->receiver_status = Conversation::STATUS_NORMAL;
530
            $conversation->sender_status = Conversation::STATUS_NORMAL;
307 www 531
 
589 ariadna 532
            if (!$conversationMapper->update($conversation)) {
533
                return new JsonModel([
534
                    'success' => false,
535
                    'data' => $conversationMapper->getError()
536
                ]);
537
            }
538
        } else {
539
            // Crear nueva conversación
540
            $conversation = new Conversation();
541
            $conversation->sender_id = $currentUser->id;
542
            $conversation->sender_status = Conversation::STATUS_NORMAL;
543
            $conversation->receiver_id = $user->id;
544
            $conversation->receiver_status = Conversation::STATUS_NORMAL;
582 ariadna 545
 
589 ariadna 546
            if (!$conversationMapper->insert($conversation)) {
547
                return new JsonModel([
548
                    'success' => false,
549
                    'data' => $conversationMapper->getError()
550
                ]);
551
            }
552
        }
307 www 553
 
589 ariadna 554
        // Procesar archivo adjunto si existe
555
        $files = $this->getRequest()->getFiles()->toArray();
556
        $type = Message::TYPE_TEXT;
557
        $message_tmp_filename = '';
558
        $message_filename = '';
307 www 559
 
589 ariadna 560
        if (isset($files['file']) && empty($files['file']['error'])) {
561
            $message_tmp_filename = $files['file']['tmp_name'];
562
            $message_filename = \LeadersLinked\Library\Functions::normalizeStringFilename($files['file']['name']);
307 www 563
 
589 ariadna 564
            // Determinar el tipo de archivo
565
            $mime_type = mime_content_type($message_tmp_filename);
566
            if ($mime_type == 'image/jpg' || $mime_type == 'image/jpeg' || $mime_type == 'image/png') {
567
                $type = Storage::FILE_TYPE_IMAGE;
568
            } else if ($mime_type == 'video/webm' || $mime_type == 'video/mpeg' || $mime_type == 'video/mpg' || $mime_type == 'video/mp4') {
569
                $type = Storage::FILE_TYPE_VIDEO;
570
            } else if ($mime_type == 'application/pdf') {
571
                $type = Storage::FILE_TYPE_DOCUMENT;
572
            }
573
        }
307 www 574
 
589 ariadna 575
        // Crear y guardar el mensaje
576
        $message = new Message();
577
        $message->conversation_id = $conversation->id;
578
        $message->read = Message::NO;
579
        $message->message = $type == Message::TYPE_TEXT ? $dataPost['message'] : '';
580
        $message->receiver_id = $user->id;
581
        $message->receiver_status = Message::STATUS_NORMAL;
582
        $message->sender_id = $currentUser->id;
583
        $message->sender_status = Message::STATUS_NORMAL;
584
        $message->type = $type;
307 www 585
 
589 ariadna 586
        $messageMapper = MessageMapper::getInstance($this->adapter);
587
        if (!$messageMapper->insert($message)) {
588
            return new JsonModel([
589
                'success' => false,
590
                'data' => $messageMapper->getError()
591
            ]);
592
        }
307 www 593
 
589 ariadna 594
        // Procesar archivo adjunto si existe
595
        if ($message_filename) {
596
            $storage = new Storage();
597
            $storage->setAdapter($this->adapter);
598
            $storage->setLogger($this->logger);
599
            $storage->setTranslator($this->translator);
307 www 600
 
589 ariadna 601
            if (!$storage->uploadMessageFile($message_tmp_filename, $message_filename, $message->uuid)) {
602
                return new JsonModel([
603
                    'success' => false,
604
                    'data' => $storage->getError()
605
                ]);
606
            }
307 www 607
 
589 ariadna 608
            $message->filename = $message_filename;
609
            if (!$messageMapper->update($message)) {
1 efrain 610
                return new JsonModel([
589 ariadna 611
                    'success' => false,
612
                    'data' => $messageMapper->getError()
1 efrain 613
                ]);
614
            }
615
        }
589 ariadna 616
 
617
        // Preparar respuesta exitosa
618
        $filename = '';
619
        if ($message->filename) {
620
            $filename = $this->url()->fromRoute('storage', [
621
                'type' => 'message',
622
                'filename' => $message->filename,
623
                'code' => $message->uuid
624
            ], ['force_canonical' => true]);
625
        }
626
 
627
        // Actualizar última actividad del usuario
628
        $userMapper->updateLastActivity($currentUser->id);
629
 
630
        // Devolver respuesta exitosa con datos del mensaje
631
        return new JsonModel([
632
            'success' => true,
633
            'data' => [
634
                'sender_name' => trim($currentUser->first_name . ' ' . $currentUser->last_name),
635
                'sender_image' => $this->url()->fromRoute('storage', [
636
                    'type' => 'user',
637
                    'filename' => $currentUser->image,
638
                    'code' => $currentUser->uuid
639
                ], ['force_canonical' => true]),
640
                'sender_profile' => $this->url()->fromRoute('profile/view', ['id' => $currentUser->uuid]),
641
                'receiver_name' => trim($user->first_name . ' ' . $user->last_name),
642
                'receiver_image' => $this->url()->fromRoute('storage', [
643
                    'type' => 'user',
644
                    'filename' => $user->image,
645
                    'code' => $user->uuid
646
                ], ['force_canonical' => true]),
647
                'receiver_profile' => $this->url()->fromRoute('profile/view', ['id' => $user->uuid]),
648
                'side' => 'left',
649
                'message' => $message->message,
650
                'type' => $message->type,
651
                'filename' => $filename,
652
                'date' => $this->timeAgo($now, $now),
653
            ]
654
        ]);
1 efrain 655
    }
307 www 656
 
657
    /**
658
     *
659
     * @param string $timestamp
660
     * @param string $now
661
     * @return string
662
     */
663
    private function timeAgo($timestamp, $now = '')
664
    {
582 ariadna 665
 
307 www 666
        if ($now) {
667
            $datetime1 = \DateTime::createFromFormat('Y-m-d H:i:s', $now);
1 efrain 668
        } else {
307 www 669
            $now = date('Y-m-d H:i:s');
670
            $datetime1 = date_create($now);
1 efrain 671
        }
307 www 672
        $datetime2 = date_create($timestamp);
582 ariadna 673
 
307 www 674
        $diff = date_diff($datetime1, $datetime2);
675
        $timemsg = '';
676
        if ($diff->y > 0) {
582 ariadna 677
            $timemsg = $diff->y . ' ' . ($diff->y > 1 ? $this->translator->translate('LABEL_YEARS_SMALL')  : $this->translator->translate('LABEL_YEAR_SMALL'));
307 www 678
        } else if ($diff->m > 0) {
582 ariadna 679
            $timemsg = $diff->m  . ' ' . ($diff->m > 1 ? $this->translator->translate('LABEL_MONTHS_SMALL')  : $this->translator->translate('LABEL_MONTH_SMALL'));
307 www 680
        } else if ($diff->d > 0) {
582 ariadna 681
            $timemsg = $diff->d . ' ' . ($diff->d > 1 ? $this->translator->translate('LABEL_DAYS_SMALL')  : $this->translator->translate('LABEL_DAY_SMALL'));
307 www 682
        } else if ($diff->h > 0) {
582 ariadna 683
            $timemsg = $diff->h  . ' ' . ($diff->h > 1 ? $this->translator->translate('LABEL_HOURS_SMALL')  : $this->translator->translate('LABEL_HOUR_SMALL'));
307 www 684
        } else if ($diff->i > 0) {
582 ariadna 685
            $timemsg = $diff->i  . ' ' . ($diff->i > 1 ? $this->translator->translate('LABEL_MINUTES_SMALL')  : $this->translator->translate('LABEL_MINUTE_SMALL'));
307 www 686
        } else if ($diff->s > 0) {
582 ariadna 687
            $timemsg = $diff->s  . ' ' . ($diff->s > 1 ? $this->translator->translate('LABEL_SECONDS_SMALL')  : $this->translator->translate('LABEL_SECOND_SMALL'));
307 www 688
        }
689
        if (!$timemsg) {
582 ariadna 690
            $timemsg = $this->translator->translate('LABEL_NOW');
307 www 691
        } else {
582 ariadna 692
            $timemsg = $this->translator->translate('LABEL_AGO_SMALL') . ' ' . $timemsg . '';
307 www 693
        }
694
        return $timemsg;
1 efrain 695
    }
307 www 696
 
685 stevensc 697
    /**
698
     * Elimina una conversación de mensajes
699
     *
700
     * Endpoint: POST /inmail/messages/delete/:uuid
701
     *
702
     * Respuesta exitosa:
703
     * [
704
     *   success: true,
705
     *   data: "LABEL_CONVERSATION_WAS_DELETED"
706
     * ]
707
     *
708
     * Respuesta de error:
709
     * [
710
     *   success: false,
711
     *   data: mensaje de error
712
     * ]
713
     *
714
     * @return \Laminas\View\Model\JsonModel
715
     */
684 stevensc 716
    public function deleteMessageAction()
1 efrain 717
    {
718
        $request = $this->getRequest();
719
        if ($request->isPost()) {
720
            $currentUserPlugin = $this->plugin('currentUserPlugin');
721
            $currentUser = $currentUserPlugin->getUser();
582 ariadna 722
 
684 stevensc 723
            $uuid = $this->params()->fromRoute('uuid');
724
            if (!$uuid) {
1 efrain 725
                return new JsonModel([
726
                    'success' => false,
727
                    'data' => 'ERROR_PARAMETERS_ARE_INVALID'
728
                ]);
729
            }
582 ariadna 730
 
307 www 731
            $userMapper = UserMapper::getInstance($this->adapter);
684 stevensc 732
            $user = $userMapper->fetchOneByUuid($uuid);
1 efrain 733
            if (!$user) {
734
                return new JsonModel([
735
                    'success' => false,
736
                    'data' => 'ERROR_REQUEST_IS_INVALID'
737
                ]);
738
            }
582 ariadna 739
 
307 www 740
            $conversationMapper = ConversationMapper::getInstance($this->adapter);
741
            $conversation = $conversationMapper->fetchOneByUserId1AndUserId2($currentUser->id, $user->id);
582 ariadna 742
 
743
 
307 www 744
            if ($conversation) {
582 ariadna 745
 
307 www 746
                if ($conversation->sender_id == $currentUser->id && $conversation->receiver_id == $user->id) {
747
                    $conversation->sender_status = Conversation::STATUS_DELETED;
748
                    if ($conversationMapper->update($conversation)) {
749
                        $response = [
750
                            'success' => true,
751
                            'data' => 'LABEL_CONVERSATION_WAS_DELETED'
752
                        ];
753
                    } else {
582 ariadna 754
 
755
 
307 www 756
                        $response = [
757
                            'success' => false,
758
                            'data' => $conversationMapper->getError()
759
                        ];
291 www 760
                    }
307 www 761
                }
582 ariadna 762
 
307 www 763
                if ($conversation->receiver_id == $currentUser->id && $conversation->sender_id == $user->id) {
764
                    $conversation->receiver_status = Conversation::STATUS_DELETED;
765
                    if ($conversationMapper->update($conversation)) {
766
                        $response = [
767
                            'success' => true,
768
                            'data' => 'LABEL_CONVERSATION_WAS_DELETED'
769
                        ];
291 www 770
                    } else {
582 ariadna 771
 
772
 
307 www 773
                        $response = [
774
                            'success' => false,
775
                            'data' => $conversationMapper->getError()
776
                        ];
1 efrain 777
                    }
778
                }
582 ariadna 779
 
307 www 780
                return new JsonModel($response);
1 efrain 781
            } else {
307 www 782
                $response = [
783
                    'success' => false,
784
                    'data' => 'ERROR_CONVERSATION_NOT_FOUND'
785
                ];
1 efrain 786
            }
582 ariadna 787
 
307 www 788
            return new JsonModel($response);
1 efrain 789
        } else {
307 www 790
            $response = [
1 efrain 791
                'success' => false,
792
                'data' => 'ERROR_METHOD_NOT_ALLOWED'
307 www 793
            ];
1 efrain 794
        }
582 ariadna 795
 
307 www 796
        return new JsonModel($response);
1 efrain 797
    }
798
}