[Fixes #13010] Add describe layer to the WMS harvester

Author: mattiagiupponi

geonode/harvesting/harvesters/wms.py

@@ -184,22 +184,29 @@ def get_ogc_wms_url(self, wms_url, version=None):
             logger.exception(e)
         return ogc_wms_url
 
-    def get_capabilities(self) -> requests.Response:
+    def wms_call(self, kind="GetCapabilities", override_version=None, additional_params={}) -> requests.Response:
         params = self._base_wms_parameters.copy()
         params.update(
             {
-                "request": "GetCapabilities",
+                "request": kind,
             }
         )
         (wms_url, _service, _version, _request) = self._get_cleaned_url_params(self.remote_url)
         if _service:
             params["service"] = _service
-        if _version:
-            params["version"] = _version
+        if override_version or _version:
+            params["version"] = override_version or _version
         if wms_url.query:
             for _param in parse_qsl(wms_url.query):
                 params[_param[0]] = _param[1]
-
+        # updating default params with custom ones
+        params = {**params, **additional_params}
+        
+        # adding basic auth if required
+        harvester = models.Harvester.objects.get(pk=self.harvester_id).first()
+        if harvester and harvester._service:
+            _service = harvester._service
+        
         get_capabilities_response = self.http_session.get(
             self.get_ogc_wms_url(wms_url, version=_version), params=params
         )
@@ -237,7 +244,7 @@ def list_resources(self, offset: typing.Optional[int] = 0) -> typing.List[base.B
 
     def check_availability(self, timeout_seconds: typing.Optional[int] = 5) -> bool:
         try:
-            response = self.get_capabilities()
+            response = self.wms_call()
         except (requests.HTTPError, requests.ConnectionError):
             result = False
         else:
@@ -326,7 +333,7 @@ def get_resource(
 
     def _get_data(self) -> typing.Dict:
         """Return data from the harvester URL in JSON format."""
-        get_capabilities_response = self.get_capabilities()
+        get_capabilities_response = self.wms_call()
         root = etree.fromstring(get_capabilities_response.content, parser=XML_PARSER)
         nsmap = _get_nsmap(root.nsmap)
 
@@ -532,6 +539,14 @@ def finalize_resource_update(
             forced_crs=target_crs,
             overwrite=True,
         )
+        # ref GeoNode #13010
+        # A describeLayer is perfomed to see if we can add the WDS link 
+        # to the resource
+        response = self.wms_call(
+            kind="DescribeLayer",
+            override_version="1.1.1",
+            additional_params={"layers": geonode_resource.alternate}
+        )
 
 
 def _get_nsmap(original: typing.Dict):