
    3g
                     D    d dl mZmZ d dlmZ d dlmZmZ d Zd Zd Z	dS )    )requestjsonify)get_db_connection)datetime	timedeltac                  p   t           j        } |                     d          }|                     d          }|                     dd                                          }|r|r|st	          ddi          dfS 	 t                      }|                                }|                    d|||f           |                                 |	                                 |	                                 t	          d	d
i          S # t          $ r*}t	          dt          |          i          dfcY d }~S d }~ww xY w)N	sender_idreceiver_idcontent errorz)Missing sender_id, receiver_id or content  zl
            INSERT INTO messages (sender_id, receiver_id, content)
            VALUES (%s, %s, %s)
        messagezMessage sent successfully  )r   jsongetstripr   r   cursorexecutecommitclose	Exceptionstr)datar	   r
   r   connr   es          5/var/www/wisegym.app/api/functions/message_service.pysend_messager      sJ   <D%%I((=))Khhy"%%++--G TK Tw T!LMNNPSSS/ ""  g.	0 	0 	0
 	

	#>?@@@ / / /Q())3......./s   9BD 
D5D0*D50D5c                     t           j                            d          } | st          ddi          dfS 	 t	                      }|                                }|                    d| f           |                                 |                                 |                                 t          ddi          S # t          $ r*}t          dt          |          i          dfcY d }~S d }~ww xY w)	N
message_idr   zMissing message_idr   z"DELETE FROM messages WHERE id = %sr   zMessage deletedr   )r   r   r   r   r   r   r   r   r   r   r   )r    r   r   r   s       r   delete_messager!      s    !!,//J =!5677<<	/ "";j]KKK

	#45666 / / /Q())3......./s   BB< <
C0C+%C0+C0c                     t           j                            d          } t           j                            d          }| r|st          ddi          dfS 	 t	                      }|                    d          }|                    d| ||| f           |                    d	| ||| f           |                                }|                                 |	                                 |	                                 t          |          S # t          $ r*}t          dt          |          i          d
fcY d }~S d }~ww xY w)Nuser_id	friend_idr   zMissing user_id or friend_idr   T)
dictionaryz
            DELETE FROM messages
            WHERE (
               (sender_id = %s AND receiver_id = %s)
               OR (sender_id = %s AND receiver_id = %s)
              ) AND sent_at < (NOW() - INTERVAL 30 DAY)
        z
            SELECT * FROM messages
            WHERE (
               (sender_id = %s AND receiver_id = %s)
               OR (sender_id = %s AND receiver_id = %s))
            ORDER BY sent_at ASC
        r   )r   argsr   r   r   r   r   fetchallr   r   r   r   )r#   r$   r   r   messagesr   s         r   get_conversationr)   /   sa   ly))G  --I G) G!?@AA3FF/ ""-- 	  y)W5	7 	7 	7 	  y)W5	7 	7 	7 ??$$

x    / / /Q())3......./s   B6D 
ED=7E=EN)
flaskr   r   	db_configr   r   r   r   r!   r)        r   <module>r.      s~    " " " " " " " " ' ' ' ' ' ' ( ( ( ( ( ( ( (/ / /4/ / / $/ $/ $/ $/ $/r-   