public_comment_callback.hpp

Go to the documentation of this file.

Go to the SVN repository for this file.

#ifndef PUBLIC_COMMENT_CALLBACK__HPP
#define PUBLIC_COMMENT_CALLBACK__HPP
 
/*  $Id: public_comment_callback.hpp 98837 2023-01-12 13:25:00Z satskyse $
 * ===========================================================================
 *
 *                            PUBLIC DOMAIN NOTICE
 *               National Center for Biotechnology Information
 *
 *  This software/database is a "United States Government Work" under the
 *  terms of the United States Copyright Act.  It was written as part of
 *  the author's official duties as a United States Government employee and
 *  thus cannot be copyrighted.  This software/database is freely available
 *  to the public for use. The National Library of Medicine and the U.S.
 *  Government have not placed any restriction on its use or reproduction.
 *
 *  Although all reasonable efforts have been taken to ensure the accuracy
 *  and reliability of the software and data, the NLM and the U.S.
 *  Government do not and cannot warrant the performance or results that
 *  may be obtained by using this software or data. The NLM and the U.S.
 *  Government disclaim all warranties, express or implied, including
 *  warranties of performance, merchantability or fitness for any particular
 *  purpose.
 *
 *  Please cite the author in any work or product based on this material.
 *
 * ===========================================================================
 *
 * Authors: Sergey Satskiy
 *
 * File Description:
 *
 */
 
#include "http_daemon.hpp"
#include "cass_fetch.hpp"
 
#include <functional>
 
 
using TPublicCommentConsumeCB =
                function<void(CCassPublicCommentFetch *  fetch_details,
                              string  comment,
                              bool  is_found)>;
using TPublicCommentErrorCB =
                function<void(CCassPublicCommentFetch *  fetch_details,
                              CRequestStatus::ECode  status,
                              int  code,
                              EDiagSev  severity,
                              const string &  message)>;
 
class IPSGS_Processor;
 
 
 
class CPublicCommentConsumeCallback
{
    public:
        CPublicCommentConsumeCallback(
                IPSGS_Processor *  processor,
                TPublicCommentConsumeCB  consume_cb,
                CCassPublicCommentFetch *  fetch_details) :
            m_Processor(processor),
            m_ConsumeCB(consume_cb),
            m_FetchDetails(fetch_details),
            m_PublicCommentRetrieveTiming(psg_clock_t::now())
        {}
 
        void operator()(string  comment, bool  is_found)
        {
            EPSGOperationStatus     op_status = eOpStatusFound;
            if (!is_found)
                op_status = eOpStatusNotFound;
 
            CPubseqGatewayApp::GetInstance()->GetTiming().
                Register(m_Processor, ePublicCommentRetrieve, op_status,
                         m_PublicCommentRetrieveTiming);
 
            m_ConsumeCB(m_FetchDetails, comment, is_found);
        }
 
    private:
        IPSGS_Processor *               m_Processor;
        TPublicCommentConsumeCB         m_ConsumeCB;
        CCassPublicCommentFetch *       m_FetchDetails;
        psg_time_point_t                m_PublicCommentRetrieveTiming;
};
 
 
class CPublicCommentErrorCallback
{
    public:
        CPublicCommentErrorCallback(
                IPSGS_Processor *  processor,
                TPublicCommentErrorCB  error_cb,
                CCassPublicCommentFetch *  fetch_details) :
            m_Processor(processor),
            m_ErrorCB(error_cb),
            m_FetchDetails(fetch_details),
            m_PublicCommentRetrieveTiming(psg_clock_t::now())
        {}
 
        void operator()(CRequestStatus::ECode  status,
                        int  code,
                        EDiagSev  severity,
                        const string &  message)
        {
            if (status == CRequestStatus::e404_NotFound)
                CPubseqGatewayApp::GetInstance()->GetTiming().
                    Register(m_Processor, ePublicCommentRetrieve,
                             eOpStatusNotFound,
                             m_PublicCommentRetrieveTiming);
            m_ErrorCB(m_FetchDetails, status, code, severity, message);
        }
 
    private:
        IPSGS_Processor *               m_Processor;
        TPublicCommentErrorCB           m_ErrorCB;
        CCassPublicCommentFetch *       m_FetchDetails;
        psg_time_point_t                m_PublicCommentRetrieveTiming;
};
 
 
#endif