constr_CHOICE_jer.c

Go to the documentation of this file.

/*
 * Copyright (c) 2017 Lev Walkin <vlm@lionet.info>.
 * All rights reserved.
 * Redistribution and modifications are permitted subject to BSD license.
 */
#include <etsi_its_cpm_ts_coding/asn_internal.h>
#include <etsi_its_cpm_ts_coding/constr_CHOICE.h>
 
/*
 * Return a standardized complex structure.
 */
#undef RETURN
#define RETURN(_code)                     \
    do {                                  \
        rval.code = _code;                \
        rval.consumed = consumed_myself;  \
        return rval;                      \
    } while(0)
 
#undef JER_ADVANCE
#define JER_ADVANCE(num_bytes)                                    \
    do {                                                          \
        size_t num = num_bytes;                                   \
        buf_ptr = (const void *)(((const char *)buf_ptr) + num);  \
        size -= num;                                              \
        consumed_myself += num;                                   \
    } while(0)
 
/*
 * Decode the JER (JSON) data.
 */
asn_dec_rval_t
CHOICE_decode_jer(const asn_codec_ctx_t *opt_codec_ctx,
                  const asn_TYPE_descriptor_t *td,
                  const asn_jer_constraints_t *constraints,
                  void **struct_ptr, const void *buf_ptr, size_t size) {
    /*
     * Bring closer parts of structure description.
     */
    const asn_CHOICE_specifics_t *specs = (const asn_CHOICE_specifics_t *)td->specifics;
 
    /*
     * Parts of the structure being constructed.
     */
    void *st = *struct_ptr;  /* Target structure. */
    asn_struct_ctx_t *ctx;   /* Decoder context */
 
    asn_dec_rval_t rval;          /* Return value of a decoder */
    ssize_t consumed_myself = 0;  /* Consumed bytes from ptr */
    size_t edx;                   /* Element index */
 
    /*
     * Create the target structure if it is not present already.
     */
    if(st == 0) {
        st = *struct_ptr = CALLOC(1, specs->struct_size);
        if(st == 0) RETURN(RC_FAIL);
    }
 
    /*
     * Restore parsing context.
     */
    ctx = (asn_struct_ctx_t *)((char *)st + specs->ctx_offset);
 
    /*
     * Phases of JER/JSON processing:
     * Phase 0: Check that the opening key matches our expectations.
     * Phase 1: Processing body and reacting on closing token.
     * Phase 2: Processing inner type.
     * Phase 3: Only waiting for closing token.
     * Phase 4: Skipping unknown extensions.
     * Phase 5: PHASED OUT
     */
    for(edx = ctx->step; ctx->phase <= 4;) {
        pjer_chunk_type_e ch_type;  /* JER chunk type */
        ssize_t ch_size;            /* Chunk size */
        jer_check_sym_e scv;        /* Tag check value */
        asn_TYPE_member_t *elm;
 
        /*
         * Go inside the member.
         */
        if(ctx->phase == 2) {
            asn_dec_rval_t tmprval;
            void *memb_ptr;    /* Pointer to the member */
            void **memb_ptr2;  /* Pointer to that pointer */
            unsigned old_present __attribute__((unused));
 
            elm = &td->elements[edx];
 
            if(elm->flags & ATF_POINTER) {
                /* Member is a pointer to another structure */
                memb_ptr2 = (void **)((char *)st
                    + elm->memb_offset);
            } else {
                memb_ptr = (char *)st + elm->memb_offset;
                memb_ptr2 = &memb_ptr;
            }
 
            /* Start/Continue decoding the inner member */
            tmprval = elm->type->op->jer_decoder(opt_codec_ctx,
                                                 elm->type,
                                                 elm->encoding_constraints.jer_constraints,
                                                 memb_ptr2,
                                                 buf_ptr, size);
            JER_ADVANCE(tmprval.consumed);
            ASN_DEBUG("JER/CHOICE: itdf: [%s] code=%d",
                      elm->type->name, tmprval.code);
            old_present = _fetch_present_idx(st,
                                             specs->pres_offset,
                                             specs->pres_size);
            assert(old_present == 0 || old_present == edx + 1);
            /* Record what we've got */
            _set_present_idx(st,
                             specs->pres_offset,
                             specs->pres_size, edx + 1);
            if(tmprval.code != RC_OK)
                RETURN(tmprval.code);
            ctx->phase = 3;
            /* Fall through */
        }
 
        /*
         * Get the next part of the JSON stream.
         */
        ch_size = jer_next_token(&ctx->context, buf_ptr, size, &ch_type);
        if(ch_size == -1) {
            RETURN(RC_FAIL);
        } else {
            switch(ch_type) {
            case PJER_WMORE:
                RETURN(RC_WMORE);
 
            case PJER_TEXT:  /* Ignore free-standing text */
                JER_ADVANCE(ch_size);  /* Skip silently */
                continue;
 
            case PJER_DLM:
            case PJER_VALUE: 
            case PJER_KEY:
                break;  /* Check the rest down there */
            }
        }
 
        scv = jer_check_sym(buf_ptr, ch_size, NULL);
        ASN_DEBUG("JER/CHOICE checked [%c%c%c%c] of [%s], scv=%d",
                  ch_size>0?((const uint8_t *)buf_ptr)[0]:'?',
                  ch_size>1?((const uint8_t *)buf_ptr)[1]:'?',
                  ch_size>2?((const uint8_t *)buf_ptr)[2]:'?',
                  ch_size>3?((const uint8_t *)buf_ptr)[3]:'?',
                  td->name, scv);
 
        /* Skip the extensions section */
        if(ctx->phase == 4) {
            ASN_DEBUG("skip_unknown(%d, %ld)",
                      scv, (long)ctx->left);
            switch(jer_skip_unknown(scv, &ctx->left)) {
            case -1:
                ctx->phase = 5;
                RETURN(RC_FAIL);
            case 1:
                ctx->phase = 3;
                /* Fall through */
            case 0:
                JER_ADVANCE(ch_size);
                continue;
            case 2:
                ctx->phase = 3;
                break;
            }
        }
 
        switch(scv) {
        case JCK_OEND:
            if(ctx->phase != 3)
                break;
            JER_ADVANCE(ch_size);
            ctx->phase = 5;  /* Phase out */
            RETURN(RC_OK);
 
        case JCK_COMMA:
            JER_ADVANCE(ch_size);
            continue;
 
        case JCK_OSTART:
            if(ctx->phase == 0) {
                JER_ADVANCE(ch_size);
                ctx->phase = 1;  /* Processing body phase */
                continue;
            }
            /* Fall through */
        case JCK_KEY:
        case JCK_UNKNOWN:
 
            if(ctx->phase != 1)
                break;  /* Really unexpected */
 
            /*
             * Search which inner member corresponds to this key.
             */
            for(edx = 0; edx < td->elements_count; edx++) {
                elm = &td->elements[edx];
                scv = jer_check_sym(buf_ptr,ch_size,elm->name);
                switch(scv) {
                case JCK_KEY:
                    /*
                     * Process this member.
                     */
                    ctx->step = edx;
                    ctx->phase = 2;
                    JER_ADVANCE(ch_size); /* skip key */
                    /* skip colon */
                    ch_size = jer_next_token(&ctx->context, buf_ptr, size,
                            &ch_type);
                    if(ch_size == -1) {
                        RETURN(RC_FAIL);
                    } else {
                        switch(ch_type) {
                        case PJER_WMORE:
                            RETURN(RC_WMORE);
                        case PJER_TEXT:  
                            JER_ADVANCE(ch_size);
                            break;
                        default:
                            RETURN(RC_FAIL);
                        }
                    }
                    break;
                case JCK_UNKNOWN:
                    continue;
                default:
                    edx = td->elements_count;
                    break;  /* Phase out */
                }
                break;
            }
            if(edx != td->elements_count)
                continue;
 
            /* It is expected extension */
            if(specs->ext_start != -1) {
                ASN_DEBUG("Got anticipated extension");
                ctx->left = 1;
                ctx->phase = 4; /* Skip ...'s */
                JER_ADVANCE(ch_size);
                continue;
            }
 
            /* Fall through */
        default:
            break;
        }
 
        ASN_DEBUG("Unexpected JSON token [%c%c%c%c] in CHOICE [%s]"
                  " (ph=%d)",
                  ch_size>0?((const uint8_t *)buf_ptr)[0]:'?',
                  ch_size>1?((const uint8_t *)buf_ptr)[1]:'?',
                  ch_size>2?((const uint8_t *)buf_ptr)[2]:'?',
                  ch_size>3?((const uint8_t *)buf_ptr)[3]:'?',
                  td->name, ctx->phase);
        break;
    }
 
    ctx->phase = 5;  /* Phase out, just in case */
    RETURN(RC_FAIL);
}
 
