whip-utils.h 2.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. #pragma once
  2. #include <obs.h>
  3. #include <string>
  4. #include <random>
  5. #include <sstream>
  6. #define do_log(level, format, ...) \
  7. blog(level, "[obs-webrtc] [whip_output: '%s'] " format, \
  8. obs_output_get_name(output), ##__VA_ARGS__)
  9. static uint32_t generate_random_u32()
  10. {
  11. std::random_device rd;
  12. std::mt19937 gen(rd());
  13. std::uniform_int_distribution<uint32_t> dist(1, (UINT32_MAX - 1));
  14. return dist(gen);
  15. }
  16. static std::string trim_string(const std::string &source)
  17. {
  18. std::string ret(source);
  19. ret.erase(0, ret.find_first_not_of(" \n\r\t"));
  20. ret.erase(ret.find_last_not_of(" \n\r\t") + 1);
  21. return ret;
  22. }
  23. static size_t curl_writefunction(char *data, size_t size, size_t nmemb,
  24. void *priv_data)
  25. {
  26. auto read_buffer = static_cast<std::string *>(priv_data);
  27. size_t real_size = size * nmemb;
  28. read_buffer->append(data, real_size);
  29. return real_size;
  30. }
  31. #define LOCATION_HEADER_LENGTH 10
  32. static size_t curl_header_location_function(char *data, size_t size,
  33. size_t nmemb, void *priv_data)
  34. {
  35. auto header_buffer = static_cast<std::vector<std::string> *>(priv_data);
  36. size_t real_size = size * nmemb;
  37. if (real_size < LOCATION_HEADER_LENGTH)
  38. return real_size;
  39. if (!astrcmpi_n(data, "location: ", LOCATION_HEADER_LENGTH)) {
  40. char *val = data + LOCATION_HEADER_LENGTH;
  41. auto header_temp =
  42. std::string(val, real_size - LOCATION_HEADER_LENGTH);
  43. header_temp = trim_string(header_temp);
  44. header_buffer->push_back(header_temp);
  45. }
  46. return real_size;
  47. }
  48. static inline std::string generate_user_agent()
  49. {
  50. #ifdef _WIN64
  51. #define OS_NAME "Windows x86_64"
  52. #elif __APPLE__
  53. #define OS_NAME "Mac OS X"
  54. #elif __OpenBSD__
  55. #define OS_NAME "OpenBSD"
  56. #elif __FreeBSD__
  57. #define OS_NAME "FreeBSD"
  58. #elif __linux__ && __LP64__
  59. #define OS_NAME "Linux x86_64"
  60. #else
  61. #define OS_NAME "Linux"
  62. #endif
  63. // Build the user-agent string
  64. std::stringstream ua;
  65. // User agent header prefix
  66. ua << "User-Agent: Mozilla/5.0 ";
  67. // OBS version info
  68. ua << "(OBS-Studio/" << obs_get_version_string() << "; ";
  69. // Operating system version info
  70. ua << OS_NAME << "; " << obs_get_locale() << ")";
  71. return ua.str();
  72. }