Revert changes to downloads api (#600)

* Revert go changes

Author: oskarhurst

api/models/download.go

@@ -68,7 +68,6 @@ type PackagerRequest struct {
 	Contents   []PackagerContentItem `json:"contents"`
 	Format     string                `json:"format"`
 	Extent     Extent                `json:"extent"`
-	ProductIDs []uuid.UUID           `json:"product_ids"`
 }
 
 // Extent is a name and a bounding box
@@ -211,8 +210,7 @@ func GetDownloadPackagerRequest(db *pgxpool.Pool, downloadID *uuid.UUID) (*Packa
 				   '/download_', d.id, '.', f.extension
 				) AS output_key,
 			   f.abbreviation AS format,
-			   COALESCE(c.contents, '[]'::jsonb) AS contents,
-			   ARRAY(SELECT product_id FROM download_product WHERE download_id = $1) AS product_ids
+			   COALESCE(c.contents, '[]'::jsonb) AS contents
 		FROM download d
 		INNER JOIN download_format f ON f.id = d.download_format_id
 		LEFT JOIN watershed w ON w.id = d.watershed_id

async_packager/packager.py

@@ -57,6 +57,14 @@ def handle_message(message):
         if resp.status_code != 200:
             raise Exception(resp)
 
+        # get the full download record to retrieve the requested product_id list
+        dl_resp = requests.request(
+            "GET",
+            url=f"{CUMULUS_API_URL}/downloads/{download_id}",
+            params={"key": APPLICATION_KEY},
+        )
+        requested_product_ids = dl_resp.json().get("product_id", []) if dl_resp.status_code == 200 else []
+
         # create a temporary directory and release in final exception
         dst = TemporaryDirectory()
         logger.debug(f"Temporary Directory: {dst.name}")
@@ -78,7 +86,7 @@ def handle_message(message):
                 product_stats = writer_result["product_stats"]
 
                 # Fill in products that had 0 files in contents
-                for pid in PayloadResp.product_ids:
+                for pid in requested_product_ids:
                     if str(pid) not in product_stats:
                         product_stats[str(pid)] = {"expected": 0, "successful": 0}