git.marmaro.de Git - mmh/blob - docs/historical/mh-6.8.5/support/pop/mmdfII/pop/qu2po_send.c

   1 #ifndef POP
   2 /* qu2bb_send.c - manager for qu --> bb */
   3 #else   POP
   4 /* qu2po_send.c - manager for qu --> po */
   5 #endif  POP
   6
   7
   8 #include "util.h"
   9 #include "mmdf.h"
  10 #include "phs.h"
  11 #include "ch.h"
  12
  13 /* \f */
  14
  15 extern LLog *logptr;
  16 extern char *supportaddr;
  17
  18 struct rp_construct rp_hend  = { /* end of host list */
  19     RP_NOOP,
  20     'e', 'n', 'd', ' ', 'o', 'f', ' ', 'h', 'o', 's', 't', ' ',
  21     'i', 'g', 'n', 'o', 'r', 'e', 'd',
  22     NULL
  23 };
  24
  25 struct rp_construct rp_aend = { /* end of address list */
  26     RP_OK,
  27 #ifndef POP
  28     'b', 'b', 'o', 'a', 'r', 'd', 's', ' ', 'e', 'n', 'd', ' ',
  29 #else   POP
  30     'p', 'o', 'p', ' ', 'e', 'n', 'd', ' ',
  31 #endif  POP
  32     'o', 'f', ' ', 'a', 'd', 'd', 'r', ' ', 'l', 'i', 's', 't',
  33     NULL
  34 };
  35
  36 struct rp_construct rp_badr = { /* no such bboard */
  37     RP_USER,
  38     'u', 'n', 'k', 'n', 'o', 'w', 'n', ' ',
  39 #ifndef POP
  40     'b', 'b', 'o', 'a', 'r', 'd',
  41 #else   POP
  42     'p', 'o', 'p', ' ', 's', 'u', 'b', 's', 'c', 'r', 'i', 'b', 'e', 'r',
  43 #endif  POP
  44     NULL
  45 };
  46
  47 struct rp_construct rp_err = {  /* error, retry later */
  48     RP_AGN,
  49     'u', 'n', 'k', 'n', 'o', 'w', 'n', ' ', 'e', 'r', 'r', 'o', 'r',
  50     NULL
  51 };
  52
  53 /* \f */
  54
  55 qu2bb_send (chanptr)
  56 Chan *chanptr;
  57 {
  58     short   result;
  59     char    info[LINESIZE],
  60             sender[LINESIZE];
  61
  62 #ifdef DEBUG
  63     ll_log (logptr, LLOGBTR, "qu2bb_send()");
  64 #endif
  65
  66     if (rp_isbad (result = qu_pkinit ()))
  67         return result;
  68     if (rp_isbad (result = bb_sbinit ()))
  69         return result;
  70
  71     while (rp_gval ((result =
  72             qu_rinit (info, sender, chanptr -> ch_apout))) == RP_OK) {
  73 #ifdef  DEBUG
  74         ll_log (logptr, LLOGGEN, "info=%s sender=%s", info, sender);
  75 #endif
  76         if (rp_isbad (result = bb_winit (info, sender)))
  77             return result;
  78         if (rp_isbad (result = qu2bb_each (sender)))
  79             return result;
  80         qu_rend();
  81     }
  82     qu_rend();
  83
  84     if (rp_gval (result) != RP_DONE) {
  85         ll_log (logptr, LLOGTMP, "not DONE [%s]", rp_valstr (result));
  86         return RP_RPLY;
  87     }
  88
  89     qu_pkend ();
  90     bb_sbend ();
  91
  92     return result;
  93 }
  94
  95 /* \f */
  96 LOCFUN
  97 qu2bb_each (sender)
  98 char   *sender;
  99 {
 100     short   result;
 101     char    adr[LINESIZE],
 102             host[LINESIZE];
 103     RP_Buf replyval;
 104
 105 #ifdef DEBUG
 106     ll_log (logptr, LLOGBTR, "qu2bb_each(sender='%s')", sender);
 107 #endif
 108
 109     FOREVER {                   /* loop through the addresses */
 110         if (rp_isbad (result = qu_radr (host, adr)))
 111             return result;
 112 #ifdef  RP_HOK
 113         if (rp_gval (result) == RP_HOK) {/* no-op the sub-list indication */
 114             qu_wrply ((struct rp_bufstruct *) &rp_hend, rp_conlen (rp_hend));
 115             continue;
 116         }
 117 #endif  RP_HOK
 118         if (rp_gval (result) == RP_DONE) {
 119             qu_wrply ((RP_Buf *) &rp_aend, rp_conlen (rp_aend));
 120             return RP_OK;
 121         }
 122
 123         switch (replyval.rp_val = bb_wtadr (host, adr)) {
 124             case RP_AOK:
 125             case RP_OK:
 126                 switch (replyval.rp_val = bb_txtcpy ()) {
 127                     case RP_MOK:
 128                         replyval.rp_line[0] = NULL;
 129                         break;
 130                     default:
 131                         ll_log (logptr, LLOGFAT, "unknown error [%s]",
 132                                 rp_valstr (replyval.rp_val));
 133                         blt (&rp_err, (char *) &replyval, sizeof rp_err);
 134                         break;
 135                 }
 136                 break;
 137
 138             case RP_USER:
 139 #ifndef POP
 140                 ll_log (logptr, LLOGFAT, "unknown bboard '%s'", adr);
 141 #else   POP
 142                 ll_log (logptr, LLOGFAT, "unknown pop subscriber '%s'", adr);
 143 #endif  POP
 144                 blt (&rp_badr, (char *) &replyval, sizeof rp_badr);
 145                 break;
 146
 147             default:
 148                 ll_log (logptr, LLOGFAT, "unknown error [%s]",
 149                         rp_valstr (replyval.rp_val));
 150                 blt (&rp_err, (char *) &replyval, sizeof rp_err);
 151                 break;
 152         }
 153
 154         qu_wrply (&replyval,
 155                 (sizeof replyval.rp_val) + strlen (replyval.rp_line));
 156     }
 157 }