afw_adaptor_delete.c

Go to the documentation of this file.

// See the 'COPYING' file in the project root for licensing information.
/*
 * Adaptive Framework Adaptor Delete Object
 *
 * Copyright (c) 2010-2023 Clemson University
 *
 */
 
#include "afw_internal.h"
 
 
/* Delete object from cache and via adaptor. */
AFW_DEFINE(void)
afw_adaptor_delete_object(
    const afw_utf8_t *adaptor_id,
    const afw_utf8_t *object_type_id,
    const afw_utf8_t *object_id,
    const afw_object_t *journal_entry,
    const afw_object_t *adaptor_type_specific,
    afw_xctx_t *xctx)
{
    const afw_adaptor_session_t *session;
    const afw_object_t *request;
    afw_adaptor_impl_request_t impl_request;
 
    /* Set request in journal entry. */
    afw_memory_clear(&impl_request);
    impl_request.request = request = afw_object_create_embedded(
        journal_entry, &afw_s_request, xctx);
    impl_request.p = request->p;
    impl_request.journal_entry = journal_entry;
    impl_request.resource_id = afw_utf8_printf(impl_request.p, xctx,
        "/"
        "%" AFW_UTF8_FMT "/"
        "%" AFW_UTF8_FMT "/"
        "%" AFW_UTF8_FMT,
        AFW_UTF8_FMT_ARG(adaptor_id),
        AFW_UTF8_FMT_ARG(object_type_id),
        AFW_UTF8_FMT_ARG(object_id));
    afw_object_set_property_as_string(request,
        &afw_s_resourceId, impl_request.resource_id, xctx);
    afw_object_set_property_as_string(request,
        &afw_s_function, &afw_s_delete_object, xctx);
    afw_object_set_property_as_string(request,
        &afw_s_adaptorId, adaptor_id, xctx);
    afw_object_set_property_as_string(request,
        &afw_s_objectType, object_type_id, xctx);
    afw_object_set_property_as_string(request,
        &afw_s_objectId, object_id, xctx);
 
    /* Get an active session with adaptor. */
    session = afw_adaptor_session_get_cached(adaptor_id, true, xctx);
 
    /* Action prologue. */
    afw_adaptor_internal_journal_prologue(session, journal_entry, xctx);
 
    /* If one of the core object types, handle special */
    if (afw_utf8_starts_with(object_type_id, &AFW_OBJECT_S_CORE_ID_PREFIX)) {
 
        /* Journal entry. */
        if (afw_utf8_equal(object_type_id,
            &AFW_OBJECT_S_OBJECT_TYPE_ID_JOURNAL_ENTRY))
        {
            AFW_THROW_ERROR_Z(general,
                "delete_object() is not supported for "
                AFW_OBJECT_Q_OBJECT_TYPE_ID_JOURNAL_ENTRY,
                xctx);
        }
    }
 
 
    /* Delete object. */
    afw_adaptor_session_delete_object(session, &impl_request,
        object_type_id, object_id, adaptor_type_specific, xctx);
 
    /* Action epilogue. */
    afw_adaptor_internal_journal_epilogue(session, journal_entry, true, xctx);
}