Messaging and Directory Server software used around the world in the Government, Military, Aviation and Commercial sectors. Section Contents Main Page Modules File List File Members

Documentation Isode X.400 Client API     x400_msrcv.c /* Copyright (c) 2003-2007, Isode Limited, London, England. * All rights reserved. * * Acquisition and use of this software and related materials for any * purpose requires a written licence agreement from Isode Limited, * or a written licence from an organisation licenced by Isode Limited * to grant such a licence. * */ /* $RCSfile: x400_msrcv.c,v $ $Revision: 1.37 $ $Date: 2007/09/25 14:16:12 $ $State: Exp $ * * $Log: x400_msrcv.c,v $ * Revision 1.37 2007/09/25 14:16:12 paga * T070925E - #define out dl expansion history and security label code. * * Revision 1.36 2007/08/31 12:52:55 ir * T070831G - Fetch and display attachements as BodyParts. * Fetch and display forwarded messge after extracting from BodyPart. * Add functions get_body_parts(), get_bp(), get_msgbp(), do_xmsg_headers(), * do_xmsg_content_as_bp(), do_xrep_headers(), do_xmsg_headers(). * Add call to test X400msMsgCountRecip(). * Get the envelope recipients (in addition to the headers). * Add call to test X400msDLExpHistGet(). * * Revision 1.35 2007/08/29 15:35:48 paga * T070829J - Add in security label examples. * * Revision 1.34 2007/08/28 15:29:52 paga * T070828E - No longer delete the DL Expansion list structure explicity. * (It's now deleted when the message is deleted). * * Revision 1.33 2007/08/21 16:38:31 ldv * T070821K - Correct typo in Usage message, for the -7 flag * * Revision 1.32 2007/08/02 15:05:46 paga * T070801H - Add a "\n" to a message. * * Revision 1.31 2007/07/31 16:25:33 paga * T070730F - Add example DL history expansion code * * Revision 1.30 2007/07/24 12:45:36 dbw * T070724D - Fix warnings * * Revision 1.29 2007/07/11 11:02:39 kurt * T070615E - %* requires int * * Revision 1.28 2007/05/15 13:11:05 dbw * T070515D - Update/Add copyright * * Revision 1.27 2007/04/27 14:50:28 dbw * T070427F - Three possible connection types * * Revision 1.26 2006/09/11 09:43:26 ir * T060825A - Add switch which accepts defaults (as overridden on the command line) * stopping the prompts so that the programs can be run unattended. * * Revision 1.25 2006/07/28 09:05:16 ir * T060728A - Add -u switch to example progs to accept cmd line args without * prompting. * * Revision 1.24 2006/02/25 17:00:35 brs * T060224E - Change types to conform to function prototypes (between char* * and u_char*, and int* and size_t*, primarily). * * Revision 1.23 2005/11/25 11:50:40 ldv * T051125A - Correct the meaning of the -W flag in the usage message * * Revision 1.22 2005/11/17 10:38:37 ldv * T051110B - Remove double call to X400msClose(sp) (core dumps!) * * Revision 1.21 2005/11/03 11:55:03 tc * T051103A - Delete unnecessary Doxygen text. * * Revision 1.20 2005/10/12 10:42:58 ir * T051012A - Move otherwise unused variable into conditional compilation. * Include <stdlib.h> for exit() prototype. * * Revision 1.19 2005/10/10 07:57:12 ir * T051007C - Call get_args() to parse cmdline args. * * Revision 1.18 2005/09/23 12:30:15 ldv * T050922E - Set up logging from the file x400api.xml * * Revision 1.17 2005/09/08 14:05:48 tc * T050908C - Add example of setting of Wait interval. * Don't register auto-forwarding by default. * * Revision 1.16 2005/09/06 14:22:40 tc * T050906C - Add examples of how to set AutoForward and AutoAlert autoactions. * * Revision 1.15 2005/05/25 16:23:34 dbw * T050525C - Files updated in 2004 * * Revision 1.14 2004/07/09 09:20:25 ldv * T040708C - Handle Delivery Reports * * Revision 1.13 2004/06/30 09:31:15 ldv * T040625G - Improve the examples to use the new API functionality * * Revision 1.12 2004/06/29 09:07:49 tc * T040629A - Delete include of cmd_srch.h. * * Revision 1.11 2004/05/27 12:01:40 dbw * T040527A - user_name becomes user_addr and user_dn * Change in X400msOpen argument. * * Revision 1.10 2004/05/11 10:23:59 tc * T040511B - Print a warning message and delete message if report retrieved. * * Revision 1.9 2004/05/06 09:26:33 tc * T040505C - Replace use of X400Message with X400msMessage. * Call common 'do_tailoring' function to get data from x400tailor file. * Rearrange data input code. * Call common 'set_defaults' routine. * * Revision 1.8 2004/02/19 15:09:15 tc * T040219A - Update X400msOpen call to include user orname parameter. Add code * to read user orname from stdin. Improve output messages. Report * error codes returned from API functions. * * Revision 1.7 2003/10/20 09:14:49 tc-local * T031017B - Rename amhs->x400 throughout. * * Revision 1.6 2003/09/30 15:32:08 tc * T030930A - Correct call to exit(). * * Revision 1.5 2003/09/29 16:36:31 ir * T030929C - Tidy up use of return codes. * * Revision 1.4 2003/09/26 13:31:15 tc-local * T030925E - Add code to allow choice of P7 or P3 connection and option of specifying * presentation address. Do not exit if messages_waiting = 0. Call AMHSmsWait() * before trying to read a message. * * Revision 1.3 2003/09/11 11:01:15 ir * T030911A - Use AMHSMessage and AMHSRecipient over AMHS API. * * Revision 1.2 2003/09/10 15:59:16 tc-local * T030910C - Change AMHSmsRecipient to AMHSRecipient. Add call to AMHSmsClose(). * * Revision 1.1 2003/08/27 15:21:57 ir * T030819A - Initial checkin of AMHS module. * * * Simple example program for receiving a message from a store. */ #include <stdio.h> #include <stdlib.h> #include <x400_msapi.h> #include <seclabel_api.h> /* For security labels */ #include "example.h" static char *optstr = "u371m:d:p:w:M:D:P:W:"; static void usage(void); #ifdef WANT_DL_EXP_HIST static int do_dl_hist ( struct X400msMessage *mp ); #endif static int get_body_parts( struct X400msMessage *mp ); static int get_bp( struct X400msMessage *mp, struct X400Bodypart **bp, int att_num ); static int get_msgbp( struct X400msMessage *mp, struct X400Message **x400_mp, int att_num ); static int do_xmsg_headers( struct X400Message *x400_mp ); static int do_xmsg_content_as_bp( struct X400Message *x400_mp ); static int do_xrep_headers( struct X400Message *x400_mp ); static int do_xmsg_headers( struct X400Message *x400_mp ); static int do_xrep_content_as_bp( struct X400Message *x400_mp ); static int get_recips( struct X400Message *x400_mp, int type ); static int do_redirection_hist ( struct X400Recipient *rp ); static int do_redirection_hist_env ( struct X400msMessage *mp ); static int do_trace_info ( struct X400msMessage *mp ); static int do_internal_trace_info ( struct X400msMessage *mp ); static int do_orig_and_dl ( struct X400msMessage *mp ); int main( int argc, char **argv) { char buffer[BUFSIZ]; char pa[BUFSIZ]; char orn[BUFSIZ]; int status; int nummsg; int type; int seqn; struct X400msSession *sp; struct X400msMessage *mp; struct X400Recipient *rp; int n; size_t length; int contype; char *def_oraddr; char *def_dn; char *def_pa; int intparam; char recipient_str[BUFSIZ]; int num_recips = -1; if (get_args(argc, argv, optstr)) { usage(); exit(-1); } printf("Connection type (0 = P7, 1 = P3 submit only, 2 = P3 both directions) [%d]: ", x400_contype); contype = ic_fgetc(x400_contype, stdin); if (contype != 10) ic_fgetc(x400_contype, stdin); if ( contype < '0' || '2' < contype ) contype = x400_contype; else contype -= '0'; if (contype == 0) { def_oraddr = x400_ms_user_addr; def_dn = x400_ms_user_dn; def_pa = x400_ms_presentation_address; } else { def_oraddr = x400_mta_user_addr; def_dn = x400_mta_user_dn; def_pa = x400_mta_presentation_address; } printf("Your ORAddress [%s] > ", def_oraddr); ic_fgets(orn, sizeof orn, stdin); if (orn[strlen(orn) - 1] == '\n') orn[strlen(orn) - 1] = '\0'; if (orn[0] == '\0') strcpy(orn, def_oraddr); /* Prompt for password; note: reflected. */ printf("Password [%s]: ", contype == 0 ? x400_p7_password : x400_p3_password); if (ic_fgets(buffer, sizeof buffer, stdin) == NULL) exit(1); if (buffer[strlen(buffer) - 1] == '\n') buffer[strlen(buffer) - 1] = '\0'; if (buffer[0] == '\0') strcpy(buffer, contype == 0 ? x400_p7_password : x400_p3_password); printf("Presentation Address [%s] > ", def_pa); ic_fgets(pa, sizeof pa, stdin); if (pa[strlen(pa) - 1] == '\n') pa[strlen(pa) - 1] = '\0'; if (pa[0] == '\0') strcpy(pa, def_pa); if (talking_to_marben_ms) X400msSetConfigRequest(0); status = X400msOpen(contype, orn, def_dn, buffer, pa, &nummsg, &sp); if (status != X400_E_NOERROR) { fprintf(stderr, "Error in Open: %s\n", X400msError(status)); exit(status); } if (talking_to_marben_ms) X400msSetIntDefault(sp, X400_N_STRICT_P7_1988, 1); #ifdef USING_ALERTS /* If we register the alert auto-action, we will get an alert indication when a message is delivered. So there is no need to poll at short intervals within X400ms_Wait - we can do a slow background poll and rely on the Alert indication to wake the code up instead */ X400msSetIntDefault(sp, X400_N_WAIT_INTERVAL, 1000); #endif /* setup logging from $(ETCDIR)x400api.xml or $(SHAREDIR)x400api.xml */ X400msSetStrDefault(sp, X400_S_LOG_CONFIGURATION_FILE, "x400api.xml", 0); if (contype == 0) { #ifdef WANT_AUTOFORWARDING struct X400msAutoActionParameter *aa_param; /* Register an Autoforwarding Autoaction. */ aa_param = X400msNewAutoActionParameter(); /* Add mandatory things to AutoAction parameter for auto-forwarding: i.e. recipient address */ X400RecipNew(0, &rp); X400RecipAddStrParam(rp, X400_S_OR_ADDRESS, def_oraddr, strlen(def_oraddr)); X400msAutoActionParameterAddRecip(aa_param, X400_RECIP_STANDARD, rp); X400msAutoActionParameterAddStrParam(aa_param, X400_S_CONTENT_IDENTIFIER, "AF contentid", -1); X400msAutoActionParameterAddIntParam(aa_param, X400_N_DISCLOSURE, 1); X400msAutoActionParameterAddIntParam(aa_param, X400_N_IMPLICIT_CONVERSION_PROHIBITED, 1); X400msAutoActionParameterAddIntParam(aa_param, X400_N_ALTERNATE_RECIPIENT_ALLOWED, 1); X400msAutoActionParameterAddIntParam(aa_param, X400_N_CONTENT_RETURN_REQUEST, 1); X400msAutoActionParameterAddIntParam(aa_param, X400_N_PRIORITY, 2); X400msAutoActionParameterAddStrParam(aa_param, X400_S_AUTO_FORWARDING_COMMENT, "This message was autoforwarded", -1); X400msAutoActionParameterAddStrParam(aa_param, X400_S_COVER_NOTE, "This is a cover note", -1); X400msAutoActionParameterAddStrParam(aa_param, X400_S_THIS_IPM_PREFIX, "AutoForwarded:", -1); status = X400msRegisterAutoAction(sp, X400_AUTO_FORWARDING, 4, aa_param); if (status != X400_E_NOERROR) { fprintf(stderr, "Error in RegisterAutoAction: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Registered AutoForwarding autoaction (id = 4) OK\n"); X400msFreeAutoActionParameter(aa_param); #endif #ifdef USING_ALERTS /* No parameter needed for Alert autoaction - we do not support configuration of requested-attributes in this API yet. */ status = X400msRegisterAutoAction(sp, X400_AUTO_ALERT, 9, NULL); if (status != X400_E_NOERROR) { fprintf(stderr, "Error in RegisterAutoAction: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Registered AutoAlert autoaction (id = 9) OK\n"); #endif /* Just test the register and deregister functions */ status = X400msRegisterAutoAction(sp, X400_AUTO_ALERT, 10, NULL); if (status != X400_E_NOERROR) { fprintf(stderr, "Error in RegisterAutoAction: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Registered AutoAlert autoaction (id = 10) OK\n"); /* Lets do a deregistration of the action we just registered */ status = X400msDeregisterAutoAction(sp, X400_AUTO_ALERT, 10); if (status != X400_E_NOERROR) { fprintf(stderr, "Error in DeregisterAutoAction: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Deregistered AutoAlert autoaction (id = 10) OK\n"); } if (nummsg == 0) { printf ("no messages - waiting 60 seconds for a message to be delivered.....\n"); } else { printf("%d messages waiting\n", nummsg); } status = X400msWait(sp, 1, &nummsg); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from Wait: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } if (x400_default_recipient != NULL) printf("Getting message\n"); status = X400msMsgGet(sp, 0, &mp, &type, &seqn); switch (status) { case X400_E_NOERROR: fprintf(stderr, "MsgGet successfully got message\n"); break; default : fprintf(stderr, "Error from MsgGet: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); break; } if (type != X400_MSG_MESSAGE) { fprintf(stderr, "Got a report (printing only some attributes)\n"); /* The ORADDRESS in the message is the (envelope) originator */ status = X400msMsgGetStrParam(mp, X400_S_SUBJECT_IDENTIFIER, buffer, sizeof buffer, &length); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from MsgGetStrParam: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Subject Identifier: %.*s\n", (int)length, buffer); /* Get hold of the Originator and DL history*/ status = do_orig_and_dl (mp); if (status != X400_E_NOERROR && status != X400_E_MISSING_ATTR) { fprintf(stderr,"Failed to fetch originator and dl history: %s\n", X400msError (status)); } /* Get the primary recipients */ for (n = 1;; n++) { status = X400msRecipGet(mp, X400_RECIP_REPORT, n, &rp); if (status == X400_E_NO_RECIP) break; if (status != X400_E_NOERROR) { fprintf(stderr, "Error from RecipGet: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } /* Note: recipient may not actually have an O/R address */ status = X400msRecipGetStrParam(rp, X400_S_OR_ADDRESS, recipient_str, sizeof recipient_str, &length); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from RecipGetStrParam: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } /* The original message delivery time, if this attribute exists, * then the report is a positive Delivery Report */ status = X400msRecipGetStrParam(rp, X400_S_MESSAGE_DELIVERY_TIME, buffer, sizeof buffer, &length); if (status == X400_E_NOERROR) { /* Positive Delivery Report */ printf("Positive Delivery Report for recipient %d: %s\n", n, recipient_str); printf("Delivery Time: %.*s\n", (int)length, buffer); } else { /* Negative Delivery Report */ printf("Negative Delivery Report for recipient %d: %s\n", n, recipient_str); /* Supplementary Info to the report */ status = X400msRecipGetStrParam(rp, X400_S_SUPPLEMENTARY_INFO, buffer, sizeof buffer, &length); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from RecipGetStrParam: %s\n", X400msError(status)); buffer[0] = '\0'; } printf("Supplementary Info: %.*s\n", (int)length, buffer); /* The reason why the message was not delivered */ status = X400msRecipGetIntParam(rp, X400_N_NON_DELIVERY_REASON, &intparam); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from MsgGetIntParam: %s\n", X400msError(status)); } printf("Non-Delivery Reason: %d\n", intparam); /* The diagnostics of the report for this recipient */ status = X400msRecipGetIntParam(rp, X400_N_NON_DELIVERY_DIAGNOSTIC, &intparam); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from MsgGetIntParam: %s\n", X400msError(status)); } printf("Non-Delivery Diagnostic: %d\n", intparam); } } status = X400msMsgDelete(mp, 0); status = X400msClose(sp); exit(status); } /* The message identifier */ status = X400msMsgGetStrParam(mp, X400_S_MESSAGE_IDENTIFIER, buffer, sizeof buffer, &length); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from MsgGetStrParam: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Message Identifier: %.*s\n", (int)length, buffer); /* The ORADDRESS in the message is the (envelope) originator */ status = X400msMsgGetStrParam(mp, X400_S_OR_ADDRESS, buffer, sizeof buffer, &length); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from MsgGetStrParam: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("Originator: %.*s\n", (int)length, buffer); status = X400msMsgCountRecip(mp, X400_RECIP_PRIMARY, &num_recips); if (status != X400_E_NOERROR) { fprintf(stderr, "Error from MsgCountRecip: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } printf("There are %d recipients\n", num_recips); /* Get the envelope recipients */ for (n = 1;; n++) { status = X400msRecipGet(mp, X400_RECIP_ENVELOPE, n, &rp); if (status == X400_E_NO_RECIP) break; if (status != X400_E_NOERROR) { fprintf(stderr, "Error from RecipGet: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } /* Note: recipient may not actually have an O/R address */ status = X400msRecipGetStrParam(rp, X400_S_OR_ADDRESS, buffer, sizeof buffer, &length); if (status == X400_E_NOERROR) { printf("Envelope Recipient %d: %.*s\n", n, (int)length, buffer); } } /* Get the primary recipients */ for (n = 1;; n++) { status = X400msRecipGet(mp, X400_RECIP_PRIMARY, n, &rp); if (status == X400_E_NO_RECIP) break; if (status != X400_E_NOERROR) { fprintf(stderr, "Error from RecipGet: %s\n", X400msError(status)); /* tidily close the session */ status = X400msClose(sp); exit(status); } /* Note: recipient may not actually have an O/R address */ status = X400msRecipGetStrParam(rp, X400_S_OR_ADDRESS, buffer, sizeof buffer, &length); if (status == X400_E_NOERROR) { printf("Primary Recipient %d: %.*s\n", n, (int)length, buffer); } } #ifdef WANT_DL_EXP_HIST /* DL Expansion history */ { status = do_dl_hist(hist); /* Normally the status is "X400_E_NO_VALUE" If there is no * DL Expansion history. * Or X400_E_MISSING_ATTR if the DL Expansion history entry is missing * (so end of loop) */ if ( status == X400_E_NO_VALUE) { /* do nothing */ } else if (status == X400_E_MISSING_ATTR ) { printf("There is no DL expansion history\n"); } else { /* There has been an error fetching the DL expansion history*/ printf("error getting DL Expansion History\n"); fprintf (stderr, "Error in X400mtDLExpHistGet: %s\n", X400msError (status)); return status; } } #endif #define WANT_TRACE_INFO 1 #ifdef WANT_TRACE_INFO { status = do_trace_info(mp); if ( status == X400_E_NO_VALUE) { } else if (status == X400_E_MISSING_ATTR ) { printf("There is no Trace Info\n"); } else { printf("error getting Trace Info\n"); fprintf (stderr, "Error fetching trace info: %s\n", X400msError (status)); return status; } } #endif #define USE_INTERNAL_TRACE_INFO 1 #ifdef USE_INTERNAL_TRACE_INFO { status = do_internal_trace_info(mp); if ( status == X400_E_NO_VALUE) { /* do nothing */ } else if (status == X400_E_MISSING_ATTR ) { printf("There is no internal Trace Info\n"); } else { printf("error getting int Trace Info\n"); fprintf (stderr, "Error fetching int trace info: %s\n", X400msError (status)); return status; } } #endif #define USE_REDIRECTION_HISTORY 1 #ifdef USE_REDIRECTION_HISTORY { status = do_redirection_hist_env(mp); if ( status == X400_E_NO_VALUE ) { /* do nothing */ } else if (status == X400_E_MISSING_ATTR ) { printf("There is no Redirection History\n"); } else { printf("error getting Redirection History\n"); fprintf (stderr, "Error fetching Redirection History: %s\n", X400msError (status)); return status; } } #endif /* Security Label */ #ifdef USE_SEC_LABEL #define XML_BUFSIZE 1024 { char xml_buffer[XML_BUFSIZE]; unsigned char slab_buffer[XML_BUFSIZE]; status = X400msMsgGetStrParam(mp, X400_S_SECURITY_LABEL, (char*)slab_buffer, XML_BUFSIZE, &length); if (status == X400_E_NO_VALUE) { printf("No security label\n"); } else if (status != X400_E_NOERROR) { fprintf(stderr,"Failed to fetch security label: %d",status); exit(1); } else { int sec_status = 0; sec_status = SecLabelInit("Example program"); if (status != SECLABEL_E_NOERROR) { fprintf(stderr, "SecLabelInit returned error %d\n", status); exit(1); } status = SecLabelPrint(slab_buffer, length, xml_buffer, XML_BUFSIZE); if (status != SECLABEL_E_NOERROR) { fprintf(stderr, "SecLabelParse returned error %d\n", status); exit(1); } /* You could now write out the XML file, or parse it in memory..*/ printf("Got security label:%s\n",xml_buffer); } } #endif /* Subject is optional */ status = X400msMsgGetStrParam(mp, X400_S_SUBJECT, buffer, sizeof buffer, &length); if (status == X400_E_NOERROR) printf("Subject: %.*s\n", (int)length, buffer); /* And message text (or it could be another type) */ status = X400msMsgGetStrParam(mp, X400_T_IA5TEXT, buffer, sizeof buffer, &length); if (status == X400_E_NOERROR) printf("Text:\n%.*s\n", (int)length, buffer); /* get all the attachments */ status = get_body_parts(mp); /* Deletes message in message store as well as internal copy */ status = X400msMsgDelete(mp, 0); status = X400msClose(sp); return(status); } #ifdef WANT_DL_EXP_HIST static int do_dl_hist ( struct X400msMessage *mp ) { char DLORAddress[BUFSIZ]; char DLORDN[BUFSIZ]; char DLExpTime[BUFSIZ]; size_t length; int n; int status; struct X400DLExpHist *hist = NULL; /* Loop through the entries, pulling out the OR Address, DN, and expansion * time for each entry. * Stop looping when there is no n entry */ for ( n=1; ;n++ ) { status = X400msDLExpHistGet (mp,n,&hist); if (status != X400_E_NOERROR) { return status; } status = X400DLGetStrParam (hist, X400_S_OR_ADDRESS, DLORAddress, BUFSIZ , &length); if (status == X400_E_NO_VALUE) { return X400_E_NO_VALUE; } if ( status == X400_E_NOERROR ) { DLORAddress[length] = '\0'; printf ("DLExpansion List entry %d OR Address:%s\n", n,DLORAddress); } else { fprintf (stderr, "Error in :X400mtDLGetStrParam OR %s\n", X400msError (status)); } status = X400DLGetStrParam (hist, X400_S_DIRECTORY_NAME, DLORDN, BUFSIZ , &length); if ( status == X400_E_NOERROR ) { DLORDN[length] = '\0'; printf ("DLExpansion List entry %d DN :%s\n",n,DLORDN); } else { fprintf (stderr, "Error in :X400mtDLGetStrParam DN %s\n", X400msError (status)); } status = X400DLGetStrParam (hist, X400_S_DLEXP_TIME, DLExpTime, BUFSIZ , &length); if ( status == X400_E_NOERROR ) { DLExpTime[length] = '\0'; printf ("DLExpansion List entry %d Time :%s\n",n,DLExpTime); } else { fprintf (stderr, "Error in :X400mtDLGetStrParam Time %s\n", X400msError (status)); } } if (n == 1) { printf("No DLEH found in message"); } else { printf("%d DLEH entries found in message", n - 1); } return X400_E_NOERROR; } #endif static int get_body_parts( struct X400msMessage *mp ) { #define INIT_BUFFER_SIZE 10000 int status; int num_atts = 0; int type; char *buf; size_t buflen; size_t ret_len; int i; size_t j; struct X400Message *x400_mp; struct X400Bodypart *bp; status = X400msMsgGetIntParam (mp, X400_N_NUM_ATTACHMENTS, &num_atts); if ( status != X400_E_NOERROR ) { fprintf (stderr, "Error in X400msMsgGetIntParam attachments %s\n", X400msError (status)); return status; } printf ("Number of attachments is %d\n", num_atts); buf = (char *) malloc(INIT_BUFFER_SIZE); if (buf == NULL) { fprintf(stderr, "can't alloc %d bytes\n", INIT_BUFFER_SIZE); return X400_E_NOMEMORY; } buflen = INIT_BUFFER_SIZE; for (i = 1; i <= num_atts ; i++) { printf ("Get attachment %d\n", i); status = X400msMsgGetAttachment(mp, i, &type, buf, buflen, &ret_len); if (status == X400_E_NOSPACE) { fprintf(stderr, "realloc %d bytes\n", ret_len); buf = (char *) realloc(buf, ret_len + 1); if (buf == NULL) { fprintf(stderr, "can't alloc %d bytes\n", INIT_BUFFER_SIZE); return X400_E_NOMEMORY; } buflen = ret_len; status = X400msMsgGetAttachment( mp, i, &type, buf, buflen, &ret_len); /* fall through with status set */ } /* for some attachments you must use the BodyPart functions */ if (status == X400_E_COMPLEX_BODY) { printf("got complex bodypart\n"); status = get_bp(mp, &bp, i); if (status != X400_E_NOERROR ) { return status; } } /* for forwarded messages you must use the BodyPart functions */ else if (status == X400_E_MESSAGE_BODY) { printf("got forwarded message bodypart\n"); status = get_msgbp(mp, &x400_mp, i); if (status != X400_E_NOERROR ) { return status; } } else if (status == X400_E_NOERROR) { /* process text or binary attachment */ printf("got text or binary attachment\n"); switch (type) { case X400_T_BINARY: case X400_T_FTBP: printf("First 1000 bytes of Binary Data for %s BP is:", type == X400_T_BINARY ? "Binary" : "FTBP"); for (j = 0; j < ret_len && j < 1000; j++) printf("%x ", buf[j]); printf("\n"); break; default: printf("Printable Data for BP is:\n %s", buf); break; } } else { /* got an error */ fprintf (stderr, "Error in X400msMsgGetAttachment %s\n", X400msError (status)); break; } } return status; } static int get_bp( struct X400msMessage *mp, struct X400Bodypart **bpp, int att_num ) { int status; int type; int bp_type; size_t j; char *buf; size_t buflen; size_t ret_len; #define INIT_BUFFER_SIZE 10000 printf ("Get Bodypart %d\n", att_num); /* firstly get the Bodypart */ status = X400msMsgGetBodypart(mp, att_num, &type, bpp); if (status != X400_E_NOERROR) { fprintf(stderr, "X400msMsgGetBodypart %d failed %s\n", att_num, X400msError (status)); return status; } printf("got Bodypart %d, type = %d\n", att_num, type); /* What kind of Bodypart using a attribute of the BP */ status = X400BodypartGetIntParam(*bpp, X400_N_BODY_TYPE, &bp_type); if (status != X400_E_NOERROR) { fprintf(stderr, "X400msMsgGetBodypart failed %s\n", X400msError (status)); return status; } printf("got Bodypart %d, type = %s\n", att_num, bp_type == X400_T_IA5TEXT ? "IA5" : bp_type == X400_T_ISO8859_1 ? "ISO8859-1" : bp_type == X400_T_ISO8859_2 ? "ISO8859_2" : bp_type == X400_T_BINARY ? "Binary" : bp_type == X400_T_MESSAGE ? "Message" : bp_type == X400_T_FTBP ? "File Transfer BP" : bp_type == X400_T_GENERAL_TEXT ? "General Text" : "Unknown" ); /* setup buffer to use to return BP data */ buf = (char *) malloc(INIT_BUFFER_SIZE); if (buf == NULL) { fprintf(stderr, "can't alloc %d bytes\n", INIT_BUFFER_SIZE); return X400_E_NOMEMORY; } buflen = INIT_BUFFER_SIZE; /* Read data from the Bodypart */ status = X400BodypartGetStrParam(*bpp, X400_S_BODY_DATA, buf, buflen, &ret_len); if (status == X400_E_NOSPACE) { fprintf(stderr, "realloc %d bytes\n", ret_len); buf = (char *) realloc(buf, ret_len + 1); if (buf == NULL) { fprintf(stderr, "can't alloc %d bytes\n", INIT_BUFFER_SIZE); return X400_E_NOMEMORY; } buflen = ret_len; status = X400BodypartGetStrParam(*bpp, X400_S_BODY_DATA, buf, buflen, &ret_len); /* fall through with status set */ } if (status != X400_E_NOERROR) { fprintf(stderr, "X400msMsgGetBodypart failed %s\n", X400msError (status)); return status; } printf("got %d bytes of Bodypart data\n", ret_len); switch (bp_type) { case X400_T_BINARY: case X400_T_FTBP: printf("First 1000 bytes of Binary Data for %s BP is:", type == X400_T_BINARY ? "Binary" : "FTBP"); for (j = 0; j < ret_len && j < 1000; j++) printf("%x ", buf[j]); printf("\n"); break; default: printf("Printable Data for BP is:\n %s", buf); break; } return X400_E_NOERROR; } /* * Extract and return a Bodypart from an MS Message */ static int get_msgbp( struct X400msMessage *mp, struct X400Message **x400_mpp, int bp_num ) { struct X400Message *x400_mp; int status; char buf[INIT_BUFFER_SIZE]; int buflen = sizeof buf; size_t ret_len; status = X400msMsgGetMessageBody(mp, bp_num, x400_mpp); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetMessageBody (%d) failed %s\n", bp_num, X400msError (status)); return status; } printf("Got Message BP from BP %d\n", bp_num); x400_mp = *x400_mpp; status = X400MsgGetStrParam(x400_mp, X400_S_OBJECTTYPE, buf, buflen, &ret_len); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetStrParam (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); return status; } printf("Message BP from BP is '%.*s'\n", ret_len, buf); if (strncmp(buf, "message", ret_len) == 0 ) { status = do_xmsg_headers(x400_mp); if (status != X400_E_NOERROR) return status; status = do_xmsg_content_as_bp(x400_mp); if (status != X400_E_NOERROR) return status; } else if (strncmp(buf, "report", ret_len) == 0 ) { status = do_xrep_headers(x400_mp); if (status != X400_E_NOERROR) return status; status = do_xrep_content_as_bp(x400_mp); if (status != X400_E_NOERROR) return status; } else if (strncmp(buf, "probe", ret_len) == 0 ) { status = do_xmsg_headers(x400_mp); if (status != X400_E_NOERROR) return status; } else { fprintf(stderr, "got unknown object: %s\n", buf); return X400_E_BADPARAM; } return X400_E_NOERROR; } static int do_xmsg_headers( struct X400Message *x400_mp ) { int status; char buf[INIT_BUFFER_SIZE]; int buflen = sizeof buf; size_t ret_len; int num_atts; printf("do_xmsg_headers\n"); status = X400MsgGetStrParam(x400_mp, X400_S_IPM_IDENTIFIER, buf, buflen, &ret_len); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetStrParam (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); return status; } printf("IPM Identifier from Message BP '%.*s'\n", ret_len, buf); status = X400MsgGetStrParam(x400_mp, X400_S_SUBJECT, buf, buflen, &ret_len); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetStrParam (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); return status; } printf("Subject from Message BP '%.*s'\n", ret_len, buf); status = X400MsgGetIntParam(x400_mp, X400_N_NUM_ATTACHMENTS, &num_atts); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetStrParam (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); return status; } printf("Number of attachments in Message BP %d'\n", num_atts); status = get_recips(x400_mp, X400_ORIGINATOR); if (status != X400_E_NOERROR) { return status; } status = get_recips(x400_mp, X400_RECIP_PRIMARY); if (status != X400_E_NOERROR) { return status; } return X400_E_NOERROR; } static int get_recips( struct X400Message *x400_mp, int type ) { struct X400Recipient *rp; int status; int recip_num; for (recip_num = 1; ; recip_num++ ) { char buf[INIT_BUFFER_SIZE]; int buflen = sizeof buf; size_t ret_len; status = X400MsgGetRecip(x400_mp, type, recip_num, &rp); if (status == X400_E_NO_RECIP) { if (recip_num == 1) { printf("no recips of type %x\n", type); return X400_E_NOERROR; } else { printf("no more recips of type %x\n", type); } return X400_E_NOERROR; } else if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetRecip (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); return status; } printf("got recip number %d of type %s (%x)\n", recip_num, type == X400_RECIP_PRIMARY ? "Primary" : type == X400_RECIP_CC ? "CC" : type == X400_RECIP_BCC ? "BCC" : type == X400_ORIGINATOR ? "Originator" : type == X400_AUTH_ORIG ? "Auth Orig" : type == X400_RECIP_REPLY ? "Reply" : type == X400_RECIP_REPORT ? "Reported Recip" : type == X400_RECIP_INTENDED ? "Intended" : type == X400_RECIP_ENVELOPE ? "Envelope" : "Unknown", type); if (type == X400_RECIP_ENVELOPE) { // These aren't expected as the message will be forwarded // message with no envelope status = X400RecipGetStrParam(rp, X400_S_OR_ADDRESS, buf, buflen, &ret_len); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetStrParam (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); } else { printf("Originator OR Address'%.*s'\n", ret_len, buf); } } else { status = X400RecipGetStrParam(rp, X400_S_OR_ADDRESS, buf, buflen, &ret_len); if (status != X400_E_NOERROR) { fprintf(stderr, "X400MsgGetStrParam (%d) failed %s\n", X400_S_OBJECTTYPE, X400msError (status)); } else { printf("Originator OR Address'%.*s'\n", ret_len, buf); } } #define USE_REDIRECTION_HISTORY 1 #ifdef USE_REDIRECTION_HISTORY { status = do_redirection_hist(rp); if ( status == X400_E_NO_VALUE ) { /* do nothing */ } else if (status == X400_E_MISSING_ATTR ) { printf("There is no Redirection History\n"); } else { printf("error getting Redirection History\n"); fprintf (stderr, "Error fetching Redirection History: %s\n", X400msError (status)); return status; } } #endif } } static int do_xmsg_content_as_bp( struct X400Message *x400_mp ) { printf("do_xmsg_content_as_bp NYI\n"); return X400_E_NOERROR; } static int do_xrep_headers( struct X400Message *x400_mp ) { printf("do_xrep_headers NYI\n"); return X400_E_NOERROR; } static int do_xrep_content_as_bp( struct X400Message *x400_mp ) { printf("do_xrep_content_as_bp NYI\n"); return X400_E_NOERROR; } static void usage(void) { printf("usage: %s\n", optstr); printf("\t where:\n"); printf("\t -u : Don't prompt to override defaults \n"); printf("\t -3 : Use P3 connection \n"); printf("\t -7 : Use P7 connection \n"); printf("\t -m : OR Address in P7 bind arg \n"); printf("\t -d : DN in P7 bind arg \n"); printf("\t -p : Presentation Address of P7 Store \n"); printf("\t -w : P7 password of P7 user \n"); printf("\t -M : OR Address in P3 bind arg \n"); printf("\t -D : DN in P3 bind arg \n"); printf("\t -P : Presentation Address of P3 server\n");