
    ԭhv                        d dl mZ d dlmZ d dlZd dlZd dlmZ d dlm	Z	 d dl
mZ d dlmZ  ej        ej                    ej        e          Z e            Zed	efd
            Z edde          Ze                    e           e                    d          d             Ze                    d          d             ZdS )    )FastAPI)asynccontextmanagerN)settings)connect_to_mongo)NewsAPIService)
api_router)levelappc                  K   t                               d           	 t                       d {V  t          j                            t          j        g           d {V  t                               dt          j                    t          j
        t          j                            t          j                             n0# t          $ r#}t                               d|             d }~ww xY wd W V  t                               d           t                               d           t          j                                         d {V  t                               d           d S )	Nz!Starting Google Search Service...)topicszMongoDB URL:)message_handlerzError Starting Service: zGoogle Search Service startedz&Shutting down Google Search Service...zGoogle Search Service stopped)loggerinfor   servicekafka_clientstart_consumerr   GOOGLE_QUEUE_TOPICMONGODB_URLasynciocreate_taskconsume_messages
fetch_news	Exceptionerrorstop)r
   es     /app/app/main.pylifespanr      sx      KK3444         
 "11(:U9V1WWWWWWWWW98#799::: 11'BT1UU	
 	
 	
 	
    333444 
EEEE
KK/000 KK8999


#
#
%
%%%%%%%%
KK/00000s   B(C 
C4C//C4Google Search Servicez1.0.0)titleversionr   /c                     K   dddS )Nr   running)r   status r&       r   rootr(   7   s      .)DDDr'   z/healthc                     K   ddiS )Nr%   healthyr&   r&   r'   r   health_checkr+   ;   s      i  r'   )fastapir   
contextlibr   loggingr   app.core.configr   app.core.databaser   app.services.google_search_apir   app.web.api.v1.news_responser   basicConfigINFO	getLogger__name__r   r   r   r
   include_routergetr(   r+   r&   r'   r   <module>r9      sq         * * * * * *   $ $ $ $ $ $ . . . . . . 9 9 9 9 9 9 3 3 3 3 3 3  ', ' ' ' '		8	$	$
.

1 1 1 1 1: g
!     :   E E E ! ! ! ! !r'   