Merge pull request '[DeviceShare] V1.0' (#12) from dev into master

Author: mahaotian

.DS_Store

@@ -3,4 +3,8 @@
 ./devices.json
 /dist/
 /build/
-*.spec
+*.spec
+**/*.key
+**/*.pyc
+**/*.db
+.DS_Store

.gitignore

@@ -0,0 +1,4 @@
+import pyperclip
+
+pyperclip.copy("123")
+print(pyperclip.paste())

cliptest.py

@@ -0,0 +1,58 @@
+import sys
+
+
+from PyQt5.QtWidgets import QApplication, QDialog, QVBoxLayout, QPushButton, QLabel
+import qt_material
+from src.sharer.client import Client
+from src.sharer.server import Server
+
+
+class RoleSelectionDialog(QDialog):
+    def __init__(self):
+        super().__init__()
+
+        self.setFixedSize(400, 200)
+
+        self.setWindowTitle("身份选择")
+        self.layout = QVBoxLayout()
+
+        self.server_button = QPushButton("主控机")
+        self.client_button = QPushButton("被控机")
+
+        self.layout.addWidget(self.server_button)
+        self.layout.addWidget(self.client_button)
+
+        self.setLayout(self.layout)
+
+        self.server_button.clicked.connect(self.select_server)
+        self.client_button.clicked.connect(self.select_client)
+
+        self.selected_role = None
+
+    def select_server(self):
+        self.selected_role = "server"
+        self.accept()
+
+    def select_client(self):
+        self.selected_role = "client"
+        self.accept()
+
+
+def main():
+    app = QApplication(sys.argv)
+    qt_material.apply_stylesheet(app, theme='dark_blue.xml')
+    selected_role = 'client'
+    # 显示身份选择弹窗
+    role_dialog = RoleSelectionDialog()
+    if role_dialog.exec_() == QDialog.Accepted:
+        selected_role = role_dialog.selected_role
+    # 销毁 GUI
+    app.exit()
+    if selected_role == 'server':
+        Server()
+    elif selected_role == 'client':
+        Client()
+
+
+if __name__ == "__main__":
+    main()

deviceShare.py

@@ -0,0 +1,98 @@
+import threading
+import time
+
+from evdev import InputDevice, categorize, ecodes, list_devices, UInput
+import os
+
+
+class KeyboardController:
+    def __init__(self):
+        devices = [InputDevice(path) for path in list_devices()]
+        # 打印所有设备以便调试
+        # for device in devices:
+        #     print(f"设备名: {device.name}, 设备路径: {device.path}")
+        # 找到在线的键盘设备
+        self.stop_event = threading.Event()
+
+        self.keyboard_devices = []
+        for device in devices:
+            if not os.path.exists(device.path):
+                continue
+            capabilities = device.capabilities()
+            if ecodes.EV_KEY in capabilities and ecodes.EV_SYN in capabilities:
+                if ecodes.KEY_A in capabilities[ecodes.EV_KEY]:  # 检查是否有键盘按键
+                    self.keyboard_devices.append(device)
+        capabilities = {ecodes.EV_KEY: list(ecodes.keys.keys())}
+        self.ui = UInput(capabilities, name="virtual_keyboard")
+
+    def press(self, key):
+        self.ui.write(ecodes.EV_KEY, key, 1)
+        self.ui.syn()
+
+    def release(self, key):
+        self.ui.write(ecodes.EV_KEY, ecodes.KEY_A, 0)
+        self.ui.syn()
+
+    def click(self, click_type, keyData):
+        key = self.keyFactory.outPut(keyData)
+        if click_type == 'press':
+            self.press(key)
+        elif click_type == 'release':
+            self.release(key)
+
+    def run_keyboard_listener(self, keyboard, on_press, on_release, suppress=False):
+        if suppress:
+            keyboard.grab()
+        try:
+            while not self.stop_event.is_set():
+                event = keyboard.read_one()  # 非阻塞读取事件
+                if event:
+                    if event.type == ecodes.EV_KEY:
+                        key_event = categorize(event)
+                        if key_event.keystate == key_event.key_down:
+                            on_press(key_event.keycode)
+                        elif key_event.keystate == key_event.key_up:
+                            on_release(key_event.keycode)
+                else:
+                    time.sleep(0.01)  # 如果没有事件，休眠一段时间，减少 CPU 使用率
+        except KeyboardInterrupt:
+            print("Stopped listening for events.")
+        except Exception as e:
+            print(f"发生错误: {e}")
+        finally:
+            if suppress:
+                keyboard.ungrab()
+
+    def keyboard_listener(self, on_press, on_release, suppress=False):
+        self.listener = []
+        for keyboard in self.keyboard_devices:
+            print(f"监听设备: {keyboard.name} at {keyboard.path}")
+            self.listener.append(
+                threading.Thread(target=self.run_keyboard_listener, args=(keyboard, on_press, on_release, suppress)))
+        for i in self.listener:
+            i.start()
+        return self.listener
+
+    def stop_listener(self):
+        self.stop_event.set()
+        self.listener.clear()
+
+    def __del__(self):
+        self.ui.close()
+
+
+if __name__ == '__main__':
+    def on_press(key):
+        print(f"按下: {key}")
+
+    def on_release(key):
+        print(f"释放: {key}")
+
+    keyboardController = KeyboardController()
+    keyboardController.keyboard_listener(on_press, on_release, suppress=False)
+    for i in range(10):
+        keyboardController.press(ecodes.KEY_A)
+        time.sleep(0.01)
+        keyboardController.release(ecodes.KEY_A)
+        time.sleep(1)
+    keyboardController.stop_listener()

devices.json

@@ -0,0 +1,124 @@
+import threading
+import time
+
+from evdev import InputDevice, categorize, ecodes, list_devices, UInput
+import subprocess
+
+
+class MouseController:
+
+    def __init__(self):
+        devices = [InputDevice(path) for path in list_devices()]
+        self.stop_event = threading.Event()
+        self.mouse_devices = []
+        for device in devices:
+            capabilities = device.capabilities()
+            if ecodes.EV_REL in capabilities and ecodes.EV_KEY in capabilities:
+                if ecodes.REL_X in capabilities[ecodes.EV_REL] and ecodes.REL_Y in capabilities[ecodes.EV_REL]:
+                    if ecodes.BTN_LEFT in capabilities[ecodes.EV_KEY] or ecodes.BTN_RIGHT in capabilities[
+                        ecodes.EV_KEY]:
+                        self.mouse_devices.append(device)
+        capabilities = {ecodes.EV_REL: [ecodes.REL_X, ecodes.REL_Y, ecodes.REL_WHEEL],
+                        ecodes.EV_KEY: [ecodes.BTN_LEFT, ecodes.BTN_RIGHT, ecodes.BTN_MIDDLE]}
+        self.ui = UInput(capabilities, name="virtual_mouse")
+
+    def update_last_position(self):
+        pass
+
+    def get_last_position(self):
+        pass
+
+    def get_position(self):
+        result = subprocess.run(['xdotool', 'getmouselocation'], stdout=subprocess.PIPE, stderr=subprocess.PIPE,
+                                text=True)
+        output = result.stdout
+        # 解析输出
+        location = {}
+        for item in output.split():
+            key, value = item.split(':')
+            location[key] = int(value)
+        return location['x'], location['y']
+
+    def move_to(self, position: tuple):
+        pass
+
+    def move(self, dx, dy):
+        pass
+
+    def scroll(self, dx, dy):
+        pass
+
+    def click(self, button, pressed):
+        pass
+
+    def run_mouse_listener(self, mouse, on_click, on_move, on_scroll, suppress=False):
+        if suppress:
+            mouse.grab()
+        try:
+            while not self.stop_event.is_set():
+                event = mouse.read_one()  # 非阻塞读取事件
+                if event:
+                    if event.type == ecodes.EV_REL:
+                        # if event.code == ecodes.REL_X:
+                        #     on_move(event.value, 0)
+                        # elif event.code == ecodes.REL_Y:
+                        #     on_move(0, event.value)
+                        # elif event.code == ecodes.REL_WHEEL:
+                        #     on_scroll(0, event.value)
+                        print(f"REL: {event}")
+                    elif event.type == ecodes.EV_KEY:
+                        if event.code == ecodes.BTN_LEFT:
+                            if event.value == 1:
+                                on_click('Button.left', 'press')
+                            elif event.value == 0:
+                                on_click('Button.left', 'release')
+                        elif event.code == ecodes.BTN_RIGHT:
+                            if event.value == 1:
+                                on_click('Button.right', 'press')
+                            elif event.value == 0:
+                                on_click('Button.right', 'release')
+                else:
+                    time.sleep(0.01)
+        except KeyboardInterrupt:
+            print("Stopped listening for events.")
+        except Exception as e:
+            print(f"发生错误: {e}")
+        finally:
+            if suppress:
+                mouse.ungrab()
+
+    def mouse_listener(self, on_click, on_move, on_scroll, suppress=False):
+        self.listener = []
+        for mouse in self.mouse_devices:
+            print(f"监听设备: {mouse.name} at {mouse.path}")
+            self.listener.append(threading.Thread(target=self.run_mouse_listener,args=(mouse, on_click, on_move, on_scroll, suppress)))
+        for i in self.listener:
+            i.start()
+        return self.listener
+
+    def stop_listener(self):
+        self.stop_event.set()
+        self.listener.clear()
+
+    def __del__(self):
+        self.ui.close()
+
+
+if __name__ == '__main__':
+
+    # mouseController = MouseController()
+    # mouseController.mouse_listener(None, None, None, suppress=True)
+    # for i in range(10):
+    #     mouseController.click('Button.left', 'press')
+    #     time.sleep(0.01)
+    #     mouseController.click('Button.left', 'release')
+    #     time.sleep(1)
+    # mouseController.stop_listener()
+    ui = UInput()
+    def move_mouse(dx,dy):
+        ui.write(ecodes.EV_REL, ecodes.REL_X, dx)
+        ui.write(ecodes.EV_REL, ecodes.REL_Y, dy)
+        ui.syn()
+    
+    move_mouse(100, 100)
+    ui.close()