read array

Author: abenso

app/src/metadata_reader.c

@@ -222,6 +222,7 @@ parser_error_t read_immediate(parser_context_t *ctx, primitive_t *primitive) {
             break;
         case PRIMITIVE_BYTE_VEC:
             print_string("Primitive byte vec");
+            CHECK_ERROR(read_byte_display(ctx, &primitive->byte_vec.display));
             break;
         case PRIMITIVE_FLOAT32:
             print_string("Primitive float32");
@@ -504,6 +505,20 @@ parser_error_t read_tuple(parser_context_t *ctx, schema_tuple_t *schema_tuple) {
     return parser_ok;
 }
 
+parser_error_t read_array(parser_context_t *ctx, schema_array_t *schema_array) {
+    CHECK_INPUT(schema_array);
+    CHECK_INPUT(ctx);
+
+    //read length
+    CHECK_ERROR(read_u64(ctx, (uint64_t*)&schema_array->len));
+    printf("array length: %llu\n", schema_array->len);
+
+    //read vec_type
+    CHECK_ERROR(read_link(ctx, &schema_array->value));
+
+    return parser_ok;
+}
+
 parser_error_t metadata_read(parser_context_t *ctx, parser_tx_t *txObj) {
     CHECK_INPUT(ctx);
     CHECK_INPUT(txObj);
@@ -515,7 +530,7 @@ parser_error_t metadata_read(parser_context_t *ctx, parser_tx_t *txObj) {
     }
 
     // TODO: go through all schemes
-    for (uint32_t i = 0; i < 18; i++) {
+    for (uint32_t i = 0; i < 36; i++) {
         // read type
         CHECK_ERROR(read_u8(ctx, (uint8_t*)&txObj->schema.types.schemes[i].type));
         switch (txObj->schema.types.schemes[i].type) {
@@ -539,6 +554,11 @@ parser_error_t metadata_read(parser_context_t *ctx, parser_tx_t *txObj) {
                 CHECK_ERROR(read_link(ctx, &txObj->schema.types.schemes[i].option_type));
                 print_string("READING OPTION DONE\n");
                 break;
+            case LINKING_SCHEME_ARRAY:
+                print_string("READING ARRAY");
+                CHECK_ERROR(read_array(ctx, &txObj->schema.types.schemes[i].array_type));
+                print_string("READING ARRAY DONE\n");
+                break;
             case LINKING_SCHEME_VEC:
                 print_string("READING VEC");
                 CHECK_ERROR(read_link(ctx, &txObj->schema.types.schemes[i].vec_type));

app/src/parser_txdef.h

@@ -139,7 +139,7 @@ typedef struct {
 } primitive_byte_array_t;
 
 typedef struct {
-    byte_display_type_t display;
+    byte_display_t display;
 } primitive_byte_vec_t;
 
 typedef struct {
@@ -230,6 +230,11 @@ typedef struct {
     unnamed_field_t fields[MAX_FIELDS_QTY];
 } schema_option_t;
 
+typedef struct {
+    uint64_t len;
+    link_t value;
+} schema_array_t;
+
 typedef struct {
    linking_scheme_type_t type;
    union {
@@ -238,6 +243,7 @@ typedef struct {
     schema_tuple_t tuple_type;
     link_t option_type;
     link_t vec_type;
+    schema_array_t array_type;
    };
 } linking_scheme_t;