67 lines
2.1 KiB
Go
67 lines
2.1 KiB
Go
package asteriskws
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"testing"
|
|
"time"
|
|
|
|
"ai-operator/internal/media"
|
|
"github.com/gorilla/websocket"
|
|
)
|
|
|
|
func TestMediaURLToneSilence(t *testing.T) {
|
|
u, _, err := BuildMediaWebSocketURL("ws://127.0.0.1:8088/media/", "abc")
|
|
if err != nil || u != "ws://127.0.0.1:8088/media/abc" {
|
|
t.Fatalf("%s %v", u, err)
|
|
}
|
|
if _, _, err := BuildMediaWebSocketURL("ws://x/media", ""); err == nil {
|
|
t.Fatal("want empty id error")
|
|
}
|
|
if got := len(GenerateSilence(media.CodecSLIN16, 100*time.Millisecond, 16000)); got != 3200 {
|
|
t.Fatalf("silence len=%d", got)
|
|
}
|
|
if got := len(GenerateSineToneSLIN16(440, 100*time.Millisecond, 16000, 2)); got != 3200 {
|
|
t.Fatalf("tone len=%d", got)
|
|
}
|
|
}
|
|
|
|
func TestClientStatsAndFlowControl(t *testing.T) {
|
|
up := websocket.Upgrader{Subprotocols: []string{"media"}}
|
|
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
conn, err := up.Upgrade(w, r, nil)
|
|
if err != nil {
|
|
return
|
|
}
|
|
defer conn.Close()
|
|
_ = conn.WriteMessage(websocket.TextMessage, []byte("MEDIA_START connection_id:abc format:slin16 optimal_frame_size:640 ptime:20"))
|
|
_ = conn.WriteMessage(websocket.BinaryMessage, []byte{1, 2, 3})
|
|
_ = conn.WriteMessage(websocket.TextMessage, []byte("MEDIA_XOFF"))
|
|
time.Sleep(30 * time.Millisecond)
|
|
_ = conn.WriteMessage(websocket.TextMessage, []byte("MEDIA_XON"))
|
|
for {
|
|
if _, _, err := conn.ReadMessage(); err != nil {
|
|
return
|
|
}
|
|
}
|
|
}))
|
|
defer server.Close()
|
|
u := "ws" + server.URL[len("http"):] + "/media/abc"
|
|
c := NewClient(ClientConfig{URL: u, ConnectionID: "abc", Codec: media.CodecSLIN16})
|
|
ctx, cancel := context.WithTimeout(context.Background(), time.Second)
|
|
defer cancel()
|
|
if err := c.Connect(ctx); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
defer c.Close(context.Background())
|
|
time.Sleep(80 * time.Millisecond)
|
|
if err := c.SendAudio(ctx, make([]byte, 1280)); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
st := c.Stats()
|
|
if st.InboundFrames != 1 || st.InboundBytes != 3 || st.XOFFCount != 1 || st.XONCount != 1 || st.OutboundFrames != 2 || st.MediaStart == nil {
|
|
t.Fatalf("stats=%+v", st)
|
|
}
|
|
}
|