if (content_type != NULL)
if (strlen(content_type) > 0)
for (a = 0; a < num_msgs; ++a) {
+ lprintf(9, "Trying %ld\n", msglist[a]);
GetSuppMsgInfo(&smi, msglist[a]);
+ lprintf(9, "ct is %s\n", smi.smi_content_type);
if (strcasecmp(smi.smi_content_type, content_type)) {
msglist[a] = 0L;
}
static int seqnum = 1;
struct CtdlMessage *imsg;
char *instr;
- long imsgid;
lprintf(9, "CtdlSaveMsg() called\n");
if (is_valid_message(msg) == 0) return(-1); /* self check */
imsg->cm_magic = CTDLMESSAGE_MAGIC;
imsg->cm_anon_type = MES_NORMAL;
imsg->cm_format_type = FMT_RFC822;
+ imsg->cm_fields['A'] = strdoop("Citadel");
imsg->cm_fields['M'] = instr;
- imsgid = send_message(imsg, 1, NULL);
- if (imsgid >= 0L) {
- CtdlSaveMsgPointerInRoom(SMTP_SPOOLOUT_ROOM,
- imsgid,
- SM_DONT_BUMP_REF);
- }
+ CtdlSaveMsg(imsg, "", SMTP_SPOOLOUT_ROOM, MES_LOCAL, 1);
CtdlFreeMessage(imsg);
}
}
+/**** FIX temporary hack to run the queue *****/
+void cmd_qqqq(char *argbuf) {
+ smtp_do_queue();
+ cprintf("%d ok\n", OK);
+}
CtdlRegisterServiceHook(SMTP_PORT,
smtp_greeting,
smtp_command_loop);
+
+ /**** FIX ... temporary hack to run the queue ******/
+ CtdlRegisterProtoHook(cmd_qqqq, "QQQQ", "run the queue");
+
create_room(SMTP_SPOOLOUT_ROOM, 3, "", 0);
return "$Id$";
}
if (bind(s, (struct sockaddr *)&sin, sizeof(sin)) < 0) {
lprintf(1, "citserver: Can't bind: %s\n", strerror(errno));
- sin.sin_port = 0;
- if (bind(s, (struct sockaddr *)&sin, sizeof(sin)) < 0) {
- lprintf(1, "citserver: Can't bind: %s\n",
- strerror(errno));
- return(-1);
- }
- else {
- lprintf(1, "bind to alternate port %d ok\n",
- htons(sin.sin_port) );
- }
+ return(-1);
}
if (listen(s, queue_len) < 0) {