
     h                         d dl Z ddlmZmZ d dlZd dlmZ  ej                  e      Z	d Z
d Zd Zd Zdd	Zd
 Zd Zy)    N   )ChannelTariff)settingsc                     t         j                   d} dt         j                  d}t        j                  | |      }|j
                  dk(  r|j                         }|j	                  dg       D ]}  }t        j                  j                  |d   |j	                  dd	      t        |j	                  d
d            |j	                  dd	      t        |j	                  dd            d        ydd|j
                   fS )Nz	/channelsapplication/jsonacceptTokenheaders   channelsidname orderr   linkpriceg        )r   r   r   r   )
channel_iddefaults)TzChannels updated successfully.FFailed to fetch data: )r   IPTV_BASE_URL
IPTV_TOKENrequestsgetstatus_codejsonr   objectsupdate_or_createintfloaturlr   responsedataitems        1/var/www/skyplay_api_hub/iptv_activation/utils.pyfetch_and_update_channelsr)   	   s    ##$I
.C$$$G
 ||C1Hs"}}HHZ, 		DOO,,: HHVR0 '1!56 HHVR0"488GT#:;	 - 		 6.x/C/C.DEEE    c            	      x   t         j                   d} dt         j                  d}t        j                  | |      }|j
                  dk(  r^|j                         }|j	                  dg       D ]8  }t        j                  j                  |d   d|j	                  dd	      i
       : ydd|j
                   fS )Nz	/tariffs/r   r	   r   r   tariffsr   r   r   )
tariffs_idr   )TzTariffs updated successfully.Fr   )
r   r   r   r   r   r   r   r   r   r    r#   s        r(   fetch_and_update_tariffsr.   #   s    ##$I
.C$%%G ||C1Hs"}}HHY+ 	DNN++:DHHVR0 , 	 5.x/C/C.DEEEr*   c                    t         j                   d}dt         j                  dd}	 t        j                  || |      }|j
                  dk(  r|j                         S t        j                  d|j
                   d|j                          y# t        $ r+}t        j                  d	t        |              Y d}~yd}~ww xY w)
r
    Makes a POST request to create an IPTV client.
    Returns response JSON on success, or None on failure.
    	/clients/r   r
   r   zContent-Typer   r   r   zIPTV API Error : Nz"Exception while calling IPTV API: )r   r   r   r   postr   r   loggererrortext	Exception	exceptionstr)payloadr$   r   r%   es        r(   create_iptv_clientr>   9   s    
 ##$I
.C$%%*G	==7GD3&==?"LL?8+?+?*@8==/RS =c!fXFGs   6B  /B 	C!B??Cc                    t         j                   d| d}dt         j                  dd}	 t        j                  || |      }|j
                  dv r|j                         S t        j                  d|j
                   d|j                          y	# t        $ r+}t        j                  d
t        |              Y d	}~y	d	}~ww xY w)r0   r1   /r   r2   r3   r      zIPTV update client API error r4   Nz&Exception while updating IPTV client: )r   r   r   r   patchr   r   r6   r7   r8   r9   r:   r;   )r<   	client_idr$   r   r%   r=   s         r(   update_iptv_clientrE   Q   s    
 ##$Ii[
:C %$$*G	>>#GWE:-==?"LL89M9M8NbQYQ^Q^P_`a A#a&JKs   5B "/B 	C!CCc                    t         j                   d|  }dt         j                  dd}||dt         j                  t         j                  |d}	 t        j                  |||      }|j                  dv r|j                         S t        j                  d|j                   d	|j                          y # t        $ r+}t        j                  d
t        |              Y d }~y d }~ww xY w)N/deviceCode/r   r2   dtvsol)codemactypeproxyIdtariffIdnoter3   rA   zDevice add API error r4   z(Exception while calling Device Add API: )r   r   r   IPTV_PROXY_SERVER_ID	TARIFF_IDr   r5   r   r   r6   r7   r8   r9   r:   r;   )	rD   rI   rJ   rN   r$   r   r<   r%   r=   s	            r(   add_device_coderQ   l   s    ##$L
<C$$$*G 00&&G	==7GD:-==?"LL01E1E0FbXY CCF8LMs   5B6 /B6 6	C*?!C%%C*c                    t         j                   d|  }dt         j                  d}	 t        j                  ||      }|j
                  dk(  r|j                         S t        j                  d|j
                   d|j                          y # t        $ r+}t        j                  dt        |              Y d }~y d }~ww xY w)	NrG   r   r	   r   r   zDevice code fetch failed r4   z&Exception while fetching device code: r   r   r   r   r   r   r   r6   r7   r8   r9   r:   r;   )rD   r$   r   r%   r=   s        r(   get_device_coderT      s    ##$L
<C$$$G
	<<W53&==?"LL4X5I5I4J"X]]O\] A#a&JK   5B  /B 	C!B??Cc                    t         j                   d|  }dt         j                  d}	 t        j                  ||      }|j
                  dk(  r|j                         S t        j                  d|j
                   d|j                          y # t        $ r+}t        j                  dt        |              Y d }~y d }~ww xY w)	Nz/search/name/phone/r   r	   r   r   zSearch API failed r4   z$Exception while calling search API: rS   )phoner$   r   r%   r=   s        r(   search_client_by_phonerX      s    ##$$7w
?C$$$G
	<<W53&==?"LL-h.B.B-C2hmm_UV ?AxHIrU   )r   r   test)r   modelsr   r   loggingdjango.confr   	getLogger__name__r6   r)   r.   r>   rE   rQ   rT   rX    r*   r(   <module>r`      sJ     #   			8	$F4F,068$r*   