SOUND4 x1.CLOUD Library [1.5.0]
sound4.x1.cloud_dyn.hpp
Go to the documentation of this file.
1 
7 #pragma once
8 
9 #include <string>
10 #include <exception>
11 #include <thread>
12 #include <functional>
13 #include <memory>
14 #include <array>
15 #include <assert.h>
16 #include <stdexcept>
17 #include <filesystem>
18 #include <string.h>
19 
20 #ifdef __unix__
21  #include <dlfcn.h>
22 #elif defined(_WIN32)
23  #include <libloaderapi.h>
24 #else
25  #error "Unsupported OS"
26 #endif
27 
28 // Needed to have function declarations
29 #include "sound4.x1.cloud.h"
30 
31 
32 #ifdef _WIN32
33  #include <stringapiset.h>
34  #include <wchar.h>
36  #define fs_strdup wcsdup
37 #else // !_WIN32
39  #define fs_strdup strdup
40 #endif // !_WIN32
41 
42 // bridge C callbacks to CPresetLoader
43 extern "C" {
44  static char *cloudx1_custom_reader(const fs_char *filename, void* userdata);
45  static void cloudx1_custom_reader_free(char *content, void* userdata);
46  static int cloudx1_custom_writer(const fs_char *filename, const char *content, void* userdata);
47  static int cloudx1_custom_exists(const fs_char *filename, void* userdata);
48  static fs_char** cloudx1_custom_getall(void* userdata);
49  static void cloudx1_custom_getall_free(fs_char** all, void* userdata);
50  static int cloudx1_custom_remove(const fs_char *filename, void* userdata);
51  static int cloudx1_custom_rename(const fs_char *from, const fs_char *to, void* userdata);
52 };
53 
57 namespace sound4 {
61 namespace cloudx1 {
65 namespace dyn {
66 
70  namespace helper {
71  // Storage definition, depending on OS
72  #ifdef __unix__
73  using DynLib_t = void *;
74  using DynFunc_t = void *;
75  #else
76  using DynLib_t = HMODULE;
77  using DynFunc_t = FARPROC;
78  #endif
79 
85  template <typename T>
86  class DynFuncHolder {
87  private:
88  DynFunc_t m_ptr = NULL;
89  public:
90  DynFuncHolder() = default;
91  DynFuncHolder(DynFunc_t a_ptr) : m_ptr(a_ptr) {}
92  operator bool() const { return (m_ptr!=NULL); }
93  bool IsOk() const { return m_ptr!=NULL; }
94  operator T* () const { return reinterpret_cast<T*>(m_ptr); }
95  };
96 
101  class CDynLoader {
102  private:
103  DynLib_t m_lib {};
104  public:
105  CDynLoader() = default;
106  CDynLoader(CDynLoader&&) = default;
107  // No copy allowed
108  CDynLoader(const CDynLoader&) = delete;
109  CDynLoader& operator=(CDynLoader const&) = delete;
110  operator bool() const {
111  return (m_lib!=NULL);
112  }
113  bool IsOk() const {
114  return (m_lib!=NULL);
115  }
116  #ifdef __unix__
117  void Close() {
118  if (IsOk()) {
119  #ifndef __SANITIZE_ADDRESS__ // avoid unloading to keep call stack
120  dlclose(m_lib);
121  #endif // __SANITIZE_ADDRESS__
122  m_lib=NULL;
123  }
124  }
125  bool Load(const std::filesystem::path& dynlib)
126  {
127  Close();
128  m_lib=dlopen(dynlib.c_str(), RTLD_NOW|RTLD_LOCAL);
129  return IsOk();
130  }
131  template <typename T>
132  DynFuncHolder<T> GetSymbol(const std::string& name) {
133  auto ptr=dlsym(m_lib, name.c_str());
134  if (!ptr) {
135  throw std::runtime_error("Missing function in library");
136  }
137  return DynFuncHolder<T>(ptr);
138  }
139  template <typename T>
140  DynFuncHolder<T> GetSymbol_safe(const std::string& name) {
141  auto ptr=dlsym(m_lib, name.c_str());
142  return DynFuncHolder<T>(ptr);
143  }
144  static std::filesystem::path GetThisLibraryPath(void) {
145  static Dl_info info;
146  if (! dladdr((void *) GetThisLibraryPath, & info)) return {};
147  auto rp=realpath(info.dli_fname, NULL);
148  std::filesystem::path p(rp);
149  free(rp);
150  return p;
151  }
152  #else
153  bool Load(const std::filesystem::path& dynlib, uint32_t loadflags = LOAD_LIBRARY_SEARCH_DLL_LOAD_DIR|LOAD_LIBRARY_SEARCH_APPLICATION_DIR|LOAD_LIBRARY_SEARCH_USER_DIRS|LOAD_LIBRARY_SEARCH_SYSTEM32)
154  {
155  Close();
156  m_lib=LoadLibraryExW(dynlib.c_str(), NULL, loadflags);
157  return IsOk();
158  }
159  void Close() {
160  if (IsOk()) {
161  // NOTE: On Windows, FreeLibrary may create a lot of troubles, should use FreeLibraryAndExitThread but...
162  // So define SOUND4_CALL_FREELIBRARY before including this file if you really want to unload the library dynamically
163  #if defined(SOUND4_CALL_FREELIBRARYANDEXITTHREAD)
164  FreeLibraryAndExitThread(m_lib, 0);
165  #elif defined(SOUND4_CALL_FREELIBRARY)
166  FreeLibrary(m_lib);
167  #endif // SOUND4_CALL_FREELIBRARY
168  m_lib=NULL;
169  }
170  }
171  template <typename T>
172  DynFuncHolder<T> GetSymbol(const std::string& name) {
173  auto ptr=GetProcAddress(m_lib, name.c_str());
174  if (!ptr) {
175  throw std::runtime_error("Missing function in library");
176  }
177  return DynFuncHolder<T>(ptr);
178  }
179  template <typename T>
180  DynFuncHolder<T> GetSymbol_safe(const std::string& name) {
181  auto ptr=GetProcAddress(m_lib, name.c_str());
182  return DynFuncHolder<T>(ptr);
183  }
184  static std::filesystem::path GetThisLibraryPath(void) {
185  static wchar_t path[MAX_PATH]={};
186  HMODULE hm = NULL;
187  if (GetModuleHandleExW(GET_MODULE_HANDLE_EX_FLAG_FROM_ADDRESS |
188  GET_MODULE_HANDLE_EX_FLAG_UNCHANGED_REFCOUNT,
189  (LPCWSTR) &GetThisLibraryPath, &hm))
190  {
191  if (GetModuleFileNameW(hm, path, MAX_PATH) > 0) {
192  return std::filesystem::path(path);
193  }
194  }
195  return {};
196  }
197  #endif
198  virtual ~CDynLoader() {
199  Close();
200  }
201  }; // class CDynLoader
202  }; // namespace helper
203 
210  class CDynLib {
211  private:
212  helper::CDynLoader m_lib;
213  bool m_bOK = false;
214  public:
215  CDynLib() = default;
216 
217  // All those wrapped functions have the same signature as there C cloudx1_XXX
262 #if CLOUDX1_HAS_WEBSERVER
268 #endif // CLOUDX1_HAS_WEBSERVER
269 
270  // added 2023-03-22
273 
274  // added 2023-05-22
278 
279  // added 2023-06-20
282 
283  // added 2023-09-21
287 
288 #if CLOUDX1_HAS_CLOUDBUS
289  // added 2023-06-26
290  helper::DynFuncHolder< decltype(cloudx1_NewBus ) > NewBus ;
291  helper::DynFuncHolder< decltype(cloudx1_FreeBus ) > FreeBus ;
292  helper::DynFuncHolder< decltype(cloudx1_SetInstanceBus ) > SetInstanceBus ;
293 #endif // CLOUDX1_HAS_CLOUDBUS
294 
295  // added 2024-02-19
297 
298 #if CLOUDX1_HAS_WEBSERVER
299  // added 2024-05-23
303 #endif // CLOUDX1_HAS_WEBSERVER
304 
312  bool Load(const std::filesystem::path& path = {}) {
313  std::string filename;
314  #ifdef __unix__
315  filename="libsound4.x1.cloud.so";
316  #else
317  filename="sound4.x1.cloud.dll";
318  #endif
319  m_lib.Close();
320  // If a path is given, use it directly and do not try other path
321  if (!path.empty() && !m_lib.Load(path / filename)) {
322  return false;
323  } else if (!m_lib.IsOk()) {
324  auto thisdir=helper::CDynLoader::GetThisLibraryPath().parent_path();
325  #ifndef _WIN32
326  // Linux: if in a bin directory, try ../lib first
327  if (!m_lib.IsOk() && thisdir.filename()=="bin") {
328  auto libdir = thisdir.parent_path() / "lib";
329  m_lib.Load(libdir / filename);
330  }
331  #endif // !_WIN32
332  if (!m_lib.IsOk()) {
333  // Search in the same directory this code is in
334  m_lib.Load(thisdir / filename);
335  }
336  if (!m_lib.IsOk()) {
337  // Try current path
338  m_lib.Load(std::filesystem::current_path() / filename);
339  }
340  if (!m_lib.IsOk()) {
341  return false;
342  }
343  }
344  // Load all C functions
345  try {
346  GetVersion = m_lib.GetSymbol< decltype(cloudx1_GetVersion ) >("cloudx1_GetVersion" );
347  GetChunkSizeInFrames = m_lib.GetSymbol< decltype(cloudx1_GetChunkSizeInFrames ) >("cloudx1_GetChunkSizeInFrames" );
348  GetChannelCount = m_lib.GetSymbol< decltype(cloudx1_GetChannelCount ) >("cloudx1_GetChannelCount" );
349  GetAudioInputCount = m_lib.GetSymbol< decltype(cloudx1_GetAudioInputCount ) >("cloudx1_GetAudioInputCount" );
350  GetAudioOutputCount = m_lib.GetSymbol< decltype(cloudx1_GetAudioOutputCount ) >("cloudx1_GetAudioOutputCount" );
351  GetSampleRate = m_lib.GetSymbol< decltype(cloudx1_GetSampleRate ) >("cloudx1_GetSampleRate" );
352  SetLoggerCallback = m_lib.GetSymbol< decltype(cloudx1_SetLoggerCallback ) >("cloudx1_SetLoggerCallback" );
353  SetLogSeverity = m_lib.GetSymbol< decltype(cloudx1_SetLogSeverity ) >("cloudx1_SetLogSeverity" );
354  NewParameters = m_lib.GetSymbol< decltype(cloudx1_NewParameters ) >("cloudx1_NewParameters" );
355  FreeParameters = m_lib.GetSymbol< decltype(cloudx1_FreeParameters ) >("cloudx1_FreeParameters" );
356  SetParameter = m_lib.GetSymbol< decltype(cloudx1_SetParameter ) >("cloudx1_SetParameter" );
357  GetParameter = m_lib.GetSymbol< decltype(cloudx1_GetParameter ) >("cloudx1_GetParameter" );
358  FreeParameterValue = m_lib.GetSymbol< decltype(cloudx1_FreeParameterValue ) >("cloudx1_FreeParameterValue" );
359  InitProcess = m_lib.GetSymbol< decltype(cloudx1_InitProcess ) >("cloudx1_InitProcess" );
360  InitProcess2 = m_lib.GetSymbol< decltype(cloudx1_InitProcess2 ) >("cloudx1_InitProcess2" );
361  TerminateProcess = m_lib.GetSymbol< decltype(cloudx1_TerminateProcess ) >("cloudx1_TerminateProcess" );
362  ExitProcess = m_lib.GetSymbol< decltype(cloudx1_ExitProcess ) >("cloudx1_ExitProcess" );
363  StartUpdateThread = m_lib.GetSymbol< decltype(cloudx1_StartUpdateThread ) >("cloudx1_StartUpdateThread" );
364  StopUpdateThread = m_lib.GetSymbol< decltype(cloudx1_StopUpdateThread ) >("cloudx1_StopUpdateThread" );
365  WaitUpdateThreadReady = m_lib.GetSymbol< decltype(cloudx1_WaitUpdateThreadReady ) >("cloudx1_WaitUpdateThreadReady" );
366  ProcessAudio = m_lib.GetSymbol< decltype(cloudx1_ProcessAudio ) >("cloudx1_ProcessAudio" );
367  ProcessAudio_Planar = m_lib.GetSymbol< decltype(cloudx1_ProcessAudio_Planar ) >("cloudx1_ProcessAudio_Planar" );
368  GetBufferIn = m_lib.GetSymbol< decltype(cloudx1_GetBufferIn ) >("cloudx1_GetBufferIn" );
369  GetBufferOut = m_lib.GetSymbol< decltype(cloudx1_GetBufferOut ) >("cloudx1_GetBufferOut" );
370  GetEstimatedDelay = m_lib.GetSymbol< decltype(cloudx1_GetEstimatedDelay ) >("cloudx1_GetEstimatedDelay" );
371  GetFormatName = m_lib.GetSymbol< decltype(cloudx1_GetFormatName ) >("cloudx1_GetFormatName" );
372  GetFormatFromName = m_lib.GetSymbol< decltype(cloudx1_GetFormatFromName ) >("cloudx1_GetFormatFromName" );
373  GetBytesFromFormat = m_lib.GetSymbol< decltype(cloudx1_GetBytesFromFormat ) >("cloudx1_GetBytesFromFormat" );
374  GetMaxPacketFrame = m_lib.GetSymbol< decltype(cloudx1_GetMaxPacketFrame ) >("cloudx1_GetMaxPacketFrame" );
375  AddAudio = m_lib.GetSymbol< decltype(cloudx1_AddAudio ) >("cloudx1_AddAudio" );
376  AddPadAudio = m_lib.GetSymbol< decltype(cloudx1_AddPadAudio ) >("cloudx1_AddPadAudio" );
377  GetOutputCount = m_lib.GetSymbol< decltype(cloudx1_GetOutputCount ) >("cloudx1_GetOutputCount" );
378  GetAudio = m_lib.GetSymbol< decltype(cloudx1_GetAudio ) >("cloudx1_GetAudio" );
379  AudioConvertFrom = m_lib.GetSymbol< decltype(cloudx1_AudioConvertFrom ) >("cloudx1_AudioConvertFrom" );
380  AudioConvertTo = m_lib.GetSymbol< decltype(cloudx1_AudioConvertTo ) >("cloudx1_AudioConvertTo" );
381  StereoToMono = m_lib.GetSymbol< decltype(cloudx1_StereoToMono ) >("cloudx1_StereoToMono" );
382  MonoToStereo = m_lib.GetSymbol< decltype(cloudx1_MonoToStereo ) >("cloudx1_MonoToStereo" );
383  AudioMonoFromLiveStereo = m_lib.GetSymbol< decltype(cloudx1_AudioMonoFromLiveStereo) >("cloudx1_AudioMonoFromLiveStereo");
384  AudioMonoToLiveStereo = m_lib.GetSymbol< decltype(cloudx1_AudioMonoToLiveStereo ) >("cloudx1_AudioMonoToLiveStereo" );
385  NewClient = m_lib.GetSymbol< decltype(cloudx1_NewClient ) >("cloudx1_NewClient" );
386  DeleteClient = m_lib.GetSymbol< decltype(cloudx1_DeleteClient ) >("cloudx1_DeleteClient" );
387  ProcessJson = m_lib.GetSymbol< decltype(cloudx1_ProcessJson ) >("cloudx1_ProcessJson" );
388  FreeJsonAnswer = m_lib.GetSymbol< decltype(cloudx1_FreeJsonAnswer ) >("cloudx1_FreeJsonAnswer" );
389  SaveState = m_lib.GetSymbol< decltype(cloudx1_SaveState ) >("cloudx1_SaveState" );
390 #if CLOUDX1_HAS_WEBSERVER
391  Webserver_tcp = m_lib.GetSymbol< decltype(cloudx1_Webserver_tcp ) >("cloudx1_Webserver_tcp" );
392  Webserver_tcp2 = m_lib.GetSymbol< decltype(cloudx1_Webserver_tcp2 ) >("cloudx1_Webserver_tcp2" );
393  Webserver = m_lib.GetSymbol< decltype(cloudx1_Webserver ) >("cloudx1_Webserver" );
394  Webserver_Stop = m_lib.GetSymbol< decltype(cloudx1_Webserver_Stop ) >("cloudx1_Webserver_Stop" );
395  Webserver_Status = m_lib.GetSymbol< decltype(cloudx1_Webserver_Status ) >("cloudx1_Webserver_Status" );
396 #endif // CLOUDX1_HAS_WEBSERVER
397 
398  // added 2023-03-22
399  StereoToMono_Planar = m_lib.GetSymbol< decltype(cloudx1_StereoToMono_Planar ) >("cloudx1_StereoToMono_Planar" );
400  MonoToStereo_Planar = m_lib.GetSymbol< decltype(cloudx1_MonoToStereo_Planar ) >("cloudx1_MonoToStereo_Planar" );
401 
402  } catch (std::runtime_error& ) {
403  return false;
404  }
405  // C functions allowed to be missing
406  try {
407  // added 2023-05-22
408  SetMetadata = m_lib.GetSymbol< decltype(cloudx1_SetMetadata ) >("cloudx1_SetMetadata" );
409  GetMetadataInfos = m_lib.GetSymbol< decltype(cloudx1_GetMetadataInfos ) >("cloudx1_GetMetadataInfos" );
410  FreeMetadataInfos = m_lib.GetSymbol< decltype(cloudx1_FreeMetadataInfos ) >("cloudx1_FreeMetadataInfos" );
411  // added 2023-06-20
412  SetPresetManager = m_lib.GetSymbol< decltype(cloudx1_SetPresetManager ) >("cloudx1_SetPresetManager" );
413  PresetManager_InformChange = m_lib.GetSymbol< decltype(cloudx1_PresetManager_InformChange ) >("cloudx1_PresetManager_InformChange" );
414 
415  // added 2023-09-21
416  GetPossibleChunkSizeInFrames = m_lib.GetSymbol< decltype(cloudx1_GetPossibleChunkSizeInFrames ) >("cloudx1_GetPossibleChunkSizeInFrames" );
417  GetProcessChunkFrames = m_lib.GetSymbol< decltype(cloudx1_GetProcessChunkFrames ) >("cloudx1_GetProcessChunkFrames" );
418  InitProcess3 = m_lib.GetSymbol< decltype(cloudx1_InitProcess3 ) >("cloudx1_InitProcess3" );
419 
420 #if CLOUDX1_HAS_CLOUDBUS
421  // added 2023-06-26
422  NewBus = m_lib.GetSymbol< decltype(cloudx1_NewBus ) >("cloudx1_NewBus" );
423  FreeBus = m_lib.GetSymbol< decltype(cloudx1_FreeBus ) >("cloudx1_FreeBus" );
424  SetInstanceBus = m_lib.GetSymbol< decltype(cloudx1_SetInstanceBus ) >("cloudx1_SetInstanceBus" );
425 #endif // CLOUDX1_HAS_CLOUDBUS
426 
427  // added 2024-02-19
428  SetMetadataMulti = m_lib.GetSymbol< decltype(cloudx1_SetMetadataMulti ) >("cloudx1_SetMetadataMulti" );
429 
430 #if CLOUDX1_HAS_WEBSERVER
431  // added 2024-05-23
432  Webserver_SetAppHealth = m_lib.GetSymbol< decltype(cloudx1_Webserver_SetAppHealth ) >("Webserver_SetAppHealth" );
433  Webserver_GetAppHealth = m_lib.GetSymbol< decltype(cloudx1_Webserver_GetAppHealth ) >("Webserver_GetAppHealth" );
434  Webserver_FreeString = m_lib.GetSymbol< decltype(cloudx1_Webserver_FreeString ) >("Webserver_FreeString" );
435 #endif // CLOUDX1_HAS_WEBSERVER
436 
437  } catch (std::runtime_error& ) {
438  // Ignored, handler will take care
439  }
440 
441  m_bOK=true;
442  return true;
443  }
450  bool IsOk() const {
451  return m_bOK;
452  }
453 
454  };
455 
456 
457 
458  static constexpr const char *process_name = "SOUND4 x1.CLOUD";
459  static constexpr const char *process_shortname = "x1";
485 
489  namespace helper {
490  #ifdef _WIN32
496  static inline std::string WStringToUTF8(const std::wstring& wstr) {
497  if (wstr.empty()) return {};
498  int size = WideCharToMultiByte(CP_UTF8, 0, &wstr[0], (int)wstr.size(), NULL, 0, NULL, NULL);
499  std::string str(size, 0);
500  WideCharToMultiByte(CP_UTF8, 0, &wstr[0], (int)wstr.size(), &str[0], size, NULL, NULL);
501  return str;
502  }
508  static inline std::wstring UTF8ToWString(const std::string& str) {
509  if (str.empty()) return std::wstring();
510  int size = MultiByteToWideChar(CP_UTF8, 0, &str[0], (int)str.size(), NULL, 0);
511  std::wstring wstr(size, 0);
512  MultiByteToWideChar(CP_UTF8, 0, &str[0], (int)str.size(), &wstr[0], size);
513  return wstr;
514  }
515  #endif // _WIN32
516 
522  template<typename T>
523  struct SampleFormat {
524  };
525  template<>
526  struct SampleFormat<int16_t> {
528  };
529  template<>
530  struct SampleFormat<int32_t> {
532  };
533  template<>
534  struct SampleFormat<float> {
536  };
537 
538 
543  static inline void AudioConvertFrom(CDynLib& dynlib, const uint8_t *payload, float *output, size_t nSpl, cloudx1_SampleFormat fmt) {
544  dynlib.AudioConvertFrom(payload, output, nSpl, fmt);
545  }
546  static inline void AudioConvertTo(CDynLib& dynlib, const float *input, uint8_t *payload, size_t nSpl, cloudx1_SampleFormat fmt) {
547  dynlib.AudioConvertTo(input, payload, nSpl, fmt);
548  }
549  static inline void StereoToMono(CDynLib& dynlib, const float *input, float *output, size_t nSpl) {
550  dynlib.StereoToMono(input, output, nSpl);
551  }
552  static inline void MonoToStereo(CDynLib& dynlib, const float *input, float *output, size_t nSpl) {
553  dynlib.MonoToStereo(input, output, nSpl);
554  }
555  static inline void StereoToMono_Planar(CDynLib& dynlib, const float *inputL, const float *inputR, float *output, size_t nSpl) {
556  dynlib.StereoToMono_Planar(inputL, inputR, output, nSpl);
557  }
558  static inline void MonoToStereo_Planar(CDynLib& dynlib, const float *input, float *outputL, float *outputR, size_t nSpl) {
559  dynlib.MonoToStereo_Planar(input, outputL, outputR, nSpl);
560  }
561  static inline void AudioMonoFromLiveStereo(CDynLib& dynlib, const uint8_t *payload, float *output) {
562  dynlib.AudioMonoFromLiveStereo(payload, output);
563  }
564  static inline void AudioMonoToLiveStereo(CDynLib& dynlib, const float *input, uint8_t *payload) {
565  dynlib.AudioMonoToLiveStereo(input, payload);
566  }
567 
568  }; // namespace helper
569 
575  static inline std::string GetVersion(CDynLib& dynlib)
576  {
577  return std::string(dynlib.GetVersion());
578  }
579 
590  static inline unsigned int GetChunkSizeInFrames(CDynLib& dynlib)
591  {
592  return dynlib.GetChunkSizeInFrames();
593  }
594 
603  static inline std::vector<unsigned int> GetPossibleChunkSizeInFrames(CDynLib& dynlib)
604  {
605  std::vector<unsigned int> list;
606  if (dynlib.GetPossibleChunkSizeInFrames) {
607  for (unsigned int* src=dynlib.GetPossibleChunkSizeInFrames();*src;src++) {
608  list.push_back(*src);
609  }
610  } else {
611  list.push_back(64);
612  }
613  return list;
614  }
615 
623  static inline unsigned int GetChannelCount(CDynLib& dynlib)
624  {
625  return dynlib.GetChannelCount();
626  }
627 
636  static inline unsigned int GetAudioInputCount(CDynLib& dynlib)
637  {
638  return dynlib.GetAudioInputCount();
639  }
640 
649  static inline unsigned int GetAudioOutputCount(CDynLib& dynlib)
650  {
651  return dynlib.GetAudioOutputCount();
652  }
653 
661  static inline unsigned int GetSampleRate(CDynLib& dynlib)
662  {
663  return dynlib.GetSampleRate();
664  }
665 
671  static inline void SanityCheck(CDynLib& dynlib, bool a_bCheckFrames = true)
672  {
673  // Do some sanity checks
674  if (dynlib.GetSampleRate()!=CLOUDX1_SAMPLE_RATE) {
675  throw std::runtime_error("Bad library sampling rate");
676  }
677  if (a_bCheckFrames && dynlib.GetChunkSizeInFrames()!=ChunkFrames) {
678  throw std::runtime_error("Bad library frame size");
679  }
680  if (dynlib.GetChannelCount()!=CLOUDX1_CHANNEL_COUNT) {
681  throw std::runtime_error("Bad library channel count");
682  }
683  if (dynlib.GetAudioInputCount()!=CLOUDX1_AUDIO_INPUT_COUNT) {
684  throw std::runtime_error("Bad library input count");
685  }
686  if (dynlib.GetAudioOutputCount()!=CLOUDX1_AUDIO_OUTPUT_COUNT) {
687  throw std::runtime_error("Bad library output count");
688  }
689  }
690 
697  static inline std::string GetFormatName(CDynLib& dynlib, const SampleFormat fmt)
698  {
699  return std::string(dynlib.GetFormatName(fmt));
700  }
701 
708  static inline SampleFormat GetFormatFromName(CDynLib& dynlib, const std::string& name)
709  {
710  return dynlib.GetFormatFromName(name.c_str());
711  }
712 
719  static inline unsigned int GetBytesFromFormat(CDynLib& dynlib, const SampleFormat fmt)
720  {
721  return dynlib.GetBytesFromFormat(fmt);
722  }
723 
731  using log_cb_t = std::function<void(LogSeverity,const std::string&)>;
732 
736  static log_cb_t _log_cb;
737  extern "C" {
738  static inline void _log_cb_c(cloudx1_LogSeverity severity, const char *c_msg) {
739  _log_cb(severity, std::string(c_msg));
740  }
741  }
745  static inline void SetLogSeverity(CDynLib& dynlib, LogSeverity severity)
746  {
747  dynlib.SetLogSeverity(severity);
748  }
752  static inline void SetLoggerCallback(CDynLib& dynlib, log_cb_t cb)
753  {
754  _log_cb=cb;
755  dynlib.SetLoggerCallback(&_log_cb_c);
756  }
757 
758 #if CLOUDX1_HAS_CLOUDBUS
759  class CBus {
760  public:
761  CBus(CDynLib& dynlib)
762  : m_dynlib(dynlib)
763  {
764  if (m_dynlib.NewBus) {
765  m_bus=m_dynlib.NewBus();
766  }
767  }
768  ~CBus()
769  {
770  if (m_bus && m_dynlib.FreeBus) {
771  m_dynlib.FreeBus(m_bus);
772  }
773  m_bus = nullptr;
774  }
775  cloudx1_CBus *Get() const { return m_bus; }
776  private:
777  CDynLib& m_dynlib;
778  cloudx1_CBus *m_bus;
779  };
780 #endif // CLOUDX1_HAS_CLOUDBUS
781 
787  public:
788  CPresetLoader() = default;
789  virtual ~CPresetLoader() = default;
790 
791  virtual bool IsReadOnly() = 0;
792  virtual bool Exists(const std::filesystem::path &name) = 0;
793  virtual bool Remove(const std::filesystem::path &name) = 0;
794  virtual bool Rename(const std::filesystem::path &from, const std::filesystem::path &to) = 0;
795  virtual std::vector<std::filesystem::path> GetAll() = 0;
796  virtual std::string Read(const std::filesystem::path &filename) = 0;
797  virtual bool Write(const std::filesystem::path &filename, const std::string &content) =0;
798  };
800 
804  class CInstance {
805  public:
810  : m_dynlib(dynlib)
811  {
812  params = m_dynlib.NewParameters();
813  if (!params) throw std::bad_alloc();
814  }
815  // non-copyable
816  CInstance( const CInstance& ) = delete;
817  CInstance& operator=( const CInstance& ) = delete;
822  {
823  Stop();
824  if (params) m_dynlib.FreeParameters(params);
825  }
829  bool IsOk() const { return instance!=nullptr; }
837  void SetParam(const std::string& name, const std::string& value)
838  {
839  assert(params);
840  m_dynlib.SetParameter(params, name.c_str(), value.c_str());
841  }
847  std::string GetParam(const std::string& name)
848  {
849  assert(params);
850  auto c_value=m_dynlib.GetParameter(params, name.c_str());
851  std::string ret(c_value);
852  m_dynlib.FreeParameterValue(c_value);
853  return ret;
854  }
855 #if CLOUDX1_HAS_CLOUDBUS
859  void SetBus(const CBus& bus) {
860  assert(params);
861  if (m_dynlib.SetInstanceBus) {
862  m_dynlib.SetInstanceBus(params,bus.Get());
863  }
864  }
865 #endif // CLOUDX1_HAS_CLOUDBUS
866 
876  void SetPresetManager(CPresetLoader *preset_manager)
877  {
878  if (!preset_manager) return;
879  if (!m_dynlib.SetPresetManager) return;
880  assert(params);
881  m_dynlib.SetPresetManager(params,
882  cloudx1_custom_reader,
883  cloudx1_custom_reader_free,
884  cloudx1_custom_writer,
885  cloudx1_custom_exists,
886  cloudx1_custom_getall,
887  cloudx1_custom_getall_free,
888  cloudx1_custom_remove,
889  cloudx1_custom_rename,
890  preset_manager->IsReadOnly(),
891  preset_manager
892  );
893  }
894 
909  bool Create(const std::string& LoginKey, const std::string& RadioName, const std::string& Access_Key_ID, const std::string& Access_Key_Secret, const std::filesystem::path& save_path, int json_port = 0, unsigned int frames_per_chunk=64)
910  {
911  assert(!instance);
912  std::string l_save_path;
913  if (!save_path.empty()) {
914  l_save_path = save_path.u8string();
915  }
916  if (m_dynlib.InitProcess3) {
917  instance = m_dynlib.InitProcess3(LoginKey.c_str(), RadioName.c_str(), Access_Key_ID.c_str(), Access_Key_Secret.c_str(), l_save_path.c_str(), params, frames_per_chunk);
918  } else if (frames_per_chunk!=64) {
919  return false;
920  } else {
921  instance = m_dynlib.InitProcess2(LoginKey.c_str(), RadioName.c_str(), Access_Key_ID.c_str(), Access_Key_Secret.c_str(), l_save_path.c_str(), params);
922  }
923  if (!instance) return false;
924  if (!init_metadata.empty()) {
925  for (auto&& [key,value]: init_metadata) {
926  m_dynlib.SetMetadata(instance, key.c_str(), value.c_str());
927  }
928  init_metadata.clear();
929  }
930  update_thread = std::thread([this, json_port](){
932  m_dynlib.StartUpdateThread(instance, json_port);
934  });
935  int timeout=5000;
936  #ifdef DEBUG
937  timeout=60*1000; // For debugger pauses
938  #endif
939  if (m_dynlib.WaitUpdateThreadReady(instance, timeout)<0) {
940  return false;
941  }
942  return true;
943  }
944 
952  unsigned int GetChunkFrames() {
953  if (instance && m_dynlib.GetProcessChunkFrames) {
954  return m_dynlib.GetProcessChunkFrames(instance);
955  }
956  return 64;
957  }
958 
966  void PresetManager_InformChange(const std::filesystem::path& relative_path, PresetChange_Kind change_kind)
967  {
968  if (m_dynlib.PresetManager_InformChange) {
969  m_dynlib.PresetManager_InformChange(instance, relative_path.c_str(), (cloudx1_PresetChange_Kind) change_kind);
970  }
971  }
972 
984  void SetMetadata(const std::string& key, const char* value)
985  {
986  if (m_dynlib.SetMetadata) {
987  if (instance) {
988  m_dynlib.SetMetadata(instance, key.c_str(), value);
989  } else {
990  init_metadata.push_back( {key, value} );
991  }
992  }
993  }
994 
995 
1005  void SetMetadataMulti(const std::unordered_map<std::string, const char*>& list)
1006  {
1007  if (instance) {
1008  if (m_dynlib.SetMetadataMulti) {
1009  typedef const char* pchar;
1010  pchar* keyvalue=new pchar[2*list.size()+1];
1011  size_t n=0;
1012  for (auto&& [key,value]: list) {
1013  keyvalue[2*n+0]=key.c_str();
1014  keyvalue[2*n+1]=value;
1015  n++;
1016  }
1017  keyvalue[2*n+0]=nullptr;
1018 
1019  cloudx1_SetMetadataMulti(instance, keyvalue);
1020 
1021  delete[] keyvalue;
1022  } else {
1023  for (auto&& [key,value]: list) {
1024  SetMetadata(key, value);
1025  }
1026  }
1027  } else {
1028  for (auto&& [key,value]: list) {
1029  if (value) {
1030  init_metadata.push_back( {key, value} );
1031  }
1032  }
1033  }
1034  }
1035 
1041  std::vector< std::tuple<std::string,std::string> > GetMetadataInfos()
1042  {
1043  std::vector< std::tuple<std::string,std::string> > values;
1044  if (m_dynlib.GetMetadataInfos) {
1045  const char** c_values = m_dynlib.GetMetadataInfos(instance);
1046  if (c_values) {
1047  for (const char** c_value=c_values; *c_value; ) {
1048  std::string key(*c_value);
1049  c_value++;
1050  if (*c_value) {
1051  std::string descr(*c_value);
1052  c_value++;
1053  values.push_back( {key,descr} );
1054  }
1055  }
1056  m_dynlib.FreeMetadataInfos(instance, c_values);
1057  }
1058  }
1059  return values;
1060  }
1061 
1062  // Can be overloaded, called at start of UpdateThread in the thread
1063  virtual void OnUpdateThreadStart() {}
1064  // Can be overloaded to call at end of UpdateThread in the thread
1065  virtual void OnUpdateThreadStop() {}
1066 
1067 #if CLOUDX1_HAS_WEBSERVER
1073  bool StartWebServer(int http_port, int https_port=0)
1074  {
1075  assert(instance);
1076  assert(webserver==SOUND4_INVALID_WEBSERVER_ID);
1077  webserver = m_dynlib.Webserver(http_port,https_port,instance);
1078  if (webserver==SOUND4_INVALID_WEBSERVER_ID) {
1079  return false;
1080  }
1081  int web_status=m_dynlib.Webserver_Status(webserver);
1082  if (http_port && (web_status & SOUND4_WEBSERVER_HTTP_OK) == 0) {
1083  return false;
1084  }
1085  if (https_port && (web_status & SOUND4_WEBSERVER_HTTPS_OK) == 0) {
1086  return false;
1087  }
1088  return true;
1089  }
1096  {
1097  if (webserver != SOUND4_INVALID_WEBSERVER_ID) {
1098  m_dynlib.Webserver_Stop(webserver, 1000);
1099  webserver = SOUND4_INVALID_WEBSERVER_ID;
1100  }
1101  }
1102 
1106  void SetWebServerAppHealth(int httpcode, const std::string& contenttype, const std::string& content)
1107  {
1108  assert(instance);
1109  if (!m_dynlib.Webserver_SetAppHealth) return;
1110  m_dynlib.Webserver_SetAppHealth(instance, httpcode, contenttype.c_str(), content.c_str());
1111  }
1115  void GetWebServerAppHealth(int &httpcode, std::string& contenttype, std::string& content)
1116  {
1117  assert(instance);
1118  if (!m_dynlib.Webserver_GetAppHealth) return;
1119  char* c_contenttype=nullptr;
1120  char* c_content=nullptr;
1121  m_dynlib.Webserver_GetAppHealth(instance, &httpcode, &c_contenttype, &c_content);
1122  contenttype=c_contenttype;
1123  content=c_content;
1124  m_dynlib.Webserver_FreeString(c_contenttype);
1125  m_dynlib.Webserver_FreeString(c_content);
1126  }
1127 #endif // CLOUDX1_HAS_WEBSERVER
1128 
1136  {
1137  if (!instance) return 0;
1138  return m_dynlib.TerminateProcess(instance);
1139  }
1140 
1146  void Stop()
1147  {
1148  if (!instance) return;
1149 #if CLOUDX1_HAS_WEBSERVER
1150  StopWebServer();
1151 #endif // CLOUDX1_HAS_WEBSERVER
1152  if (update_thread.joinable()) {
1153  m_dynlib.StopUpdateThread(instance); // this will exit the update thread
1154  update_thread.join();
1155  }
1156  m_dynlib.ExitProcess(instance);
1157  instance=nullptr;
1158  }
1159 
1165  unsigned int GetEstimatedDelay()
1166  {
1167  assert(instance);
1168  return m_dynlib.GetEstimatedDelay(instance);
1169  }
1170 
1181  std::array<float,InputSampleSize>& GetBufferIn()
1182  {
1183  assert(instance);
1184  float *buf=m_dynlib.GetBufferIn(instance);
1185  return reinterpret_cast< std::array<float,InputSampleSize>& >(*buf);
1186 
1187  }
1198  std::array<float,OutputSampleSize>& GetBufferOut()
1199  {
1200  assert(instance);
1201  float *buf= m_dynlib.GetBufferOut(instance);
1202  return reinterpret_cast< std::array<float,OutputSampleSize>& >(*buf);
1203  }
1210  {
1211  assert(instance);
1212  m_dynlib.ProcessAudio(instance, m_dynlib.GetBufferIn(instance), m_dynlib.GetBufferOut(instance));
1213  }
1227  // void ProcessAudio_Planar(const std::array< const std::array<const float,ChunkFrames>, InputChannels>& input, std::array< std::array<float,ChunkFrames>, OutputChannels>& output)
1228  void ProcessAudio_Planar(float const * const *input, float * const *output)
1229  {
1230  assert(instance);
1231  m_dynlib.ProcessAudio_Planar(instance, input, output);
1232  }
1233 
1245  template<typename T>
1246  std::vector<T> ProcessAnyAudio(const std::vector<T> input)
1247  {
1248  assert(instance);
1249  std::vector<T> output;
1250  unsigned int out_offset=0;
1251  unsigned int in_offset=0;
1252  unsigned int todo = input.size();
1253  while (todo>0) {
1254  unsigned int left = AddAudio(&input[in_offset], todo);
1255  unsigned int out_avail = m_dynlib.GetOutputCount(instance);
1256  output.resize(out_offset + out_avail);
1257  GetAudio(&output[out_offset], out_avail);
1258  out_offset+=out_avail;
1259  in_offset += todo-left;
1260  todo=left;
1261  }
1262  return output;
1263  }
1264 
1270  class CClient {
1271  public:
1272  CClient(cloudx1_CInstance* instance, CDynLib& dynlib)
1273  : m_dynlib(dynlib)
1274  {
1275  assert(instance);
1276  client=m_dynlib.NewClient(instance);
1277  if (!client) throw std::bad_alloc();
1278  }
1279  // non-copyable
1280  CClient( const CInstance& ) = delete;
1281  CClient& operator=( const CInstance& ) = delete;
1283  {
1284  if (client) {
1285  m_dynlib.DeleteClient(client);
1286  client=nullptr;
1287  }
1288  }
1296  std::string ProcessJson(const std::string &request, bool *NeedSave = nullptr)
1297  {
1298  assert(client);
1299  int need_save=0;
1300  const char *canswer = m_dynlib.ProcessJson(client, request.c_str(), &need_save);
1301  if (!canswer) return {};
1302  std::string answer(canswer);
1303  m_dynlib.FreeJsonAnswer (canswer);
1304  if (NeedSave) {
1305  *NeedSave=(need_save!=0);
1306  }
1307  return answer;
1308  }
1309  private:
1310  CDynLib& m_dynlib;
1311  cloudx1_CClientInstance *client = nullptr;
1312  };
1320  std::shared_ptr<CClient> NewClient()
1321  {
1322  assert(instance);
1323  return std::make_shared<CClient>(instance, m_dynlib);
1324  }
1325 
1326  protected:
1327  template<typename T>
1328  unsigned int AddAudio(const T* payload, unsigned int nFrame)
1329  {
1330  assert(instance);
1331  return m_dynlib.AddAudio(instance, reinterpret_cast<const T*>(payload), nFrame, helper::SampleFormat<T>::format);
1332  }
1333  template<typename T>
1334  unsigned int GetAudio(T* payload, unsigned int max_nFrame)
1335  {
1336  assert(instance);
1337  return m_dynlib.GetAudio(instance, reinterpret_cast<T*>(payload), max_nFrame, helper::SampleFormat<T>::format);
1338  }
1339 
1340  private:
1341  CDynLib& m_dynlib;
1342  cloudx1_CParameters* params = nullptr;
1343  cloudx1_CInstance* instance = nullptr;
1344  std::thread update_thread;
1345  std::vector< std::pair<std::string,std::string> > init_metadata;
1346 #if CLOUDX1_HAS_WEBSERVER
1347  uint64_t webserver = SOUND4_INVALID_WEBSERVER_ID;
1348 #endif // CLOUDX1_HAS_WEBSERVER
1349  };
1350 
1351 }; // namespace dyn
1352 }; // namespace cloudx1
1353 }; // namespace sound4
1354 
1355 
1356 // bridge C callbacks to CPresetLoader
1357 extern "C" {
1358  static char *cloudx1_custom_reader(const fs_char *filename, void* userdata) {
1359  sound4::cloudx1::dyn::CPresetLoader *preset_loader=reinterpret_cast<sound4::cloudx1::dyn::CPresetLoader*>(userdata);
1360  std::string content=preset_loader->Read(filename);
1361  return strdup(content.c_str());
1362  }
1363  static void cloudx1_custom_reader_free(char *content, void* userdata) {
1364  if (!content) return;
1365  free(content);
1366  }
1367  static int cloudx1_custom_writer(const fs_char *filename, const char *content, void* userdata) {
1368  sound4::cloudx1::dyn::CPresetLoader *preset_loader=reinterpret_cast<sound4::cloudx1::dyn::CPresetLoader*>(userdata);
1369  auto res=preset_loader->Write(filename,content);
1370  return res?0:-1;
1371  }
1372  static int cloudx1_custom_exists(const fs_char *filename, void* userdata) {
1373  sound4::cloudx1::dyn::CPresetLoader *preset_loader=reinterpret_cast<sound4::cloudx1::dyn::CPresetLoader*>(userdata);
1374  auto res=preset_loader->Exists(filename);
1375  return res?0:-1;
1376  }
1377  static fs_char** cloudx1_custom_getall(void* userdata) {
1378  sound4::cloudx1::dyn::CPresetLoader *preset_loader=reinterpret_cast<sound4::cloudx1::dyn::CPresetLoader*>(userdata);
1379  auto res=preset_loader->GetAll();
1380  fs_char**all=(fs_char**)malloc((res.size()+1)*sizeof(const fs_char*));
1381  for (size_t n=0;n<res.size();n++) {
1382  all[n]=fs_strdup(res[n].c_str());
1383  }
1384  all[res.size()]=nullptr;
1385  return all;
1386  }
1387  static void cloudx1_custom_getall_free(fs_char** all, void* userdata) {
1388  if (!all) return;
1389  for (fs_char** one=all;*one;one++) {
1390  free(*one);
1391  }
1392  free(all);
1393  }
1394  static int cloudx1_custom_remove(const fs_char *filename, void* userdata) {
1395  sound4::cloudx1::dyn::CPresetLoader *preset_loader=reinterpret_cast<sound4::cloudx1::dyn::CPresetLoader*>(userdata);
1396  auto res=preset_loader->Remove(filename);
1397  return res?0:-1;
1398  }
1399  static int cloudx1_custom_rename(const fs_char *from, const fs_char *to, void* userdata) {
1400  sound4::cloudx1::dyn::CPresetLoader *preset_loader=reinterpret_cast<sound4::cloudx1::dyn::CPresetLoader*>(userdata);
1401  auto res=preset_loader->Rename(from,to);
1402  return res?0:-1;
1403  }
1404 
1405 };
Shared Bus.
Definition: sound4cl.hpp:703
Dynamic library interface.
helper::DynFuncHolder< decltype(cloudx1_Webserver_Status) > Webserver_Status
helper::DynFuncHolder< decltype(cloudx1_SetPresetManager) > SetPresetManager
helper::DynFuncHolder< decltype(cloudx1_SetMetadata) > SetMetadata
helper::DynFuncHolder< decltype(cloudx1_FreeJsonAnswer) > FreeJsonAnswer
helper::DynFuncHolder< decltype(cloudx1_ProcessJson) > ProcessJson
helper::DynFuncHolder< decltype(cloudx1_GetProcessChunkFrames) > GetProcessChunkFrames
helper::DynFuncHolder< decltype(cloudx1_SetParameter) > SetParameter
helper::DynFuncHolder< decltype(cloudx1_DeleteClient) > DeleteClient
helper::DynFuncHolder< decltype(cloudx1_GetBytesFromFormat) > GetBytesFromFormat
helper::DynFuncHolder< decltype(cloudx1_Webserver_SetAppHealth) > Webserver_SetAppHealth
helper::DynFuncHolder< decltype(cloudx1_TerminateProcess) > TerminateProcess
helper::DynFuncHolder< decltype(cloudx1_WaitUpdateThreadReady) > WaitUpdateThreadReady
helper::DynFuncHolder< decltype(cloudx1_AudioMonoToLiveStereo) > AudioMonoToLiveStereo
helper::DynFuncHolder< decltype(cloudx1_Webserver_FreeString) > Webserver_FreeString
helper::DynFuncHolder< decltype(cloudx1_Webserver_tcp) > Webserver_tcp
helper::DynFuncHolder< decltype(cloudx1_NewParameters) > NewParameters
helper::DynFuncHolder< decltype(cloudx1_StartUpdateThread) > StartUpdateThread
helper::DynFuncHolder< decltype(cloudx1_StereoToMono_Planar) > StereoToMono_Planar
helper::DynFuncHolder< decltype(cloudx1_AddAudio) > AddAudio
helper::DynFuncHolder< decltype(cloudx1_GetBufferOut) > GetBufferOut
helper::DynFuncHolder< decltype(cloudx1_Webserver_tcp2) > Webserver_tcp2
helper::DynFuncHolder< decltype(cloudx1_SetLoggerCallback) > SetLoggerCallback
helper::DynFuncHolder< decltype(cloudx1_StopUpdateThread) > StopUpdateThread
helper::DynFuncHolder< decltype(cloudx1_ExitProcess) > ExitProcess
helper::DynFuncHolder< decltype(cloudx1_FreeParameters) > FreeParameters
helper::DynFuncHolder< decltype(cloudx1_GetMaxPacketFrame) > GetMaxPacketFrame
bool Load(const std::filesystem::path &path={})
Loads the library.
helper::DynFuncHolder< decltype(cloudx1_InitProcess) > InitProcess
helper::DynFuncHolder< decltype(cloudx1_MonoToStereo) > MonoToStereo
helper::DynFuncHolder< decltype(cloudx1_MonoToStereo_Planar) > MonoToStereo_Planar
helper::DynFuncHolder< decltype(cloudx1_GetAudioOutputCount) > GetAudioOutputCount
helper::DynFuncHolder< decltype(cloudx1_ProcessAudio_Planar) > ProcessAudio_Planar
helper::DynFuncHolder< decltype(cloudx1_GetPossibleChunkSizeInFrames) > GetPossibleChunkSizeInFrames
helper::DynFuncHolder< decltype(cloudx1_InitProcess3) > InitProcess3
helper::DynFuncHolder< decltype(cloudx1_ProcessAudio) > ProcessAudio
helper::DynFuncHolder< decltype(cloudx1_GetParameter) > GetParameter
helper::DynFuncHolder< decltype(cloudx1_GetAudio) > GetAudio
helper::DynFuncHolder< decltype(cloudx1_FreeParameterValue) > FreeParameterValue
helper::DynFuncHolder< decltype(cloudx1_AudioConvertTo) > AudioConvertTo
helper::DynFuncHolder< decltype(cloudx1_AudioMonoFromLiveStereo) > AudioMonoFromLiveStereo
helper::DynFuncHolder< decltype(cloudx1_AddPadAudio) > AddPadAudio
helper::DynFuncHolder< decltype(cloudx1_StereoToMono) > StereoToMono
helper::DynFuncHolder< decltype(cloudx1_GetChannelCount) > GetChannelCount
helper::DynFuncHolder< decltype(cloudx1_NewClient) > NewClient
helper::DynFuncHolder< decltype(cloudx1_Webserver) > Webserver
helper::DynFuncHolder< decltype(cloudx1_GetBufferIn) > GetBufferIn
helper::DynFuncHolder< decltype(cloudx1_GetSampleRate) > GetSampleRate
helper::DynFuncHolder< decltype(cloudx1_GetChunkSizeInFrames) > GetChunkSizeInFrames
helper::DynFuncHolder< decltype(cloudx1_InitProcess2) > InitProcess2
helper::DynFuncHolder< decltype(cloudx1_SetMetadataMulti) > SetMetadataMulti
helper::DynFuncHolder< decltype(cloudx1_AudioConvertFrom) > AudioConvertFrom
helper::DynFuncHolder< decltype(cloudx1_GetOutputCount) > GetOutputCount
helper::DynFuncHolder< decltype(cloudx1_PresetManager_InformChange) > PresetManager_InformChange
helper::DynFuncHolder< decltype(cloudx1_GetFormatName) > GetFormatName
helper::DynFuncHolder< decltype(cloudx1_GetMetadataInfos) > GetMetadataInfos
helper::DynFuncHolder< decltype(cloudx1_SetLogSeverity) > SetLogSeverity
helper::DynFuncHolder< decltype(cloudx1_FreeMetadataInfos) > FreeMetadataInfos
helper::DynFuncHolder< decltype(cloudx1_Webserver_GetAppHealth) > Webserver_GetAppHealth
helper::DynFuncHolder< decltype(cloudx1_GetAudioInputCount) > GetAudioInputCount
bool IsOk() const
Check if the library was loaded correctly.
helper::DynFuncHolder< decltype(cloudx1_GetFormatFromName) > GetFormatFromName
helper::DynFuncHolder< decltype(cloudx1_SaveState) > SaveState
helper::DynFuncHolder< decltype(cloudx1_GetVersion) > GetVersion
helper::DynFuncHolder< decltype(cloudx1_Webserver_Stop) > Webserver_Stop
helper::DynFuncHolder< decltype(cloudx1_GetEstimatedDelay) > GetEstimatedDelay
std::string ProcessJson(const std::string &request, bool *NeedSave=nullptr)
Process a JSON request and returns the answer.
CClient(cloudx1_CInstance *instance, CDynLib &dynlib)
CClient(const CInstance &)=delete
CClient & operator=(const CInstance &)=delete
void SetPresetManager(CPresetLoader *preset_manager)
void SetMetadata(const std::string &key, const char *value)
void SetParam(const std::string &name, const std::string &value)
void SetMetadataMulti(const std::unordered_map< std::string, const char * > &list)
bool Create(const std::string &LoginKey, const std::string &RadioName, const std::string &Access_Key_ID, const std::string &Access_Key_Secret, const std::filesystem::path &save_path, int json_port=0, unsigned int frames_per_chunk=64)
std::vector< std::tuple< std::string, std::string > > GetMetadataInfos()
void PresetManager_InformChange(const std::filesystem::path &relative_path, PresetChange_Kind change_kind)
unsigned int GetAudio(T *payload, unsigned int max_nFrame)
void GetWebServerAppHealth(int &httpcode, std::string &contenttype, std::string &content)
std::array< float, OutputSampleSize > & GetBufferOut()
CInstance(const CInstance &)=delete
std::vector< T > ProcessAnyAudio(const std::vector< T > input)
std::array< float, InputSampleSize > & GetBufferIn()
std::shared_ptr< CClient > NewClient()
void ProcessAudio_Planar(float const *const *input, float *const *output)
unsigned int AddAudio(const T *payload, unsigned int nFrame)
void SetWebServerAppHealth(int httpcode, const std::string &contenttype, const std::string &content)
std::string GetParam(const std::string &name)
bool StartWebServer(int http_port, int https_port=0)
CInstance & operator=(const CInstance &)=delete
virtual bool Remove(const std::filesystem::path &name)=0
virtual bool Rename(const std::filesystem::path &from, const std::filesystem::path &to)=0
virtual bool Exists(const std::filesystem::path &name)=0
virtual bool Write(const std::filesystem::path &filename, const std::string &content)=0
virtual std::string Read(const std::filesystem::path &filename)=0
virtual std::vector< std::filesystem::path > GetAll()=0
static std::filesystem::path GetThisLibraryPath(void)
DynFuncHolder< T > GetSymbol(const std::string &name)
DynFuncHolder< T > GetSymbol_safe(const std::string &name)
bool Load(const std::filesystem::path &dynlib, uint32_t loadflags=LOAD_LIBRARY_SEARCH_DLL_LOAD_DIR|LOAD_LIBRARY_SEARCH_APPLICATION_DIR|LOAD_LIBRARY_SEARCH_USER_DIRS|LOAD_LIBRARY_SEARCH_SYSTEM32)
CDynLoader(const CDynLoader &)=delete
CDynLoader & operator=(CDynLoader const &)=delete
Helper to wrap a function pointer.
enum cloudx1_SampleFormat cloudx1_GetFormatFromName(const char *name)
cloudx1_SampleFormat
unsigned int cloudx1_GetOutputCount(struct cloudx1_CInstance *instance)
const char * cloudx1_GetFormatName(const enum cloudx1_SampleFormat fmt)
unsigned int cloudx1_AddAudio(struct cloudx1_CInstance *instance, const uint8_t *payload, unsigned int nFrame, enum cloudx1_SampleFormat fmt)
unsigned int cloudx1_AddPadAudio(struct cloudx1_CInstance *instance)
unsigned int cloudx1_GetBytesFromFormat(const enum cloudx1_SampleFormat fmt)
unsigned int cloudx1_GetAudio(struct cloudx1_CInstance *instance, uint8_t *payload, unsigned int max_nFrame, enum cloudx1_SampleFormat fmt)
unsigned int cloudx1_GetMaxPacketFrame(struct cloudx1_CInstance *instance)
@ F32_NATIVE
32-bit floating-point, native
@ S16_NATIVE
16-bit signed integer, native
@ S32_NATIVE
32-bit signed integer, native
int cloudx1_SaveState(struct cloudx1_CInstance *instance)
struct cloudx1_CClientInstance * cloudx1_NewClient(struct cloudx1_CInstance *instance)
void cloudx1_DeleteClient(struct cloudx1_CClientInstance *client)
void cloudx1_FreeJsonAnswer(const char *json_str)
const char * cloudx1_ProcessJson(struct cloudx1_CClientInstance *client, const char *json_str, int *need_save)
void cloudx1_AudioConvertTo(const float *input, uint8_t *payload, size_t nSpl, enum cloudx1_SampleFormat fmt)
void cloudx1_AudioMonoToLiveStereo(const float *input, uint8_t *payload)
void cloudx1_MonoToStereo_Planar(const float *input, float *outputL, float *outputR, size_t nFrame)
void cloudx1_StereoToMono(const float *input, float *output, size_t nFrame)
void cloudx1_AudioConvertFrom(const uint8_t *payload, float *output, size_t nSpl, enum cloudx1_SampleFormat fmt)
void cloudx1_MonoToStereo(const float *input, float *output, size_t nFrame)
void cloudx1_AudioMonoFromLiveStereo(const uint8_t *payload, float *output)
void cloudx1_StereoToMono_Planar(const float *inputL, const float *inputR, float *output, size_t nFrame)
float * cloudx1_GetBufferIn(struct cloudx1_CInstance *instance)
void cloudx1_ProcessAudio_Planar(struct cloudx1_CInstance *instance, float const *const *input, float *const *output)
void cloudx1_ProcessAudio(struct cloudx1_CInstance *instance, const float *input, float *output)
unsigned int cloudx1_GetEstimatedDelay(struct cloudx1_CInstance *instance)
float * cloudx1_GetBufferOut(struct cloudx1_CInstance *instance)
unsigned int cloudx1_GetAudioInputCount()
#define CLOUDX1_AUDIO_INPUT_COUNT
const char * cloudx1_GetVersion()
cloudx1_LogSeverity
unsigned int cloudx1_GetChunkSizeInFrames()
unsigned int * cloudx1_GetPossibleChunkSizeInFrames()
#define CLOUDX1_AUDIOFRAME_COUNT
unsigned int cloudx1_GetAudioOutputCount()
unsigned int cloudx1_GetChannelCount()
void cloudx1_SetLoggerCallback(cloudx1_loggerfn logger)
unsigned int cloudx1_GetSampleRate()
#define CLOUDX1_SAMPLE_RATE
#define CLOUDX1_CHANNEL_COUNT
#define CLOUDX1_AUDIO_OUTPUT_COUNT
void cloudx1_SetLogSeverity(enum cloudx1_LogSeverity severity)
void cloudx1_FreeParameterValue(const char *value)
void cloudx1_ExitProcess(struct cloudx1_CInstance *instance)
void cloudx1_FreeParameters(struct cloudx1_CParameters *params)
struct cloudx1_CParameters * cloudx1_NewParameters()
void cloudx1_SetParameter(struct cloudx1_CParameters *params, const char *name, const char *value)
int cloudx1_TerminateProcess(struct cloudx1_CInstance *instance)
struct cloudx1_CInstance * cloudx1_InitProcess3(const char *LoginKey, const char *RadioName, const char *Access_Key_ID, const char *Access_Key_Secret, const char *save_path, const struct cloudx1_CParameters *parameters, unsigned int frames_per_chunk)
struct cloudx1_CInstance * cloudx1_InitProcess(const char *LoginKey, const char *RadioName, const char *Access_Key_ID, const char *Access_Key_Secret, const char *save_path)
const char * cloudx1_GetParameter(struct cloudx1_CParameters *params, const char *name)
unsigned int cloudx1_GetProcessChunkFrames(struct cloudx1_CInstance *instance)
struct cloudx1_CInstance * cloudx1_InitProcess2(const char *LoginKey, const char *RadioName, const char *Access_Key_ID, const char *Access_Key_Secret, const char *save_path, const struct cloudx1_CParameters *parameters)
const char ** cloudx1_GetMetadataInfos(struct cloudx1_CInstance *instance)
void cloudx1_SetMetadata(struct cloudx1_CInstance *instance, const char *key, const char *value)
void cloudx1_FreeMetadataInfos(struct cloudx1_CInstance *instance, const char **infos)
void cloudx1_SetMetadataMulti(struct cloudx1_CInstance *instance, const char **keyvalue)
cloudx1_PresetChange_Kind
void cloudx1_SetPresetManager(struct cloudx1_CParameters *params, cloudx1_storage_reader reader, cloudx1_storage_reader_free, cloudx1_storage_writer writer, cloudx1_storage_exists exists, cloudx1_storage_getall getall, cloudx1_storage_getall_free getall_free, cloudx1_storage_remove remove, cloudx1_storage_rename rename, int IsReadOnly, void *userdata)
void cloudx1_PresetManager_InformChange(struct cloudx1_CInstance *instance, const fs_char *relative_path, enum cloudx1_PresetChange_Kind change_kind)
wchar_t fs_char
void cloudx1_StartUpdateThread(struct cloudx1_CInstance *instance, unsigned int port)
int cloudx1_WaitUpdateThreadReady(struct cloudx1_CInstance *instance, int milliseconds)
void cloudx1_StopUpdateThread(struct cloudx1_CInstance *instance)
#define SOUND4_WEBSERVER_HTTPS_OK
uint64_t cloudx1_Webserver_tcp2(unsigned int listenport, unsigned int listenport_secure, const char *socket_ip, unsigned int socket_port, const struct cloudx1_CParameters *parameters)
uint64_t cloudx1_Webserver(unsigned int listenport, unsigned int listenport_secure, struct cloudx1_CInstance *instance)
uint64_t cloudx1_Webserver_tcp(unsigned int listenport, unsigned int listenport_secure, const char *socket_ip, unsigned int socket_port)
void cloudx1_Webserver_FreeString(char *str)
int cloudx1_Webserver_Status(uint64_t id)
#define SOUND4_WEBSERVER_HTTP_OK
#define SOUND4_INVALID_WEBSERVER_ID
int cloudx1_Webserver_Stop(uint64_t id, int timeout_ms)
void cloudx1_Webserver_GetAppHealth(struct cloudx1_CInstance *instance, int *httpcode, char **contenttype, char **content)
void cloudx1_Webserver_SetAppHealth(struct cloudx1_CInstance *instance, int httpcode, const char *contenttype, const char *content)
cloudx1_SampleFormat SampleFormat
std::function< void(LogSeverity, const std::string &)> log_cb_t
const LogSeverity info
Definition: sound4cl.hpp:242
std::function< void(LogSeverity, const std::string &)> log_cb_t
Definition: sound4cl.hpp:252
C interface for library.
#define fs_strdup
helper for OS dependant file name copy