UserSchemaMgr.h

Go to the documentation of this file.

/*
 * Copyright (c) 2013 Mark Travis <mtravis15432+src@gmail.com>
 * All rights reserved. No warranty, explicit or implicit, provided.
 *
 * This file is part of InfiniSQL(tm).
 
 * InfiniSQL is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License version 3
 * as published by the Free Software Foundation.
 *
 * InfiniSQL 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 InfiniSQL. If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef INFINISQLUSERSCHEMAMGR_H
#define INFINISQLUSERSCHEMAMGR_H

#include "gch.h"
#include "Table.h"
#include "TransactionAgent.h"

typedef struct
{
    std::string clearpassword;
    byte digest[64];
} passwordStruct;

typedef boost::unordered_map<std::string, int64_t> domainNameToDomainIdMap;
typedef boost::unordered_map<std::string, int64_t> userNameToUserIdMap;
typedef boost::unordered_map<int64_t, passwordStruct> userIdToPasswordMap;
typedef boost::unordered_map<int64_t, userNameToUserIdMap *>
    domainIdToUserNamesMap;
typedef boost::unordered_map<int64_t, userIdToPasswordMap *>
    domainIdToUserIdsMap;

// map of domainid->nextuserid
typedef boost::unordered_map<int64_t, int64_t> domainIdToNextUserIdMap;

class UserSchemaMgr
{
public:
    UserSchemaMgr(Topology::partitionAddress *myIdentityArg);
    virtual ~UserSchemaMgr();

    // pubic for replyTa:
    class Message *msgsnd;
    int64_t operationid;
    int64_t domainid;
    int64_t userid;
    int64_t status;
    int64_t tainstance;
    //public for createSchema:
    class Message *msgrcv;
    REUSEMESSAGES
        domainidToSchemaMap domainidsToSchemata;
    class Mboxes mboxes;
    Topology::partitionAddress myIdentity;

private:
    class Topology myTopology;
    int64_t getnextdomainid();
    int64_t getnextuserid(int64_t argdomainid);
    void operationHandler(class MessageUserSchema &msgrcvref);
    int64_t operationLogin(string &username, string &domainname,
                           string &password, int64_t *uid, int64_t *did);

    void login();
    void changepassword();
    void createdomain();
    void createuser();
    void deleteuser();
    void deletedomain();
    void createschema(builtincmds_e cmd);
    void createtable(builtincmds_e cmd);
    void addcolumn(builtincmds_e cmd);
    void deleteindex(builtincmds_e cmd);
    void deletetable(builtincmds_e cmd);
    void deleteschema(builtincmds_e cmd);

    //private:
    int64_t argsize;
    int64_t instance;
    class Mbox *mymboxPtr;
    domainNameToDomainIdMap domainNameToDomainId;
    domainNameToDomainIdMap::iterator domainNameToDomainIdIterator;
    domainIdToUserNamesMap domainIdToUserNames;
    domainIdToUserNamesMap::iterator domainIdToUserNamesIterator;
    domainIdToUserIdsMap domainIdToUserIds;
    domainIdToUserIdsMap::iterator domainIdToUserIdsIterator;
    domainIdToNextUserIdMap domainIdToNextUserId;
    domainIdToNextUserIdMap::iterator domainIdToNextUserIdIterator;
    userNameToUserIdMap *userNameToUserId;
    userNameToUserIdMap::iterator userNameToUserIdIterator;
    userIdToPasswordMap *userIdToPassword;
    userIdToPasswordMap::iterator userIdToPasswordIterator;
    passwordStruct pwdStruct;
    passwordStruct *pwdStructPtr;
    std::vector<std::string> *resultVector;
    int64_t nextdomainid;
    domainidToSchemaMap::iterator domainidsToSchemataIterator;
    boost::unordered_map <std::string, fieldtype_e> fieldTypeMap;
    boost::unordered_map <std::string, indextype_e> indexTypeMap;
};

void *userSchemaMgr(void *identity);

#endif  /* INFINISQLUSERSCHEMAMGR_H */