From b0bf43e6a272d42a55158e657bd937cb82fc3d8d Mon Sep 17 00:00:00 2001
From: Evgeny Zinoviev <me@ch1p.io>
Date: Sat, 10 Jun 2023 23:02:34 +0300
Subject: move files, rename home package to homekit

---
 src/home/relay/sunxi_h3_server.py | 82 ---------------------------------------
 1 file changed, 82 deletions(-)
 delete mode 100644 src/home/relay/sunxi_h3_server.py

(limited to 'src/home/relay/sunxi_h3_server.py')

diff --git a/src/home/relay/sunxi_h3_server.py b/src/home/relay/sunxi_h3_server.py
deleted file mode 100644
index 1f33969..0000000
--- a/src/home/relay/sunxi_h3_server.py
+++ /dev/null
@@ -1,82 +0,0 @@
-import asyncio
-import logging
-
-from pyA20.gpio import gpio
-from pyA20.gpio import port as gpioport
-from ..util import Addr
-
-logger = logging.getLogger(__name__)
-
-
-class RelayServer:
-    OFF = 1
-    ON = 0
-
-    def __init__(self,
-                 pinname: str,
-                 addr: Addr):
-        if not hasattr(gpioport, pinname):
-            raise ValueError(f'invalid pin {pinname}')
-
-        self.pin = getattr(gpioport, pinname)
-        self.addr = addr
-
-        gpio.init()
-        gpio.setcfg(self.pin, gpio.OUTPUT)
-
-        self.lock = asyncio.Lock()
-
-    def run(self):
-        asyncio.run(self.run_server())
-
-    async def relay_set(self, value):
-        async with self.lock:
-            gpio.output(self.pin, value)
-
-    async def relay_get(self):
-        async with self.lock:
-            return int(gpio.input(self.pin)) == RelayServer.ON
-
-    async def handle_client(self, reader, writer):
-        request = None
-        while request != 'quit':
-            try:
-                request = await reader.read(255)
-                if request == b'\x04':
-                    break
-                request = request.decode('utf-8').strip()
-            except Exception:
-                break
-
-            data = 'unknown'
-            if request == 'on':
-                await self.relay_set(RelayServer.ON)
-                logger.debug('set on')
-                data = 'ok'
-
-            elif request == 'off':
-                await self.relay_set(RelayServer.OFF)
-                logger.debug('set off')
-                data = 'ok'
-
-            elif request == 'get':
-                status = await self.relay_get()
-                data = 'on' if status is True else 'off'
-
-            writer.write((data + '\r\n').encode('utf-8'))
-            try:
-                await writer.drain()
-            except ConnectionError:
-                break
-
-        try:
-            writer.close()
-        except ConnectionError:
-            pass
-
-    async def run_server(self):
-        host, port = self.addr
-        server = await asyncio.start_server(self.handle_client, host, port)
-        async with server:
-            logger.info('Server started.')
-            await server.serve_forever()
-- 
cgit v1.2.3