|
| 1 | +import { EventEmitter } from 'node:events' |
| 2 | +import { SerialPilot } from 'serialpilot' |
| 3 | +import type { Transport } from '@serialpilot/driver-kit' |
| 4 | + |
| 5 | +/** |
| 6 | + * Adapt a `SerialPilot` (callback-style API) to the promise-based `Transport` |
| 7 | + * interface that `@serialpilot/driver-*` packages expect. Keeps examples readable |
| 8 | + * without forcing driver-kit to take a runtime dependency on the core toolkit. |
| 9 | + */ |
| 10 | +export function serialPilotTransport(opts: { path: string, baudRate: number }): Transport { |
| 11 | + const port = new SerialPilot({ path: opts.path, baudRate: opts.baudRate, autoOpen: false }) |
| 12 | + const emitter = new EventEmitter() as EventEmitter & Transport |
| 13 | + |
| 14 | + const transport: Transport = Object.assign(emitter, { |
| 15 | + get isOpen() { return port.isOpen }, |
| 16 | + open() { |
| 17 | + return new Promise<void>((resolve, reject) => { |
| 18 | + port.open(err => err ? reject(err) : resolve()) |
| 19 | + }) |
| 20 | + }, |
| 21 | + close() { |
| 22 | + return new Promise<void>((resolve, reject) => { |
| 23 | + port.close(err => err ? reject(err) : resolve()) |
| 24 | + }) |
| 25 | + }, |
| 26 | + write(data: Uint8Array | string) { |
| 27 | + return new Promise<void>((resolve, reject) => { |
| 28 | + port.write(data as Buffer | string, err => err ? reject(err) : resolve()) |
| 29 | + }) |
| 30 | + }, |
| 31 | + setSignals(signals: { dtr?: boolean, rts?: boolean }) { |
| 32 | + return new Promise<void>((resolve, reject) => { |
| 33 | + port.set(signals, err => err ? reject(err) : resolve()) |
| 34 | + }) |
| 35 | + }, |
| 36 | + }) |
| 37 | + |
| 38 | + port.on('data', (chunk: Buffer) => emitter.emit('data', chunk)) |
| 39 | + port.on('error', (err: Error) => emitter.emit('error', err)) |
| 40 | + port.on('close', () => emitter.emit('close')) |
| 41 | + |
| 42 | + return transport |
| 43 | +} |
0 commit comments