|
7 | 7 | from sqlalchemy.orm import Session |
8 | 8 |
|
9 | 9 | import schemas.schema |
| 10 | +from crud.charge import add_charge |
10 | 11 | from crud.company import create_company |
11 | 12 | from crud.contact import create_contact |
12 | 13 | from crud.message import save_message |
13 | 14 | from models.message import MessageType |
14 | 15 | from models.message import Carrier |
15 | | -from models.message import Message |
16 | 16 | from models.payment import Organization |
17 | 17 | from tests.test_database import SQLALCHEMY_DATABASE_URL |
18 | 18 |
|
@@ -52,20 +52,36 @@ def client(db): |
52 | 52 |
|
53 | 53 | @pytest.fixture |
54 | 54 | def organization(db): |
55 | | - create_company(db, schemas.schema.CreateCompany(name="Test org", org_id=12345)) |
| 55 | + yield create_company( |
| 56 | + db, schemas.schema.CreateCompany(name="Test org", org_id=12345) |
| 57 | + ) |
| 58 | + |
| 59 | + |
| 60 | +@pytest.fixture |
| 61 | +@pytest.mark.asyncio |
| 62 | +async def charge_onboarding(db, organization): |
| 63 | + await add_charge( |
| 64 | + db, |
| 65 | + schemas.schema.CreateCharge( |
| 66 | + company_name="Test org", |
| 67 | + currency="USD", |
| 68 | + charge_type="ONBOARDING", |
| 69 | + amount=200, |
| 70 | + ), |
| 71 | + organization.id, |
| 72 | + ) |
56 | 73 |
|
57 | 74 |
|
58 | 75 | @pytest.fixture |
59 | | -def message(db): |
| 76 | +@pytest.mark.asyncio |
| 77 | +async def message(db): |
60 | 78 | message_data = dict( |
61 | 79 | message_id="123657ab", |
62 | 80 | status_code=202, |
63 | 81 | message_type=MessageType.EMAIL.value, |
64 | 82 | carrier=Carrier.SENDGRID.value, |
65 | 83 | ) |
66 | | - db_item = Message(**message_data) |
67 | | - db.add(db_item) |
68 | | - db.commit() |
| 84 | + await save_message(db, message_data) |
69 | 85 |
|
70 | 86 |
|
71 | 87 | @pytest.fixture |
|
0 commit comments