GDBMS_for_documentation/session_mode_commands.cpp

Go to the documentation of this file.

#include "maininclude.h"
#include "listi.h"
#include "settings.h"
#include "hash_table.h"
#include "tr_twin_ht.h"
#include "file_semaphore.h"
#include "some_functions.h"
#include "initial_mode_commands.h"
#include "session_mode_commands.h"
#include "transaction_mode_commands.h"
#include "transaction_mode_commands_types.h"
#include "transaction_mode_commands_nodes.h"
#include "transaction_mode_commands_edges.h"
#include "transaction_mode_commands_find.h"
using namespace std;
int session_mode_commands::CloseSession(int session_USCOREid, ns1__CloseSessionResponse& _param_11)
{
    hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "id");
  if(!buf){
    //nyama takava sesiya
    _param_11.retvalue=1;
    
    return 0;
  
  }
  
  file_semaphore ssem("admin/sessions/ssem");
  ssem.getResource();
  ses.DeleteRecord("id", buf);  
  ssem.freeResource();
  delete buf;
  _param_11.retvalue=0;
  return 0;
  
}
int session_mode_commands::CreateGraph(int session_USCOREid, std::string gr_USCOREname, std::string description, std::string uname, ns1__CreateGraphResponse& _param_8)
{
    hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_8.retvalue=3;
    
    return 0;
  
  }
  
  std::string usid=buf;
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_8.retvalue=1;
    delete buf;
    return 0;
  
  }
  delete buf;
  
  hash_table grp("graphs", "admin/graphs", "id;name;description;creator_id;t_created", "id;name", "id");
  buf=grp.FindRecord("name", gr_USCOREname.c_str(), "id");
  if(buf){
    //ve4e ima graf s tova ime
      _param_8.retvalue=3;
      delete buf;
      return 0;
      
  }
  file_semaphore sem("admin/graphs/ssem");
  char *buf2=conn.FindRecord("name", uname.c_str(), "id");
  if(!buf2){
      //nqma takyv potrebitel, za kojto da se syzdade grafa
      _param_8.retvalue=3;
      delete buf2;
      return 0;
  }
  sem.getResource();
  int br=grp.getMAXID()+1;
  buf=inttostr(br);
  std::string aaa;
  aaa=buf;
  aaa+=";";
  aaa+=gr_USCOREname;
  aaa+=";";
  aaa+=description;
  aaa+=";";
  aaa+=buf2; 
  aaa+=";";
  aaa+=current_moment();
  grp.AddRecord("id;name;description;creator_id;t_created", aaa.c_str());  
  sem.freeResource();
  std::string foname;
  foname=strcat("admin/", buf);
  foname+="/gr_main";
  //mkdir(foname.c_str(), S_IRWXU | S_IRWXG | S_IRWXO);
  hash_table grp1("gr_main", foname.c_str(), "id;node_maxid;edge_maxid;rights_word", "id;node_maxid", "id");
  string gr_types_dir;
  gr_types_dir=strcat("admin/", buf);
  gr_types_dir+="/gr_types";
  hash_table grt("gr_types", gr_types_dir.c_str(), "id;name;parsestr;composite;array;asize;aid;internal", "id;name", "id");
  string edgesdir;
  edgesdir=strcat("admin/", buf);
  edgesdir+="/edges";
  hash_table edg("edges", edgesdir.c_str(), "id;name;data;inodes;onodes;type_id;tr_id", "id;name;inodes;onodes;type_id;tr_id", "id");
  string nodesdir;
  nodesdir==strcat("admin/", buf);
  nodesdir+="/nodes";
  hash_table nod("nodes", nodesdir.c_str(), "id;name;data;iedges;oedges;type_id;tr_id", "id;name;iedges;oedges;type_id;tr_id", "id");
  _param_8.retvalue=0;
  delete buf2;
  return 0;
}
int session_mode_commands::CreateUser(int session_USCOREid, std::string uname, std::string gr_USCOREname, std::string passwd, ns1__CreateUserResponse& _param_6)
{
  hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_6.retvalue=3;
    
    return 0;
  
  }
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_6.retvalue=1;
    delete buf;
    return 0;
  
  }
  delete buf;
  //proverka, dali izob6to ima takava grupa
  
  hash_table gr("usergroups", "admin/usergroups" "id;name;admin", "id;name", "id");
  if(!(buf=gr.FindRecord("name", gr_USCOREname.c_str(), "id"))){
    //nqma takava grupa i ne moje da se syzdade user kym tazi grupa
    _param_6.retvalue=3;
   
    
    return 0;
  
  
  }
  std::string gr_id;
  
  gr_id=buf;
  delete buf;
  //proverka dali ima takyv user
  if(buf=conn.FindRecord("name", uname.c_str(), "id")){
    //ima takyv user i ne moje da syzdade drug takyv
    _param_6.retvalue=3;
    delete buf;
    return 0;
  }
  //nqma takyv user i moje da se syzdade
  std::string buf1;
  file_semaphore sem("admin/users/ssem");
  sem.getResource();
  int br=conn.getMAXID()+1;
  buf1=inttostr(br);
  buf1+=";";
  buf1+=uname;
  buf1+=";";
  buf1+=passwd;
  buf1+=";";
  buf1+=gr_id;
  conn.AddRecord("id;name;pass;gr_id", buf1.c_str());  
  sem.freeResource();
  _param_6.retvalue=0;
  return 0;
}
int session_mode_commands::CreateUserGroup(int session_USCOREid, std::string group_USCOREname, ns1__CreateUserGroupResponse& _param_3)
{
  hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
if(!buf){
  //nyama takava sesiya
  _param_3.retvalue=3;
  _param_3.u_USCOREgroup_USCOREid=0;
  return 0;
  
}
if(!settings::is_admin(strtoint(buf))){
  //ne e administrator i nqma pravo da pravi tova
  _param_3.retvalue=2;
  _param_3.u_USCOREgroup_USCOREid=0;
  delete buf;
  return 0;
  
}
delete buf;
//administrator e i moje da napravi grupa
hash_table gr("usergroups", "admin/usergroups" "id;name;admin", "id;name", "id");
if(buf=gr.FindRecord("name", group_USCOREname.c_str(), "id")){
  //ve4e ima takava grupa i ne moje da se syzdade nova
  _param_3.retvalue=1;
  _param_3.u_USCOREgroup_USCOREid=0;
  delete buf;
  return 0;
  
  
}
//moje da se dobavi grupa
file_semaphore sem("admin/usergroups/ssem");
sem.getResource();

int br=gr.getMAXID()+1;
char buf1[50];
std::string b;
b+=inttostr(br);
b+=";";
b+=group_USCOREname;
b+=";";
b+="false";
gr.AddRecord("id;name;admin", b.c_str());
sem.freeResource();
_param_3.retvalue=0;
_param_3.u_USCOREgroup_USCOREid=br;
return 0;

}
int session_mode_commands::DeleteGraph(int session_USCOREid, std::string gr_USCOREname, ns1__DeleteGraphResponse& _param_9)
{
    hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_9.retvalue=3;
    
    return 0;
  
  }
  
  std::string usid=buf;
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_9.retvalue=1;
    delete buf;
    return 0;
  
  }
  delete buf;
  
  hash_table grp("graphs", "admin/graphs", "id;name;description;creator_id;t_created", "id;name", "id");
  buf=grp.FindRecord("name", gr_USCOREname.c_str(), "id");
  if(!buf){
    //nyama takyv graf
    _param_9.retvalue=3;
    
    return 0;
    
  }
  char *buf1;
  hash_table trn("transactions", "admin/transactions", "id;user_id;graph_id;time_started", "id;user_id;graph_id", "id");
  buf1=trn.FindRecord("graph_id", buf, "id");
  if(buf1){
    //ima aktivna tranzakciya na grafa i ne moje da se iztrie, dokato ne se priklu4i
    _param_9.retvalue=3;
    delete buf1;
    delete buf;
    return 0;
    
  }
  //moje da se iztrie grafa
  
  //iztrivane na grafa ot glavnata tablica
  
  file_semaphore ssem("admin/graphs/ssem");
  ssem.getResource();
  grp.DeleteRecord("id", buf);  
  ssem.freeResource();
  //iztrivane na papkata na grafa
  std::string fullfoldername;
  fullfoldername=MAINFOLDER;
  fullfoldername+="/admin/";
  fullfoldername+=buf;
  string command;
  command="rm -r ";
  command += fullfoldername;
  
  system(command.c_str());
  _param_9.retvalue=0;
  
  delete buf;
  return 0;
  
  
}
int session_mode_commands::DeleteUser(int session_USCOREid, std::string uname, ns1__DeleteUserResponse& _param_7)
{
  hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_7.retvalue=3;
    
    return 0;
  
  }
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_7.retvalue=1;
    delete buf;
    return 0;
  
  }
  delete buf;
  //proverka dali ima takyv user
  if(!(buf=conn.FindRecord("name", uname.c_str(), "id"))){
    //nqma takyv user i ne moje da se iztrie
    _param_7.retvalue=3;
   
    return 0;
  }
  std::string uid_tobedeleted;
  uid_tobedeleted=buf;
  delete buf;
  file_semaphore sem("admin/sessions/ssem");
  file_semaphore sem1("admin/users/ssem");
  sem1.getResource();
  sem.getResource();
  if(buf=ses.FindRecord("user_id", uid_tobedeleted.c_str(), "id")){
    //ima nepriklu4ila sesiya
    sem.freeResource();
    sem1.freeResource();
    _param_7.retvalue=2;
    delete buf;
    
    return 0;
    
    
  }
  //moje da se iztrie
  
  
  conn.DeleteRecord("id", uid_tobedeleted.c_str());
  
  sem.freeResource();
  sem1.freeResource();
  _param_7.retvalue=0;
  return 0;
  
  
}
int session_mode_commands::DeleteUserGroup(int session_USCOREid, std::string group_USCOREname, ns1__DeleteUserGroupResponse& _param_4)
{
   hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_4.retvalue=3;
    
    return 0;
  
  }
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_4.retvalue=1;
    delete buf;
    return 0;
  
  }
  delete buf;
  //moje da se iztrie grupa
  hash_table gr("usergroups", "admin/usergroups" "id;name;admin", "id;name", "id");
  if(!(buf=gr.FindRecord("name", group_USCOREname.c_str(), "id"))){
    //nqma takava grupa i ne moje da se iztrie
    _param_4.retvalue=3;
   
    
    return 0;
  
  
  }
  //ima takava grupa
  std::string buf1;
  buf1=buf;
  delete buf;
  buf=conn.FindRecord("gr_id", buf1.c_str(), "id");
  
  if(buf){
    //ima pone 1 takyf potrebitel, kojto e ot grupata i ne moje da se iztrie
    _param_4.retvalue=2;
    delete buf;
    return 0;
  }
  //moje da se iztrie
  file_semaphore sem("admin/usergroups/ssem");
  
  sem.getResource();
  
  gr.DeleteRecord("id", buf1.c_str());
  
  sem.freeResource();
  _param_4.retvalue=0;
  return 0;
  
  
  
}
int session_mode_commands::GetTransactionId(int session_USCOREid, std::string graph_USCOREname, ns1__GetTransactionIdResponse& _param_12)
{
  hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_12.retvalue=3;
    _param_12.transaction_USCOREid=0;
    
    return 0;
  
  }
  hash_table trn("transactions", "admin/transactions", "id;user_id;graph_id;time_started", "id;user_id;graph_id", "id");
  char *buf2=0;
  buf2=trn.FindRecord("user_id", buf, "id");
  if(buf2){
    //ve4e ima tranzakciya na tozi user
    _param_12.retvalue=3;
    _param_12.transaction_USCOREid=strtoint(buf2);
    delete buf2;
    delete buf;
    return 0;
  }
  hash_table grp("graphs", "admin/graphs", "id;name;description;creator_id;t_created", "id;name", "id");
  char *buf4=grp.FindRecord("name", graph_USCOREname.c_str(), "id");
  if(!buf4)
  {
    //nqma takyv graf s tova ime
     _param_12.retvalue=3;
     _param_12.transaction_USCOREid=0;
     delete buf;
     return 0;
    
  }
  
  file_semaphore trsem("admin/transactions/ssem");
  trsem.getResource();
  string vals;
  int trid;
  trid=trn.getMAXID();
  char *buf3=0;
  buf3=inttostr(trid);
  vals+=buf3;
  vals+=";";
  vals+=buf;
  vals+=";";
  vals+=buf4;
  vals+=";";
  vals+=current_moment();
  trn.AddRecord("id;user_id;graph_id;time_started", vals.c_str());
  
  
  
  
  
  trsem.freeResource();
  string trfolder;
  
  trfolder+="admin/";
  trfolder+=buf4;
  trfolder+="/";
  trfolder+=buf3;
  string cmd;
  cmd="mkdir ";
  cmd+=MAINFOLDER;
  cmd+=trfolder;
  //system(cmd.c_str());
  string edgfolder;
  edgfolder+=trfolder;
  edgfolder+="/edges";
  cmd="mkdir ";
  cmd+=MAINFOLDER;
  cmd+=edgfolder;
  //system(cmd.c_str());
  string nodefolder;
  nodefolder=trfolder;
  nodefolder+="/nodes";
  cmd="mkdir ";
  cmd+=MAINFOLDER;
  cmd+=nodefolder;
  //system(cmd.c_str());
  
  string grfolder;
  grfolder+="admin/";
  grfolder+=buf4;
  string realedges_folder;
  realedges_folder+=grfolder;
  realedges_folder+="/edges";
  
  string realnodes_folder;
  realnodes_folder+=grfolder;
  realnodes_folder+="/nodes";
  
  
  hash_table real_edges("edges", realedges_folder.c_str(), "id;name;data;inodes;onodes;type_id;tr_id", "id;name;inodes;onodes;type_id;tr_id", "id");
  hash_table real_nodes("nodes", realnodes_folder.c_str(), "id;name;data;iedges;oedges;type_id;tr_id", "id;name;iedges;oedges;type_id;tr_id", "id");
  
  tr_twin_ht edgtwin("edges", edgfolder.c_str(), "id;name;data;inodes;onodes;type_id;tr_id", "id;name;inodes;onodes;type_id;tr_id", "id", strtoint(buf3), edgfolder.c_str(), &real_edges);
  tr_twin_ht nodtwin("nodes", nodefolder.c_str(), "id;name;data;iedges;oedges;type_id;tr_id", "id;name;iedges;oedges;type_id;tr_id", "id", strtoint(buf3), nodefolder.c_str(), &real_nodes);
  
  edgtwin.begin_transaction();
  nodtwin.begin_transaction();
  
  _param_12.retvalue=0;
  _param_12.transaction_USCOREid=strtoint(buf3);
  
  if(buf3)
    delete buf3;
  if(buf)
    delete buf;
  return 0;
  
}
int session_mode_commands::GrantRightsToGraph(int session_USCOREid, std::string gr_USCOREname, int rights_USCOREword, ns1__GrantRightsToGraphResponse& _param_10)
{
    hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_10.retvalue=3;
    
    return 0;
  
  }
  
  std::string usid=buf;
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_10.retvalue=1;
    
    delete buf;
    return 0;
  
  }
  delete buf;
  
  hash_table grp("graphs", "admin/graphs", "id;name;description;creator_id;t_created", "id;name", "id");
  buf=grp.FindRecord("name", gr_USCOREname.c_str(), "id");
  if(!buf){
    //nyama takyv graf
    _param_10.retvalue=3;
    
    return 0;
    
  }
  //moje da se dadat prava
  file_semaphore ssem("admin/graphs/ssem");
  ssem.getResource();
  string folname2;
  folname2+="admin/";
  folname2+=buf;
  hash_table grp1("gr_main", folname2.c_str(), "id;node_maxid;edge_maxid;rights_word", "id;node_maxid", "id");
  string updv;
  updv=inttostr(rights_USCOREword);
  
  grp1.UpdateRecord("id", "1", "rights_word", updv.c_str());
  
  
  ssem.freeResource();
  _param_10.retvalue=0;
  
  delete buf;
  return 0;
  
  
  
}
int session_mode_commands::GrantRightsToGroup(int session_USCOREid, std::string group_USCOREname, int rights, ns1__GrantRightsToGroupResponse& _param_5)
{
    hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
  char *buf=ses.FindRecord("id", inttostr(session_USCOREid), "user_id");
  if(!buf){
    //nyama takava sesiya
    _param_5.retvalue=3;
    
    return 0;
  
  }
  if(!settings::is_admin(strtoint(buf))){
    //ne e administrator i nqma pravo da pravi tova
    _param_5.retvalue=1;
    delete buf;
    return 0;
  
  }
  delete buf;
  //proverka, dali izob6to ima takava grupa
  hash_table gr("usergroups", "admin/usergroups" "id;name;admin", "id;name", "id");
  if(!(buf=gr.FindRecord("name", group_USCOREname.c_str(), "id"))){
    //nqma takava grupa i ne moje da se napravi administratorska
    _param_5.retvalue=3;
   
    
    return 0;
  
  
  }
  //ima takava grupa
  file_semaphore sem("admin/usergroups/ssem");
  std::string buf1;
  if(rights){
    buf1=inttostr(1);
  }else{
    buf1=inttostr(0);
    
  }
  sem.getResource();
  gr.UpdateRecord("id", buf, "admin", buf1.c_str());
  
  sem.freeResource();
  _param_5.retvalue=0;
  return 0;
  
}