28 lines
773 B
Python
28 lines
773 B
Python
from types import SimpleNamespace
|
|
|
|
from pipelines.item_sync import run_item_sync
|
|
|
|
|
|
class FakeItemSvc:
|
|
def __init__(self):
|
|
self.created = []
|
|
|
|
async def create(self, data: dict):
|
|
self.created.append(dict(data))
|
|
|
|
|
|
async def test_run_item_sync_creates_item():
|
|
svc = FakeItemSvc()
|
|
job = SimpleNamespace(id="j1", name="widget", payload={"quantity": 4})
|
|
await run_item_sync(job, {"item_svc": svc})
|
|
|
|
assert len(svc.created) == 1
|
|
assert svc.created[0] == {"name": "widget", "quantity": 4}
|
|
|
|
|
|
async def test_run_item_sync_uses_payload_name():
|
|
svc = FakeItemSvc()
|
|
job = SimpleNamespace(id="j1", name="ignored", payload={"name": "gadget"})
|
|
await run_item_sync(job, {"item_svc": svc})
|
|
|
|
assert svc.created[0]["name"] == "gadget" |