tmp

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

Author: kvmw

greeter-messages/app.py

@@ -1,4 +1,5 @@
 import os
+import asyncio
 from flask import Flask, request
 from eureka_client import EurekaServerClient
 
@@ -13,7 +14,7 @@ def greeting():
     return f"{salutation}, {name}!"
 
 if __name__ == '__main__':
-    port = int(os.getenv("PORT", '8080'))
+    port = int(os.getenv('PORT', '8080'))
     eureka_client = EurekaServerClient(port)
     asyncio.run(eureka_client.start())
     app.run(host='0.0.0.0', port=port)

greeter-messages/eureka_client.py

@@ -1,6 +1,33 @@
+import os
+import urllib.request
 from cfenv import AppEnv
 from oauth2 import OAuth2Client
 from py_eureka_client.eureka_client import EurekaClient
+import py_eureka_client.logger as logger
+import py_eureka_client.http_client as http_client
+from urllib.error import URLError
+from typing import Union
+
+logger.set_level('DEBUG')
+
+class MyHttpClient(http_client.HttpClient):
+
+    async def urlopen(self, request: Union[str, http_client.HttpRequest] = None,
+                      data: bytes = None, timeout: float = None) -> http_client.HttpResponse:
+        if isinstance(request, http_client.HttpRequest):
+            req = request
+        elif isinstance(request, str):
+            req = http_client.HttpRequest(request, headers={'Accept-Encoding': 'gzip'})
+        else:
+            raise URLError("Invalid URL")
+
+        req = req._to_urllib_request()
+        req.add_header("Connection", "close")
+        req.add_header("Authorization", f"Bearer {self.oauth_client.get_access_token()}")
+        res = urllib.request.urlopen(req, data=data, timeout=timeout)
+        return http_client.HttpResponse(res)
+
+http_client.set_http_client(MyHttpClient())
 
 class EurekaServerClient:
     def __init__(self, port: int):
@@ -22,12 +49,21 @@ def __init__(self, port: int):
 
         self.client = EurekaClient(
             app_name=self.env.name,
+            instance_host=self.env.uris[0],
+            instance_ip=os.getenv('CF_INSTANCE_INTERNAL_IP'),
+            instance_id=f"{self.env.uris[0]}:{self.env.app.get('instance_id') or '0'}",
+            instance_unsecure_port_enabled=True,
             instance_port=port,
+            instance_secure_port_enabled=True,
+            instance_secure_port=port,
             eureka_server=self.credentials['uri']
         )
 
+        self.client.start()
+
     def on_err(err_type: str, err: Exception):
         print(f"{err_type}::{err}")
+        raise err
 
     async def start(self):
         await self.client.start()