How to write generated ogg data into a webrtc audio track?

[shellfly]

I'm using Text to Speech service to generate streaming OGG data, I want to send the streaming output into a WebRTC audio track. I checked the play-from-disk example in the repo and the below code is what I have written so far.

The problem is that I can send data to the client but I can't hear the audio on the client.

Other things I have tested:

1. If I save the data into a ogg file, it's a valid file and I can play it.
2. Change the oggreader.NewWith(data) to oggreader.NewWith(f) where f is a file opened from disk. There is sound in the client but the speed is weird.

It seems it's something about the ogg options, but I'm not familiar with it. Any idea how can I get this code to work?

func sendAudioData(data io.Reader, audioTrack *webrtc.TrackLocalStaticSample) error {
    ogg, _, oggErr := oggreader.NewWith(data)
    if oggErr != nil {
        return oggErr
    }
    var lastGranule uint64
    for {
        pageData, pageHeader, oggErr := ogg.ParseNextPage()
        if errors.Is(oggErr, io.EOF) {
            fmt.Printf("All audio pages parsed and sent")
            return nil
        }

        if oggErr != nil {
            return oggErr
        }
        slog.Info("ParseNextPage", "header", pageHeader)
        // The amount of samples is the difference between the last and current timestamp
        sampleCount := float64(pageHeader.GranulePosition - lastGranule)
        lastGranule = pageHeader.GranulePosition
        sampleDuration := time.Duration((sampleCount/48000)*1000) * time.Millisecond

        slog.Info("Write Sample", "duration", sampleDuration, "length", len(pageData))
        if oggErr = audioTrack.WriteSample(media.Sample{Data: pageData, Duration: sampleDuration}); oggErr != nil {
            return oggErr
        }
    }
}