encoding: add flb_encoding

Add flb_encoding functions for charset encodings to utf8.

* Uses lib/tutf8e-library.
* Only 8-bit source charsets are supported.
* Encoding options (//OPTION) :
 //IGNORE, //QUESTION, //REPLACEMENT ///<text>
* This commit doesn't add support to any input plugin.
* Depends on fluent#2326

Signed-off-by: Jukka Pihl <[email protected]>

Author: bluebike

CMakeLists.txt

@@ -196,6 +196,7 @@ if(FLB_ALL)
   # Global
   set(FLB_DEBUG        1)
   set(FLB_TLS          1)
+  set(FLB_UTF8_ENCODER 1)
 
   # Input plugins
   set(FLB_IN_CPU       1)
@@ -353,7 +354,8 @@ add_subdirectory(${FLB_PATH_LIB_MINIZ} EXCLUDE_FROM_ALL)
 
 # tutf8e
 if(FLB_UTF8_ENCODER)
-  add_subdirectory(${FLB_PATH_LIB_TUTF8E} EXCLUDE_FROM_ALL)
+  add_subdirectory(${FLB_PATH_LIB_TUTF8E})
+  FLB_DEFINITION(FLB_HAVE_UTF8_ENCODER)
 endif()
 
 # Chunk I/O

include/fluent-bit/flb_encoding.h

@@ -0,0 +1,43 @@
+/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+
+/*  Fluent Bit
+ *  ==========
+ *  Copyright (C) 2019      The Fluent Bit Authors
+ *  Copyright (C) 2015-2018 Treasure Data Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+#ifndef FLB_ENCODING_H
+#define FLB_ENCODING_H
+
+#include <tutf8e.h>
+
+
+#define FLB_ENCODING_SUCCESS      0
+#define FLB_ENCODING_FAILURE     -1
+
+struct flb_encoding {
+    TUTF8encoder encoder;
+    const char *invalid;
+};
+
+struct flb_encoding *flb_encoding_open(const char *encoding);
+
+int flb_encoding_decode(struct flb_encoding *ec,
+                        char *str, size_t slen,
+                        char **result, size_t *result_len);
+
+void flb_encoding_close(struct flb_encoding *ic);
+
+#endif

src/CMakeLists.txt

@@ -278,6 +278,10 @@ set(FLB_DEPS
   ${FLB_DEPS}
   tutf8e
   )
+set(src
+  ${src}
+  "flb_encoding.c"
+  )
 endif()
 
 # Record Accessor

src/flb_encoding.c

@@ -0,0 +1,138 @@
+/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
+
+/*  Fluent Bit
+ *  ==========
+ *  Copyright (C) 2019      The Fluent Bit Authors
+ *  Copyright (C) 2015-2018 Treasure Data Inc.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+
+#include <stdio.h>
+
+#include <string.h>
+#include <time.h>
+#include <ctype.h>
+
+#include <fluent-bit/flb_macros.h>
+#include <fluent-bit/flb_config.h>
+#include <fluent-bit/flb_error.h>
+#include <fluent-bit/flb_mem.h>
+#include <fluent-bit/flb_str.h>
+#include <fluent-bit/flb_encoding.h>
+
+
+#include <tutf8e.h>
+
+/*
+ *
+ *  flb_encoding_open(encoding):
+ *  iso-8859-1,...
+ *  windows-1251 windows-1252, ..
+ * 
+ *  <charset>                     - fail if bad chars
+ *  <charset>//IGNORE             - ignore bad chars
+ *  <charset>//REPLACEMENT //R    - use unicode replacement chars for bad chars
+ *  <charset>//QUESTION  //Q      - use '?' for bad chars
+ *  <charset>///<str>             - use <str> for bad chars
+ */
+
+
+static  unsigned char replacement_utf8[] = { 0xEF, 0xBF, 0xBD , 0 };
+
+struct flb_encoding *flb_encoding_open(const char *encoding) {
+    struct flb_encoding *ec;
+    TUTF8encoder encoder;
+    const char *invalid;
+    char *opt;
+
+    if ((opt = strstr(encoding,"//")) != NULL) {
+        *opt = 0;
+        opt += 2;
+        if (*opt == '/') {
+            invalid = opt + 1;
+        } else if (!strcmp(opt,"I") || !strcmp(opt,"IGNORE")) {
+            invalid = "";
+        } else if (!strcmp(opt,"R") || !strcmp(opt,"REPLACEMENT")) {
+            invalid = (const char *) replacement_utf8;
+        } else if (!strcmp(opt,"Q") || !strcmp(opt,"QUESTION")) {
+            invalid = "?";
+        } else {
+            flb_error("[flb_encoding] unknown encodig option: %s", opt);
+        }
+    } else {
+        invalid = NULL;
+    }
+    
+    if ((encoder = tutf8e_encoder(encoding)) == NULL) {
+        flb_error("[flb_encoding] unknown encoding: %s", encoding);
+        return NULL;
+    }
+    ec =   flb_calloc(sizeof(struct flb_encoding),1);
+    ec->encoder = encoder;
+    ec->invalid = invalid ? flb_strdup(invalid) : NULL;
+    return ec;
+}
+
+
+int flb_encoding_decode(struct flb_encoding *ec,
+                        char *str, size_t slen,
+                        char **result, size_t *result_len) 
+{
+    size_t outlen = 0;
+    char *outbuf;
+    int ret;
+
+    *result = NULL;
+    *result_len = 0;
+
+    if (slen == 0) {
+        *result = flb_strdup("");
+        *result_len = 0;
+        return FLB_ENCODING_SUCCESS;
+    }
+    
+    ret = tutf8e_encoder_buffer_length(ec->encoder, str, ec->invalid,  slen, &outlen);
+    
+    if (ret != TUTF8E_OK) {
+        return FLB_ENCODING_FAILURE;
+    }
+    
+
+    outbuf = flb_malloc(outlen + 1);
+    if(outbuf == NULL) {
+        flb_error("[flb_encoding] out of memory (%zu)", (int) outlen  + 1);
+        return FLB_ENCODING_FAILURE;
+    }
+
+    ret = tutf8e_encoder_buffer_encode(ec->encoder, str, slen, ec->invalid, outbuf, &outlen);
+    
+    if (ret != TUTF8E_OK) {
+        flb_free(outbuf);
+        return FLB_ENCODING_FAILURE;
+    }
+    outbuf[outlen] = 0;
+    *result = outbuf;
+    *result_len = outlen;
+    
+    return FLB_ENCODING_SUCCESS;
+}
+    
+void flb_encoding_close(struct flb_encoding *ec) {
+    if (ec) {
+        if (ec->invalid) {
+            flb_free((char*)ec->invalid);
+        }
+    }
+}
+