15847482271

Committed 24 Jun 2025 10:04AM UTC coverage: 69.194% (+5.8%) from 63.351%

Build # 15847482271

Build Type

push

github

Committed by

web-flow

Commit Message

v0.3.30: change to vitest and lodash-es (#196)

Run Details

502 of 657 branches covered (76.41%)

Branch coverage included in aggregate %.

12 of 18 new or added lines in 14 files covered. (66.67%)

218 existing lines in 5 files now uncovered.

2683 of 3946 relevant lines covered (67.99%)

3159783.57 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/plugin/SerialPortAdapter.ts

import * as _ from 'lodash-es'
import { SerialPort } from 'serialport'
import { Duplex } from 'stream'
import { type ChameleonPlugin, type ChameleonUltra, type PluginInstallContext } from '../ChameleonUltra'
import { setObject } from '../iifeExportHelper'

async function findDevicePath (): Promise<string> {
  const device = _.find(await SerialPort.list(), { vendorId: '6868', productId: '8686' }) // ChameleonUltra
  if (_.isNil(device)) throw new Error('device not found')
  return device?.path
}

export default class SerialPortAdapter implements ChameleonPlugin {
  duplex: SerialPort | null = null
  name = 'adapter'
  readonly #emitErr: (err: Error) => void
  ultra?: ChameleonUltra

  constructor () {
    this.#emitErr = (err: Error): void => { this.ultra?.emitter.emit('error', _.set(new Error(err.message), 'originalError', err)) }
  }

  #debug (formatter: any, ...args: [] | any[]): void {
    this.ultra?.emitter.emit('debug', 'serial', formatter, ...args)
  }

  async install (context: AdapterInstallContext, pluginOption: SerialPortOption = {}): Promise<AdapterInstallResp> {
    const ultra = this.ultra = context.ultra

    if (!_.isNil(ultra.$adapter)) {
      await ultra.disconnect(new Error('adapter replaced'))
    }

    const adapter: AdapterInstallResp = {
      isSupported: () => !_.isNil(SerialPort),
    }

    ultra.addHook('connect', async (ctx: any, next: () => Promise<unknown>) => {
      if (ultra.$adapter !== adapter) return await next() // 代表已經被其他 adapter 接管

      try {
        if (!adapter.isSupported()) throw new Error('SerialPort not supported')

        const baudRate = pluginOption?.baudRate ?? 115200
        const path = pluginOption?.path ?? await findDevicePath()

        this.duplex = await new Promise<SerialPort>((resolve, reject) => {
          const tmp = new SerialPort({ baudRate, path }, err => { _.isNil(err) ? resolve(tmp) : reject(err) })
        })
        this.duplex?.once('close', () => { void ultra.disconnect(new Error('SerialPort closed')) })
        this.#debug(`port connected, path = ${path}, baudRate = ${baudRate}`)
        ultra.port = _.merge(Duplex.toWeb(this.duplex), {
          isOpen: () => { return this.duplex?.isOpen ?? false },
          isDfu: () => false, // TODO: dfu
        })
        return await next()
      } catch (err) {
        this.#debug(err)
        throw err
      }
    })

    ultra.addHook('disconnect', async (ctx: any, next: () => Promise<unknown>) => {
      if (ultra.$adapter !== adapter || _.isNil(this.duplex)) return await next() // 代表已經被其他 adapter 接管

      await next().catch(this.#emitErr)
      await new Promise<void>((resolve, reject) => { this.duplex?.close(err => { _.isNil(err) ? resolve() : reject(err) }) })
      this.duplex = null
    })

    return adapter
  }
}

setObject(globalThis, ['ChameleonUltraJS', 'SerialPortAdapter'], SerialPortAdapter)

/** @inline */
type AdapterInstallContext = PluginInstallContext & {
  ultra: PluginInstallContext['ultra'] & { $adapter?: any }
}

/** @inline */
interface SerialPortOption {
  path?: string
  baudRate?: number
}

/** @inline */
interface AdapterInstallResp {
  isSupported: () => boolean
}

NEW 1	import * as _ from 'lodash-es'	×
2	import { SerialPort } from 'serialport'	×
3	import { Duplex } from 'stream'	×
4	import { type ChameleonPlugin, type ChameleonUltra, type PluginInstallContext } from '../ChameleonUltra'
5	import { setObject } from '../iifeExportHelper'	×
6
7	async function findDevicePath (): Promise<string> {	×
8	const device = _.find(await SerialPort.list(), { vendorId: '6868', productId: '8686' }) // ChameleonUltra	×
9	if (_.isNil(device)) throw new Error('device not found')	×
10	return device?.path	×
11	}	×
12
13	export default class SerialPortAdapter implements ChameleonPlugin {	×
14	duplex: SerialPort \| null = null	×
15	name = 'adapter'	×
16	readonly #emitErr: (err: Error) => void	×
17	ultra?: ChameleonUltra	×
18
19	constructor () {	×
20	this.#emitErr = (err: Error): void => { this.ultra?.emitter.emit('error', _.set(new Error(err.message), 'originalError', err)) }	×
21	}	×
22
23	#debug (formatter: any, ...args: [] \| any[]): void {	×
24	this.ultra?.emitter.emit('debug', 'serial', formatter, ...args)	×
25	}	×
26
27	async install (context: AdapterInstallContext, pluginOption: SerialPortOption = {}): Promise<AdapterInstallResp> {	×
28	const ultra = this.ultra = context.ultra	×
29
30	if (!_.isNil(ultra.$adapter)) {	×
31	await ultra.disconnect(new Error('adapter replaced'))	×
32	}	×
33
34	const adapter: AdapterInstallResp = {	×
35	isSupported: () => !_.isNil(SerialPort),	×
36	}	×
37
38	ultra.addHook('connect', async (ctx: any, next: () => Promise<unknown>) => {	×
39	if (ultra.$adapter !== adapter) return await next() // 代表已經被其他 adapter 接管	×
40
41	try {	×
42	if (!adapter.isSupported()) throw new Error('SerialPort not supported')	×
43
44	const baudRate = pluginOption?.baudRate ?? 115200	×
45	const path = pluginOption?.path ?? await findDevicePath()	×
46
47	this.duplex = await new Promise<SerialPort>((resolve, reject) => {	×
48	const tmp = new SerialPort({ baudRate, path }, err => { _.isNil(err) ? resolve(tmp) : reject(err) })	×
49	})	×
50	this.duplex?.once('close', () => { void ultra.disconnect(new Error('SerialPort closed')) })	×
51	this.#debug(`port connected, path = ${path}, baudRate = ${baudRate}`)	×
52	ultra.port = _.merge(Duplex.toWeb(this.duplex), {	×
53	isOpen: () => { return this.duplex?.isOpen ?? false },	×
54	isDfu: () => false, // TODO: dfu	×
55	})	×
56	return await next()	×
57	} catch (err) {	×
58	this.#debug(err)	×
59	throw err	×
60	}	×
61	})	×
62
63	ultra.addHook('disconnect', async (ctx: any, next: () => Promise<unknown>) => {	×
64	if (ultra.$adapter !== adapter \|\| _.isNil(this.duplex)) return await next() // 代表已經被其他 adapter 接管	×
65
66	await next().catch(this.#emitErr)	×
67	await new Promise<void>((resolve, reject) => { this.duplex?.close(err => { _.isNil(err) ? resolve() : reject(err) }) })	×
68	this.duplex = null	×
69	})	×
70
71	return adapter	×
72	}	×
73	}	×
74
75	setObject(globalThis, ['ChameleonUltraJS', 'SerialPortAdapter'], SerialPortAdapter)	×
76
77	/** @inline */
78	type AdapterInstallContext = PluginInstallContext & {
79	ultra: PluginInstallContext['ultra'] & { $adapter?: any }
80	}
81
82	/** @inline */
83	interface SerialPortOption {
84	path?: string
85	baudRate?: number
86	}
87
88	/** @inline */
89	interface AdapterInstallResp {
90	isSupported: () => boolean
91	}

taichunmin / chameleon-ultra.js / 15847482271

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous