openAdmin/adminSrvr.cpp

Go to the documentation of this file.

/*
  User and group administration daemon.

  Copyright 2002 David K. McCombs.
  
*/

#include "ocString.h"
#include "ocAdmin.h"
#include <sys/types.h>
#include <unistd.h>
#include "ocSockServer.h"
#include "ocFileSys.h"
#include <string>
#include <fstream>
#include <iomanip>

// #define DO_OPEN_LOGGING
#include "openLogger.h"

class uAdmin: public ocSockServer
{
  public:
  uAdmin( int port, int connections ):
  ocSockServer(port, connections ){ ; }
  private:
  
  bool readFile ( ocString filename, string & filter )
  {
    char linebuffer[1024];
    // unwarranted optimism
    bool bret = true;  
    writelog2("filename",filename);
    // check for a wildcard
    if ( filename.regExMatch("[*]") )
    {
      writelog2( "found wildcard: ", filename );
      filename = filename.remove("*");
      string::size_type idx = filename.find_last_of('/');
      if( idx != string::npos )
      {
        string path = filename.substr(0,idx);
        writelog2( "path: ", path );
        ocString pattern = filename.substr(idx);
        writelog2( "pattern: ", pattern );
        ocFileSys fs;
        if( fs.openDir( path ) )
        {
          ocDirectory & dir = fs.getDirectoryEntries();
          for( int i=0; i<dir.size(); ++i)
          {
            ocString test = "/";
            test += dir[i].name;
            if( test.regExMatch( pattern.c_str() ))
            {
              // recursion!
              string fullpath = path;
              fullpath += test;
              writelog2( "read: ", fullpath );
              readFile ( fullpath, filter );
            }
          }
        }        
      }             
    }
    else
    { 
      ifstream ifile;
      ifile.open(filename.c_str());

      while( ifile )
      {
        ifile.getline(linebuffer,sizeof(linebuffer));       
        ocString line = linebuffer;
        line += "\n";  
        if( filter.length() )
        {
          if( line.regExMatch(filter.c_str() ) )
          {
            Write(line.c_str(),line.length() );
            writelog2("wrote",line);
          }
        }
        else
        { // write it out always  
          Write(line.c_str(),line.length() );
          writelog2("wrote",line);
        }
      }
      writelog("end of file found");
      ifile.close();
    }
    return bret;
  }
  // implement pure virtual base method to make things work
  virtual void daemonAction( void )
  {
    ocAdmin admin( "/usr/bin/", "/usr/sbin/");
    ocString cmd = ReadLine();
    string response = "bad";
    string type = cmd.parse( "," );
    string user, passwd, dir, grp;
    // ofstream log( "/var/log/adminsvr.log", ios::app );
    // log << "Woke to do: [" << cmd.c_str() << "]" << endl;
    if( type == "au" ) // adduser
    {
      user = cmd.parse( "," );
      passwd = cmd.parse( "," );
      dir = cmd.parse( "," );
      grp = cmd.parse( "\n" );
      if( admin.addUser( user, passwd, dir, grp ) ) response = "good";
    }
    else if( type == "cp" ) // change password
    {
      user = cmd.parse( "," );
      passwd = cmd.parse( "\n" );
      // log << "User: " << user << " password: " << passwd << endl;
      if( admin.changePassword( user, passwd ) ) response = "good";
    }
    else if( type == "du" ) // delete user
    {
      user = cmd.parse( "\n" );
      if( admin.deleteUser( user ) ) response = "good";
    }
    else if( type == "ag" ) // add group
    {
      grp = cmd.parse( "\n" );
      if( admin.addGroup( grp ) ) response = "good";
    }
    else if( type == "dg" ) // delete group
    {
      grp = cmd.parse( "\n" );
      if( admin.deleteGroup( grp ) ) response = "good";
    }
    else if( type == "re" ) // re,file,filter
    {
      // get the file
      string file = cmd.parse( "," );
      // get the filter
      string filter = cmd.parse( "\n" );
      // read a file
      readFile( file, filter );
      response = "";    
    }
    response += "\n";
    Write(response.c_str(), response.length());
  }
};

int main( int argc, char ** argv )
{
  uAdmin u( 50001, 20 );
  u.daemonServe();
  return 0;
}

---