Daily Transport Provider

The Daily provider implements bidirectional audio transport through Daily.co rooms. It enables voice pipelines to send and receive audio via Daily’s WebRTC infrastructure.

Choose Daily when you want a managed WebRTC service with simple room-based audio transport. Daily handles the WebRTC infrastructure, letting you focus on voice pipeline logic. For self-hosted WebRTC infrastructure, consider LiveKit. For interoperability with Pipecat-based processing systems, consider Pipecat.

Installation

go get github.com/lookatitude/beluga-ai/voice/transport/providers/daily

Configuration

Field	Required	Default	Description
URL	Yes	—	Daily.co room URL
Token	No	—	Daily room token for authentication
SampleRate	No	16000	Audio sample rate in Hz

Basic Usage

package main

import (
    "context"
    "fmt"
    "log"

    "github.com/lookatitude/beluga-ai/voice/transport"
    _ "github.com/lookatitude/beluga-ai/voice/transport/providers/daily"
)

func main() {
    t, err := transport.New("daily", transport.Config{
        URL:   "https://myapp.daily.co/room-name",
        Token: "your-daily-token",
    })
    if err != nil {
        log.Fatal(err)
    }
    defer t.Close()

    // Receive incoming audio frames
    frames, err := t.Recv(context.Background())
    if err != nil {
        log.Fatal(err)
    }

    for frame := range frames {
        fmt.Printf("Received %d bytes of audio\n", len(frame.Data))
    }
}

Advanced Features

Sending Audio

Write processed audio frames back to the Daily room using voice.NewAudioFrame:

frame := voice.NewAudioFrame(processedPCM, 16000)
err := t.Send(ctx, frame)
if err != nil {
    log.Printf("send failed: %v", err)
}

Raw Audio Output

For direct audio piping without frame wrapping:

writer := t.AudioOut()
_, err := writer.Write(rawPCMData)
if err != nil {
    log.Printf("audio write failed: %v", err)
}

Direct Construction

import "github.com/lookatitude/beluga-ai/voice/transport/providers/daily"

t, err := daily.New(transport.Config{
    URL:        "https://myapp.daily.co/room-name",
    Token:      "your-daily-token",
    SampleRate: 16000,
})

Error Handling

t, err := transport.New("daily", transport.Config{})
if err != nil {
    // "daily: URL is required"
    log.Fatal(err)
}

frames, err := t.Recv(ctx)
if err != nil {
    // Transport may be closed
    log.Fatal(err)
}

The transport returns an error from Recv and Send if Close has already been called.

Refer to the Daily.co documentation for room setup and token generation.