DPL: introduce a WebSocketHandler

Framework/Core/CMakeLists.txt

@@ -60,6 +60,7 @@ o2_add_library(Framework
                        src/ConfigurationOptionsRetriever.cxx
                        src/FreePortFinder.cxx
                        src/GraphvizHelpers.cxx
+                       src/HTTPParser.cxx
                        src/InputRecord.cxx
                        src/InputSpec.cxx
                        src/OutputSpec.cxx
@@ -97,6 +98,8 @@ o2_add_library(Framework
                        src/ExternalFairMQDeviceProxy.cxx
                        src/HistogramRegistry.cxx
                        src/StepTHn.cxx
+                       src/SHA1.cxx
+                       src/Base64.cxx
                        test/TestClasses.cxx
                PRIVATE_INCLUDE_DIRECTORIES ${CMAKE_CURRENT_LIST_DIR}/src
                PUBLIC_LINK_LIBRARIES AliceO2::Common
@@ -157,6 +160,7 @@ foreach(t
         Graphviz
         GroupSlicer
         HistogramRegistry
+        HTTPParser
         IndexBuilder
         InfoLogger
         InputRecord

Framework/Core/src/Base64.cxx

@@ -0,0 +1,237 @@
+// Copyright CERN and copyright holders of ALICE O2. This software is
+// distributed under the terms of the GNU General Public License v3 (GPL
+// Version 3), copied verbatim in the file "COPYING".
+//
+// See http://alice-o2.web.cern.ch/license for full licensing information.
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+#include "Base64.h"
+
+#include <cstdint>
+#include <cstdlib>
+#include <cstring>
+
+#include <cstdio>
+#include <cassert>
+
+namespace o2::framework::internal
+{
+static char encoder[] = "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
+static char decoder[256];
+static int initialized;
+
+static void
+  base64_init_decoder()
+{
+  int i = 0;
+
+  if (initialized) {
+    return;
+  }
+
+  // -1 is used for error detection
+  memset(decoder, -1, sizeof decoder);
+
+  for (; i < 64; decoder[(int)encoder[i]] = i, ++i) {
+  }
+
+  initialized = 1;
+
+  return;
+}
+
+static int
+  base64_encsize(int size)
+{
+  return 4 * ((size + 2) / 3);
+}
+
+int base64_encode(char* dest, int size, unsigned char* src, int slen)
+{
+  int dlen, i, j;
+  uint32_t a, b, c, triple;
+
+  dlen = base64_encsize(slen);
+
+  // Sanity checks
+  if (src == nullptr || dest == nullptr) {
+    return -1;
+  }
+  if (dlen + 1 > size) {
+    return -1;
+  }
+  if (slen == 0) {
+    if (size > 0) {
+      dest[0] = 0;
+      return 0;
+    }
+    return -1;
+  }
+
+  for (i = 0, j = 0; i < slen;) {
+    a = src[i++];
+
+    // b and c may be off limit
+    b = i < slen ? src[i++] : 0;
+    c = i < slen ? src[i++] : 0;
+
+    triple = (a << 16) + (b << 8) + c;
+
+    dest[j++] = encoder[(triple >> 18) & 0x3F];
+    dest[j++] = encoder[(triple >> 12) & 0x3F];
+    dest[j++] = encoder[(triple >> 6) & 0x3F];
+    dest[j++] = encoder[triple & 0x3F];
+  }
+
+  // Pad zeroes at the end
+  switch (slen % 3) {
+    case 1:
+      dest[j - 2] = '=';
+    case 2:
+      dest[j - 1] = '=';
+  }
+
+  // Always add \0
+  dest[j] = 0;
+
+  return dlen;
+}
+
+char* base64_enc_malloc(unsigned char* src, int slen)
+{
+  int size;
+  char* buffer;
+
+  size = base64_encsize(slen) + 1;
+
+  buffer = (char*)malloc(size);
+  if (buffer == nullptr) {
+    return nullptr;
+  }
+
+  size = base64_encode(buffer, size, src, slen);
+  if (size == -1) {
+    free(buffer);
+    return nullptr;
+  }
+
+  return buffer;
+}
+
+static int
+  base64_decsize(char* src)
+{
+  int slen, size, i;
+
+  if (src == nullptr) {
+    return 0;
+  }
+
+  slen = strlen(src);
+  size = slen / 4 * 3;
+
+  // Count pad chars
+  for (i = 0; src[slen - i - 1] == '='; ++i) {
+  }
+
+  // Remove at most 2 bytes.
+  return size - (i >= 2 ? 2 : i);
+}
+
+int base64_decode(unsigned char* dest, int size, char* src)
+{
+  int slen, dlen, padlen, i, j;
+  uint32_t a, b, c, d, triple;
+
+  // Initialize decoder
+  base64_init_decoder();
+
+  // Sanity checks
+  if (src == nullptr || dest == nullptr) {
+    return -1;
+  }
+
+  slen = strlen(src);
+  if (slen == 0) {
+    if (size > 0) {
+      dest[0] = 0;
+      return 0;
+    }
+    return -1;
+  }
+
+  // Remove trailing pad characters.
+  for (padlen = 0; src[slen - padlen - 1] == '='; ++padlen) {
+  }
+  if (padlen > 2) {
+    slen -= padlen - 2;
+  }
+  if (slen % 4) {
+    return -1;
+  }
+
+  dlen = base64_decsize(src);
+
+  // Check buffer size
+  if (dlen + 1 > size) {
+    return -1;
+  }
+
+  for (i = 0, j = 0; i < slen;) {
+    a = decoder[(int)src[i++]];
+    b = decoder[(int)src[i++]];
+    c = decoder[(int)src[i++]];
+    d = decoder[(int)src[i++]];
+
+    // Sextet 3 and 4 may be zero at the end
+    if (i == slen) {
+      if (src[slen - 1] == '=') {
+        d = 0;
+        if (src[slen - 2] == '=') {
+          c = 0;
+        }
+      }
+    }
+
+    // Non-Base64 char
+    if (a == -1 || b == -1 || c == -1 || d == -1) {
+      return -1;
+    }
+
+    triple = (a << 18) + (b << 12) + (c << 6) + d;
+
+    dest[j++] = (triple >> 16) & 0xFF;
+    dest[j++] = (triple >> 8) & 0xFF;
+    dest[j++] = triple & 0xFF;
+  }
+
+  // Always add \0
+  dest[j] = 0;
+
+  return dlen;
+}
+
+unsigned char*
+  base64_dec_malloc(char* src)
+{
+  int size;
+  unsigned char* buffer;
+
+  size = base64_decsize(src) + 1;
+
+  buffer = (unsigned char*)malloc(size);
+  if (buffer == nullptr) {
+    return nullptr;
+  }
+
+  size = base64_decode(buffer, size, src);
+  if (size == -1) {
+    free(buffer);
+    return nullptr;
+  }
+
+  return buffer;
+}
+} // namespace o2::framework::internal

Framework/Core/src/Base64.h

@@ -0,0 +1,22 @@
+// Copyright CERN and copyright holders of ALICE O2. This software is
+// distributed under the terms of the GNU General Public License v3 (GPL
+// Version 3), copied verbatim in the file "COPYING".
+//
+// See http://alice-o2.web.cern.ch/license for full licensing information.
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+#ifndef O2_FRAMEWORK_BASE64_H_
+#define O2_FRAMEWORK_BASE64_H_
+
+namespace o2::framework::internal
+{
+int base64_encode(char* dest, int size, unsigned char* src, int slen);
+char* base64_enc_malloc(unsigned char* src, int slen);
+int base64_decode(unsigned char* dest, int size, char* src);
+unsigned char* base64_dec_malloc(char* src);
+} // namespace o2::framework::internal
+
+#endif // O2_FRAMEWORK_BASE64_H_