CAMsg.cpp

Go to the documentation of this file.

/*
Copyright (c) 2000, The JAP-Team
All rights reserved.
Redistribution and use in source and binary forms, with or without modification,
are permitted provided that the following conditions are met:

  - Redistributions of source code must retain the above copyright notice,
    this list of conditions and the following disclaimer.

  - Redistributions in binary form must reproduce the above copyright notice,
    this list of conditions and the following disclaimer in the documentation and/or
    other materials provided with the distribution.

  - Neither the name of the University of Technology Dresden, Germany nor the names of its contributors
    may be used to endorse or promote products derived from this software without specific
    prior written permission.


THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS'' AND ANY EXPRESS
OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS
BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA,
OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE
*/
#include "StdAfx.h"
#include "CAMsg.hpp"
#include "CACmdLnOptions.hpp"
#include "CAASymCipher.hpp"
#include "CASymCipher.hpp"
#include "CAUtil.hpp"
#include "CABase64.hpp"
#include "CALibProxytest.hpp"

#define FILENAME_ENCRYPTEDLOG "/encrypted_messages"
#define FILENAME_INFOLOG "/messages"
#define FILENAME_INFOLOG_GZ "/messages.gz"

#define MAX_MSG_SIZE 8192

CAMsg* CAMsg::pMsg=NULL;

const char* const CAMsg::m_strMsgTypes[6]={", error   ] ",", critical] ",", info    ] ",", debug   ] ",", special ] ",", warning ] "}; //all same size!
#define STRMSGTYPES_SIZE 12


CAMsg::CAMsg()
    {
      m_pcsPrint=new CAMutex();
      m_logLevel = LOG_DEBUG;
      setZero64(m_maxLogFileSize);
      m_strMsgBuff=new char[MAX_MSG_SIZE+1+20+STRMSGTYPES_SIZE];
      m_uLogType=MSG_STDOUT;
      m_hFileInfo=-1;
      m_hFileEncrypted=-1;
      m_strLogFile=new char[1024];
      m_strMsgBuff[0]='[';
#ifdef COMPRESSED_LOGS
      m_gzFileInfo=NULL;
#endif
      m_pCipher=NULL;
      m_lastLogFileNumber = 0;
      m_alreadyOpened = false;
    }

CAMsg::~CAMsg()
    {
      closeLog();
#ifndef ONLY_LOCAL_PROXY
      closeEncryptedLog();
#endif
      delete[] m_strMsgBuff;
      m_strMsgBuff = NULL;
      delete[] m_strLogFile;
      m_strLogFile = NULL;
      delete m_pcsPrint;
      m_pcsPrint = NULL;
    }

char* CAMsg::createLogFileMessage(UINT32 opt)
{
  const char* strLogAtPath = " at path '%s'";
  char* strLogFile = NULL;
  
  
  if ((opt & MSG_FILE) == MSG_FILE || (opt & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
  {
    if (pMsg->m_strLogFile != NULL)
    {
      strLogFile = new char[strlen(strLogAtPath) + strlen(pMsg->m_strLogFile) + 1];
      sprintf(strLogFile, strLogAtPath, pMsg->m_strLogFile);
    }
  }
  if (strLogFile == NULL)
  {
    strLogFile = new char[1];
    strLogFile[0] = '\0';
  }
  return strLogFile;
}

char* CAMsg::createLogDirMessage(UINT32 opt)
{
  const char* strLogAtPath = " Please also check if the directory '%s' exists and create or change it if it does not.";
  char* strLogFile = NULL;


  if ((opt & MSG_FILE) == MSG_FILE || (opt & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
  {
    if (pMsg->m_strLogDir != NULL)
    {
      strLogFile = new char[strlen(strLogAtPath) + strlen(pMsg->m_strLogDir) + 1];
      sprintf(strLogFile, strLogAtPath, pMsg->m_strLogDir);
    }
  }
  if (strLogFile == NULL)
  {
    strLogFile = new char[1];
    strLogFile[0] = '\0';
  }
  return strLogFile;
}


SINT32 CAMsg::setLogLevel(UINT32 a_logLevel)
{
  if (a_logLevel == LOG_DEBUG ||
    a_logLevel == LOG_INFO ||
    a_logLevel == LOG_WARNING ||
    a_logLevel == LOG_ERR ||
    a_logLevel == LOG_CRIT)
  {
    pMsg->m_logLevel = a_logLevel;
    return E_SUCCESS;
  }
  return E_UNKNOWN;
}

SINT32 CAMsg::setLogOptions(UINT32 opt)
    {
      SINT32 ret; 
      const char* strLogOpened = "Message log opened%s%s.\n";
      const char* strLogErrorMsg = "Could not open message log%s%s!%s Do you have write permissions?%s\n";
      const char* strReasonMsg = " Reason: %s (%u)";
      char* strLogFile = NULL;
      char* strLogDir = NULL;
      char* strReason = NULL;
      char* strBuff;
      const char* strLogType = "";
  

      if(pMsg->m_uLogType==opt)
      {
          return E_SUCCESS;
      }


      if (opt == MSG_LOG)
      {
        strLogType = " as Syslog";
      }
      else if ((opt & MSG_LOG) == MSG_LOG)
      {
        strLogType = " as Syslog and";
      }

      if ((opt & MSG_FILE) == MSG_FILE)
      {
        strLogType = " as file";
      }
      else if ((opt & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
      {
        strLogType = " as compressed file";
      }
      
      

      if((ret = pMsg->openLog(opt))==E_SUCCESS)
      {
        strLogFile = pMsg->createLogFileMessage(opt);
        strBuff = new char[strlen(strLogOpened) + strlen(strLogType) + strlen(strLogFile) + 1];
        sprintf(strBuff, strLogOpened, strLogType, strLogFile);
        delete[] strLogFile;
        printMsg(LOG_DEBUG, strBuff);
        delete[] strBuff;

        pMsg->closeLog(); //closes the OLD Log!
        pMsg->m_uLogType=opt;

        
        return E_SUCCESS;
      }
      

      strLogFile = pMsg->createLogFileMessage(opt);
      
      strLogDir = pMsg->createLogDirMessage(opt);

      if (ret == E_FILE_OPEN)
      {
        strReason = new char[strlen(strReasonMsg) + strlen(GET_NET_ERROR_STR(GET_NET_ERROR)) + 5 + 1];
        sprintf(strReason, strReasonMsg, GET_NET_ERROR_STR(GET_NET_ERROR), GET_NET_ERROR);
      }
      else
      {
        strReason = new char[1];
        strReason[0] = '\0';
      }

      strBuff = new char[strlen(strLogErrorMsg) + strlen(strLogType) + strlen(strLogFile) + strlen(strReason) + strlen(strLogDir) + 1];
    
      sprintf(strBuff, strLogErrorMsg, strLogType, strLogFile, strReason, strLogDir);
      //snprintf(strBuff, strlen(strLogErrorMsg) + strlen(strLogFile) + strlen(strReason) + 1,  strLogErrorMsg, strLogFile, strReason);
      delete[] strLogFile;
      delete[] strReason;

      printMsg(LOG_CRIT, strBuff);

      delete[] strBuff;
      return ret;
    }

SINT32 CAMsg::printMsg(UINT32 type,const char* format,...)
  {
    if(pMsg != NULL)
    {
      pMsg->m_pcsPrint->lock();
      va_list ap;
      va_start(ap,format);
      SINT32 ret=E_SUCCESS;
      
      //Date is: yyyy/mm/dd-hh:mm:ss   -- the size is: 19
      time_t currtime=time(NULL);
      strftime(pMsg->m_strMsgBuff+1,255,"%Y/%m/%d-%H:%M:%S",localtime(&currtime));
      switch(type)
        {
          case LOG_DEBUG:
            if (pMsg->m_logLevel != LOG_DEBUG)
            {
              ret = E_UNKNOWN;
            }
            strcat(pMsg->m_strMsgBuff,pMsg->m_strMsgTypes[3]);
          break;
          case LOG_INFO:
            if (pMsg->m_logLevel == LOG_WARNING || pMsg->m_logLevel == LOG_ERR || pMsg->m_logLevel == LOG_CRIT)
            {
              ret = E_UNKNOWN;
            }
            strcat(pMsg->m_strMsgBuff,pMsg->m_strMsgTypes[2]);
          break;
          case LOG_CRIT:
            strcat(pMsg->m_strMsgBuff,pMsg->m_strMsgTypes[1]);
          break;
          case LOG_ERR:
            if (pMsg->m_logLevel == LOG_CRIT)
            {
              ret = E_UNKNOWN;
            }
            strcat(pMsg->m_strMsgBuff,pMsg->m_strMsgTypes[0]);
          break;
          case LOG_ENCRYPTED:
            strcat(pMsg->m_strMsgBuff,pMsg->m_strMsgTypes[4]);
          break;
          case LOG_WARNING:
            if (pMsg->m_logLevel == LOG_ERR || pMsg->m_logLevel == LOG_CRIT)
            {
              ret = E_UNKNOWN;
            }
            strcat(pMsg->m_strMsgBuff,pMsg->m_strMsgTypes[5]);
          break;
          default:
            va_end(ap);
            pMsg->m_pcsPrint->unlock();
            return E_UNKNOWN;
        }
  #ifdef HAVE_VSNPRINTF
      vsnprintf(pMsg->m_strMsgBuff+20+STRMSGTYPES_SIZE,MAX_MSG_SIZE,format,ap);
  #else
      trio_vsnprintf(pMsg->m_strMsgBuff+20+STRMSGTYPES_SIZE,MAX_MSG_SIZE,format,ap);
  #endif
      va_end(ap);
      if (ret != E_SUCCESS)
      {
        pMsg->m_pcsPrint->unlock();
        return ret;
      }
      if(type==LOG_ENCRYPTED)
      {
        ret=strlen(pMsg->m_strMsgBuff);
        if( pMsg->m_pCipher==NULL)
        {
          ret=E_UNKNOWN;
        }
        else
        {
          UINT8 bp[MAX_MSG_SIZE];
          AES_ofb128_encrypt((UINT8*)pMsg->m_strMsgBuff,
                              bp,ret,
                              &(pMsg->m_pCipher->oKey),
                              pMsg->m_pCipher->iv,
                              &(pMsg->m_pCipher->iv_off));
          if(write(pMsg->m_hFileEncrypted,bp,ret)!=ret)
            ret=E_UNKNOWN;
        }
      }
      else
        {
              if ((pMsg->m_uLogType & MSG_LOG) == MSG_LOG)
              {
  #ifndef _WIN32
            syslog(type,pMsg->m_strMsgBuff);
  #endif
              }
  #ifdef COMPRESSED_LOGS
              if ((pMsg->m_uLogType & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
              {
                if(pMsg->m_gzFileInfo!=NULL)
                {
                  if(gzwrite(pMsg->m_gzFileInfo,pMsg->m_strMsgBuff,strlen(pMsg->m_strMsgBuff))==-1)
                    ret=E_UNKNOWN;
                }
              }
  #endif
              else if ((pMsg->m_uLogType & MSG_FILE) == MSG_FILE)
              {
/*                if(pMsg->m_hFileInfo==-1)
                  {
                    pMsg->m_hFileInfo=open(pMsg->m_strLogFile,O_APPEND|O_CREAT|O_WRONLY|O_NONBLOCK|O_LARGEFILE|O_SYNC,S_IREAD|S_IWRITE);
                  }
*///                if(pMsg->m_hFileInfo!=-1)
//                  {
      #ifdef PSEUDO_LOG
                    char buff[255];
                    sprintf(buff,"%.15s mix AnonMix: ",ctime(&currtime)+4);
                    write(pMsg->m_hFileInfo,buff,strlen(buff));
      #endif
                    if(write(pMsg->m_hFileInfo,pMsg->m_strMsgBuff,strlen(pMsg->m_strMsgBuff))==-1)
                      ret=E_UNKNOWN;
                    pMsg->m_NrOfWrites++;
                    if( //(pMsg->m_NrOfWrites > 10000) &&
                      !isZero64(pMsg->m_maxLogFileSize) &&
                      isGreater64(filesize64(pMsg->m_hFileInfo), pMsg->m_maxLogFileSize))
                      {
                        pMsg->closeLog();
                        pMsg->openLog(pMsg->m_uLogType);
                      }
//                  }
              }
              if ((pMsg->m_uLogType & MSG_STDOUT) == MSG_STDOUT)
              {
                printf("%s",pMsg->m_strMsgBuff);
              }
        }
      pMsg->m_pcsPrint->unlock();
      return ret;
    }
    else
    {
      printf("Warning logger is not active!\n");
      return E_UNKNOWN;
    }
  }

SINT32 CAMsg::closeLog()
  {
        if ((pMsg->m_uLogType & MSG_LOG) == MSG_LOG)
        {
#ifndef _WIN32
          ::closelog();
#endif
        }
#ifdef COMPRESSED_LOGS
        if ((pMsg->m_uLogType & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
        {
          if(m_gzFileInfo!=NULL)
            gzclose(m_gzFileInfo);
          m_gzFileInfo=NULL;
        }
#endif
        else if ((pMsg->m_uLogType & MSG_FILE) == MSG_FILE)
        {
          if(m_hFileInfo!=-1)
            close(m_hFileInfo);
          m_hFileInfo=-1;
        }
    return E_SUCCESS;
  }

SINT32 CAMsg::rotateLog()
{
    if ((pMsg->m_uLogType & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
    {
      // TODO
    }
    else if ((pMsg->m_uLogType & MSG_FILE) == MSG_FILE)
    {

      char logFileSaveName[1026];
      memset(logFileSaveName, 0, 1026);
      //memcpy(logFileSave, m_strMsgBuff, 1024);
      snprintf(logFileSaveName, 1025, "%s%u", m_strLogFile, m_lastLogFileNumber);
      m_lastLogFileNumber = (m_lastLogFileNumber+1) % CALibProxytest::getOptions()->getMaxLogFiles();
      rename(m_strLogFile, logFileSaveName);
      /*if(m_hFileInfo!=-1)
        close(m_hFileInfo);
      m_hFileInfo=-1;*/
    }

  return E_SUCCESS;
}

SINT32 CAMsg::openLog(UINT32 type)
  {
        if ((type & MSG_LOG) == MSG_LOG)
        {
#ifndef _WIN32
      openlog("AnonMix",0,LOG_USER);
#endif
        }
#ifdef COMPRESSED_LOGS
        if ((type & MSG_COMPRESSED_FILE) == MSG_COMPRESSED_FILE)
        {
      char logdir[255];
      char buff[1024];
      if(CALibProxytest::getOptions()->getLogDir((UINT8*)logdir,255)!=E_SUCCESS)
        return E_UNKNOWN;
      strcpy(buff,logdir);
      strcat(buff,FILENAME_INFOLOG_GZ);
      tmpHandle=open(buff,O_APPEND|O_CREAT|O_WRONLY,S_IREAD|S_IWRITE);
      if (tmpHandle == -1)
      {
        return E_FILE_OPEN;
      }
      m_gzFileInfo=gzdopen(tmpHandle,"wb9");
      if(m_gzFileInfo==NULL)
      {
        SINT32 iError = GET_NET_ERROR;
        close(tmpHandle);
        SET_NET_ERROR(iError);
        return E_FILE_OPEN;
      }
      }
#endif
    else if ((type & MSG_FILE) == MSG_FILE)
        {
          if(CALibProxytest::getOptions()->getLogDir((UINT8*)m_strLogFile,1024)!=E_SUCCESS)
          {
            return E_UNKNOWN;
          }
          m_strLogDir = new char[strlen(m_strLogFile) + 1];
          strcpy(m_strLogDir, m_strLogFile);
          strcat(m_strLogFile,FILENAME_INFOLOG);
          if(CALibProxytest::getOptions()->getMaxLogFileSize()>0)
          {
            if(m_alreadyOpened)
            {
              rotateLog();
            }

            setMaxLogFileSize(CALibProxytest::getOptions()->getMaxLogFileSize());
            m_alreadyOpened = true;
          }
          m_NrOfWrites=0;
          m_hFileInfo=open(m_strLogFile,O_APPEND|O_CREAT|O_WRONLY|O_NONBLOCK|O_LARGEFILE,S_IREAD|S_IWRITE);
          if (m_hFileInfo == -1)
          {
            return E_FILE_OPEN;
          }
        }
    return E_SUCCESS;
  }

#ifndef ONLY_LOCAL_PROXY

  SINT32 CAMsg::openEncryptedLog()
  {
    CACertificate* pCert=CALibProxytest::getOptions()->getLogEncryptionKey();
    if(pCert==NULL)
      return E_UNKNOWN;
    CAASymCipher oRSA;
    SINT32 ret=oRSA.setPublicKey(pCert);
    delete pCert;
    pCert = NULL;
    if(ret!=E_SUCCESS)
      return E_UNKNOWN;
    UINT8 buff[1024];
    if(CALibProxytest::getOptions()->getEncryptedLogDir(buff,1024)!=E_SUCCESS)
      if(CALibProxytest::getOptions()->getLogDir(buff,1024)!=E_SUCCESS)
        return E_UNKNOWN;
    strcat((char*)buff,FILENAME_ENCRYPTEDLOG);
    pMsg->m_hFileEncrypted=open((char*)buff,O_APPEND|O_CREAT|O_WRONLY|O_LARGEFILE|O_BINARY,S_IREAD|S_IWRITE);
    if(pMsg->m_hFileEncrypted<=0)
      {
        pMsg->m_hFileEncrypted=-1;
        return E_UNKNOWN;
      }
    //create sym enc key and write it to the file (enc with pub enc key)
    write(pMsg->m_hFileEncrypted,"\n----Start of EncryptionKey----\n",32);
    UINT8 keyandiv[128];
    getRandom(keyandiv,128);
    keyandiv[0]&=0x7F;
    pMsg->m_pCipher=new t_LogEncCipher;
    AES_set_encrypt_key(keyandiv+50,128,&pMsg->m_pCipher->oKey);
    memcpy(pMsg->m_pCipher->iv,keyandiv+66,16);
    pMsg->m_pCipher->iv_off=0;
    UINT8 out[255];
    UINT32 outlen=255;
    oRSA.encrypt(keyandiv,keyandiv);
    CABase64::encode(keyandiv,128,out,&outlen);
    write(pMsg->m_hFileEncrypted,out,outlen);
    write(pMsg->m_hFileEncrypted,"-----End of EncryptionKey-----\n",31);
    return E_SUCCESS;
  }

SINT32 CAMsg::closeEncryptedLog()
  {
    if(pMsg->m_hFileEncrypted>=0)
      {
        close(pMsg->m_hFileEncrypted);
      }
    delete pMsg->m_pCipher;
    pMsg->m_pCipher=NULL;
    pMsg->m_hFileEncrypted=-1;
    return E_SUCCESS;
  }
#endif //ONLY_LOCAL_PROXY