Airbyte Source HubSpot

from source_hubspot import SourceHubspot
from source_hubspot.run import run

from source_hubspot.streams import (
    API, Contacts, Companies, Deals, Tickets, Leads, DealSplits,
    EngagementsCalls, EngagementsEmails, Forms, Goals, LineItems,
    Products, FeedbackSubmissions, CustomObject, WebAnalyticsStream
)

from source_hubspot import SourceHubspot
from airbyte_cdk.models import ConfiguredAirbyteCatalog

# OAuth configuration
config = {
    "credentials": {
        "credentials_title": "OAuth Credentials",
        "client_id": "your_client_id",
        "client_secret": "your_client_secret",
        "refresh_token": "your_refresh_token"
    },
    "start_date": "2023-01-01T00:00:00Z"
}

# Create source instance
source = SourceHubspot(catalog=None, config=config, state=None)

# Check connection
is_healthy, error = source.check_connection(logger, config)

# Get available streams
streams = source.streams(config)

class SourceHubspot(YamlDeclarativeSource):
    def __init__(catalog: Optional[ConfiguredAirbyteCatalog], config: Optional[Mapping[str, Any]], state: TState, **kwargs): ...
    def check_connection(logger: logging.Logger, config: Mapping[str, Any]) -> Tuple[bool, Optional[Any]]: ...
    def streams(config: Mapping[str, Any]) -> List[Stream]: ...

class API:
    def __init__(credentials: Mapping[str, Any]): ...
    def get(url: str, params: MutableMapping[str, Any] = None) -> Tuple[Union[MutableMapping[str, Any], List[MutableMapping[str, Any]]], requests.Response]: ...
    def post(url: str, data: Mapping[str, Any], params: MutableMapping[str, Any] = None) -> Tuple[Union[Mapping[str, Any], List[Mapping[str, Any]]], requests.Response]: ...
    def get_custom_objects_metadata() -> Iterable[Tuple[str, str, Mapping[str, Any]]]: ...

class Contacts(CRMSearchStream): ...
class Companies(CRMSearchStream): ...
class Deals(CRMSearchStream): ...
class Tickets(CRMSearchStream): ...
class Leads(CRMSearchStream): ...
class DealSplits(CRMSearchStream): ...

class EngagementsCalls(CRMSearchStream): ...
class EngagementsEmails(CRMSearchStream): ...
class EngagementsMeetings(CRMSearchStream): ...
class EngagementsNotes(CRMSearchStream): ...
class EngagementsTasks(CRMSearchStream): ...

class Forms(ClientSideIncrementalStream): ...
class FormSubmissions(ClientSideIncrementalStream): ...
class Owners(ClientSideIncrementalStream): ...
class Products(CRMObjectIncrementalStream): ...
class Goals(CRMObjectIncrementalStream): ...
class LineItems(CRMObjectIncrementalStream): ...
class FeedbackSubmissions(CRMObjectIncrementalStream): ...

class CustomObject(CRMSearchStream, ABC):
    def __init__(entity: str, schema: Mapping[str, Any], fully_qualified_name: str, custom_properties: Mapping[str, Any], **kwargs): ...

class WebAnalyticsStream(HttpSubStream, BaseStream): ...
class ContactsWebAnalytics(WebAnalyticsStream): ...
class CompaniesWebAnalytics(WebAnalyticsStream): ...

class HubspotError(AirbyteTracedException): ...
class HubspotInvalidAuth(HubspotError): ...
class HubspotRateLimited(HTTPError): ...
class HubspotTimeout(HTTPError): ...

class CompaniesPropertyHistory(IncrementalStream): ...
class ContactsPropertyHistory(IncrementalStream): ...
class DealsPropertyHistory(IncrementalStream): ...

class BaseStream(HttpStream, ABC): ...
class IncrementalStream(BaseStream, ABC): ...
class CRMSearchStream(IncrementalStream, ABC): ...
class CRMObjectStream(BaseStream): ...
class CRMObjectIncrementalStream(CRMObjectStream, IncrementalStream): ...
class ClientSideIncrementalStream(BaseStream, CheckpointMixin): ...

# Configuration types
Mapping[str, Any]  # Configuration object
List[Stream]      # Stream collection
Tuple[bool, Optional[Any]]  # Check connection result

# Authentication credential types
class OAuthCredentials:
    credentials_title: str = "OAuth Credentials"
    client_id: str
    client_secret: str
    refresh_token: str

class PrivateAppCredentials:  
    credentials_title: str = "Private App Credentials"
    access_token: str