/* Are we downloading a MIME component? */
if (mode == MT_DOWNLOAD) {
- if (TheMessage->cm_format_type != 4) {
+ if (TheMessage->cm_format_type != FMT_RFC822) {
cprintf("%d This is not a MIME message.\n",
ERROR);
} else if (CC->download_fp != NULL) {
* MIME message, *lie* about it and tell the user it's fixed-format.
*/
if (mode == MT_CITADEL) {
- if (TheMessage->cm_format_type == 4)
+ if (TheMessage->cm_format_type == FMT_RFC822)
cprintf("type=1\n");
else
cprintf("type=%d\n", TheMessage->cm_format_type);
mptr = TheMessage->cm_fields['M'];
/* Tell the client about the MIME parts in this message */
- if (TheMessage->cm_format_type == 4) { /* legacy textual dump */
+ if (TheMessage->cm_format_type == FMT_RFC822) { /* legacy text dump */
if (mode == MT_CITADEL) {
mime_parser(mptr, NULL, *list_this_part);
}
/* signify start of msg text */
if (mode == MT_CITADEL)
cprintf("text\n");
- if ((mode == MT_RFC822) && (TheMessage->cm_format_type != 4))
+ if ((mode == MT_RFC822) && (TheMessage->cm_format_type != FMT_RFC822))
cprintf("\n");
/* If the format type on disk is 1 (fixed-format), then we want
* everything to be output completely literally ... regardless of
* what message transfer format is in use.
*/
- if (TheMessage->cm_format_type == 1) {
+ if (TheMessage->cm_format_type == FMT_FIXED) {
strcpy(buf, "");
while (ch = *mptr++, ch > 0) {
if (ch == 13)
* for new paragraphs is correct and the client will reformat the
* message to the reader's screen width.
*/
- if (TheMessage->cm_format_type == 0) {
+ if (TheMessage->cm_format_type == FMT_CITADEL) {
memfmout(80, mptr, 0);
}
* this message is format 1 (fixed format), so the callback function
* we use will display those parts as-is.
*/
- if (TheMessage->cm_format_type == 4) {
+ if (TheMessage->cm_format_type == FMT_RFC822) {
CtdlAllocUserData(SYM_MA_INFO, sizeof(struct ma_info));
memset(ma, 0, sizeof(struct ma_info));
mime_parser(mptr, NULL, *fixed_output);
/*
* Save a message to disk
*/
-void CtdlSaveMsg(struct CtdlMessage *msg, /* message to save */
+long CtdlSaveMsg(struct CtdlMessage *msg, /* message to save */
char *rec, /* Recipient (mail) */
char *force, /* force a particular room? */
int mailtype, /* local or remote type */
static int seqnum = 1;
lprintf(9, "CtdlSaveMsg() called\n");
- if (is_valid_message(msg) == 0) return; /* self check */
+ if (is_valid_message(msg) == 0) return(-1); /* self check */
/* If this message has no timestamp, we take the liberty of
* giving it one, right now.
*/
if (msg->cm_fields['T'] == NULL) {
+ lprintf(9, "Generating timestamp\n");
sprintf(aaa, "%ld", time(NULL));
msg->cm_fields['T'] = strdoop(aaa);
}
/* If this message has no path, we generate one.
*/
if (msg->cm_fields['P'] == NULL) {
- msg->cm_fields['P'] = strdoop(msg->cm_fields['A']);
- for (a=0; a<strlen(msg->cm_fields['P']); ++a) {
- if (isspace(msg->cm_fields['P'][a])) {
- msg->cm_fields['P'][a] = ' ';
+ lprintf(9, "Generating path\n");
+ if (msg->cm_fields['A'] != NULL) {
+ msg->cm_fields['P'] = strdoop(msg->cm_fields['A']);
+ for (a=0; a<strlen(msg->cm_fields['P']); ++a) {
+ if (isspace(msg->cm_fields['P'][a])) {
+ msg->cm_fields['P'][a] = ' ';
+ }
}
}
+ else {
+ msg->cm_fields['P'] = strdoop("unknown");
+ }
}
strcpy(force_room, force);
strcpy(&recipient[a], &recipient[a + 1]);
/* Learn about what's inside, because it's what's inside that counts */
+ lprintf(9, "Learning what's inside\n");
switch (msg->cm_format_type) {
case 0:
}
/* Goto the correct room */
+ lprintf(9, "Switching rooms\n");
strcpy(hold_rm, CC->quickroom.QRname);
strcpy(actual_rm, CC->quickroom.QRname);
/* If the user is a twit, move to the twit room for posting */
+ lprintf(9, "Handling twit stuff\n");
if (TWITDETECT) {
if (CC->usersupp.axlevel == 2) {
strcpy(hold_rm, actual_rm);
strcpy(actual_rm, force_room);
}
+ lprintf(9, "Possibly relocating\n");
if (strcasecmp(actual_rm, CC->quickroom.QRname))
getroom(&CC->quickroom, actual_rm);
/* Perform "before save" hooks (aborting if any return nonzero) */
- if (PerformMessageHooks(msg, EVT_BEFORESAVE) > 0) return;
+ lprintf(9, "Performing before-save hooks\n");
+ if (PerformMessageHooks(msg, EVT_BEFORESAVE) > 0) return(-1);
/* If this message has an Extended ID, perform replication checks */
- if (ReplicationChecks(msg) > 0) return;
+ lprintf(9, "Performing replication checks\n");
+ if (ReplicationChecks(msg) > 0) return(-1);
/* Network mail - send a copy to the network program. */
- if ((strlen(recipient) > 0) && (mailtype != MES_LOCAL)) {
+ if ((strlen(recipient) > 0) && (mailtype == MES_BINARY)) {
+ lprintf(9, "Sending network spool\n");
sprintf(aaa, "./network/spoolin/netmail.%04lx.%04x.%04x",
(long) getpid(), CC->cs_pid, ++seqnum);
lprintf(9, "Saving a copy to %s\n", aaa);
}
/* Save it to disk */
+ lprintf(9, "Saving to disk\n");
newmsgid = send_message(msg, generate_id, network_fp);
if (network_fp != NULL) {
fclose(network_fp);
system("exec nohup ./netproc -i >/dev/null 2>&1 &");
}
- if (newmsgid <= 0L) return;
+ if (newmsgid <= 0L) return(-1);
/* Write a supplemental message info record. This doesn't have to
* be a critical section because nobody else knows about this message
* yet.
*/
+ lprintf(9, "Creating SuppMsgInfo record\n");
memset(&smi, 0, sizeof(struct SuppMsgInfo));
smi.smi_msgnum = newmsgid;
smi.smi_refcount = 0;
PutSuppMsgInfo(&smi);
/* Now figure out where to store the pointers */
+ lprintf(9, "Storing pointers\n");
/* If this is being done by the networker delivering a private
CtdlSaveMsgPointerInRoom(actual_rm, newmsgid, 0);
}
+ /* For internet mail, drop a copy in the outbound queue room */
+ /* FIX ... nothing's going to get delivered until we add
+ some delivery instructions!!! */
+ if (mailtype == MES_INTERNET) {
+ CtdlSaveMsgPointerInRoom(SMTP_SPOOLOUT_ROOM, newmsgid, 0);
+ }
+
/* Bump this user's messages posted counter. */
+ lprintf(9, "Updating user\n");
lgetuser(&CC->usersupp, CC->curr_user);
CC->usersupp.posted = CC->usersupp.posted + 1;
lputuser(&CC->usersupp);
*/
if ((strlen(recipient) > 0) && (mailtype == MES_LOCAL)) {
if (getuser(&userbuf, recipient) == 0) {
+ lprintf(9, "Delivering private mail\n");
MailboxName(actual_rm, &userbuf, MAILROOM);
CtdlSaveMsgPointerInRoom(actual_rm, newmsgid, 0);
}
}
/* Perform "after save" hooks */
+ lprintf(9, "Performing after-save hooks\n");
PerformMessageHooks(msg, EVT_AFTERSAVE);
/* */
+ lprintf(9, "Returning to original room\n");
if (strcasecmp(hold_rm, CC->quickroom.QRname))
getroom(&CC->quickroom, hold_rm);
+
+ return(newmsgid);
}
/*
* Back end function used by make_message() and similar functions
*/
-char *CtdlReadMessageBody(char *terminator, size_t maxlen) {
+char *CtdlReadMessageBody(char *terminator, /* token signalling EOT */
+ size_t maxlen, /* maximum message length */
+ char *exist /* if non-null, append to it;
+ exist is ALWAYS freed */
+ ) {
char buf[256];
size_t message_len = 0;
size_t buffer_len = 0;
char *ptr, *append;
char *m;
- m = mallok(4096);
+ if (exist == NULL) {
+ m = mallok(4096);
+ }
+ else {
+ m = reallok(exist, strlen(exist) + 4096);
+ if (m == NULL) phree(exist);
+ }
if (m == NULL) {
while ( (client_gets(buf)>0) && strcmp(buf, terminator) ) ;;
return(NULL);
msg->cm_fields['D'] = strdoop(dest_node);
- msg->cm_fields['M'] = CtdlReadMessageBody("000", config.c_maxmsglen);
+ msg->cm_fields['M'] = CtdlReadMessageBody("000",
+ config.c_maxmsglen, NULL);
return(msg);