actr-cli 0.3.1

# DO NOT EDIT - Generated scaffold

from __future__ import annotations

from actr_workload import Workload as WorkloadProtocol

from generated.{{ACTOR_MODULE}} import {{DISPATCHER_NAME}}
from {{PB2_MODULE}} import {{PROTO_MODULE}}_pb2 as pb2


class {{SERVICE_NAME}}Handler:
{{#if HAS_SERVICES}}
{{#each SERVICES}}
{{#each methods}}
    def {{snake_name}}(self, req: pb2.{{input_type}}) -> pb2.{{output_type}}:
        return pb2.{{output_type}}()

{{/each}}
{{/each}}
{{else}}
    pass
{{/if}}


class {{WORKLOAD_NAME}}(WorkloadProtocol):
    def __init__(self) -> None:
        self._dispatcher = {{DISPATCHER_NAME}}({{SERVICE_NAME}}Handler())

    def dispatch(self, envelope) -> bytes:
        return self._dispatcher.dispatch(envelope)

    def on_start(self) -> None:
        return None

    def on_ready(self) -> None:
        return None

    def on_stop(self) -> None:
        return None

    def on_error(self, event) -> None:
        return None

    def on_signaling_connecting(self) -> None:
        return None

    def on_signaling_connected(self) -> None:
        return None

    def on_signaling_disconnected(self) -> None:
        return None

    def on_websocket_connecting(self, event) -> None:
        return None

    def on_websocket_connected(self, event) -> None:
        return None

    def on_websocket_disconnected(self, event) -> None:
        return None

    def on_webrtc_connecting(self, event) -> None:
        return None

    def on_webrtc_connected(self, event) -> None:
        return None

    def on_webrtc_disconnected(self, event) -> None:
        return None

    def on_credential_renewed(self, event) -> None:
        return None

    def on_credential_expiring(self, event) -> None:
        return None

    def on_mailbox_backpressure(self, event) -> None:
        return None


__all__ = ["Workload"]