ice_selected_pair.cpp

Go to the documentation of this file.

 
#include <rtc/rtc.hpp>
#include <string>
#include <cstring>
 
#include <ascii-chat/network/webrtc/ice.h>
#include <ascii-chat/network/webrtc/webrtc.h>
 
// Windows.h defines these as macros which conflict with our error codes
#ifdef _WIN32
#undef ERROR_INVALID_STATE
#undef ERROR_INVALID_PARAM
#endif
#include <ascii-chat/common/error_codes.h>
 
static asciichat_error_t parse_datachannel_candidate(const std::string &candidate_str, ice_candidate_t *candidate) {
  if (!candidate) {
    return ERROR_INVALID_PARAM;
  }
 
  // Remove "candidate:" prefix if present
  std::string line = candidate_str;
  const char *prefix = "candidate:";
  size_t prefix_len = strlen(prefix);
  if (line.compare(0, prefix_len, prefix) == 0) {
    line = line.substr(prefix_len);
  }
 
  // Use the existing ice_parse_candidate function
  return ice_parse_candidate(line.c_str(), candidate);
}
 
extern "C" {
 
asciichat_error_t ice_get_selected_pair_impl(webrtc_peer_connection_t *pc, ice_candidate_t *local_candidate,
                                             ice_candidate_t *remote_candidate) {
  if (!pc) {
    return ERROR_INVALID_PARAM;
  }
 
  try {
    // Get the libdatachannel peer connection ID using helper function
    int rtc_id = webrtc_get_rtc_id(pc);
    if (rtc_id < 0) {
      return ERROR_INVALID_PARAM;
    }
 
    // Query selected candidate pair from libdatachannel
    // Note: This requires libdatachannel to have the selected candidate pair available
    char local_buf[512];
    char remote_buf[512];
 
    // Try to get the selected local candidate
    if (rtcGetSelectedCandidatePair(rtc_id, local_buf, sizeof(local_buf), remote_buf, sizeof(remote_buf)) < 0) {
      // No pair selected yet, or error accessing it
      return ERROR_INVALID_STATE;
    }
 
    // Parse local candidate if requested
    if (local_candidate) {
      std::string local_str(local_buf);
      asciichat_error_t err = parse_datachannel_candidate(local_str, local_candidate);
      if (err != ASCIICHAT_OK) {
        return err;
      }
    }
 
    // Parse remote candidate if requested
    if (remote_candidate) {
      std::string remote_str(remote_buf);
      asciichat_error_t err = parse_datachannel_candidate(remote_str, remote_candidate);
      if (err != ASCIICHAT_OK) {
        return err;
      }
    }
 
    return ASCIICHAT_OK;
 
  } catch (const std::exception &e) {
    return ERROR_NETWORK;
  } catch (...) {
    return ERROR_NETWORK;
  }
}
 
} // extern "C"