DAS-2446 - Add get_opendap_nc4 subtest and new unexecuted_url_requested unit tests.

Author: lyonthefrog

tests/unit/test_adapter.py

@@ -80,6 +80,45 @@ def create_message(
 
         return Message(json.dumps(message_content))
 
+    @patch('hoss.adapter.unexecuted_url_requested')
+    def test_opendap_url_request(
+        self,
+        mock_unexecuted_url_requested,
+        mock_stage,
+        mock_subset_granule,
+        mock_get_mimetype,
+    ):
+        """A request that returns an unexecuted OPeNDAP request URL instead
+        of subset data.
+
+        """
+        mock_subset_granule.return_value = (
+            'https://opendap.earthdata.nasa.gov/requst_url'
+        )
+        mock_unexecuted_url_requested.return_value = True
+
+        message = self.create_message(
+            'C123456789-EEDTEST',
+            'short_name',
+            ['variable'],
+            'some_user',
+        )
+
+        hoss = HossAdapter(message, config=self.config, catalog=self.africa_stac)
+
+        with patch.object(HossAdapter, 'process_item', self.process_item_spy):
+            hoss.invoke()
+
+        mock_subset_granule.assert_called_once_with(
+            self.africa_granule_url,
+            message.sources[0],
+            ANY,
+            hoss.message,
+            hoss.config,
+        )
+        mock_stage.assert_not_called()
+        mock_get_mimetype.assert_not_called()
+
     def test_temporal_request(self, mock_stage, mock_subset_granule, mock_get_mimetype):
         """A request that specifies a temporal range should result in a
         temporal subset.

tests/unit/test_utilities.py

@@ -16,6 +16,7 @@
     get_opendap_nc4,
     get_value_or_default,
     move_downloaded_nc4,
+    unexecuted_url_requested,
 )
 
 
@@ -151,13 +152,34 @@ def test_get_opendap_nc4(self, mock_download, mock_move_download):
         access_token = 'secret_token!!!'
         expected_data = {'dap4.ce': 'variable'}
 
+        with self.subTest('Request with OPeNDAP URL mimetype'):
+            opendap_url_mimetype = 'application/x-netcdf4;profile="opendap_url"'
+            output_url = get_opendap_nc4(
+                url,
+                required_variables,
+                output_dir,
+                access_token,
+                self.config,
+                opendap_url_mimetype,
+            )
+            self.assertEqual(
+                'https://opendap.earthdata.nasa.gov/granule.dap.nc4?dap4.ce=variable',
+                output_url,
+            )
+            mock_download.assert_not_called()
+            mock_move_download.assert_not_called()
+
+        mock_download.reset_mock()
+        mock_move_download.reset_mock()
+
         with self.subTest('Request with variables includes dap4.ce'):
             output_file = get_opendap_nc4(
                 url,
                 required_variables,
                 output_dir,
                 access_token,
                 self.config,
+                'fake-mimetype',
             )
 
             self.assertEqual(output_file, moved_file_name)
@@ -279,3 +301,29 @@ def test_get_value_or_default(self):
 
         with self.subTest('Value = None returns the supplied default'):
             self.assertEqual(get_value_or_default(None, 20), 20)
+
+    def test_unexecuted_url_requested(self):
+        """Ensure that True is returned when a valid OPeNDAP URL format
+        string is in the Harmony message, otherwise False should be returned.
+
+        """
+        with self.subTest('Valid opendap_url format 1'):
+            self.assertTrue(
+                unexecuted_url_requested('application/x-netcdf4; profile="opendap_url"')
+            )
+
+        with self.subTest('Valid opendap_url format 2'):
+            self.assertTrue(
+                unexecuted_url_requested('application/x-netcdf4;profile="opendap_url"')
+            )
+
+        with self.subTest('Valid opendap_url format 3'):
+            self.assertTrue(
+                unexecuted_url_requested('application/x-netcdf4;profile=opendap_url')
+            )
+
+        with self.subTest('NetCDF4 format'):
+            self.assertFalse(unexecuted_url_requested('application/x-netcdf4'))
+
+        with self.subTest('Some other format'):
+            self.assertFalse(unexecuted_url_requested('fake-mimetype'))