WIP

Author: callumknights

lib/content_item_loader.rb

@@ -30,8 +30,11 @@ def load_from_sources(base_path)
       load_json_file(base_path)
     elsif use_graphql?
       graphql_response = GdsApi.publishing_api.graphql_content_item(Graphql::EditionQuery.new(base_path).query)
-      if GRAPHQL_ALLOWED_SCHEMAS.include?(graphql_response["schema_name"])
-        graphql_response
+      debugger
+      if graphql_response.to_hash.key?("errors")
+        set_prometheus_labels("contains_errors" => true)
+      elsif GRAPHQL_ALLOWED_SCHEMAS.include?(graphql_response["schema_name"])
+        graphql_response 
       else
         GdsApi.content_store.content_item(base_path)
       end
@@ -88,4 +91,12 @@ def load_json_file(base_path)
   def headers
     { cache_control: "max-age=0, public", expires: "" }
   end
+
+  def set_prometheus_labels(hash)
+    return unless hash
+
+    prometheus_labels = request.env.fetch("govuk.prometheus_labels", {})
+
+    request.env["govuk.prometheus_labels"] = prometheus_labels.merge(hash)
+  end
 end

spec/unit/content_item_loader_spec.rb

@@ -219,6 +219,13 @@
           expect(item_request).not_to have_been_made
         end
       end
+
+      context "given a response from graphql containing errors" do #pick this up here tomorrow
+        subject(:content_item_loader) { described_class.for_request(request) }
+
+        let!(:graphql_request) { stub_publishing_api_graphql_query(graphql_query, { data: { edition: { schema_name: "news_article" } } }) }
+        let(:request) { instance_double(ActionDispatch::Request, path: "/my-random-item", env: {}, params: { "graphql" => "true" }) }
+
     end
 
     context "when the content item schema is not in GRAPHQL_ALLOWED_SCHEMAS" do