vendor_fabric.zoom

Zoom connector built on extended-data primitives.

Submodules

Package Contents

Classes

ZoomConnector

Zoom connector for user management.

Data

DEFAULT_REQUEST_TIMEOUT

API

vendor_fabric.zoom.DEFAULT_REQUEST_TIMEOUT = 30
class vendor_fabric.zoom.ZoomConnector(client_id: str | None = None, client_secret: str | None = None, account_id: str | None = None, logger: extended_data.logging.Logging | None = None, **kwargs: Any)

Bases: vendor_fabric.base.ConnectorBase

Zoom connector for user management.

Initialization

Initialize the connector.

Args: api_key: API key (overrides environment variable) base_url: Base URL (overrides class default) timeout: HTTP timeout in seconds logger: Logger instance **kwargs: Passed to InputProvider

get_access_token() → str | None

Get an OAuth access token from Zoom.

get_headers() → dict[str, str]

Get headers with authorization for Zoom API calls.

list_users() → extended_data.containers.ExtendedDict

List all Zoom users.

Returns: Dictionary mapping user emails to user data.

remove_zoom_user(email: str) → None

Remove a Zoom user.

create_zoom_user(email: str, first_name: str, last_name: str) → bool

Create a Zoom user with a paid license.

get_user(user_id: str) → extended_data.containers.ExtendedDict

Get a specific Zoom user by ID or email.

Args: user_id: User ID or email address

Returns: User data dictionary

list_meetings(user_id: str, meeting_type: str = 'scheduled') → extended_data.containers.ExtendedList[extended_data.containers.ExtendedDict]

List meetings for a specific user.

Args: user_id: User ID or email address meeting_type: Type of meetings to list (scheduled, live, upcoming, previous_meetings)

Returns: List of meeting data dictionaries

get_meeting(meeting_id: str) → extended_data.containers.ExtendedDict

Get details of a specific meeting.

Args: meeting_id: Meeting ID

Returns: Meeting data dictionary

BASE_URL: ClassVar[str] = <Multiline-String>
API_KEY_ENV: ClassVar[str] = <Multiline-String>
CONNECTOR_CATEGORY: ClassVar[str] = 'external'
CONNECTOR_CAPABILITIES: ClassVar[tuple[str, ...]] = ()
TIMEOUT: ClassVar[float] = 300.0
MIN_REQUEST_INTERVAL: ClassVar[float] = 0.0
MAX_RETRIES: ClassVar[int] = 5
property api_key: str
property client: httpx.Client
close() → None
request(method: str, endpoint: str, *, headers: dict[str, str] | None = None, **kwargs: Any) → httpx.Response
decode_response(response: httpx.Response, *, suffix: str | None = None, as_extended: bool = True) → Any
decode_response_file(response: httpx.Response, *, source: str | None = None, suffix: str | None = None, as_extended: bool = True, metadata: collections.abc.Mapping[str, Any] | None = None) → extended_data.io.DataFile
extend_result(value: Any) → Any
request_data(method: str, endpoint: str, *, headers: dict[str, str] | None = None, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → Any
request_data_file(method: str, endpoint: str, *, headers: dict[str, str] | None = None, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.io.DataFile
request_workflow(method: str, endpoint: str, *, headers: dict[str, str] | None = None, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.workflows.DataWorkflow
get(endpoint: str, **kwargs: Any) → httpx.Response
get_data(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → Any
get_workflow(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.workflows.DataWorkflow
post(endpoint: str, **kwargs: Any) → httpx.Response
post_data(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → Any
post_workflow(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.workflows.DataWorkflow
put(endpoint: str, **kwargs: Any) → httpx.Response
put_data(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → Any
put_workflow(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.workflows.DataWorkflow
delete(endpoint: str, **kwargs: Any) → httpx.Response
delete_data(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → Any
delete_workflow(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.workflows.DataWorkflow
patch(endpoint: str, **kwargs: Any) → httpx.Response
patch_data(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → Any
patch_workflow(endpoint: str, *, suffix: str | None = None, as_extended: bool = True, **kwargs: Any) → extended_data.workflows.DataWorkflow
download(url: str, output_path: str) → int
vendor_capabilities: ClassVar[dict[str, vendor_fabric.capabilities.CapabilitySpec]] = None
vendor_capability_methods: ClassVar[dict[str, str]] = None
get_input(k: str, default: Any | None = None, required: bool = False, is_bool: bool = False, is_integer: bool = False, is_float: bool = False, is_path: bool = False, is_datetime: bool = False, as_extended: bool = False) → Any
decode_input(k: str, default: Any | None = None, required: bool = False, decode_from_json: bool = False, decode_from_yaml: bool = False, decode_from_base64: bool = False, allow_none: bool = True, as_extended: bool = False) → Any
freeze_inputs() → extended_data.containers.mappings.ExtendedDict
thaw_inputs() → extended_data.containers.mappings.ExtendedDict
snapshot_inputs(*, frozen: bool = False) → extended_data.containers.mappings.ExtendedDict
replace_inputs(new_inputs: collections.abc.Mapping[str, Any] | None, *, clear_frozen: bool = True) → extended_data.containers.mappings.ExtendedDict
merge_inputs(new_inputs: collections.abc.Mapping[str, Any] | None) → extended_data.containers.mappings.ExtendedDict
shift_inputs() → extended_data.containers.mappings.ExtendedDict