X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=citadel%2Fmodules%2Fnetwork%2Fserv_netspool.c;h=0edb1f11efa0e240bcf7c7c3d79ead11d21b3934;hb=17facca88daba3788c5fcf6ffc8d57f3ed7a5905;hp=500d931bf0c57cce635bb116a0283449fe8956ac;hpb=9530aa5d9ba02e3b186aec0c24a1fa7824b7b086;p=citadel.git diff --git a/citadel/modules/network/serv_netspool.c b/citadel/modules/network/serv_netspool.c index 500d931bf..0edb1f11e 100644 --- a/citadel/modules/network/serv_netspool.c +++ b/citadel/modules/network/serv_netspool.c @@ -182,6 +182,7 @@ void InspectQueuedRoom(SpoolControl **pSC, HashList *working_ignetcfg, HashList *the_netmap) { + struct CitContext *CCC = CC; SpoolControl *sc; int i = 0; @@ -204,7 +205,7 @@ void InspectQueuedRoom(SpoolControl **pSC, } if (sc->room.QRhighest <= sc->lastsent) { - syslog(LOG_DEBUG, "nothing to do for <%s>\n", room_to_spool->name); + QN_syslog(LOG_DEBUG, "nothing to do for <%s>\n", room_to_spool->name); free(sc); return; } @@ -353,16 +354,6 @@ void network_spoolout_room(SpoolControl *sc) syslog(LOG_INFO, "Networking started for <%s>\n", CCC->room.QRname); - /* If there are digest recipients, we have to build a digest */ - if (sc->Users[digestrecp] != NULL) { - - sc->digestfp = create_digest_file(&sc->room); - sc->haveDigest = ftell(sc->digestfp) > 0; - if (!sc->haveDigest) { - fprintf(sc->digestfp, "Content-type: text/plain\n\n"); - } - } - CalcListID(sc); /* remember where we started... */ @@ -394,7 +385,7 @@ void network_spoolout_room(SpoolControl *sc) /* If we wrote a digest, deliver it and then close it */ - if (sc->digestfp != NULL) { + if (sc->Users[digestrecp] != NULL) { time_t now = time(NULL); time_t secs_today = now % (24 * 60 * 60); long delta = 0; @@ -404,25 +395,31 @@ void network_spoolout_room(SpoolControl *sc) delta = (24 * 60 * 60) - delta; } - if (sc->haveDigest && - (secs_today < 300) && - (delta < 300) ) + if ((secs_today < 300) && + (delta < 300)) { - last_digest_delivery = now; - fprintf(sc->digestfp, - " -----------------------------------" - "------------------------------------" - "-------\n" - "You are subscribed to the '%s' " - "list.\n" - "To post to the list: %s\n", - CCC->room.QRname, buf - ); - network_deliver_digest(sc); /* deliver */ + if (sc->digestfp == NULL) { + sc->digestfp = create_digest_file(&sc->room, 0); + } + if (sc->digestfp != NULL) { + last_digest_delivery = now; + fprintf(sc->digestfp, + " -----------------------------------" + "------------------------------------" + "-------\n" + "You are subscribed to the '%s' " + "list.\n" + "To post to the list: %s\n", + CCC->room.QRname, buf + ); + network_deliver_digest(sc); /* deliver */ + remove_digest_file(&sc->room); + } } + } + if (sc->digestfp != NULL) { fclose(sc->digestfp); sc->digestfp = NULL; - remove_digest_file(&sc->room); } /* Now rewrite the config file */