asn_enc_rval_t
CHOICE_encode_jer(const asn_TYPE_descriptor_t *td, const asn_jer_constraints_t *constraints,
                  const void *sptr, int ilevel, enum jer_encoder_flags_e flags,
                  asn_app_consume_bytes_f *cb, void *app_key) {
    const asn_CHOICE_specifics_t *specs =
        (const asn_CHOICE_specifics_t *)td->specifics;
    asn_enc_rval_t er = {0,0,0};
    unsigned present = 0;
    int jmin = (flags & JER_F_MINIFIED);
 
    if(!sptr)
        ASN__ENCODE_FAILED;
 
    /*
     * Figure out which CHOICE element is encoded.
     */
    present = _fetch_present_idx(sptr, specs->pres_offset,specs->pres_size);
 
    if(present == 0 || present > td->elements_count) {
        ASN__ENCODE_FAILED;
    } else {
        asn_enc_rval_t tmper = {0,0,0};
        asn_TYPE_member_t *elm = &td->elements[present-1];
        const void *memb_ptr = NULL;
        const char *mname = elm->name;
        unsigned int mlen = strlen(mname);
 
        if(elm->flags & ATF_POINTER) {
            memb_ptr =
                *(const void *const *)((const char *)sptr + elm->memb_offset);
            if(!memb_ptr) ASN__ENCODE_FAILED;
        } else {
            memb_ptr = (const void *)((const char *)sptr + elm->memb_offset);
        }
 
        er.encoded = 0;
 
        ASN__CALLBACK("{",1);
        if(!jmin) {
            ASN__TEXT_INDENT(1, ilevel + 1);
            ASN__CALLBACK3("\"", 1, mname, mlen, "\": ", 3);
        } else {
            ASN__CALLBACK3("\"", 1, mname, mlen, "\":", 2);
        }
 
        tmper = elm->type->op->jer_encoder(elm->type,
                                           elm->encoding_constraints.jer_constraints,
                                           memb_ptr,
                                           ilevel + 1, flags, cb, app_key);
        if(tmper.encoded == -1) return tmper;
        er.encoded += tmper.encoded;
 
        if(!jmin) ASN__TEXT_INDENT(1, ilevel);
        ASN__CALLBACK("}", 1);
    }
 
    ASN__ENCODED_OK(er);
cb_failed:
    ASN__ENCODE_FAILED;
}