writer_trig.c

Go to the documentation of this file.

#include "volksdata/codec/writer_trig.h"
 
 
// Position of a cursor.
typedef enum {
    TRIG_POS_START,         
    TRIG_POS_START_BODY,    
    TRIG_POS_GRAPH,         
    TRIG_POS_END_GR,        
    TRIG_POS_END,           
} TRIGPos;

struct trig_encode_iter_t {
    VOLK_rc             rc;         
    VOLK_Store *        store;      
    VOLK_TermSet *      gr_uri_ts;  
    TTLEncodeIterator * gr_it;      
    TRIGPos             pos;        
    void *              txn;        
};
 
 
/* * * Codec functions. * * */

static VOLK_rc
trig_build_prolog (TRIGEncodeIterator *it, char **res_p)
{
    char *res = fmt_header ("# ");
 
    const char ***nsm = VOLK_nsmap_dump ();
    char *ns_tpl = "@prefix %s: <%s> .\n";
 
    // Prefix map.
    for (size_t i = 0; nsm[i]; i++) {
        const char **ns = nsm[i];
        size_t old_len = strlen (res);
        size_t ns_len = strlen (ns[0]) + strlen (ns[1]) + strlen (ns_tpl);
        char *tmp = realloc (res, old_len + ns_len + 1);
        if (UNLIKELY (!tmp)) return VOLK_MEM_ERR;
        res = tmp;
 
        sprintf (res + old_len, ns_tpl, ns[0], ns[1]);
        free (ns);
    }
    free (nsm);
 
    *res_p = res;
    it->pos = TRIG_POS_START_BODY;
    it->rc = VOLK_OK;
 
    return VOLK_OK;
}
 
 
void *
trig_encode_store_init (VOLK_Store *store)
{
    NLNL (store);
    if (!(VOLK_store_features (store) & VOLK_STORE_CTX)) {
        log_error ("Store is not context-aware.");
        return NULL;
    }
    TRIGEncodeIterator *it;
    CALLOC_GUARD (it, NULL);
 
    it->store = store;
    VOLK_rc rc = VOLK_store_begin (it->store, VOLK_STORE_TXN_RO, &it->txn);
    // TODO RCCK (rc);
    it->gr_uri_ts = VOLK_graph_list_txn (it->txn, it->store);
    //it->gr_it = NULL;
    it->pos = TRIG_POS_START;
 
    it->rc = VOLK_NORESULT;
 
    return it;
}
 
 
VOLK_rc
trig_encode_store_iter (void *h, char **res_p)
{
    TRIGEncodeIterator *it = h;
 
    // Beginning of overall encoding process: write prolog.
    if (it->pos == TRIG_POS_START) return trig_build_prolog (it, res_p);
    else if (it->pos == TRIG_POS_END_GR) {
        // End of graph encoding loop: finalize graph codec iterator.
        ttl_encode_graph_done (it->gr_it);
        it->gr_it = NULL;
    }
    char *gr_uri_trig = NULL;
 
    // After writing prolog: populate first graph.
    // Or: a graph just finished encoding, try to get the next one.
    // Allocate the boundary symbols.
    if (it->pos == TRIG_POS_START_BODY || it->pos == TRIG_POS_END_GR) {
        // Preallocate closing brace + newline in any case.
        size_t out_size = 3;
 
        VOLK_Term *gr_uri = VOLK_term_set_pop (it->gr_uri_ts);
        if (gr_uri) {
            ttl_encode_term (gr_uri, &gr_uri_trig);
            VOLK_Graph *gr = VOLK_graph_new (it->store, gr_uri->data);
            VOLK_term_free (gr_uri);
            out_size += strlen (gr_uri_trig) + 4;
            it->gr_it = ttl_encode_graph_init (gr, VOLK_CODEC_NO_PROLOG);
        } else {
            log_debug ("End of store encoding.");
            it->pos = TRIG_POS_END;
            it->rc = VOLK_END;
        }
 
        char *tmp = realloc (*res_p, out_size);  // Only one realloc.
        NLRCCK (tmp, VOLK_MEM_ERR);
        *res_p = tmp;
    }
 
    if (it->pos == TRIG_POS_GRAPH) {
        VOLK_rc gr_rc = ttl_encode_graph_iter (it->gr_it, res_p);
        if (gr_rc == VOLK_END || gr_rc == VOLK_NORESULT)
            it->pos = TRIG_POS_END_GR;
    } else {
        // Write closing and/or opening braces. This uses up the iteration.
        size_t offset = 0;  // Where to start writing graph name.
        if (it->pos == TRIG_POS_END_GR || it->pos == TRIG_POS_END) {
            sprintf (*res_p, "}\n");
            *res_p[2] = '0';
            offset = 2;
        }
        if (it->pos == TRIG_POS_START_BODY || it->pos == TRIG_POS_END_GR) {
            sprintf (*res_p + offset, "\n%s {\n", gr_uri_trig);
            offset += strlen (gr_uri_trig) + 3;
            free (gr_uri_trig);
            it->pos = TRIG_POS_GRAPH;
            it->rc = VOLK_OK;
            *res_p[offset] = '0';
        }
    }
 
    return it->rc;
}
 
 
void
trig_encode_store_done (void *h)
{
    if (!h) return;
    TRIGEncodeIterator *it = h;
 
    VOLK_store_abort (it->store, it->txn);
    VOLK_term_set_free (it->gr_uri_ts);
    free (it);
}