tmp 3

Signed-off-by: kvmw <mshamsi@broadcom.com>

Author: kvmw

greeter-messages/app.py

@@ -1,17 +1,27 @@
 import os
+import logging
 from flask import Flask, request
 from eureka import init_client
 
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
+
 app = Flask(__name__)
 
 port = int(os.getenv('PORT', '8080'))
-init_client(port)
+
+try:
+    init_client(port)
+    logger.info("Eureka client initialized successfully")
+except Exception as e:
+    logger.error(f"Failed to initialize Eureka client: {e}")
 
 @app.route('/greeting')
 def greeting():
     salutation = request.args.get('salutation', 'Hello')
     name = request.args.get('name', 'Bob')
 
+    logger.info(f"Greeting request: salutation='{salutation}', name='{name}'")
     return f"{salutation}, {name}!"
 
 if __name__ == '__main__':

greeter-messages/eureka.py

@@ -1,12 +1,14 @@
 import os
 import urllib.request
+import logging
 from cfenv import AppEnv
 from oauth2 import OAuth2Client
 import py_eureka_client.eureka_client as eureka_client
 import py_eureka_client.http_client as http_client
 from urllib.error import URLError
 from typing import Union
 
+logger = logging.getLogger(__name__)
 
 class _OAuth2HttpClient(http_client.HttpClient):
     """
@@ -36,10 +38,9 @@ async def urlopen(self, request: Union[str, http_client.HttpRequest] = None,
         return http_client.HttpResponse(res)
 
 def _on_err(err_type: str, err: Exception):
+    logger.error(f"Eureka client error - Type: {err_type}, Error: {err}")
     if err_type in (eureka_client.ERROR_REGISTER, eureka_client.ERROR_DISCOVER):
         eureka_client.stop()
-    else:
-        print(f"{err_type}::{err}")
 
 def init_client(port: int):
     """

greeter-messages/oauth2.py

@@ -1,7 +1,10 @@
 import time
+import logging
 from typing import Optional
 import requests
 
+logger = logging.getLogger(__name__)
+
 class OAuth2Client:
     """OAuth 2.0 client for handling client credentials flow with token caching"""
 
@@ -50,10 +53,12 @@ def _request_new_token(self) -> str:
             self.token_expires_at = time.time() + expires_in
 
             if not self.access_token:
-                raise ValueError("No access token received from OAuth server")
+                logger.error("No access token received")
+                raise ValueError("No access token received")
 
             return self.access_token
         except requests.exceptions.RequestException as e:
+            logger.error(f"Failed to get access token: {e}")
             raise ValueError(f"Failed to get access token: {e}") from e
 
     def get_access_token(self) -> str: