Merge branch 'ZeshanHyder-731-feature/layergroups'

Author: allixender

lib/geoserver_config/coverages.ex

@@ -31,15 +31,33 @@ defmodule GeoserverConfig.Coverages do
   ## Example
       GeoserverConfig.Coverages.list_coverages("demo_workspace", "dem_store")
   """
-  @spec list_coverages(String.t(), String.t()) :: Req.Response.t()
+  @spec list_coverages(String.t(), String.t()) :: {:ok, list()} | {:error, term()}
   def list_coverages(workspace, coverage_store) do
     url = "#{@base_url}/workspaces/#{workspace}/coveragestores/#{coverage_store}/coverages"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(
+          url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"Accept", "application/json"}]
+        ) do
+      {:ok, %{status: 200, body: body}} ->
+        case body do
+          %{"coverages" => %{"coverage" => coverages}} when is_list(coverages) ->
+            {:ok, coverages}
+
+          %{"coverages" => %{}} ->
+            {:ok, []}
+
+          _ ->
+            {:error, :unexpected_format, body}
+        end
+
+      {:ok, %{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, reason} ->
+        {:error, {:request_failed, reason}}
+    end
   end
 
   @doc """

lib/geoserver_config/coveragestores.ex

@@ -30,14 +30,33 @@ defmodule GeoserverConfig.Coveragestores do
   ## Example
       GeoserverConfig.Coveragestores.list_coveragestores("demo_workspace")
   """
+
   def list_coveragestores(workspace) do
     url = "#{@base_url}/workspaces/#{workspace}/coveragestores"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(
+          url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"Accept", "application/json"}]
+        ) do
+      {:ok, %{status: 200, body: body}} ->
+        case body do
+          %{"coverageStores" => %{"coverageStore" => stores}} when is_list(stores) ->
+            {:ok, stores}
+
+          %{"coverageStores" => %{}} ->
+            {:ok, []}
+
+          _ ->
+            {:error, :unexpected_format, body}
+        end
+
+      {:ok, %{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, reason} ->
+        {:error, {:request_failed, reason}}
+    end
   end
 
 @doc """

lib/geoserver_config/datastores.ex

@@ -37,14 +37,41 @@ defmodule GeoserverConfig.Datastores do
   ## Example
       GeoserverConfig.Datastores.list_datastores("demo_workspace")
   """
+  # def list_datastores(workspace) do
+  #   url = "#{@base_url}/workspaces/#{workspace}/datastores"
+
+  #   Req.get!(
+  #     url,
+  #     auth: {:basic, "#{@username}:#{@password}"},
+  #     headers: [{"Accept", "application/json"}]
+  #   )
+  # end
+
   def list_datastores(workspace) do
     url = "#{@base_url}/workspaces/#{workspace}/datastores"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(
+          url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"accept", "application/json"}]
+        ) do
+      {:ok, %Req.Response{status: 200, body: %{"dataStores" => %{"dataStore" => stores}}}}
+      when is_list(stores) ->
+        {:ok, stores}
+
+      {:ok, %Req.Response{status: 200, body: %{"dataStores" => %{"dataStore" => store}}}}
+      when is_map(store) ->
+        {:ok, [store]}
+
+      {:ok, %Req.Response{status: 200, body: %{"dataStores" => _}}} ->
+        {:ok, []}
+
+      {:ok, %Req.Response{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, exception} ->
+        {:error, exception}
+    end
   end
 
   @doc """

lib/geoserver_config/layergroups.ex

@@ -26,15 +26,27 @@ defmodule GeoserverConfig.LayerGroups do
   ## Example
       GeoserverConfig.list_layer_groups()
   """
-  @spec list_layer_groups() :: Req.Response.t()
+  @spec list_layer_groups() :: {:ok, list()} | {:error, any()}
   def list_layer_groups do
     url = "#{@base_url}/layergroups"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(
+          url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"Accept", "application/json"}]
+        ) do
+      {:ok, %{status: 200, body: %{"layerGroups" => %{"layerGroup" => groups}}}} when is_list(groups) ->
+        {:ok, groups}
+
+      {:ok, %{status: 200, body: %{"layerGroups" => %{}}}} ->
+        {:ok, []}
+
+      {:ok, %{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, reason} ->
+        {:error, {:request_failed, reason}}
+    end
   end
 
   @doc """

lib/geoserver_config/styles.ex

@@ -25,15 +25,27 @@ defmodule GeoserverConfig.Styles do
   ## Example
       GeoserverConfig.Styles.list_styles()
   """
-  @spec list_styles() :: Req.Response.t()
-  def list_styles() do
+  @spec list_styles() :: {:ok, list()} | {:error, any()}
+  def list_styles do
     url = "#{@base_url}/styles"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(
+          url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"Accept", "application/json"}]
+        ) do
+      {:ok, %{status: 200, body: %{"styles" => %{"style" => styles}}}} when is_list(styles) ->
+        {:ok, styles}
+
+      {:ok, %{status: 200, body: %{"styles" => %{}}}} ->
+        {:ok, []}
+
+      {:ok, %{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, reason} ->
+        {:error, {:request_failed, reason}}
+    end
   end
 
   @doc """
@@ -48,14 +60,27 @@ defmodule GeoserverConfig.Styles do
   ## Example
       GeoserverConfig.Styles.list_styles_workspace_specific("demo")
   """
+  @spec list_styles_workspace_specific(String.t()) :: {:ok, list()} | {:error, any()}
   def list_styles_workspace_specific(workspace) do
     url = "#{@base_url}/workspaces/#{workspace}/styles"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(
+          url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"Accept", "application/json"}]
+        ) do
+      {:ok, %{status: 200, body: %{"styles" => %{"style" => styles}}}} when is_list(styles) ->
+        {:ok, styles}
+
+      {:ok, %{status: 200, body: %{"styles" => %{}}}} ->
+        {:ok, []}
+
+      {:ok, %{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, reason} ->
+        {:error, {:request_failed, reason}}
+    end
   end
 
   @doc """

lib/geoserver_config/workspaces.ex

@@ -26,14 +26,27 @@ defmodule GeoserverConfig.Workspaces do
   ## Example
       GeoserverConfig.Workspaces.fetch_workspaces()
   """
+
   def fetch_workspaces do
     url = "#{@base_url}/workspaces"
 
-    Req.get!(
-      url,
-      auth: {:basic, "#{@username}:#{@password}"},
-      headers: [{"Accept", "application/json"}]
-    )
+    case Req.get(url,
+          auth: {:basic, "#{@username}:#{@password}"},
+          headers: [{"Accept", "application/json"}]
+        ) do
+      {:ok, %Req.Response{status: 200, body: %{"workspaces" => %{"workspace" => workspaces}}}}
+      when is_list(workspaces) ->
+        {:ok, workspaces}
+
+      {:ok, %Req.Response{status: 200, body: %{"workspaces" => _}}} ->
+        {:ok, []}
+
+      {:ok, %Req.Response{status: status, body: body}} ->
+        {:error, {:http_error, status, body}}
+
+      {:error, exception} ->
+        {:error, {:request_failed, Exception.message(exception)}}
+    end
   end
 
   @doc """

run.exs

@@ -103,7 +103,7 @@
 # IO.inspect(response)
 
 # GET Method: List of Coverages
-# response = GeoserverConfig.Coverages.list_coverages("sf", "sfdem")
+# response = GeoserverConfig.Coverages.list_coverages("nurc", "mosaic")
 # IO.inspect(response)
 
 # POST Method: Creation of Coverage Layers
@@ -143,7 +143,7 @@
 # response = GeoserverConfig.Styles.list_styles()
 # IO.inspect(response)
 
-# # GET Method: Styles (Workspace Specific)
+# GET Method: Styles (Workspace Specific)
 # response = GeoserverConfig.list_styles_workspace_specific("ne")
 # IO.inspect(response)
 
@@ -232,10 +232,9 @@
 
 
 # LayerGroups GET Method
-response = GeoserverConfig.list_layer_groups().body
+response = GeoserverConfig.list_layer_groups()
 IO.inspect(response)
 
-
 # LayerGroups POST Method
 # xml_body = """
 # <?xml version="1.0" encoding="UTF-8"?>