Merge pull request #289 from af83/5707_chouette_status

5707 chouette status

6 files changed, 77 insertions, 0 deletions

diff --git a/app/controllers/statuses_controller.rb b/app/controllers/statuses_controller.rb
new file mode 100644
index 000000000..e38a92982
--- /dev/null
+++ b/app/controllers/statuses_controller.rb
@@ -0,0 +1,20 @@
+class StatusesController < ChouetteController
+  respond_to :json
+
+  def index
+
+    status = {
+      referentials_blocked: Referential.blocked.count,
+      imports_blocked: Import.blocked.count,
+      compliance_check_sets_blocked: ComplianceCheckSet.blocked.count
+    }
+    status[:status] = global_status status
+    render json: status.to_json
+  end
+
+  private
+
+  def global_status status
+    status.values.all?(&:zero?) ? 'ok' : 'ko'
+  end
+end
diff --git a/app/models/compliance_check_set.rb b/app/models/compliance_check_set.rb
index 3ea832048..289fc134f 100644
--- a/app/models/compliance_check_set.rb
+++ b/app/models/compliance_check_set.rb
@@ -19,6 +19,8 @@ class ComplianceCheckSet < ActiveRecord::Base
     where('created_at BETWEEN :begin AND :end', begin: period_range.begin, end: period_range.end)
   end
 
+  scope :blocked, -> { where('created_at < ? AND status = ?', 4.hours.ago, 'running') }
+
   def self.finished_statuses
     %w(successful failed warning aborted canceled)
   end
diff --git a/app/models/import.rb b/app/models/import.rb
index 049a65f40..d8e763bf3 100644
--- a/app/models/import.rb
+++ b/app/models/import.rb
@@ -13,6 +13,8 @@ class Import < ActiveRecord::Base
     where('started_at BETWEEN :begin AND :end', begin: period_range.begin, end: period_range.end)
    end
 
+  scope :blocked, -> { where('created_at < ? AND status = ?', 4.hours.ago, 'running') }
+
   extend Enumerize
   enumerize :status, in: %w(new pending successful warning failed running aborted canceled), scope: true, default: :new
 
diff --git a/app/models/referential.rb b/app/models/referential.rb
index f64db4ebf..509e0412f 100644
--- a/app/models/referential.rb
+++ b/app/models/referential.rb
@@ -62,6 +62,7 @@ class Referential < ActiveRecord::Base
   scope :order_by_validity_period, ->(dir) { joins(:metadatas).order("unnest(periodes) #{dir}") }
   scope :order_by_lines, ->(dir) { joins(:metadatas).group("referentials.id").order("sum(array_length(referential_metadata.line_ids,1)) #{dir}") }
   scope :not_in_referential_suite, -> { where referential_suite_id: nil }
+  scope :blocked, -> { where('ready = ? AND created_at < ?', false, 4.hours.ago) }
 
   def save_with_table_lock_timeout(options = {})
     save_without_table_lock_timeout(options)
diff --git a/config/routes.rb b/config/routes.rb
index 2715ca428..0b657b028 100644
--- a/config/routes.rb
+++ b/config/routes.rb
@@ -256,4 +256,6 @@ ChouetteIhm::Application.routes.draw do
   match '/422', to: 'errors#server_error', via: :all, as: 'unprocessable_entity'
   match '/500', to: 'errors#server_error', via: :all, as: 'server_error'
 
+  match '/status', to: 'statuses#index', via: :get
+
 end
diff --git a/spec/controllers/statuses_controller_spec.rb b/spec/controllers/statuses_controller_spec.rb
new file mode 100644
index 000000000..8a6db8e28
--- /dev/null
+++ b/spec/controllers/statuses_controller_spec.rb
@@ -0,0 +1,50 @@
+RSpec.describe StatusesController, :type => :controller do
+
+  describe "GET index" do
+    login_user
+    render_views
+
+
+    let(:request){ get :index}
+    let(:parsed_response){ JSON.parse response.body }
+    it "should be ok" do
+      request
+      expect(response).to have_http_status 200
+      expect(parsed_response["status"]).to eq "ok"
+    end
+    context "without blocked object" do
+      before do
+        create :referential
+        create :import
+        create :compliance_check_set
+        request
+      end
+
+      it "should be ok" do
+        expect(response).to have_http_status 200
+        expect(parsed_response["status"]).to eq "ok"
+        expect(parsed_response["referentials_blocked"]).to eq 0
+        expect(parsed_response["imports_blocked"]).to eq 0
+        expect(parsed_response["imports_blocked"]).to eq 0
+      end
+    end
+
+    context "with a blocked object" do
+      before do
+        create :referential, created_at: 5.hours.ago, ready: false
+        create :import
+        create :compliance_check_set
+        request
+      end
+
+      it "should be ko" do
+        expect(Referential.blocked.count).to eq 1
+        expect(response).to have_http_status 200
+        expect(parsed_response["status"]).to eq "ko"
+        expect(parsed_response["referentials_blocked"]).to eq 1
+        expect(parsed_response["imports_blocked"]).to eq 0
+        expect(parsed_response["imports_blocked"]).to eq 0
+      end
+    end
+  end
+end