/*
 * Copyright (c) 2019 TAOS Data, Inc. <jhtao@taosdata.com>
 *
 * This program is free software: you can use, redistribute, and/or modify
 * it under the terms of the GNU Affero General Public License, version 3
 * or later ("AGPL"), as published by the Free Software Foundation.
 *
 * This program 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.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */

#define _DEFAULT_SOURCE
#include "os.h"
#include "mgmtAcct.h"

static SAcctObj tsAcctObj;

int32_t   (*mgmtInitAcctsFp)() = NULL;
void      (*mgmtCleanUpAcctsFp)() = NULL;
SAcctObj *(*mgmtGetAcctFp)(char *acctName) = NULL;
int32_t   (*mgmtCheckUserLimitFp)(SAcctObj *pAcct) = NULL;
int32_t   (*mgmtCheckDbLimitFp)(SAcctObj *pAcct) = NULL;
int32_t   (*mgmtCheckTableLimitFp)(SAcctObj *pAcct, int32_t numOfTimeSeries) = NULL;

int32_t mgmtAddDbIntoAcct(SAcctObj *pAcct, SDbObj *pDb) {
  pthread_mutex_lock(&pAcct->mutex);
  pDb->next = pAcct->pHead;
  pDb->prev = NULL;

  if (pAcct->pHead) {
    pAcct->pHead->prev = pDb;
  }

  pAcct->pHead = pDb;
  pAcct->acctInfo.numOfDbs++;
  pthread_mutex_unlock(&pAcct->mutex);

  return 0;
}

int32_t mgmtRemoveDbFromAcct(SAcctObj *pAcct, SDbObj *pDb) {
  pthread_mutex_lock(&pAcct->mutex);
  if (pDb->prev) {
    pDb->prev->next = pDb->next;
  }

  if (pDb->next) {
    pDb->next->prev = pDb->prev;
  }

  if (pDb->prev == NULL) {
    pAcct->pHead = pDb->next;
  }

  pAcct->acctInfo.numOfDbs--;
  pthread_mutex_unlock(&pAcct->mutex);

  return 0;
}

int32_t mgmtAddUserIntoAcct(SAcctObj *pAcct, SUserObj *pUser) {
  pthread_mutex_lock(&pAcct->mutex);
  pUser->next = pAcct->pUser;
  pUser->prev = NULL;

  if (pAcct->pUser) {
    pAcct->pUser->prev = pUser;
  }

  pAcct->pUser = pUser;
  pAcct->acctInfo.numOfUsers++;
  pUser->pAcct = pAcct;
  pthread_mutex_unlock(&pAcct->mutex);

  return 0;
}

int32_t mgmtRemoveUserFromAcct(SAcctObj *pAcct, SUserObj *pUser) {
  pthread_mutex_lock(&pAcct->mutex);
  if (pUser->prev) {
    pUser->prev->next = pUser->next;
  }

  if (pUser->next) {
    pUser->next->prev = pUser->prev;
  }
  
  if (pUser->prev == NULL) {
    pAcct->pUser = pUser->next;
  }

  pAcct->acctInfo.numOfUsers--;
  pthread_mutex_unlock(&pAcct->mutex);

  return 0;
}

int32_t mgmtInitAccts() {
  if (mgmtInitAcctsFp) {
    return (*mgmtInitAcctsFp)();
  } else {
    tsAcctObj.acctId = 0;
    strcpy(tsAcctObj.user, "root");
    return 0;
  }
}

SAcctObj *mgmtGetAcct(char *acctName) {
  if (mgmtGetAcctFp) {
    return (*mgmtGetAcctFp)(acctName);
  } else {
    return &tsAcctObj;
  }
}

void mgmtCleanUpAccts() {
  if (mgmtCleanUpAcctsFp) {
    (*mgmtCleanUpAcctsFp)();
  }
}

int32_t mgmtCheckUserLimit(SAcctObj *pAcct) {
  if (mgmtCheckUserLimitFp) {
    return (*mgmtCheckUserLimitFp)(pAcct);
  }
  return 0;
}

int32_t mgmtCheckDbLimit(SAcctObj *pAcct) {
  if (mgmtCheckDbLimitFp) {
    return (*mgmtCheckDbLimitFp)(pAcct);
  } else {
    return 0;
  }
}

int32_t mgmtCheckTableLimit(SAcctObj *pAcct, int32_t numOfTimeSeries) {
  if (mgmtCheckTableLimitFp) {
    return (*mgmtCheckTableLimitFp)(pAcct, numOfTimeSeries);
  } else {
    return 0;
  }
}