hudiy.eu

Code: Select all

#
#  Copyright (C) Hudiy Project - All Rights Reserved
#

import threading
import common.Api_pb2 as hudiy_api
from common.Client import Client, ClientEventHandler


class EventHandler(ClientEventHandler):

    def on_hello_response(self, client, message):
        print(
            "received hello response, result: {}, app version: {}.{}, api version: {}.{}"
            .format(message.result, message.app_version.major,
                    message.app_version.minor, message.api_version.major,
                    message.api_version.minor))

        set_status_subscriptions = hudiy_api.SetStatusSubscriptions()
        set_status_subscriptions.subscriptions.append(
            hudiy_api.SetStatusSubscriptions.Subscription.PROJECTION)
        set_status_subscriptions.subscriptions.append(
            hudiy_api.SetStatusSubscriptions.Subscription.PHONE)
        client.send(hudiy_api.MESSAGE_SET_STATUS_SUBSCRIPTIONS, 0,
                    set_status_subscriptions.SerializeToString())

    def on_projection_status(self, client, message):
        print("projection status, active: {}".format(message.active))

        if message.active:
            threading.Timer(
                10.0, 
                self.dispatch_action, 
                args=[client, "quit_android_auto"]
            ).start()

    def on_phone_connection_status(self, client, message):
        print("phone connection status: {}, name: {}".format(
            message.state, message.name))

        if message.state == hudiy_api.PhoneConnectionStatus.PHONE_CONNECTION_STATE_CONNECTED:
            threading.Timer(
                10.0, 
                self.dispatch_action, 
                args=[client, "connect_android_auto_wifi"]
            ).start()

    def dispatch_action(self, client, action_name):
        dispatch_action = hudiy_api.DispatchAction()
        dispatch_action.action = action_name
        client.send(hudiy_api.MESSAGE_DISPATCH_ACTION, 0,
                    dispatch_action.SerializeToString())


def main():
    client = Client("projection status example")
    event_handler = EventHandler()
    client.set_event_handler(event_handler)
    client.connect('127.0.0.1', 44405)

    active = True
    while active:
        try:
            active = client.wait_for_message()
        except KeyboardInterrupt:
            break

    client.disconnect()


if __name__ == "__main__":
    main()