Node.js serialportライブラリにて、readを停止させる方法

Question

背景・目的

現在、Node.js + serialportライブラリを使用し、
raspiをシリアル接続し、入力したコマンドの結果をコンソールに出力させるスクリプトを作成しています。

最終的には、シリアル通信可能な機器に接続し、コマンドを送受信する事が目的であり、
現在は、Ubuntu搭載機器に接続し、スクリプトを実装しています。

該当のソースコード

const SerialPort = require('serialport');
const { Readline } = SerialPort.parsers;
const port = new SerialPort("COM6", { baudRate: 115200 });

port.write('ls\r\n', function (err) {
  if (err) {
    console.log('Error writing: ', err.message)
  }
})

const parser = port.pipe(new Readline({ delimiter: '\r\n' }));
parser.on('data', (value) => {
  console.log(value);
})

発生している事象

上記スクリプトを実行すると、下記の様に出力されます。

node .\main.js
ls
sample_1  sample_2  sample_3  sample_4  sample_5
ubuntu@ubuntu:~$ 
　　　　　←ここは空白になっており、何も出力する文字が無い場合、このまま固まり、処理が全く進まない。

出力結果は理想なのですが、問題は処理の話であり、
上記スクリプトでの実行結果は、ユーザが強制終了をさせない限り(Ctrl + C)、ずっと動作し続ける(処理が固まっているように見える)事になっております。

また、この動作はThreadX、Ubuntuの両方で確認が取れています。

解決したい内容

原因は、予想としては下記の

parser.on('data', (value) => {
  console.log(value);
})

だと考えているのですが、終了させる処理が、公式サイトにもStack OverFlowにも見当たらず、1か月程沼にはまっております。

最終目的は、この処理を終了させることです。
(具体的には、エンターキーを押せば反応する)

どなたか、ご教授の程、お願いいたします。

補足情報（FW/ツールのバージョンなど）

OS : Windows 10 Pro
Node.js : v14.18.0
serialport : v9.2.4
使用機器 : raspi3 model-B (Ubuntu 20.04.02 LTS)

Answer 1

自分なりの回答が出たので、ここに回答します。

シリアルコンソールで出力される「プロンプト名」
でクローズする処理を組み込むことで、この質問の処理が実現できました。

Node.js初心者のスクリプトの為、
不備などは各自修正してください。(下記は動作検証済)

async function Execute_Command(send_command, prompt_name) {
  const DATA_FILE = "./hoge,txt";

  await new Promise(function (resolve, reject) {
    PORT.write(send_command + "\r\n");
    PORT.on('data', (data) => {
      Fs.appendFileSync(DATA_FILE, data);

      if (data.toString().includes(prompt_name)) {
        PORT.close();
        resolve();
      }
    });
  });

  let file_data = Fs.readFileSync(DATA_FILE, "ascii");
  if (!file_data == "") {
    Fs.unlinkSync(DATA_FILE);
  }
  let ret_str = file_data.replace(send_command, "").replace(prompt_name, "");
  return ret_str.toString();
}

Answer 2

serialportのソースを辿って行ったらcloseメソッドがありました。

//@serialport\stream\lib\index.js 412行目から
/**
 * Closes an open connection.
 *
 * If there are in progress writes when the port is closed the writes will error.
 * @param {errorCallback} callback Called once a connection is closed.
 * @param {Error} disconnectError used internally to propagate a disconnect error
 * @emits close
 * @returns {undefined}
 */
SerialPort.prototype.close = function (callback, disconnectError) {
  disconnectError = disconnectError || null

  if (!this.isOpen) {
    debug('close attempted, but port is not open')
    return this._asyncError(new Error('Port is not open'), callback)
  }
//以下略

これで行けませんか？

※追記
シリアルポートを閉じたいタイミングでcloseするという事です。

SerialPort.close();

Comments

[DEADBEEF]

ご回答ありがとうございます。
こちらの回答が遅くなりました。

===============
SerialPort.close();
===============
関数を、任意の場所に組み込んで実行させました。

================================================
const parser = port.pipe(new Readline({ delimiter: '\n' }));
parser.on('data', (value) => {
console.log(value);

// クローズさせる処理をここに挿入
if (value.includes("/dev/null")) {
if (value === "") {
console.log("portを閉じます")
port.close(function (err) {});
}
}
================================================

上記に書き換えたら、closeが機能しました。
ありがとうございます。

ここからは、Teratermでコマンドが終了しているメカニズム(終端コードを読み取っている？)
を解析し、コマンドを終了させられるようしてみます。