sync_states_spec.rb in rhoconnect-5.1.1

- old
+ new
@@ -1,78 +1,78 @@
 require File.join(File.dirname(__FILE__),'spec_helper')
 
 describe "Sync Server States" do
-  it_behaves_like "SharedRhoconnectHelper", :rhoconnect_data => true do
-    before(:each) do   
-      @s = Source.load(@s_fields[:name],@s_params) 
-      @model = Rhoconnect::Model::Base.create(@s)
-      rhcud = lambda { @model.send(params[:operation].to_sym, params["#{params[:operation]}_object".to_sym]) }
-      @sscud = Rhoconnect::Handler::Changes::Runner.new(['create', 'update', 'delete'], @model, @c, rhcud, {})
-      rh = lambda { @model.query(params[:query]) } 
-      @ssq = Rhoconnect::Handler::Query::Runner.new(@model, @c, rh, {})
-    end
+  include_examples "SharedRhoconnectHelper", :rhoconnect_data => true
 
-    describe "client creates objects" do
+  before(:each) do
+    @s = Source.load(@s_fields[:name],@s_params)
+    @model = Rhoconnect::Model::Base.create(@s)
+    rhcud = lambda { @model.send(params[:operation].to_sym, params["#{params[:operation]}_object".to_sym]) }
+    @sscud = Rhoconnect::Handler::Changes::Runner.new(['create', 'update', 'delete'], @model, @c, rhcud, {})
+    rh = lambda { @model.query(params[:query]) }
+    @ssq = Rhoconnect::Handler::Query::Runner.new(@model, @c, rh, {})
+  end
 
-      it "should create object and create link for client" do
-        @product1['link'] = 'temp1'
-        params = {'create'=>{'1'=>@product1}}
-        backend_data = {'backend_id'=>@product1}
-        set_doc_state(@sscud.client, :cd_size => 0)
-        set_doc_state(@s, :md_size => 0)
-        @s.read_state.refresh_time = Time.now.to_i + 3600
-        @sscud.params = params
-        @sscud.run
-        verify_source_queue_data(@s, :create => [])
-        verify_doc_result(@c, {:cd_size => "1",
-                               :cd => backend_data,
-                               :create_links => {'1'=>{'l'=>'backend_id'}}})
-        verify_doc_result(@s, {:md_size => "1",
-                               :md => backend_data})
-      end
+  describe "client creates objects" do
 
-      it "should create object and send link to client" do
-        @product1['link'] = 'temp1'
-        params = {'create'=>{'1'=>@product1}}
-        backend_data = {'backend_id'=>@product1}
-        set_doc_state(@sscud.client, :cd_size => 0)
-        set_doc_state(@s, :md_size => 0)
-        @s.read_state.refresh_time = Time.now.to_i + 3600
-        @sscud.params = params
-        @sscud.run
-        verify_source_queue_data(@s, :create => [])
-        verify_doc_result(@c, {:cd_size => "1",
-                               :cd => backend_data,
-                               :create_links => {'1'=>{'l'=>'backend_id'}}})
-        verify_doc_result(@s, {:md_size => "1",
-                               :md => backend_data})
-        res = @ssq.run
-        res.should == [{'version'=>Rhoconnect::SYNC_VERSION},{"token"=>res[1]['token']}, 
-          {"count"=>0}, {"progress_count"=>0}, {"total_count"=>1}, 
-          {"links"=> {'1'=>{'l'=>'backend_id'}}}]
+    it "should create object and create link for client" do
+      @product1['link'] = 'temp1'
+      params = {'create'=>{'1'=>@product1}}
+      backend_data = {'backend_id'=>@product1}
+      set_doc_state(@sscud.client, :cd_size => 0)
+      set_doc_state(@s, :md_size => 0)
+      @s.read_state.refresh_time = Time.now.to_i + 3600
+      @sscud.params = params
+      @sscud.run
+      verify_source_queue_data(@s, :create => [])
+      verify_doc_result(@c, {:cd_size => "1",
+                             :cd => backend_data,
+                             :create_links => {'1'=>{'l'=>'backend_id'}}})
+      verify_doc_result(@s, {:md_size => "1",
+                             :md => backend_data})
+    end
 
-      end
+    it "should create object and send link to client" do
+      @product1['link'] = 'temp1'
+      params = {'create'=>{'1'=>@product1}}
+      backend_data = {'backend_id'=>@product1}
+      set_doc_state(@sscud.client, :cd_size => 0)
+      set_doc_state(@s, :md_size => 0)
+      @s.read_state.refresh_time = Time.now.to_i + 3600
+      @sscud.params = params
+      @sscud.run
+      verify_source_queue_data(@s, :create => [])
+      verify_doc_result(@c, {:cd_size => "1",
+                             :cd => backend_data,
+                             :create_links => {'1'=>{'l'=>'backend_id'}}})
+      verify_doc_result(@s, {:md_size => "1",
+                             :md => backend_data})
+      res = @ssq.run
+      res.should == [{'version'=>Rhoconnect::SYNC_VERSION},{"token"=>res[1]['token']},
+        {"count"=>0}, {"progress_count"=>0}, {"total_count"=>1},
+        {"links"=> {'1'=>{'l'=>'backend_id'}}}]
+
     end
+  end
 
-    describe "client deletes objects" do
-      it "should delete object" do
-        params = {'delete'=>{'1'=>@product1}}
-        data = {'1'=>@product1,'2'=>@product2,'3'=>@product3}
-        expected = {'2'=>@product2,'3'=>@product3}
-        set_doc_state(@sscud.client, {:cd => data,
-                                  :cd_size => data.size})
-        set_doc_state(@s, {:md => data,
-                           :md_size => data.size})
-        @s.read_state.refresh_time = Time.now.to_i + 3600
-        @sscud.params = params
-        @sscud.run
-        verify_source_queue_data(@s, :delete => [])
-        verify_doc_result(@sscud.client, {:cd => expected,
-                                       :delete_page => {},
-                                       :cd_size => "2"})
-        verify_doc_result(@s, {:md => expected,
-                               :md_size => "2"})
-        verify_result('test_delete_storage' => {'1'=>@product1})
-      end
+  describe "client deletes objects" do
+    it "should delete object" do
+      params = {'delete'=>{'1'=>@product1}}
+      data = {'1'=>@product1,'2'=>@product2,'3'=>@product3}
+      expected = {'2'=>@product2,'3'=>@product3}
+      set_doc_state(@sscud.client, {:cd => data,
+                                :cd_size => data.size})
+      set_doc_state(@s, {:md => data,
+                         :md_size => data.size})
+      @s.read_state.refresh_time = Time.now.to_i + 3600
+      @sscud.params = params
+      @sscud.run
+      verify_source_queue_data(@s, :delete => [])
+      verify_doc_result(@sscud.client, {:cd => expected,
+                                     :delete_page => {},
+                                     :cd_size => "2"})
+      verify_doc_result(@s, {:md => expected,
+                             :md_size => "2"})
+      verify_result('test_delete_storage' => {'1'=>@product1})
     end
-  end  
+  end
 end
\ No newline at end of file