chore: tests

Author: Dzeranov

packages/examples/cvat/exchange-oracle/tests/integration/services/test_exchange.py

@@ -220,6 +220,51 @@ def test_create_assignment_no_required_qualifications(self):
             with pytest.raises(Exception, match="User doesn't have required qualifications."):
                 create_assignment(ESCROW_ADDRESS, Networks.localhost, user_address, [])
 
+    def test_create_assignment_with_required_qualifications(self):
+        cvat_project, cvat_task, cvat_job = create_project_task_and_job(
+            self.session, ESCROW_ADDRESS, 1
+        )
+        initial_job_updated_at = cvat_job.updated_at
+        initial_task_updated_at = cvat_task.updated_at
+        initial_project_updated_at = cvat_project.updated_at
+
+        user_address = WALLET_ADDRESS1
+        user = User(
+            wallet_address=user_address,
+            cvat_email="[email protected]",
+            cvat_id=1,
+        )
+        self.session.add(user)
+
+        self.session.commit()
+
+        with (
+            open("tests/utils/manifest.json") as data,
+            patch("src.services.exchange.get_escrow_manifest") as mock_get_manifest,
+            patch("src.services.exchange.cvat_api"), 
+        ):
+            manifest = json.load(data)
+            manifest["qualifications"] = ["test", "test2"]
+            mock_get_manifest.return_value = manifest
+            assignment_id = create_assignment(
+                cvat_project.escrow_address, Networks(cvat_project.chain_id), user_address, ["test", "test2", "test3"]
+            )
+
+        assignment = self.session.query(Assignment).filter_by(id=assignment_id).first()
+
+        assert assignment.cvat_job_id == cvat_job.cvat_id
+        assert assignment.user_wallet_address == user_address
+        assert assignment.status == AssignmentStatuses.created
+
+        self.session.refresh(cvat_job)
+        assert cvat_job.updated_at != initial_job_updated_at
+
+        self.session.refresh(cvat_task)
+        assert cvat_task.updated_at != initial_task_updated_at
+
+        self.session.refresh(cvat_project)
+        assert cvat_project.updated_at != initial_project_updated_at
+
     def test_create_assignment_unfinished_assignment(self):
         _, _, cvat_job = create_project_task_and_job(self.session, ESCROW_ADDRESS, 1)