{{ description }}
+ +{{ form.answer }}
+ {{ description }}
+ +Internal meeting notes
", +# "status": "active", +# "start_time": "2019-08-24T14:15:22.123456Z", +# "end_time": "2019-08-24T14:15:22.123456Z", +# "event_type": "https://api.calendly.com/event_types/GBGBDCAADAEDCRZ2", +# "location": { +# "type": "physical", +# "location": "string", +# "additional_info": "string" +# }, +# "invitees_counter": { +# "total": 0, +# "active": 0, +# "limit": 0 +# }, +# "created_at": "2019-01-02T03:04:05.678123Z", +# "updated_at": "2019-01-02T03:04:05.678123Z", +# "event_memberships": [ +# { +# "user": "https://api.calendly.com/users/GBGBDCAADAEDCRZ2", +# "user_email": "user@example.com", +# "user_name": "John Smith" +# } +# ], +# "event_guests": [ +# { +# "email": "user@example.com", +# "created_at": "2019-08-24T14:15:22.123456Z", +# "updated_at": "2019-08-24T14:15:22.123456Z" +# } +# ] +# } +# } + def invitee_created(client, webhook, payload: dict): # lazyload to fix circular import - from breathecode.mentorship.models import MentorshipService, MentorProfile, MentorshipSession + from breathecode.mentorship.models import MentorProfile, MentorshipService, MentorshipSession + from breathecode.mentorship.tasks import create_room_on_google_meet + # from breathecode.events.actions import update_or_create_event # payload = payload['resource'] @@ -80,4 +166,7 @@ def invitee_created(client, webhook, payload: dict): session.calendly_uuid = event_uuid session.save() + if session.service and session.service.video_provider == MentorshipService.VideoProvider.GOOGLE_MEET: + create_room_on_google_meet.delay(session.id) + return session diff --git a/breathecode/services/google_meet/__init__.py b/breathecode/services/google_meet/__init__.py new file mode 100644 index 000000000..1919cdab5 --- /dev/null +++ b/breathecode/services/google_meet/__init__.py @@ -0,0 +1 @@ +from .google_meet import * # noqa: F401 diff --git a/breathecode/services/google_meet/google_meet.py b/breathecode/services/google_meet/google_meet.py index 2b0d1909f..9fe838196 100644 --- a/breathecode/services/google_meet/google_meet.py +++ b/breathecode/services/google_meet/google_meet.py @@ -1,7 +1,82 @@ -from typing import Optional +from typing import Optional, TypedDict, Unpack +import google.apps.meet_v2.services.conference_records_service.pagers as pagers from asgiref.sync import async_to_sync from google.apps import meet_v2 +from google.apps.meet_v2.types import Space +from google.protobuf.field_mask_pb2 import FieldMask +from google.protobuf.timestamp_pb2 import Timestamp + +__all__ = ['GoogleMeet'] + + +class CreateSpaceRequest(TypedDict): + space: Space + + +class EndActiveConferenceRequest(TypedDict): + name: str + + +class GetConferenceRecordRequest(TypedDict): + name: str + + +class GetParticipantRequest(TypedDict): + name: str + + +class GetParticipantSessionRequest(TypedDict): + name: str + + +class GetRecordingRequest(TypedDict): + name: str + + +class GetSpaceRequest(TypedDict): + name: str + + +class UpdateSpaceRequest(TypedDict): + space: Space + update_mask: FieldMask + + +class GetTranscriptRequest(TypedDict): + name: str + + +class ListConferenceRecordsRequest(TypedDict): + page_size: int + page_token: str + filter: str # in EBNF format, space.meeting_code, space.name, start_time and end_time + + +class ListRecordingsRequest(TypedDict): + parent: str + page_size: int + page_token: str + + +class ListParticipantSessionsRequest(TypedDict): + parent: str + page_size: int + page_token: str + filter: str # in EBNF format, start_time and end_time + + +class ListTranscriptsRequest(TypedDict): + parent: str + page_size: int + page_token: str + + +class ListParticipantsRequest(TypedDict): + parent: str + page_size: int + page_token: str + filter: str # in EBNF format, start_time and end_time class GoogleMeet: @@ -9,9 +84,12 @@ class GoogleMeet: _conference_records_service_client: Optional[meet_v2.ConferenceRecordsServiceAsyncClient] def __init__(self): + from breathecode.setup import resolve_gcloud_credentials + + resolve_gcloud_credentials() + self._spaces_service_client = None self._conference_records_service_client = None - pass async def spaces_service_client(self): if self._spaces_service_client is None: @@ -25,31 +103,28 @@ async def conference_records_service_client(self): return self._conference_records_service_client - async def acreate_meeting(self, **kwargs): + async def acreate_space(self, **kwargs: Unpack[CreateSpaceRequest]) -> meet_v2.Space: # Create a client client = await self.spaces_service_client() # Initialize request argument(s) - request = meet_v2.CreateSpaceRequest() + request = meet_v2.CreateSpaceRequest(**kwargs) # Make the request - response = await client.create_space(request=request) - - # Handle the response - print(response) + return await client.create_space(request=request) @async_to_sync - async def create_meeting(self): - return await self.acreate_meeting() + async def create_space(self, **kwargs: Unpack[CreateSpaceRequest]) -> meet_v2.Space: + return await self.acreate_space(**kwargs) - async def aget_meeting(self): + async def aget_space(self, **kwargs: Unpack[GetSpaceRequest]) -> meet_v2.Space: # Create a client client = await self.spaces_service_client() # Initialize request argument(s) - request = meet_v2.GetSpaceRequest() + request = meet_v2.GetSpaceRequest(**kwargs) # Make the request response = await client.get_space(request=request) @@ -58,15 +133,15 @@ async def aget_meeting(self): print(response) @async_to_sync - async def get_meeting(self): - return await self.aget_meeting() + async def get_space(self, **kwargs: Unpack[GetSpaceRequest]) -> meet_v2.Space: + return await self.aget_space(**kwargs) - async def aupdate_space(self): + async def aupdate_space(self, **kwargs: Unpack[UpdateSpaceRequest]) -> meet_v2.Space: # Create a client client = await self.spaces_service_client() # Initialize request argument(s) - request = meet_v2.UpdateSpaceRequest() + request = meet_v2.UpdateSpaceRequest(**kwargs) # Make the request response = await client.update_space(request=request) @@ -75,117 +150,90 @@ async def aupdate_space(self): print(response) @async_to_sync - async def update_space(self): - return await self.aupdate_space() + async def update_space(self, **kwargs: Unpack[UpdateSpaceRequest]) -> meet_v2.Space: + return await self.aupdate_space(**kwargs) - async def aend_meeting(self, name: str): + async def aend_active_conference(self, **kwargs: Unpack[EndActiveConferenceRequest]) -> None: # Create a client client = await self.spaces_service_client() # Initialize request argument(s) - request = meet_v2.EndActiveConferenceRequest(name=name) + request = meet_v2.EndActiveConferenceRequest(**kwargs) # Make the request - await client.end_active_conference(request=request) + return await client.end_active_conference(request=request) @async_to_sync - async def end_meeting(self, name: str): - return await self.aend_meeting(name) + async def end_active_conference(self, **kwargs: Unpack[EndActiveConferenceRequest]) -> None: + return await self.aend_active_conference(**kwargs) - async def alist_participants(self, parent: str): + async def alist_participants(self, **kwargs: Unpack[ListParticipantsRequest]) -> pagers.ListParticipantsAsyncPager: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.ListParticipantsRequest(parent=parent) + request = meet_v2.ListParticipantsRequest(**kwargs) # Make the request - page_result = client.list_participants(request=request) - - # Handle the response - async for response in page_result: - print(response) + return await client.list_participants(request=request) - @async_to_sync - async def list_participants(self, parent: str): - return await self.alist_participants(parent) - - async def aget_participant(self, name: str): + async def aget_participant(self, **kwargs: Unpack[GetParticipantRequest]) -> meet_v2.Participant: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.GetParticipantRequest(name=name) + request = meet_v2.GetParticipantRequest(**kwargs) # Make the request - response = await client.get_participant(request=request) - - # Handle the response - print(response) + return await client.get_participant(request=request) @async_to_sync - async def get_participant(self, name: str): - return await self.aget_participant(name) + async def get_participant(self, **kwargs: Unpack[GetParticipantRequest]) -> meet_v2.Participant: + return await self.aget_participant(**kwargs) - async def alist_participant_sessions(self, parent: str): + async def alist_participant_sessions( + self, **kwargs: Unpack[ListParticipantSessionsRequest]) -> pagers.ListParticipantSessionsAsyncPager: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.ListParticipantSessionsRequest(parent=parent) + request = meet_v2.ListParticipantSessionsRequest(**kwargs) # Make the request - page_result = client.list_participant_sessions(request=request) - - # Handle the response - async for response in page_result: - print(response) - - @async_to_sync - async def list_participant_sessions(self, parent: str): - return await self.alist_participant_sessions(parent) + return await client.list_participant_sessions(request=request) - async def aget_participant_session(self, name: str): + async def aget_participant_session(self, + **kwargs: Unpack[GetParticipantSessionRequest]) -> meet_v2.ParticipantSession: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.GetParticipantSessionRequest(name=name) + request = meet_v2.GetParticipantSessionRequest(**kwargs) # Make the request - response = await client.get_participant_session(request=request) - - # Handle the response - print(response) + return await client.get_participant_session(request=request) @async_to_sync - async def get_participant_session(self, name: str): - return await self.aget_participant_session(name) + async def get_participant_session(self, + **kwargs: Unpack[GetParticipantSessionRequest]) -> meet_v2.ParticipantSession: + return await self.aget_participant_session(**kwargs) - async def alist_recordings(self, parent: str): + async def alist_recordings(self, **kwargs: Unpack[ListRecordingsRequest]) -> pagers.ListRecordingsAsyncPager: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.ListRecordingsRequest(parent=parent) + request = meet_v2.ListRecordingsRequest(**kwargs) # Make the request - page_result = client.list_recordings(request=request) + return await client.list_recordings(request=request) - # Handle the response - async for response in page_result: - print(response) - - @async_to_sync - async def list_recordings(self, parent: str): - return await self.alist_recordings(parent) - - async def aget_recording(self, name: str): + async def aget_recording(self, **kwargs: Unpack[GetRecordingRequest]) -> meet_v2.Recording: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.GetRecordingRequest(name=name) + request = meet_v2.GetRecordingRequest(**kwargs) # Make the request response = await client.get_recording(request=request) @@ -194,33 +242,25 @@ async def aget_recording(self, name: str): print(response) @async_to_sync - async def get_recording(self, name: str): - return await self.aget_recording(name) + async def get_recording(self, **kwargs: Unpack[GetRecordingRequest]) -> meet_v2.Recording: + return await self.aget_recording(**kwargs) - async def alist_transcripts(self, parent: str): + async def alist_transcripts(self, **kwargs: Unpack[ListTranscriptsRequest]) -> pagers.ListTranscriptsAsyncPager: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.ListTranscriptsRequest(parent=parent) + request = meet_v2.ListTranscriptsRequest(**kwargs) # Make the request - page_result = client.list_transcripts(request=request) - - # Handle the response - async for response in page_result: - print(response) - - @async_to_sync - async def list_transcripts(self, parent: str): - return await self.alist_transcripts(parent) + return await client.list_transcripts(request=request) - async def aget_transcript(self, name: str): + async def aget_transcript(self, **kwargs: Unpack[GetTranscriptRequest]) -> meet_v2.Transcript: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.GetTranscriptRequest(name=name) + request = meet_v2.GetTranscriptRequest(**kwargs) # Make the request response = await client.get_transcript(request=request) @@ -229,40 +269,30 @@ async def aget_transcript(self, name: str): print(response) @async_to_sync - async def get_transcript(self, name: str): - return await self.aget_transcript(name) + async def get_transcript(self, **kwargs: Unpack[GetTranscriptRequest]) -> meet_v2.Transcript: + return await self.aget_transcript(**kwargs) - async def alist_conference_records(self): + async def alist_conference_records( + self, **kwargs: Unpack[ListConferenceRecordsRequest]) -> pagers.ListConferenceRecordsAsyncPager: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.ListConferenceRecordsRequest() + request = meet_v2.ListConferenceRecordsRequest(**kwargs) # Make the request - page_result = client.list_conference_records(request=request) + return await client.list_conference_records(request=request) - # Handle the response - async for response in page_result: - print(response) - - @async_to_sync - async def list_conference_records(self): - return await self.alist_conference_records() - - async def aget_conference_record(self, name: str): + async def aget_conference_record(self, **kwargs: Unpack[GetConferenceRecordRequest]) -> meet_v2.ConferenceRecord: # Create a client client = await self.conference_records_service_client() # Initialize request argument(s) - request = meet_v2.GetConferenceRecordRequest(name=name) + request = meet_v2.GetConferenceRecordRequest(**kwargs) # Make the request - response = await client.get_conference_record(request=request) - - # Handle the response - print(response) + return await client.get_conference_record(request=request) @async_to_sync - async def get_conference_record(self, name: str): - return await self.aget_conference_record(name) + async def get_conference_record(self, **kwargs: Unpack[GetConferenceRecordRequest]) -> meet_v2.ConferenceRecord: + return await self.aget_conference_record(**kwargs) diff --git a/breathecode/tests/mixins/generate_models_mixin/utils/create_models.py b/breathecode/tests/mixins/generate_models_mixin/utils/create_models.py index 2b286e4a0..210d466cf 100644 --- a/breathecode/tests/mixins/generate_models_mixin/utils/create_models.py +++ b/breathecode/tests/mixins/generate_models_mixin/utils/create_models.py @@ -1,9 +1,10 @@ import logging from typing import Any -from breathecode.tests.mixins.generate_models_mixin.exceptions import BadArgument from mixer.backend.django import mixer +from breathecode.tests.mixins.generate_models_mixin.exceptions import BadArgument + from .argument_parser import argument_parser __all__ = ['create_models'] @@ -44,8 +45,8 @@ def debug_mixer(attr, path, **kwargs): def create_models(attr, path, **kwargs): - # does not remove this line are use very often - # debug_mixer(attr, path, **kwargs) + # does not remove this line it's used very often + debug_mixer(attr, path, **kwargs) result = [ cycle(how_many).blend(path, **{ diff --git a/capyc/django/pytest/fixtures/database.py b/capyc/django/pytest/fixtures/database.py index 8da56a78e..bb691aef1 100644 --- a/capyc/django/pytest/fixtures/database.py +++ b/capyc/django/pytest/fixtures/database.py @@ -3,6 +3,7 @@ import functools import random import re +from copy import copy from typing import Any, Generator, final import pytest @@ -352,6 +353,12 @@ def create(cls, **models): pending = {} + keys = [*models.keys()] + + for key in keys: + if models[key] is None or models[key] == 0: + del models[key] + # get descriptors for model_alias, _value in models.items(): try: