ハンズオンNode.jsを進める【第3章 EventEmitterとストリーム】

const events = require("events")
const fooEventEmitter = new events.EventEmitter()

for (let i = 0; i <= 11; i++) {
  fooEventEmitter.on("foo", () => {
    console.log("fooイベントリスナの実行");
  })
}

console.log("fooイベント発行", fooEventEmitter.emit("foo"));

// =>
// node main.js
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベントリスナの実行
// fooイベント発行 true
// (node:23632) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 foo listeners added to [EventEmitter]. Use emitter.setMaxListeners() to increase limit
// (Use `node --trace-warnings ...` to show where the warning was created)

node
Welcome to Node.js v18.9.1.
Type ".help" for more information.
> {
... const a = 1
... }
undefined
> a
Uncaught ReferenceError: a is not defined
> const a = 1
undefined
> a
1
>

node
Welcome to Node.js v18.9.1.
Type ".help" for more information.
> const emitter = new events.EventEmitter();
undefined
> emitter;
EventEmitter {
  _events: [Object: null prototype] {},
  _eventsCount: 0,
  _maxListeners: undefined,
  [Symbol(kCapture)]: false
}
> emitter.on("foo", () => console.log("fooイベントリスナの実行"));
EventEmitter {
  _events: [Object: null prototype] { foo: [Function (anonymous)] },
  _eventsCount: 1,
  _maxListeners: undefined,
  [Symbol(kCapture)]: false
}
> emitter.listeners("foo");
[ [Function (anonymous)] ]
>

> emitter
EventEmitter {
  _events: [Object: null prototype] { foo: [Function (anonymous)] },
  _eventsCount: 1,
  _maxListeners: undefined,
  [Symbol(kCapture)]: false
}
> .editor
// Entering editor mode (Ctrl+D to finish, Ctrl+C to cancel)
{
  emitter.on("message", () => console.log("hello"))
}

EventEmitter {
  _events: [Object: null prototype] {
    foo: [Function (anonymous)],
    message: [Function (anonymous)]
  },
  _eventsCount: 2,
  _maxListeners: undefined,
  [Symbol(kCapture)]: false
}
> emitter.listeners("message")
[ [Function (anonymous)] ]
> emitter
EventEmitter {
  _events: [Object: null prototype] {
    foo: [Function (anonymous)],
    message: [Function (anonymous)]
  },
  _eventsCount: 2,
  _maxListeners: undefined,
  [Symbol(kCapture)]: false
}

const events = require("events")

try {
  // リスナが存在しない状態でこのイベントをemitすると、エラーが投げられる
  new events.EventEmitter().emit("error", new Error())
} catch (err) {
  console.log("catch"); // => catch
}

const events = require("events")

try {
  // リスナが存在しない状態でこのイベントをemitすると、エラーが投げられる
  const emitter = new events.EventEmitter()
  emitter.on("error", (err) => console.log("エラーです", err))
  emitter.emit("error", new Error("オエラ"))
} catch (err) {
  console.log("catch"); // => catch
}

// =>
// エラーです Error: オエラ
//     at Object.<anonymous> (/Users/yuuki_haga/repos/node/node-practice/chapter_3/src/main.js:7:25)
//     at Module._compile (node:internal/modules/cjs/loader:1119:14)
//     at Module._extensions..js (node:internal/modules/cjs/loader:1173:10)
//     at Module.load (node:internal/modules/cjs/loader:997:32)
//     at Module._load (node:internal/modules/cjs/loader:838:12)
//     at Function.executeUserEntryPoint [as runMain] (node:internal/modules/run_main:81:12)
//     at node:internal/main/run_main_module:18:47

const events = require("events")

function startListener() {
  console.log("start");
}

function fizzListener(count) {
  console.log("Fizz", count);
}

function buzzListener(count) {
  console.log("FizzBuzz", count);
}

function fizzBuzzListener(count) {
  console.log("FizzBuzz", count);
}

function endListener() {
  console.log("end");
  // EventEmitterの主要なインスタンスメソッドの中でemit以外のメソッドはそのメソッドを持つ
  // EventEmitterインスタンスを返すため、メソッドチェーンが可能になっている
  // リスナに渡す関数の中ではthisによってEventEmitterインスタンスにアクセスできる
  // emit()メソッドの戻り値はそのイベントに対するリスナが登録されているかどうかを示すbooleanです
  // offは指定したイベントに登録されたリスナを削除する
  // 以下の処理では全てのイベントからリスナを削除している
  this
    .off("start", startListener)
    .off("Fizz", fizzListener)
    .off("FizzBuzz", fizzBuzzListener)
    .off("end", endListener)
}

class FizzBuzzEventEmitter extends events.EventEmitter {
  async start(until) {
    this.emit("start")
    let count = 1

    while (true) {
      if (count % 15 === 0) {
        this.emit("FizzBuzz", count)
      } else if (count % 3 === 0) {
        this.emit("Fizz", count)
      } else if (count % 5 === 0) {
        this.emit("Buzz", count)
      }
      count += 1
      if (count >= until) {
        break
      }

      await new Promise(resolve => setTimeout(resolve, 100))
    }

    this.emit("end")
  }
}

const emitter = new FizzBuzzEventEmitter()
emitter
  .on("start", startListener)
  .on("Fizz", fizzListener)
  .on("Buzz", buzzListener)
  .on("FizzBuzz", fizzBuzzListener)
  .on("end", endListener)
  .start(20)

const fs = require("fs")

const readStream = fs.createReadStream("./sample.txt")

function handleReadStream() {
  readStream
    .on("readable", () => {
      // readableイベントを発行する
      console.log("readable");
      let chunk;
      // 現在読み込み可能なデータを全て読み込む
      // チャンクは、送信や処理中のデータの一部のデータのこと
      while((chunk = readStream.read()) !== null) {
        console.log(`chunk: ${chunk.toString()}`);
      }
    })
    .on("end", () => console.log("end")) // endイベントリスナの登録
}

module.exports = {
  handleReadStream,
}

// =>
// node main.js
// readable
// chunk: The standard chunk of Lorem Ipsum used since the 1500s is reproduced below for those interested. Sections 1.10.32 and 1.10.33 from "de Finibus Bonorum et Malorum" by Cicero are also reproduced in their exact original form, accompanied by English versions from the 1914 translation by H. Rackham.

// Where can I get some?
// There are many variations of passages of Lorem Ipsum available, but the majority have suffered alteration in some form, by injected humour, or randomised words which don't look even slightly believable. If you are going to use a passage of Lorem Ipsum, you need to be sure there isn't anything embarrassing hidden in the middle of text. All the Lorem Ipsum generators on the Internet tend to repeat predefined chunks as necessary, making this the first true generator on the Internet. It uses a dictionary of over 200 Latin words, combined with a handful of model sentence structures, to generate Lorem Ipsum which looks reasonable. The generated Lorem Ipsum is therefore always free from repetition, injected humour, or non-characteristic words etc.

// 5
// 	paragraphs
// 	words
// 	bytes
// 	lists
// 	Start with 'Lorem
// ipsum dolor sit amet...'

// readable
// end

const fs = require("fs")

function buildWriteStream() {
  return fs.createWriteStream("dest.txt")
}

function handleWriteStream() {
  writeStream = buildWriteStream()
  // 書き込みストリームにはwrite()でデータを流し
  writeStream.write("Hello\n")
  writeStream.write("World\n")
  // 全てのデータを流し終えたらend()を実行する。
  writeStream.end()
}

module.exports = {
  handleWriteStream,
}

const fs = require("fs")

function buildWriteStream() {
  return fs.createWriteStream("dest.txt")
}

function handleWriteStream() {
  writeStream = buildWriteStream()
  // 書き込みストリームにはwrite()でデータを流し
  writeStream.write("Hello\n")
  writeStream.write("World\n")
  // 全てのデータを流し終えたらend()を実行する。
  writeStream.end()
}

module.exports = {
  handleWriteStream,
}

const fs = require("fs")

fs.createReadStream("no-such-file.txt")
  .pipe(fs.createWriteStream("dest.txt"))
  .on("error", err => console.log("エラーイベント", err.message))

// =>
// node main.js
// node:events:491
//       throw er; // Unhandled 'error' event
//       ^

// Error: ENOENT: no such file or directory, open 'no-such-file.txt'
// Emitted 'error' event on ReadStream instance at:
//     at emitErrorNT (node:internal/streams/destroy:151:8)
//     at emitErrorCloseNT (node:internal/streams/destroy:116:3)
//     at process.processTicksAndRejections (node:internal/process/task_queues:82:21) {
//   errno: -2,
//   code: 'ENOENT',
//   syscall: 'open',
//   path: 'no-such-file.txt'
// }

// Node.js v18.9.1

const fs = require("fs")

fs.createReadStream("no-such-file.txt")
  .on("error", err => console.log("エラーイベント", err.message))
  .pipe(fs.createWriteStream("dest.txt"))
  .on("error", err => console.log("エラーイベント", err.message))

// =>
// node main.js
// エラーイベント ENOENT: no such file or directory, open 'no-such-file.txt'

const fs = require("fs")
const stream = require("stream")

// stream.pipeline()は2つ以上のストリームを引数に取り、それらをpipe()で連結する
// 連結したストリームのどこかでエラーが発生した場合、最後の引数として渡したコールバックがそのエラーを引数に実行される
// エラーの発生なくストリームが終了した場合、コールバックが引数なしで実行される
// いずれの場合でも、引数に渡したストリームは全て自動的に破棄される(コンピュータリソースであるメモリのメモリリークの心配がない)
stream.pipeline(
  // pipe()したい2つ以上のストリーム
  fs.createReadStream("no-such-file.txt"),
  fs.createWriteStream("dest.txt"),
  // コールバック
  err => err
    ? console.error("エラー発生", err.message)
    : console.log("正常終了")
)

// =>
// node main.js
// エラー発生 ENOENT: no such file or directory, open 'no-such-file.txt'