Merge pull request #23 from maxipavlovic/bugfix-2/LITE-17616

LITE-17616 Fixed `cqrs.bulk_create` output: returns a list of created objects

Author: maxipavlovic

dj_cqrs/managers.py

@@ -28,6 +28,8 @@ def bulk_create(self, objs, **kwargs):
             model = type(objs[0])
             model.call_post_bulk_create(objs, using=self.db)
 
+        return objs
+
     def bulk_update(self, queryset, **kwargs):
         """ Custom update method to support sending of update signals.
 

integration_tests/tests/test_asynchronous_consuming.py

@@ -15,14 +15,13 @@ def test_both_consumers_consume(settings, replica_cursor, clean_rabbit_transport
     assert count_replica_rows(replica_cursor, REPLICA_BASIC_TABLE) == 0
     assert count_replica_rows(replica_cursor, REPLICA_EVENT_TABLE) == 0
 
-    master_instances = BasicFieldsModel.objects.bulk_create([
+    BasicFieldsModel.cqrs.bulk_create([
         BasicFieldsModel(
             int_field=index,
             char_field='text',
         )
         for index in range(1, 10)
     ])
-    BasicFieldsModel.call_post_bulk_create(master_instances)
 
     transport_delay(5)
     assert count_replica_rows(replica_cursor, REPLICA_BASIC_TABLE) == 9

tests/test_master/test_signals.py

@@ -71,10 +71,17 @@ def test_manual_post_bulk_create(mocker):
 def test_automatic_post_bulk_create(mocker):
     publisher_mock = mocker.patch('dj_cqrs.controller.producer.produce')
 
-    models.SimplestTrackedModel.cqrs.bulk_create([
+    instances = models.SimplestTrackedModel.cqrs.bulk_create([
         models.SimplestTrackedModel(id=i, status='new') for i in range(1, 4)
     ])
 
+    assert len(instances) == 3
+    for index in range(3):
+        instance = instances[index]
+        assert instance.id == index + 1
+        assert instance.status == 'new'
+        assert instance.cqrs_revision == 0
+
     assert publisher_mock.call_count == 3
 
     for index, call in enumerate(publisher_mock.call_args_list, start=1):