import "github.com/quicr/qgo"

func main() {
    // Create and connect client
    client, _ := qgo.NewClient(qgo.ClientConfig{
        ConnectURI: "moq://localhost:4433",
        EndpointID: "my-app",
    })
    defer client.Close()
    
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()
    client.Connect(ctx)

    // Publish objects
    pub, _ := client.PublishTrack(qgo.PublishTrackConfig{
        FullTrackName: qgo.FullTrackName{
            Namespace: qgo.ParseNamespace("app/channel"),
            TrackName: qgo.NewTrackName("data"),
        },
    })
    pub.PublishObject(qgo.ObjectHeaders{GroupID: 1, ObjectID: 1}, []byte("hello"))

    // Subscribe to objects
    sub, _ := client.SubscribeTrack(qgo.SubscribeTrackConfig{
        FullTrackName: qgo.FullTrackName{
            Namespace: qgo.ParseNamespace("app/channel"),
            TrackName: qgo.NewTrackName("data"),
        },
    })
    sub.OnObjectReceived(func(obj qgo.Object) {
        fmt.Println("Received:", string(obj.Data))
    })
}