home *** CD-ROM | disk | FTP | other *** search
/ InfoMagic Internet Tools 1993 July / Internet Tools.iso / RockRidge / mail / mmdf / mmdf-IIb.43 / src / bboards / qu2bb_send.c < prev    next >
Encoding:
C/C++ Source or Header  |  1990-02-28  |  3.5 KB  |  158 lines
  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. /*   */
  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. /*   */
  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. /*   */
  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. }
  158.