spec/basecrm/sync_spec.rb in basecrm-1.1.0 vs spec/basecrm/sync_spec.rb in basecrm-1.1.1

@@ -59,12 +59,12 @@
         ['User-1234-1', 'Source-1234-1']
       end
 
       let(:queue_items) do
         [
-          [BaseCRM::SyncMeta.new(event_type: 'created', ack_key: 'User-1234-1'), BaseCRM::User.new(id: 1)],
-          [BaseCRM::SyncMeta.new(event_type: 'created', ack_key: 'Source-1234-1'), BaseCRM::Source.new(id: 1)]
+          [BaseCRM::Meta.new(type: 'user', sync: BaseCRM::SyncMeta.new(event_type: 'created', ack_key: 'User-1234-1')), BaseCRM::User.new(id: 1)],
+          [BaseCRM::Meta.new(type: 'source', sync: BaseCRM::SyncMeta.new(event_type: 'created', ack_key: 'Source-1234-1')), BaseCRM::Source.new(id: 1)]
         ]
       end
 
       before :each do
         expect(client.sync).to receive(:start).with(device_uuid).and_return(session)
@@ -72,22 +72,23 @@
         expect(client.sync).to receive(:fetch).with(device_uuid, session_id).and_return([])
         expect(client.sync).to receive(:ack).with(device_uuid, ack_keys).and_return(true)
       end
 
       it 'does whole synchronization flow' do
-        subject.fetch { |s, r| s.ack }
+        subject.fetch { |m, r| m.sync.ack }
       end
 
       it 'calls a provided block as many times as items in the queue' do
         counter = 0
-        subject.fetch { |s, r| counter += 1; s.ack }
+        subject.fetch { |m, r| counter += 1; m.sync.ack }
         expect(counter).to eq(2)
       end
 
       it 'passes two elements to provided block: first element is BaseCRM::SyncMeta and the second is a resource' do
-        subject.fetch do |s, r|
-          expect(s).to be_a BaseCRM::SyncMeta
-          s.ack
+        subject.fetch do |m, r|
+          expect(m).to be_a BaseCRM::Meta
+          expect(m.sync).to be_a BaseCRM::SyncMeta
+          m.sync.ack
         end
       end
     end
   end
 end