r5stream_manager.h

/*
 * Copyright (c) 2022 Infrared5, Inc.
 * License information: https://account.red5.net/assets/LICENSE.txt
 *
 */

#pragma once

#include <vector>
#include "r5common.h"

namespace r5::core {

enum class StreamDirection {
    Undefined = -1, 
    Publish = 0, 
    Subscribe 
};

typedef struct NodeRequest
{
    std::string contextName; 
    std::string streamName; 
    std::string region; 
} NodeRequest;

typedef struct ProvisionRequest
{
    std::string contextName; 
    std::string streamName; 
    std::string username; 
    std::string password; 
    std::vector<r5::common::ProvisionDesc> provisions; 
    std::vector<std::string> regions; 
} ProvisionRequest;
typedef struct StreamManagerResponse
{
    std::string contextName; 
    std::string streamName; 
    std::string region; 
    std::string serverAddress; 
    int returnCode; 
    std::string message; 
    std::string timestamp; 
} StreamManagerResponse;

typedef struct StreamId
{
    std::string contextName; 
    std::string streamName; 
} StreamId;

typedef struct TranscodingVariant
{
    std::string name; 
    int level; 
} TranscodingVariant;

typedef struct ProvisionResponse
{
    std::string contextName; 
    std::string streamName; 
    std::string username; 
    std::string password; 
    std::vector<TranscodingVariant> variants; 

    std::vector<std::string> regions; 
    int returnCode; 
    std::string message; 
    std::string timestamp; 
} ProvisionResponse;

class R5_SDK_CORE_EXPORT Red5ProStreamManager
{
public:
    static int SendNodeRequest(std::string streamManagerUrl, StreamDirection direction, const NodeRequest &request, StreamManagerResponse &response,
                               std::string customParams = "");
    static int SendProvisionRequest(std::string streamManagerUrl, std::string accessToken, const ProvisionRequest &request,
                                    StreamManagerResponse &response, std::string customParams = "");
    static int GetTranscodeStreamsList(std::string streamManagerUrl, std::string accessToken, std::vector<StreamId> &streams);
    static int GetProvision(std::string streamManagerUrl, std::string accessToken, StreamId streamId, ProvisionResponse &response,
                            std::string customParams = "");
    static int DeleteProvision(std::string streamManagerUrl, std::string accessToken, StreamId streamId, ProvisionResponse &response,
                               std::string customParams = "");
};
}