validation_decorator.py

def validation_required(validator_function):

    def decorator(function):

        async def error(websocket, err):
            await websocket.send(err)

        async def wrapper(websocket, data):
            status, err = validator_function(data)
            if status:
                return await function(websocket, data)
            else:
                return await error(websocket, err)

        return wrapper

    return decorator
  

def validate(data):
  return True, ""
  
  
@validation_required(validate) 
 async def some_function(websocket, data):
    pass