from socket import *
import sys
import time
import threading
import random
from twisted.internet import task
from twisted.internet import reactor

host = 'localhost'
port = 10003
addr = (host, port)
timeout = 60.0
class connMake():
    def __init__(self):
        self.sock = socket(AF_INET, SOCK_STREAM)
        self.msg = ''

    def madeConn(self):
        self.sock.connect(addr)

    def sendMsg(self, msg):
        self.sock.send(msg.encode())
        print('send:', msg)
        self.data = self.sock.recv(1024)
        print('receive:', self.data)


class watleakS(connMake):  # датчик протечки воды
    def __init__(self):
        self.bg = '1010'
        self.sock = ''
        self.id = '101'
        self.addr = '001'
        self.data = '00000'
        self.batt = 'bat'
        self.crc = ''
        self.fn = '1011'
    def fuck(self):
        self.sendMsg("fdfdfdfd")
sock = socket(AF_INET, SOCK_STREAM)
sock.connect(addr)
p=watleakS()
l = task.LoopingCall(p.fuck)
l.start(timeout)
reactor.run()