test2.cxx

Go to the documentation of this file.

//
// Copyright 2002, Lowell Boggs Jr.
//
// This file or directory, containing source code for a computer program,
// is Copyrighted by Lowell Boggs, Jr.  987 Regency Drive, Lewisville
// TX (USA), 75067.  You may use, copy, modify, and distribute this
// source file without charge or obligation so long as you agree to
// the following:
//
//  1.  You must indemnify Lowell Boggs against any and all financial
//      obligations caused by its use, misuse, function, or malfunction.
//      Further, you acknowledge that there is no warranty of any kind,
//      whatsoever.
//
//  2.  You agree not to attempt to patent any portion of this original
//      work -- though you may attempt to patent your own extensions to
//      it if you so choose.
//
//  3.  You keep this copyright notice with the file and all copies
//      of the file and do not change it anyway except language translation.
//
// You are responsible for enforcing your own compliance with these
// conditions and may not use this source file if you cannot agree to the
// above terms and conditions.
//
// Warning:  not all files in this directory structure are covered by the
// same copyright.  Some of them are part of the GNU source distribution
// and you must obey the GPL copyright for those files.

//@File
//


#include <stdio.h>
#include <stdlib.h>
#include <libspopc.h>
#include <cxxtls/file.h>
#include <cxxtls/options.h>
#include <errno.h>
#include <string.h>


using namespace std;
using namespace cxxtls;

int main(int argc, char **argv, char **environ)
{
  static char const* allowed_arguments =
    "-delete,"
  ;

  ProgramOptions::global_options_ = new ProgramOptions(allowed_arguments,
                                                       argc,
                                                       argv,
                                                       environ);

  ProgramOptions& options = *ProgramOptions::global_options_;

  if(options.argv.size() != 4)
  { 
     fprintf(stderr, "Error:  expect 4 parameters\n");
     fprintf(stderr, "        hostname\n");
     fprintf(stderr, "        username\n");
     fprintf(stderr, "        password\n");
     exit(1);
  }

  popsession *session;

  char const *error = popbegin(options.argv[1].c_str(),
                               options.argv[2].c_str(),
                               options.argv[3].c_str(),
                               &session
                              );

  if(error)
  {
    fprintf(stderr, "Error:  %s", error);
    exit(1);
  }

  if(options.option("-delete"))
    popsetdel(session);


  int message_count = popnum(session);

  printf("message count is %d\n", message_count);

  int i;

  // make sure the incoming directory exists

  FileName incoming_dir("incoming");
  incoming_dir.mkdir();

  for(i=0; i < message_count; ++i)
  {
    int message_number = i + 1;

    //
    //  Read the id of each message, use the id to construct a filename
    //  If the file does NOT exist, read the message body and write it
    //  to the file
    //

    char *msg_id = popmsguid(session, message_number);

    if(msg_id)
    {

       FileName message_file = incoming_dir + "/" + msg_id;

       if(!message_file.exists())
       {
         printf("reading new message %s\n", msg_id);

         FILE* f = fopen(message_file.c_str(), "wb");

         if(!f)
         {
           message_file.remove();

           fprintf(stderr, "Error:  can't create '%s'\n", 
                           message_file.c_str()
                  );
           exit(1);
         }

         char *body = popgetmsg(session, message_number);

         if(body)
         {
           if(1 != fwrite(body, strlen(body), 1, f) )
           {
             fclose(f);
             message_file.remove();
             
             fprintf(stderr, "Error:  can't writing to '%s'\n", 
                             message_file.c_str()
                    );
             exit(1);
           }

           fclose(f);
           free(body);

         }

       }
       else
       {
         printf("skipping old message %s\n", msg_id);

         if(options.option("-delete"))
         {
           // if we are deleting the messages, then read the body
           // just to trigger the delete mechanism.  It would be
           // nice if the popdelmsg function worked, but it is broken.

           free(popgetmsg(session, message_number));
         }

       }

    }

  }

  popend(session);

  exit(0);

}