Coverage for microservice_websocket/app/utils/organization.py: 100%

1from ..services.database import Organization 

2from .exceptions import DuplicateException 

3 

4 

5async def get_organizations() -> list[Organization]: 

6 return await Organization.find_all().to_list() 

7 

8 

9async def create_organization(name: str) -> Organization: 

10 organization = await Organization.find_one(Organization.organizationName == name) 

11 

12 if organization is not None: 

13 raise DuplicateException("organizationName") 

14 

15 organization = Organization(organizationName=name) 

16 await organization.save() 

17 

18 return organization