nttcom · yuki-uchida · Feb 24, 2025 · Feb 24, 2025 · Feb 24, 2025 · Feb 24, 2025
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/README.md b/README.md
@@ -17,20 +17,23 @@ Supported version: draft-ietf-moq-transport-06
   - [x] ANNOUNCE_ERROR
   - [ ] ANNOUNCE_CANCEL
   - [ ] TRACK_STATUS_REQUEST
-  - [x] SUBSCRIBE_NAMESPACE
-  - [ ] UNSUBSCRIBE_NAMESPACE
+  - [x] SUBSCRIBE_ANNOUNCES
+  - [ ] UNSUBSCRIBE_ANNOUNCES
   - [x] SUBSCRIBE_OK
   - [x] SUBSCRIBE_ERROR
   - [ ] SUBSCRIBE_DONE
   - [ ] MAX_SUBSCRIBE_ID
   - [x] ANNOUNCE
   - [ ] UNANNOUNCE
   - [ ] TRACK_STATUS
-  - [x] SUBSCRIBE_NAMESPACE_OK
-  - [x] SUBSCRIBE_NAMESPACE_ERROR
+  - [x] SUBSCRIBE_ANNOUNCES_OK
+  - [x] SUBSCRIBE_ANNOUNCES_ERROR
+  - [ ] FETCH
+  - [ ] FETCH_OK
+  - [ ] FETCH_ERROR
+  - [ ] FETCH_CANCEL
 - [x] Data Streams
   - [x] Datagram
-  - [x] Track Stream
   - [x] Subgroup Stream
 - [ ] Features
   - [x] Manage Publisher / Subscriber

diff --git a/docs/flow.drawio.svg b/docs/flow.drawio.svg
diff --git a/js/examples/media/index.html b/js/examples/media/index.html
@@ -0,0 +1,15 @@
+<!doctype html>
+<html lang="ja">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>Media Examples</title>
+  </head>
+  <body>
+    <h1>Media Examples</h1>
+    <div>
+      <a href="./publisher/index.html">Publisher</a>
+      <a href="./subscriber/index.html">Subscriber</a>
+    </div>
+  </body>
+</html>
diff --git a/js/examples/media/publisher/audioEncoder.ts b/js/examples/media/publisher/audioEncoder.ts
@@ -0,0 +1,47 @@
+let audioEncoder: AudioEncoder | undefined
+const AUDIO_ENCODER_CONFIG = {
+  codec: 'opus',
+  sampleRate: 48000, // Opusの推奨サンプルレート
+  numberOfChannels: 1, // モノラル
+  bitrate: 64000 // 64kbpsのビットレート
+}
+
+function sendAudioChunkMessage(chunk: EncodedAudioChunk, metadata: EncodedAudioChunkMetadata | undefined) {
+  self.postMessage({ chunk, metadata })
+}
+
+async function initializeAudioEncoder() {
+  const init: AudioEncoderInit = {
+    output: sendAudioChunkMessage,
+    error: (e: any) => {
+      console.log(e.message)
+    }
+  }
+
+  const encoder = new AudioEncoder(init)
+  encoder.configure(AUDIO_ENCODER_CONFIG)
+  return encoder
+}
+
+async function startAudioEncode(audioReadableStream: ReadableStream<AudioData>) {
+  if (!audioEncoder) {
+    audioEncoder = await initializeAudioEncoder()
+  }
+  const audioReader = audioReadableStream.getReader()
+  while (true) {
+    const audioResult = await audioReader.read()
+    if (audioResult.done) break
+    const audio = audioResult.value
+    audioEncoder.encode(audio)
+    audio.close()
+  }
+}
+
+self.onmessage = async (event) => {
+  const audioReadableStream: ReadableStream<AudioData> = event.data.audioStream
+  if (!audioReadableStream) {
+    console.error('MediaStreamTrack が渡されていません')
+    return
+  }
+  await startAudioEncode(audioReadableStream)
+}
diff --git a/js/examples/media/publisher/const.ts b/js/examples/media/publisher/const.ts
@@ -0,0 +1,2 @@
+export const KEYFRAME_INTERVAL = 300
+export const AUTH_INFO = 'secret'
diff --git a/js/examples/media/publisher/index.html b/js/examples/media/publisher/index.html
@@ -0,0 +1,95 @@
+<!doctype html>
+<html lang="en">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>MOQT Media Publisher Test</title>
+  </head>
+  <body>
+    <h1>Publisher</h1>
+    <div id="app">
+      <form name="form" id="form">
+        <div>
+          <h2>Connection</h2>
+          <label for="url">URL:</label>
+          <input type="url" name="url" id="url" value="https://localhost:4433" />
+          <button type="button" id="connectBtn">Connect</button>
+          <button type="button" id="closeBtn">Close</button>
+        </div>
+        <br />
+        <div>
+          <h2>Forwarding Preference</h2>
+          <label
+            ><input type="radio" name="forwarding-preference" id="selectDatagram" value="datagram" />Datagram
+          </label>
+          <label
+            ><input type="radio" name="forwarding-preference" id="selectSubgroup" value="subgroup" checked />Subgroup
+          </label>
+          <br />
+          *You must select at first
+
+          <h3>CLIENT_SETUP</h3>
+          Max Subscribe ID: <input type="text" name="max-subscribe-id" id="" value="2" />
+          <br />
+          <button type="button" id="sendSetupBtn">Send</button>
+
+          <h3>ANNOUNCE</h3>
+          <label
+            >Track Namespace: <input type="text" name="announce-track-namespace" id="" value="video_audio" />
+          </label>
+          <br />
+          <button type="button" id="sendAnnounceBtn">Send</button>
+          <h3>OBJECT</h3>
+          <div id="headerField" style="display: blocked">
+            <h4>Header</h4>
+          </div>
+          <label>Video Track Alias: <input type="text" name="video-object-track-alias" id="" value="0" /> </label>
+          <label>Audio Track Alias: <input type="text" name="audio-object-track-alias" id="" value="1" /> </label>
+          <br />
+          <label
+            >Video Publisher Priority: <input type="text" name="video-publisher-priority" id="" value="0" />
+          </label>
+          <label
+            >Audio Publisher Priority: <input type="text" name="audio-publisher-priority" id="" value="0" />
+          </label>
+          <br />
+          <div id="objectField" style="display: blocked">
+            <h4>Object</h4>
+          </div>
+          <div id="datagramObjectContents" style="display: none">
+            Group ID:
+            <p id="datagramGroupId">0</p>
+            <br />
+            <button type="button" id="descendDatagramGroupIdBtn">&lt;</button>
+            <button type="button" id="ascendDatagramGroupIdBtn">&gt;</button>
+            <br />
+            <br />
+          </div>
+          <br />
+          <div>
+            <button type="button" id="startGetUserMediaBtn">getUserMedia</button>
+          </div>
+          <div id="sendDatagramObject" style="display: none">
+            <button type="button" id="sendDatagramObjectBtn">Send</button>
+          </div>
+          <div id="sendSubgroupObject" style="display: blocked">
+            <button type="button" id="sendSubgroupObjectBtn">Send</button>
+          </div>
+        </div>
+        <div>
+          <video id="video" autoplay muted inline></video>
+        </div>
+        <br />
+
+        <br />
+      </form>
+    </div>
+
+    <script type="module" src="./main.ts"></script>
+  </body>
+  <style>
+    p {
+      display: inline;
+    }
+  </style>
+</html>
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		export const KEYFRAME_INTERVAL = 300
		export const AUTH_INFO = 'secret'