module_usage_example.py

import asyncio
import logging
import random
import sys

# pip install SenseLink
from senselink import SenseLink

root = logging.getLogger()
root.setLevel(logging.DEBUG)
handler = logging.StreamHandler(sys.stdout)


async def change_mutable_plug_power(plug):
    while True:
        power = random.randrange(2, 15, 1)
        plug.data_source.power = power
        logging.info(f"Changed power to {power}")
        await asyncio.sleep(random.randrange(1, 4, 1))


# Config example
# sources:
#   - mutable:
#       plugs:
#       - mutable1:
#           alias: "Mutable 1"
#           mac: 50:c7:bf:f6:4f:39 # used specifically below
#           power: 15


async def main():
    # Get config
    config = open('config.yml', 'r')
    # Create controller, with config
    controller = SenseLink(config)
    # Create instances
    controller.create_instances()

    # Get Mutable controller object, and create task to update it
    mutable_plug = controller.plug_for_mac("50:c7:bf:f6:4f:39")
    plug_update = change_mutable_plug_power(mutable_plug)

    # Get base SenseLink tasks (for other controllers in the config, perhaps), and
    # add our new top level plug task, as well as the main SenseLink controller itself
    tasks = controller.tasks
    tasks.add(plug_update)
    tasks.add(controller.server_start())

    # Start all the tasks
    logging.info("Starting SenseLink controller")
    await asyncio.gather(*tasks)


if __name__ == "__main__":
    try:
        asyncio.run(main())
    except KeyboardInterrupt:
        logging.info("Interrupt received, stopping SenseLink")