NodeJS製WebRTC DataChannel、NodeRTCのコードを読む Part.4

class: Sendor

• extends `Readable`
  • しかし`_read()`は空っぽ
  • 代わりにどこかで`this.push()`してるはず
  • 実態はおそらく`constructor()`で受け取った`session`からデータを供給する存在
• `this.push()`してるのは主に`_bufferDrain()`
  • これは`output.record.on('data')`で呼ばれる
• `output.record`
  • GitHub - reklatsmasters/binary-data: Declarative encoder/decoder of various binary data. の`createEncodeStream()`
  • これの`write()`でデータが流れる
• `sendRecord()`という関数がそれ
  • 各所で呼ばれてるが、メインは`_applicationData()`
  • これは`session.on('send:appdata')`で呼ばれる
• これが`emit()`されるのは、`session.sendMessage()`
  • そしてこれは`socket._write()`すると呼ばれる

つまり・・・、

// socket from socket.js
socket._write()
  session.sendMessage()
    this.emit('send:appdata')

// writer from sender.js
session.on('send:appdata')
  this.sendRecord()
    this.output.record.write(record);

this.output.record.on('data')
  this[_bufferDrain](packet)
    this.push(packet)

これで回り回って、`pipeline()`につないだ次の`socket`（つまり接続ピア）にデータが流れてくことになる。

最初に呼ばれるであろう`socket._write()`はこうなってた。

_write(chunk, encoding, callback) {
  if (this[_session].isHandshakeInProcess) {
    this[_queue].push(chunk);
    this.once('connect', () => callback());
  } else {
    this[_session].sendMessage(chunk);
    callback();
  }
}

ハンドシェイクが終わるまでキューに貯めてる。

`Writable._write()`は、1つ上の層（おそらくSCTPの実装）で使われるてるはず。
`socket.write()`的な感じで。

binary-data

GitHub - reklatsmasters/binary-data: Declarative encoder/decoder of various binary data.

作者謹製のライブラリで、頻繁に使われてるので軽く見ておく。

• バイナリに対してスキーマを定義できる
• それを`encode()` / `decode()`することで、バイナリを意識しないでいい
  • `Transform`ストリームも作れる

const protocol = {
  type: uint8,
  value: array(string(null), uint8),
};
const message = {
  type: 12,
  value: ['foo', 1],
};

socket.on('message', msg => {
  const packet = decode(msg, protocol);
});

socket.write(encode(msg, protocol));

まあ確かにこういうの欲しいよねーという感じ。

class: Protocol12ReaderClient

変数`protocol`の中身。

• extends `Writable`
  • `constructor()`で`session`を受け取る
• `session.handshakeProtocolReaderState`で挙動が変わる
• `_write()`で最終的にデータを流すかどうか判断してる
• 疎通後のデータは`this.session.packet()`で流される
  • `session.emit('data')`

これがまたおそらく次に読むSCTPのどこかで`on('data')`されてるはず・・。