src/bindings/qt4/raopservice.cpp

   1 #include "raopservice.h"
   2
   3 #include <QDebug>
   4
   5 #include <shairplay/raop.h>
   6
   7 #define RSA_KEY \
   8 "-----BEGIN RSA PRIVATE KEY-----\n"\
   9 "MIIEpQIBAAKCAQEA59dE8qLieItsH1WgjrcFRKj6eUWqi+bGLOX1HL3U3GhC/j0Qg90u3sG/1CUt\n"\
  10 "wC5vOYvfDmFI6oSFXi5ELabWJmT2dKHzBJKa3k9ok+8t9ucRqMd6DZHJ2YCCLlDRKSKv6kDqnw4U\n"\
  11 "wPdpOMXziC/AMj3Z/lUVX1G7WSHCAWKf1zNS1eLvqr+boEjXuBOitnZ/bDzPHrTOZz0Dew0uowxf\n"\
  12 "/+sG+NCK3eQJVxqcaJ/vEHKIVd2M+5qL71yJQ+87X6oV3eaYvt3zWZYD6z5vYTcrtij2VZ9Zmni/\n"\
  13 "UAaHqn9JdsBWLUEpVviYnhimNVvYFZeCXg/IdTQ+x4IRdiXNv5hEewIDAQABAoIBAQDl8Axy9XfW\n"\
  14 "BLmkzkEiqoSwF0PsmVrPzH9KsnwLGH+QZlvjWd8SWYGN7u1507HvhF5N3drJoVU3O14nDY4TFQAa\n"\
  15 "LlJ9VM35AApXaLyY1ERrN7u9ALKd2LUwYhM7Km539O4yUFYikE2nIPscEsA5ltpxOgUGCY7b7ez5\n"\
  16 "NtD6nL1ZKauw7aNXmVAvmJTcuPxWmoktF3gDJKK2wxZuNGcJE0uFQEG4Z3BrWP7yoNuSK3dii2jm\n"\
  17 "lpPHr0O/KnPQtzI3eguhe0TwUem/eYSdyzMyVx/YpwkzwtYL3sR5k0o9rKQLtvLzfAqdBxBurciz\n"\
  18 "aaA/L0HIgAmOit1GJA2saMxTVPNhAoGBAPfgv1oeZxgxmotiCcMXFEQEWflzhWYTsXrhUIuz5jFu\n"\
  19 "a39GLS99ZEErhLdrwj8rDDViRVJ5skOp9zFvlYAHs0xh92ji1E7V/ysnKBfsMrPkk5KSKPrnjndM\n"\
  20 "oPdevWnVkgJ5jxFuNgxkOLMuG9i53B4yMvDTCRiIPMQ++N2iLDaRAoGBAO9v//mU8eVkQaoANf0Z\n"\
  21 "oMjW8CN4xwWA2cSEIHkd9AfFkftuv8oyLDCG3ZAf0vrhrrtkrfa7ef+AUb69DNggq4mHQAYBp7L+\n"\
  22 "k5DKzJrKuO0r+R0YbY9pZD1+/g9dVt91d6LQNepUE/yY2PP5CNoFmjedpLHMOPFdVgqDzDFxU8hL\n"\
  23 "AoGBANDrr7xAJbqBjHVwIzQ4To9pb4BNeqDndk5Qe7fT3+/H1njGaC0/rXE0Qb7q5ySgnsCb3DvA\n"\
  24 "cJyRM9SJ7OKlGt0FMSdJD5KG0XPIpAVNwgpXXH5MDJg09KHeh0kXo+QA6viFBi21y340NonnEfdf\n"\
  25 "54PX4ZGS/Xac1UK+pLkBB+zRAoGAf0AY3H3qKS2lMEI4bzEFoHeK3G895pDaK3TFBVmD7fV0Zhov\n"\
  26 "17fegFPMwOII8MisYm9ZfT2Z0s5Ro3s5rkt+nvLAdfC/PYPKzTLalpGSwomSNYJcB9HNMlmhkGzc\n"\
  27 "1JnLYT4iyUyx6pcZBmCd8bD0iwY/FzcgNDaUmbX9+XDvRA0CgYEAkE7pIPlE71qvfJQgoA9em0gI\n"\
  28 "LAuE4Pu13aKiJnfft7hIjbK+5kyb3TysZvoyDnb3HOKvInK7vXbKuU4ISgxB2bB3HcYzQMGsz1qJ\n"\
  29 "2gG0N5hvJpzwwhbhXqFKA4zaaSrw622wDniAK5MlIE0tIAKKP4yxNGjoD2QYjhBGuhvkWKY=\n"\
  30 "-----END RSA PRIVATE KEY-----\n"
  31
  32
  33 static void*
  34 audio_init_cb(void *cls, int bits, int channels, int samplerate)
  35 {
  36     void *session;
  37     QMetaObject::invokeMethod((QObject*)cls, "audioInit", Qt::BlockingQueuedConnection,
  38                               Q_ARG(void*, (void*)&session),
  39                               Q_ARG(int, bits),
  40                               Q_ARG(int, channels),
  41                               Q_ARG(int, samplerate));
  42     return session;
  43 }
  44
  45 static void
  46 audio_process_cb(void *cls, void *session, const void *buffer, int buflen)
  47 {
  48     QMetaObject::invokeMethod((QObject*)cls, "audioProcess", Qt::BlockingQueuedConnection,
  49                               Q_ARG(void*, session),
  50                               Q_ARG(void*, (void*)buffer),
  51                               Q_ARG(int, buflen));
  52 }
  53
  54 static void
  55 audio_destroy_cb(void *cls, void *session)
  56 {
  57     QMetaObject::invokeMethod((QObject*)cls, "audioDestroy", Qt::BlockingQueuedConnection,
  58                               Q_ARG(void*, session));
  59 }
  60
  61 static void
  62 audio_flush_cb(void *cls, void *session)
  63 {
  64     QMetaObject::invokeMethod((QObject*)cls, "audioFlush", Qt::BlockingQueuedConnection,
  65                               Q_ARG(void*, session));
  66 }
  67
  68 static void
  69 audio_set_volume_cb(void *cls, void *session, float volume)
  70 {
  71     QMetaObject::invokeMethod((QObject*)cls, "audioSetVolume", Qt::BlockingQueuedConnection,
  72                               Q_ARG(void*, session),
  73                               Q_ARG(float, volume));
  74 }
  75
  76 static void
  77 audio_set_metadata_cb(void *cls, void *session, const void *buffer, int buflen)
  78 {
  79     QMetaObject::invokeMethod((QObject*)cls, "audioSetVolume", Qt::BlockingQueuedConnection,
  80                               Q_ARG(void*, session),
  81                               Q_ARG(void*, (void*)buffer),
  82                               Q_ARG(int, buflen));
  83 }
  84
  85 static void
  86 audio_set_coverart_cb(void *cls, void *session, const void *buffer, int buflen)
  87 {
  88     QMetaObject::invokeMethod((QObject*)cls, "audioSetVolume", Qt::BlockingQueuedConnection,
  89                               Q_ARG(void*, session),
  90                               Q_ARG(void*, (void*)buffer),
  91                               Q_ARG(int, buflen));
  92 }
  93
  94 RaopService::RaopService(QObject *parent) :
  95     QObject(parent),
  96     m_raop(0)
  97 {
  98     /* This whole hack is required because QAudioOutput
  99      * needs to be created in a QThread, threads created
 100      * outside Qt are not allowed (they have no eventloop) */
 101     m_handler.moveToThread(&m_thread);
 102 }
 103
 104 RaopService::~RaopService()
 105 {
 106     this->stop();
 107     raop_destroy(m_raop);
 108 }
 109
 110 bool RaopService::init(int max_clients, RaopCallbacks *callbacks)
 111 {
 112     raop_callbacks_t raop_cbs;
 113
 114     m_handler.init(callbacks);
 115     raop_cbs.cls = &m_handler;
 116     raop_cbs.audio_init = &audio_init_cb;
 117     raop_cbs.audio_process = &audio_process_cb;
 118     raop_cbs.audio_destroy = &audio_destroy_cb;
 119     raop_cbs.audio_flush = &audio_flush_cb;
 120     raop_cbs.audio_set_volume = &audio_set_volume_cb;
 121     raop_cbs.audio_set_metadata = &audio_set_metadata_cb;
 122     raop_cbs.audio_set_coverart = &audio_set_coverart_cb;
 123
 124     m_raop = raop_init(max_clients, &raop_cbs, RSA_KEY);
 125     if (!m_raop) {
 126         printf("Foobar\n");
 127         return false;
 128     }
 129     return true;
 130 }
 131
 132 bool RaopService::isRunning()
 133 {
 134     return (raop_is_running(m_raop) != 0);
 135 }
 136
 137 bool RaopService::start(quint16 port, const QByteArray & hwaddr)
 138 {
 139     int ret;
 140     m_thread.start();
 141     ret = raop_start(m_raop, &port, hwaddr.data(), hwaddr.size(), 0);
 142     if (ret < 0) {
 143         m_thread.quit();
 144         m_thread.wait();
 145         return false;
 146     }
 147     return true;
 148 }
 149
 150 void RaopService::stop()
 151 {
 152     if (m_raop) {
 153         raop_stop(m_raop);
 154     }
 155     if (m_thread.isRunning()) {
 156         m_thread.quit();
 157         m_thread.wait();
 158     }
 159 }