Python-сообщество

 import uasyncio, uio, machine, sys, uos
import webnode.webmodule as webmodule
from webnode.utils import *
class Stream( uio.IOBase ):
    def __init__( self, wm ):
        self.wm = wm
        
    # запись
    def write( self, d ):
        # потом эти данные будут отправлятся в сокет
        self.wm.wdata.append( d )
    
    def read( self, n = -1 ):
        if not self.wm.rdata: return None
        if n >= 0 and n < len( self.wm.rdata ):
            d = self.wm.rdata[:n]
            self.wm.rdata = self.wm.rdata[n:]
            return d
        d = self.wm.rdata
        self.wm.rdata= '';
        return d
    
    def readline( self ):
        if not self.wm.rdata: return None
        i = self.wm.rdata.find('\r\n')
        return self.read( i )
    
    def readinto( self,  buf ):
        if self.wm.rdata:
            d = self.wm.rdata
            self.wm.rdata = ''
            buf.write( d )
        
    
class WebModule( webmodule.WebModule ):
    
    name = 'Repl'
   
    async def onText( self, frame ):
        self._log('appendData', frame['body'] )
        self.rdata += frame['body']
    
    async def onLoop( self ):
        if self.wdata:
            d = self.wdata.pop(0)
            await self.asocket.asendWS( d )
    
    def onConnect( self, headers ):
        
        self.wdata = []
        self.rdata = ''
        
        await self.asocket.asendWS( data='Прювет из модуля '+self.name )
        self.stream = Stream( self )
        uos.dupterm( self.stream, 1)
    
    def onSocketError( self, msg = 'socket error' ):
        self._log( msg )
        self.disconnect()
        return False
    
    def disconnect( self ):
        self._log('disconnect')
        uart = machine.UART(0, 115200)
        uos.dupterm(uart, 1)
        del self.stream.wm
        del self.stream
        del self.asocket