Initial commit: Refactor AgvAutoRunControls

2025-12-18 23:52:02 +09:00
commit c4089aeb20
25 changed files with 7517 additions and 0 deletions
--- a/services/serialService.ts
+++ b/services/serialService.ts
@@ -0,0 +1,124 @@
+export type SerialDataCallback = (data: Uint8Array) => void;
+
+// Define Web Serial API types
+interface SerialPortInfo {
+  usbVendorId?: number;
+  usbProductId?: number;
+}
+
+interface SerialPort {
+  open(options: { baudRate: number }): Promise<void>;
+  close(): Promise<void>;
+  getInfo(): SerialPortInfo;
+  readable: ReadableStream<Uint8Array> | null;
+  writable: WritableStream<Uint8Array> | null;
+}
+
+declare global {
+  interface Navigator {
+    serial: {
+      requestPort(options?: any): Promise<SerialPort>;
+    };
+  }
+}
+
+export class SerialPortHandler {
+  private port: SerialPort | null = null;
+  private reader: ReadableStreamDefaultReader<Uint8Array> | null = null;
+  private writer: WritableStreamDefaultWriter<Uint8Array> | null = null;
+  private isConnected: boolean = false;
+  private onData: SerialDataCallback;
+
+  constructor(onData: SerialDataCallback) {
+    this.onData = onData;
+  }
+
+  async connect(baudRate: number = 9600) {
+    if (!navigator.serial) {
+      throw new Error('Web Serial API not supported in this browser.');
+    }
+
+    try {
+      this.port = await navigator.serial.requestPort();
+      await this.port.open({ baudRate });
+
+      if (this.port.readable) {
+        this.reader = this.port.readable.getReader();
+      }
+      
+      if (this.port.writable) {
+         this.writer = this.port.writable.getWriter();
+      }
+
+      this.isConnected = true;
+      this.readLoop();
+    } catch (error: any) {
+      if (error.name === 'NotFoundError') {
+        throw new Error('USER_CANCELLED');
+      }
+      console.error('Serial connection failed:', error);
+      this.disconnect();
+      throw error;
+    }
+  }
+
+  async disconnect() {
+    if (this.reader) {
+      await this.reader.cancel();
+      this.reader.releaseLock();
+    }
+    if (this.writer) {
+      await this.writer.close();
+      this.writer.releaseLock();
+    }
+    if (this.port) {
+      await this.port.close();
+    }
+    this.isConnected = false;
+    this.port = null;
+  }
+
+  async send(data: string | Uint8Array) {
+    if (this.writer && this.isConnected) {
+      let payload: Uint8Array;
+      if (typeof data === 'string') {
+        payload = new TextEncoder().encode(data + '\n');
+      } else {
+        payload = data;
+      }
+      await this.writer.write(payload);
+    }
+  }
+
+  getPortInfo(): string | null {
+      if (this.port) {
+          const info = this.port.getInfo();
+          if (info.usbVendorId && info.usbProductId) {
+              return `ID:${info.usbVendorId.toString(16).padStart(4,'0').toUpperCase()}:${info.usbProductId.toString(16).padStart(4,'0').toUpperCase()}`;
+          }
+          return "USB Device";
+      }
+      return null;
+  }
+
+  private async readLoop() {
+    while (true) {
+      try {
+        const { value, done } = await this.reader!.read();
+        if (done) {
+          break;
+        }
+        if (value) {
+          this.onData(value);
+        }
+      } catch (error) {
+        console.error('Serial read error:', error);
+        break;
+      }
+    }
+  }
+
+  get connected() {
+    return this.isConnected;
+  }
+}