#include "StoreFactory.h"

#include "GSException.h"

#define MAX_PROPS 10

namespace griddb {

StoreFactory::StoreFactory() : mFactory(NULL) {

}

StoreFactory::~StoreFactory() {

//allRelated = FALSE, since Gridstore object is managed by Store class

close(GS_FALSE);

}

/**

void StoreFactory::close(GSBool allRelated) {

}

StoreFactory* StoreFactory::get_instance() {

GSGridStoreFactory* pFactory = gsGetDefaultFactory();

StoreFactory* factory(new StoreFactory());

factory->set_factory(pFactory);

return factory;

}

/*

void StoreFactory::set_property_entry(GSPropertyEntry *prop, const char* name, const char* value) {

prop->name = name;

prop->value = value;

}

/*

bool StoreFactory::check_multicast(const char* address) {

}

/*

Store* StoreFactory::get_store(const char* host, int32_t port, const char* cluster_name,

const char* database, const char* user, const char* password,

const char* notification_member, const char* notification_provider) {

int index = 0;

GSPropertyEntry local_props[MAX_PROPS] = {0};

std::string lport = std::to_string((long long int)port);

if (check_multicast(host)) {

set_property_entry(&local_props[0], "notificationAddress", host);

set_property_entry(&local_props[1], "notificationPort", lport.c_str());

index = 2;

} else {

if (host) {

set_property_entry(&local_props[0], "host", host);

set_property_entry(&local_props[1], "port", lport.c_str());

index += 2;

}

if (notification_member) {

set_property_entry(&local_props[index], "notificationMember", notification_member);

index++;

}

if (notification_provider) {

set_property_entry(&local_props[index], "notificationProvider", notification_provider);

index++;

}

}

if (cluster_name) {

set_property_entry(&local_props[index], "clusterName", cluster_name);

index++;

}

if (database) {

set_property_entry(&local_props[index], "database", database);

index++;

}

if (user) {

set_property_entry(&local_props[index], "user", user);

index++;

}

if (password) {

set_property_entry(&local_props[index], "password", password);

index++;

}

GSGridStore *store;

GSResult ret = gsGetGridStore(mFactory, local_props, index, &store);

// Check ret, if error, throw exception

if (ret != GS_RESULT_OK) {

throw GSException(mFactory, ret);

}

return new Store(store);

}

/**

void StoreFactory::set_properties(const GSPropertyEntry* props,

}

/*

string StoreFactory::get_version() {

return CLIENT_VERSION;

}

void StoreFactory::set_factory(GSGridStoreFactory* factory) {

mFactory = factory;

}

}