chore: rewrite

Author: twlite

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+  "rust-analyzer.procMacro.attributes.enable": false
+}

Cargo.toml

@@ -10,7 +10,6 @@ crate-type = ["cdylib"]
 # Default enable napi4 feature, see https://nodejs.org/api/n-api.html#node-api-version-matrix
 napi = { version = "2.12.2", default-features = false, features = ["napi4"] }
 napi-derive = "2.12.2"
-symphonia = { version = "0.5.4", features = ["all"] }
 symphonium = { version = "0.2.2", features = ["all"] }
 unsafe-libopus = "0.2.0"
 

js-binding.d.ts

@@ -3,22 +3,22 @@
 
 /* auto-generated by NAPI-RS */
 
-export declare function getOpusVersion(): string;
+export declare function getOpusVersion(): string
 export interface ProbeResult {
   /** The number of channels */
-  channels: number;
+  channels: number
   /** The sample rate */
-  sampleRate: number;
+  sampleRate: number
   /** The number of frames per block */
-  framesPerBlock: number;
+  framesPerBlock: number
   /** The codec type */
-  codec: CodecType;
+  codec: CodecType
   /** The number of frames */
-  nFrames: number;
+  nFrames: number
   /** The approximate duration of this media in seconds */
-  duration: number;
+  duration: number
   /** The metadata object */
-  metadata: Array<MetadataField>;
+  metadata: Array<MetadataField>
 }
 export const enum CodecType {
   UNKNOWN = 0,
@@ -86,23 +86,23 @@ export const enum CodecType {
   WAVPACK = 8193,
   MONKEYS_AUDIO = 8194,
   ALAC = 8195,
-  TTA = 8196,
+  TTA = 8196
 }
 export interface MetadataField {
-  name: string;
-  value: string;
+  name: string
+  value: string
 }
-export declare function probe(data: Buffer): Promise<ProbeResult>;
-export declare function probeSync(data: Buffer): ProbeResult;
+export declare function probe(data: Buffer): Promise<ProbeResult>
+export declare function probeSync(data: Buffer): ProbeResult
 export declare class OpusEncoder {
-  static create(sampleRate: number, channels: number): OpusEncoder;
-  hasEncoder(): boolean;
-  hasDecoder(): boolean;
-  encode(data: Buffer): Buffer;
-  decode(data: Buffer): Buffer;
-  setBitrate(bitrate: number): void;
-  getBitrate(): number;
-  applyEncoderCtl(request: number, value: number): void;
-  applyDecoderCtl(request: number, value: number): void;
-  get version(): string;
+  static create(sampleRate: number, channels: number): OpusEncoder
+  hasEncoder(): boolean
+  hasDecoder(): boolean
+  encode(data: Buffer): Buffer
+  decode(data: Buffer): Buffer
+  setBitrate(bitrate: number): void
+  getBitrate(): number
+  applyEncoderCtl(request: number, value: number): void
+  applyDecoderCtl(request: number, value: number): void
+  get version(): string
 }

js-binding.js

@@ -116,7 +116,7 @@ switch (platform) {
         nativeBinding = require('mediaplex-darwin-universal')
       }
       break
-    } catch { }
+    } catch {}
     switch (arch) {
       case 'x64':
         localFileExisted = existsSync(join(__dirname, 'mediaplex.darwin-x64.node'))

package.json

@@ -27,6 +27,7 @@
   "author": "Twilight <[email protected]>",
   "devDependencies": {
     "@napi-rs/cli": "^2.18.4",
+    "@types/node": "^22.10.1",
     "ava": "^6.0.1"
   },
   "ava": {
@@ -45,4 +46,4 @@
     "version": "napi version"
   },
   "packageManager": "[email protected]"
-}
+}

src/lib.rs

@@ -5,3 +5,4 @@ extern crate napi_derive;
 
 pub mod opus;
 pub mod probe;
+pub mod transcoder;

src/probe/mod.rs

@@ -2,10 +2,16 @@
 
 use napi::bindgen_prelude::*;
 use napi::{Result, Task};
