hsms_factory.cpp

/*   
 *   (c) Copyright 2008 Philipp Skadorov (philipp_s@users.sourceforge.net)
 *
 *   This file is part of FREESECS.
 *
 *   FREESECS is free software: you can redistribute it and/or modify
 *   it under the terms of the GNU General Public License as published by
 *   the Free Software Foundation, either version 3 of the License, or
 *   (at your option) any later version.
 *
 *   FREESECS is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *   GNU General Public License for more details.
 *
 *   You should have received a copy of the GNU General Public License
 *   along with FREESECS, see COPYING.
 *   If not, see <http://www.gnu.org/licenses/>.
 */
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include "log.h"
#include "hsms_config.h"
#include "hsms_cnx.h"
#include "hsms_factory.h"

#define HSMS_FACTORY_LOG_LEVEL 5

using namespace freesecs;

void
hsms_factory_t::clear()
{
    active.clear    ();
    passive.clear   ();
    errors.clear    ();
}

int
hsms_factory_t::parse_config(const char *file_name)
{
    FILE                    *fp;
    char                    buf[512];
    int                     done, len, res = NO_ERR;
    hsms_config_parser_t    hp;

    if(0 >= (fp = fopen(file_name, "r")))
    {
        sprintf(buf, "Filename %s is invalid.\n", file_name);
        errors.push_back(buf);
        res = INVALID_FILENAME;
    }

    if(fp)
    {
        for(;;)
        {
            fgets(buf, sizeof(buf), fp);
            len = strlen(buf);
    
            if(ferror(fp))
            {
                sprintf(buf, "File %s read error.\n", file_name);
                errors.push_back(buf);
                res = PARSE_ERROR;
            }
    
            done = feof(fp);
            if (!hp.parse(buf, len, done))
            {
                sprintf(buf, "File %s parse error.\n", file_name);
                errors.push_back(buf);
                res = PARSE_ERROR;
            }
            if (done)
            {
                fclose(fp);
                break;
            }
        }
    }

    if(NO_ERR == res)
    {
        if(hp.active_configs.empty() 
            && hp.passive_configs.empty())
        {
            TRACE_ERROR("factory: no configs found");

            if(hp.errors.empty())
            {
                res = EMPTY_CONFIG;
            }
            else
            {
                res = PARSE_ERROR;
            }
        }
        else
        {
            std::vector<hsms_active_config_t>::iterator it_a;
            std::vector<hsms_passive_config_t>::iterator it_p;

            for(it_a = hp.active_configs.begin(); 
                    it_a != hp.active_configs.end();
                    ++it_a)
            {
                if(it_a->is_valid())
                {
                    hsms_active_params_t ap = {   it_a->name, it_a->ip,
                                                it_a->port, it_a->t5, 
                                                it_a->t6, it_a->t8, 
                                                it_a->linktest, it_a->session_id};
                    active.push_back(active_cnx_ptr_t(new hsms_active_cnx_t(ap)));
                    TRACE_DEBUG(HSMS_FACTORY_LOG_LEVEL, 
                                "factory: added %s to active", it_a->name.c_str());
                }
                else
                {
                    TRACE_DEBUG(HSMS_FACTORY_LOG_LEVEL,
                                "factory: %s is not valid", it_a->name.c_str());
                }
            }
            for(it_p = hp.passive_configs.begin(); 
                    it_p != hp.passive_configs.end();
                    ++it_p)
            {
                if(it_p->is_valid())
                {
                    hsms_passive_params_t pp = {  it_p->name, it_p->port, it_p->t6, 
                                                it_p->t7, it_p->t8, 
                                                it_p->linktest, it_p->session_id };
                    passive.push_back(passive_cnx_ptr_t(new hsms_passive_cnx_t(pp)));
                    TRACE_DEBUG(HSMS_FACTORY_LOG_LEVEL, 
                                "factory: added %s to passive", it_p->name.c_str());
                }
                else
                {
                    TRACE_DEBUG(HSMS_FACTORY_LOG_LEVEL,
                                "factory: %s is not valid", it_p->name.c_str());
                }
            }
        }
    }

    errors.insert(errors.end(), hp.errors.begin(), hp.errors.end());

    return res;
}

---