transport.h

Go to the documentation of this file.

//
// Copyright (c) 2024-2026, Daily
//
// SPDX-License-Identifier: BSD-2-Clause
//
 
 
#ifndef PIPECAT_WEBSOCKET_TRANSPORT_H
#define PIPECAT_WEBSOCKET_TRANSPORT_H
 
#include <pipecat/transport.h>
 
#include <nlohmann/json.hpp>
 
#include <cstddef>
#include <cstdint>
#include <memory>
 
namespace pipecat {
 
struct WebSocketTransportOptions {
    uint32_t user_audio_sample_rate = 16000;
    uint8_t user_audio_channels = 1;
    uint32_t bot_audio_sample_rate = 16000;
    uint8_t bot_audio_channels = 1;
};
 
class WebSocketTransport : public Transport {
   public:
    explicit WebSocketTransport(WebSocketTransportOptions options = {});
 
    ~WebSocketTransport() override;
 
    WebSocketTransport(const WebSocketTransport&) = delete;
 
    WebSocketTransport& operator=(const WebSocketTransport&) = delete;
 
    void initialize(TransportObserver* observer) override;
 
    void connect(const nlohmann::json& params) override;
 
    void disconnect() override;
 
    void send_ready_message(const rtvi::Message& message) override;
 
    void send_message(const rtvi::Message& message) override;
 
    size_t max_message_size() const override;
 
    int32_t send_user_audio(const int16_t* frames, size_t num_frames) override;
 
    int32_t read_bot_audio(int16_t* frames, size_t num_frames) override;
 
   private:
    class Impl;
    std::unique_ptr<Impl> _impl;
};
 
}  // namespace pipecat
 
#endif