-use symphonia::core::meta::MetadataRevision;
-use symphonia::core::{
-  audio::Channels, codecs::*, io::MediaSourceStream, probe::Hint, units::TimeBase,
+use symphonium::symphonia::core::{
+  audio::Channels,
+  codecs::*,
+  formats::FormatOptions,
+  io::MediaSourceStream,
+  meta::{MetadataOptions, MetadataRevision},
+  probe::Hint,
+  units::TimeBase,
 };
+use symphonium::symphonia::default::get_probe;
 
 #[napi(object, js_name = "ProbeResult")]
 pub struct JsProbeResult {
@@ -166,10 +172,10 @@ fn probe_inner(data: Vec<u8>) -> Result<JsProbeResult> {
   let hint = Hint::new();
 
   // Use the default options for metadata and format readers.
-  let meta_opts: symphonia::core::meta::MetadataOptions = Default::default();
-  let fmt_opts: symphonia::core::formats::FormatOptions = Default::default();
+  let meta_opts: MetadataOptions = Default::default();
+  let fmt_opts: FormatOptions = Default::default();
 
-  let mut probed = symphonia::default::get_probe()
+  let mut probed = get_probe()
     .format(&hint, mss, &fmt_opts, &meta_opts)
     .map_err(|e| {
       Error::new(

src/transcoder/mod.rs

@@ -0,0 +1,41 @@
+// use symphonium::{DecodedAudio, SymphoniumLoader};
+
+// fn create_media_source() {}
+
+// struct Transcoder {
+//   audio_data: DecodedAudio,
+//   frames_elapsed: usize,
+//   temp_buf_l: Vec<f32>,
+//   temp_buf_r: Vec<f32>,
+// }
+
+// impl Transcoder {
+//   fn create(audio_data: DecodedAudio, max_buffer_size: usize) -> Self {
+//     Transcoder {
+//       audio_data,
+//       frames_elapsed: 0,
+//       temp_buf_l: vec![0.0; max_buffer_size],
+//       temp_buf_r: vec![0.0; max_buffer_size],
+//     }
+//   }
+
+//   fn process(&mut self, output: &mut [f32]) {
+//     let frames = output.len() / 2;
+
+//     self.audio_data.fill_stereo(
+//       self.frames_elapsed,
+//       &mut self.temp_buf_l[..frames],
+//       &mut self.temp_buf_r[..frames],
+//     );
+
+//     for (out, (&in1, &in2)) in output
+//       .chunks_exact_mut(2)
+//       .zip(self.temp_buf_l.iter().zip(self.temp_buf_r.iter()))
+//     {
+//       out[0] = in1;
+//       out[1] = in2;
+//     }
+
+//     self.frames_elapsed += frames;
+//   }
+// }

yarn.lock

@@ -90,6 +90,15 @@ __metadata:
   languageName: node
   linkType: hard
 
+"@types/node@npm:^22.10.1":
+  version: 22.10.1
+  resolution: "@types/node@npm:22.10.1"
+  dependencies:
+    undici-types: "npm:~6.20.0"
+  checksum: 10c0/0fbb6d29fa35d807f0223a4db709c598ac08d66820240a2cd6a8a69b8f0bc921d65b339d850a666b43b4e779f967e6ed6cf6f0fca3575e08241e6b900364c234
+  languageName: node
+  linkType: hard
+
 "@vercel/nft@npm:^0.27.5":
   version: 0.27.7
   resolution: "@vercel/nft@npm:0.27.7"
@@ -940,6 +949,7 @@ __metadata:
   resolution: "mediaplex@workspace:."
   dependencies:
     "@napi-rs/cli": "npm:^2.18.4"
+    "@types/node": "npm:^22.10.1"
     ava: "npm:^6.0.1"
   languageName: unknown
   linkType: soft
@@ -1437,6 +1447,13 @@ __metadata:
   languageName: node
   linkType: hard
 
+"undici-types@npm:~6.20.0":
+  version: 6.20.0
+  resolution: "undici-types@npm:6.20.0"
+  checksum: 10c0/68e659a98898d6a836a9a59e6adf14a5d799707f5ea629433e025ac90d239f75e408e2e5ff086afc3cace26f8b26ee52155293564593fbb4a2f666af57fc59bf
+  languageName: node
+  linkType: hard
+
 "unicorn-magic@npm:^0.1.0":
   version: 0.1.0
   resolution: "unicorn-magic@npm:0.1.0"