add patch to allow new /api endpoints to work while retaining existin… (

#52)

* add patch to allow new /api endpoints to work while retaining existing capability

* patch the NotifyCumulus class for new api path

* better way to check if "/api" is in endpoint

* bump netcdf to pass tests

requirements.txt

@@ -5,7 +5,7 @@ boto3==1.34.138
 botocore==1.34.138
 celery==5.4.0
 pyplugs==0.4.0
-netCDF4==1.6.5
+netCDF4==1.7.2
 requests==2.32.3
 GDAL[numpy]==3.9.1
 psycopg2-binary==2.9.9

src/cumulus_geoproc/geoprocess/handler.py

@@ -1,7 +1,6 @@
 """handle the messages coming from the worker thread
 """
 
-
 import asyncio
 import os
 from collections import namedtuple
@@ -115,7 +114,14 @@ def upload_notify(notices: list, bucket: str):
     # notify
     if len(payload) > 0:
         cumulus_api = capi.CumulusAPI(CUMULUS_API_URL, HTTP2)
-        cumulus_api.endpoint = "productfiles"
+
+        # Patch to work with new /api endpoints if present
+        if cumulus_api.endpoint == "/api":
+            cumulus_api.endpoint = "api/productfiles"
+        else:
+            # Use the old path where there is not /api present
+            cumulus_api.endpoint = "productfiles"
+
         cumulus_api.query = {"key": APPLICATION_KEY}
 
         logger.debug(f"Payload to POST: {payload}")

src/cumulus_geoproc/utils/capi.py

@@ -5,6 +5,7 @@
 from collections import namedtuple
 from urllib.parse import urlencode, urlsplit, urlunsplit
 
+import os
 import httpx
 from cumulus_geoproc.configurations import APPLICATION_KEY
 from cumulus_geoproc import logger
@@ -98,7 +99,14 @@ class NotifyCumulus(CumulusAPI):
 
     def __init__(self, url, http2=True):
         super().__init__(url, http2)
-        self.endpoint = "productfiles"
+
+        # Patch to work with new /api endpoints if present
+        if self.endpoint == "/api":
+            self.endpoint = "api/productfiles"
+        else:
+            # Use the old path where there is not /api present
+            self.endpoint = "productfiles"
+
         self.query = {"key": APPLICATION_KEY}
 
     def run(self, payload):