KARadioProtocol

Author: pschatzmann

src/AudioTools/AudioLibs/KARadioProtocol.h

@@ -12,8 +12,13 @@ namespace audio_tools {
 
 /***
  * @brief KA-Radio Protocol: We can use the KA-Radio protocol to control the
- * audio player provided by the audiotools. Example: volume=50&play=128&infos
+ * audio player provided by the audiotools.  
+ * Supported commands: play, instant, volume, volume+, volume-, pause,
+ * resume, stop, start, next, prev, mute, infos, version.
+ * Example: volume=50&play=128&infos
  * See https://github.com/karawin/Ka-Radio32/blob/master/Interface.md
+ * 
+ * @ingroup player
  * @author Phil Schatzmann
  */
 
@@ -188,6 +193,8 @@ class KARadioProtocol {
     for (Action& act : actions) {
       if (name.equals(act.cmd)) {
         return act.callback(*p_player, name, arg, result, this);
+      } else {
+        LOGD("-> %s vs %s: failed", name.c_str(), act.cmd);
       }
     }
 
@@ -208,6 +215,7 @@ class KARadioProtocol {
     Action act;
     act.cmd = cmd;
     act.callback = cb;
+    actions.push_back(act);
   }
 
  protected:

src/AudioTools/AudioLibs/KARadioProtocolServer.h

@@ -50,25 +50,35 @@ class KARadioProtocolServer {
   void loop() { server.copy(); }
   void copy() { server.copy(); }
 
+  /// Defines the buffer size that is made available for the http reply
+  void setBufferSize(int size){
+    buffer_size = size;
+  }
+
  protected:
   WiFiServer wifi;
   HttpServer server{wifi};
   KARadioProtocol protocol;
-  RingBuffer<uint8_t> ringBuffer{512};
+  RingBuffer<uint8_t> ringBuffer{0};
   QueueStream<uint8_t> queueStream{ringBuffer};
   Vector<void*> context{1};
   int port = 80;
   const char* ssid = nullptr;
   const char* password = nullptr;
+  int buffer_size = 512;
 
   static void parse(HttpServer* server, const char* requestPath,
                     HttpRequestHandlerLine* hl) {
     LOGI("parse: %s", requestPath);
     KARadioProtocolServer* self = (KARadioProtocolServer*)hl->context[0];
+    self->ringBuffer.resize(self->buffer_size);
     QueueStream<uint8_t>& queueStream = self->queueStream;
+    queueStream.begin();
     bool ok = self->protocol.processCommand(requestPath, queueStream);
+    LOGI("available: %d", queueStream.available());
     server->reply("text/plain", queueStream, queueStream.available(),
                   ok ? 200 : 400, ok ? SUCCESS : "Error");
+    self->ringBuffer.resize(0);
   }
 };
 }  // namespace audio_tools