<filename>aiomatrix/client/apis/syncing.py
import uuid
from typing import List, Optional

from aiomatrix import types
from . import raw_api


class SyncingAPI:
    def __init__(self, raw_api_client: raw_api.RawAPI):
        self._raw_api = raw_api_client
        self.state = dict

    async def sync(
            self, filter_id: Optional[str] = None, since: Optional[str] = None, full_state: bool = False,
            set_presence: types.misc.PresenceEnum = types.misc.PresenceEnum.online,
            timeout: int = 0
    ) -> types.responses.SyncResponse:
        payload = {'params': {}}
        if filter_id is not None:
            payload['params']['filter'] = filter_id
        if since is not None:
            payload['params']['since'] = since
        if full_state is not None:
            payload['params']['full_state'] = full_state.__str__().lower()
        if set_presence is not None:
            payload['params']['set_presence'] = f'{set_presence}'
        if timeout is not None:
            payload['params']['timeout'] = timeout
        r = await self._raw_api.make_request(
            'GET', '_matrix/client/r0/sync', model_type=types.responses.SyncResponse, **payload
        )
        return r

    async def get_room_event(
            self, room_id: types.primitives.RoomID, event_id: types.primitives.EventID
    ) -> types.events.RoomEvent:
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/event/{event_id}', model_type=types.events.RoomEvent
        )
        return r

    async def get_room_state(self, room_id: types.primitives.RoomID) -> List[types.events.RoomEvent]:
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/room_events', model_type=types.events.RoomEvent
        )
        return r

    async def get_room_members(
            self, room_id: types.primitives.RoomID, at: Optional[str] = None,
            membership: Optional[types.events.RoomMemberMembershipEnum] = None,
            not_membership: Optional[types.events.RoomMemberMembershipEnum] = None
    ) -> types.responses.RoomMembersResponse:
        payload = {'params': {}}
        if at is not None:
            payload['params']['at'] = at
        if membership is not None:
            payload['params']['membership'] = f'{membership}'
        if not_membership is not None:
            payload['params']['not_membership'] = f'{not_membership}'
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/members', model_type=types.responses.RoomMembersResponse,
            **payload
        )
        return r

    async def get_room_messages(
            self, room_id: types.primitives.RoomID, from_token: str, to: Optional[str] = None, direction: str = 'f',
            limit: int = 10, filter_id: Optional[str] = None
    ) -> types.responses.RoomMessagesResponse:
        payload = {'params': {'from': from_token}}
        if to is not None:
            payload['params']['to'] = to
        if direction is not None:
            payload['params']['dir'] = direction
        if limit is not None:
            payload['params']['limit'] = limit
        if filter_id is not None:
            payload['params']['filter'] = filter_id
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/messages', model_type=types.responses.RoomMessagesResponse,
            **payload
        )
        return r

    async def send_message_event(
            self, room_id: types.primitives.RoomID, event_type: types.misc.RoomEventTypesEnum, content: dict
    ) -> types.responses.SentEventResponse:
        payload = {
            'data': content
        }
        txn_id = f'{uuid.uuid4()}'
        r = await self._raw_api.make_request(
            'PUT', f'_matrix/client/r0/rooms/{room_id}/send/{event_type}/{txn_id}',
            model_type=types.responses.SentEventResponse, **payload
        )
        return r

<filename>aiomatrix/client/apis/syncing.py
import uuid
from typing import List, Optional

from aiomatrix import types
from . import raw_api


class SyncingAPI:
    def __init__(self, raw_api_client: raw_api.RawAPI):
        self._raw_api = raw_api_client
        self.state = dict

    async def sync(
            self, filter_id: Optional[str] = None, since: Optional[str] = None, full_state: bool = False,
            set_presence: types.misc.PresenceEnum = types.misc.PresenceEnum.online,
            timeout: int = 0
    ) -> types.responses.SyncResponse:
        payload = {'params': {}}
        if filter_id is not None:
            payload['params']['filter'] = filter_id
        if since is not None:
            payload['params']['since'] = since
        if full_state is not None:
            payload['params']['full_state'] = full_state.__str__().lower()
        if set_presence is not None:
            payload['params']['set_presence'] = f'{set_presence}'
        if timeout is not None:
            payload['params']['timeout'] = timeout
        r = await self._raw_api.make_request(
            'GET', '_matrix/client/r0/sync', model_type=types.responses.SyncResponse, **payload
        )
        return r

    async def get_room_event(
            self, room_id: types.primitives.RoomID, event_id: types.primitives.EventID
    ) -> types.events.RoomEvent:
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/event/{event_id}', model_type=types.events.RoomEvent
        )
        return r

    async def get_room_state(self, room_id: types.primitives.RoomID) -> List[types.events.RoomEvent]:
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/room_events', model_type=types.events.RoomEvent
        )
        return r

    async def get_room_members(
            self, room_id: types.primitives.RoomID, at: Optional[str] = None,
            membership: Optional[types.events.RoomMemberMembershipEnum] = None,
            not_membership: Optional[types.events.RoomMemberMembershipEnum] = None
    ) -> types.responses.RoomMembersResponse:
        payload = {'params': {}}
        if at is not None:
            payload['params']['at'] = at
        if membership is not None:
            payload['params']['membership'] = f'{membership}'
        if not_membership is not None:
            payload['params']['not_membership'] = f'{not_membership}'
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/members', model_type=types.responses.RoomMembersResponse,
            **payload
        )
        return r

    async def get_room_messages(
            self, room_id: types.primitives.RoomID, from_token: str, to: Optional[str] = None, direction: str = 'f',
            limit: int = 10, filter_id: Optional[str] = None
    ) -> types.responses.RoomMessagesResponse:
        payload = {'params': {'from': from_token}}
        if to is not None:
            payload['params']['to'] = to
        if direction is not None:
            payload['params']['dir'] = direction
        if limit is not None:
            payload['params']['limit'] = limit
        if filter_id is not None:
            payload['params']['filter'] = filter_id
        r = await self._raw_api.make_request(
            'GET', f'_matrix/client/r0/rooms/{room_id}/messages', model_type=types.responses.RoomMessagesResponse,
            **payload
        )
        return r

    async def send_message_event(
            self, room_id: types.primitives.RoomID, event_type: types.misc.RoomEventTypesEnum, content: dict
    ) -> types.responses.SentEventResponse:
        payload = {
            'data': content
        }
        txn_id = f'{uuid.uuid4()}'
        r = await self._raw_api.make_request(
            'PUT', f'_matrix/client/r0/rooms/{room_id}/send/{event_type}/{txn_id}',
            model_type=types.responses.SentEventResponse, **payload
        )
        return r
