GDBMS_for_documentation/initial_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 initial_mode_commands::Connect(std::string user, std::string pass, ns1__ConnectResponse& _param_1)
{
 hash_table conn("users", "admin/users", 4, "id;name;pass;gr_id", "id;name;gr_id", "id");
 char *real_password;
 if(!(real_password=conn.FindRecord("name", user.c_str(), "pass"))){
   //nqma takyf potrebitel
   _param_1.retvalue=1;
   
   return 0;
   
   
 }
 if(strstr(real_password, pass.c_str())){
   //nqma syvpadenie s parolata
   _param_1.retvalue=2;
   return 0;
   
 }
 //vsi4ko e OK
 _param_1.retvalue=0; 
 delete real_password;
 char *buf=conn.FindRecord("name", user.c_str(), "id");
 _param_1.user_USCOREid=strtoint(buf);
 delete buf;
 return 0;
}
int initial_mode_commands::GetSessionId(int user_USCOREid, ns1__GetSessionIdResponse& _param_2)
{
  hash_table ses("sessions", "admin/sessions", "id;user_id;time_started", "id;user_id", "id");
  char *buf;
  if(buf=ses.FindRecord("user_id", inttostr(user_USCOREid), "id")){
    //ima sesiq na tozi potrebitel i ne moje da se syzdade
     _param_2.retvalue=1;
     delete buf;
      return 0;
    
    
    
  }
  //nqma sesiq na tozi potrebitel
  _param_2.retvalue=0;
  if(settings::is_admin(user_USCOREid)){
      _param_2.options=1;
     
      
   }else{
      _param_2.options=0;
      
   }
   file_semaphore sem("admin/sessions/ssem");
   buf=new char[200];
   char *buf1=new char[100];
   buf[0]=0;
   buf1[0]=0;
   
   
   sem.getResource();
   int id=ses.getMAXID()+1;
   buf=strcat(buf, inttostr(id));
   buf=strcat(buf, ";");
   buf=strcat(buf, inttostr(user_USCOREid));
   buf=strcat(buf, ";");
   buf=strcat(buf, current_moment());
   ses.AddRecord("id;user_id;time_started", buf);    
   sem.freeResource();
   _param_2.session_USCOREid=id;
    delete buf;
    delete buf1;
   return 0;
}
int initial_mode_commands::InitiateTransactionStop(std::string user, std::string pass, ns1__InitiateTransactionStopResponse& _param_30)
{
  ns1__ConnectResponse cr1;
  if(!initial_mode_commands::Connect(user, pass, cr1)){
    _param_30.user_USCOREid=cr1.user_USCOREid;
    if(settings::is_admin(cr1.user_USCOREid)){
      /*tuka se spirat vsi4ki tranzakcii*/
      file_semaphore ssem("admin/transactions/ssem");
      ssem.getResource();
      hash_table trn("transactions", "admin/transactions", "id;user_id;graph_id;time_started", "id;user_id;graph_id", "id");
      int ni=trn.getRealMaxId();
      int i;
      for(i=1; i<=ni; i++){
        char *i_str=inttostr(i);
        if(i_str){
          char *grphid=trn.FindRecord("id", i_str, "graph_id");
          if(grphid){
            
            string trfolder;
            trfolder+=MAINFOLDER;
            trfolder+=grphid;
            trfolder+="/";
            trfolder+=i_str;
            string cmd;
            cmd+="rm -r ";
            cmd+=trfolder;
            system(cmd.c_str());
            
            
            trn.DeleteRecord("id", i_str);
            
            delete grphid;
          }
          delete i_str;
        }
        
        ssem.freeResource();
      }
      
    }else{
      /*potrebitelqt ne e administrator*/
      _param_30.user_USCOREid=0;
      _param_30.retvalue=3;
      
    }
    
    
    
  }else{
    /*Neuspe6na vryzka s connect*/
    _param_30.user_USCOREid=0;
    _param_30.retvalue=2;
    
  }
  return 0;
}