From 59b564c4bebf9ec5924cb92385ac81d3038a2a5b Mon Sep 17 00:00:00 2001
From: Rohan Mitchell <rohan@rohanmitchell.com>
Date: Wed, 13 Apr 2016 16:48:07 +1000
Subject: [PATCH] Report job queue status via API

---
 app/controllers/api/statuses_controller.rb    | 17 +++++++++++
 config/routes.rb                              |  4 +++
 .../api/statuses_controller_spec.rb           | 30 +++++++++++++++++++
 3 files changed, 51 insertions(+)
 create mode 100644 app/controllers/api/statuses_controller.rb
 create mode 100644 spec/controllers/api/statuses_controller_spec.rb

diff --git a/app/controllers/api/statuses_controller.rb b/app/controllers/api/statuses_controller.rb
new file mode 100644
index 0000000000..c8844b868b
--- /dev/null
+++ b/app/controllers/api/statuses_controller.rb
@@ -0,0 +1,17 @@
+module Api
+  class StatusesController < BaseController
+    respond_to :json
+
+    def job_queue
+      render json: {alive: job_queue_alive?}
+    end
+
+
+    private
+
+    def job_queue_alive?
+      Spree::Config.last_job_queue_heartbeat_at.present? &&
+        Time.parse(Spree::Config.last_job_queue_heartbeat_at) > 6.minutes.ago
+    end
+  end
+end
diff --git a/config/routes.rb b/config/routes.rb
index 26d675838c..6293117a3f 100644
--- a/config/routes.rb
+++ b/config/routes.rb
@@ -143,6 +143,10 @@ Openfoodnetwork::Application.routes.draw do
       get :managed, on: :collection
       get :accessible, on: :collection
     end
+
+    resource :status do
+      get :job_queue
+    end
   end
 
   namespace :open_food_network do
diff --git a/spec/controllers/api/statuses_controller_spec.rb b/spec/controllers/api/statuses_controller_spec.rb
new file mode 100644
index 0000000000..f2427efb79
--- /dev/null
+++ b/spec/controllers/api/statuses_controller_spec.rb
@@ -0,0 +1,30 @@
+require 'spec_helper'
+
+module Api
+  describe StatusesController do
+    render_views
+
+    describe "job queue status" do
+      it "returns alive when up to date" do
+        Spree::Config.last_job_queue_heartbeat_at = Time.now
+        spree_get :job_queue
+        response.should be_success
+        response.body.should == {alive: true}.to_json
+      end
+
+      it "returns dead otherwise" do
+        Spree::Config.last_job_queue_heartbeat_at = 10.minutes.ago
+        spree_get :job_queue
+        response.should be_success
+        response.body.should == {alive: false}.to_json
+      end
+
+      it "returns dead when no heartbeat recorded" do
+        Spree::Config.last_job_queue_heartbeat_at = nil
+        spree_get :job_queue
+        response.should be_success
+        response.body.should == {alive: false}.to_json
+      end
+    end
+  end
+end