xmsg.c

#include "defs.h"
#include "ext.h"

#define XLENGTH 20

static void sendx(struct btmp *buser, struct user *touser,
                  char send_string[][80], int override);

static int syself_ok(const char *name);

static int displayx(int32_t pos, int num, time_t *t, int32_t *prev,
                    int32_t *next) {
    char nstr[12];
    char name[MAXALIAS + 1];
    struct xheader *xh;
    char *s;

    int8_t sender = 1;
    bool noshow = pos < 0;
    char X[200];

    pos = pos < 0 ? -pos : pos;

    xh = (struct xheader *)(void *)(xmsg + pos);

    if (msg->xcurpos + (msg->xmsgsize >> 6) >
        (pos < msg->xcurpos ? pos + msg->xmsgsize : pos)) {
        errlog("X database scrollover pos is %08x, curpos is %08x", pos,
               msg->xcurpos);
        return (1);
    }

    if (!xh->checkbit) {
        errlog("X database check bit missing");
        return (-1);
    }

    if (xh->type == X_BROADCAST) {
        my_putchar(BEL);

        my_printf("\n\n### Broadcast at %s from %s ###\n", formtime(6, xh->time),
                  getusername(xh->snum, 1));
        s = (char *)(void *)(xh + 1);
        while (*s) {
            s += sprintf(X, ">%s\n", s) - 1;
            cleanup_strings(X);
            colorize(X);
        }
        colorize(BOLD_GREEN);
        return (0);
    }

    if (xh->snum != ouruser->usernum) {
        sender = 0;
        if (xh->rnum != ouruser->usernum) {
            errlog("X database user not send/recv, got %08x and %08x", xh->snum,
                   xh->rnum);
            return (-1);
        }
    } else if (xh->rnum == ouruser->usernum) {
        sender = -1;
    }

    /* Catch wraparound when pointing to old X for user */
    if (t && *t && xh->time > *t + 300) {
        errlog(
            "X time sequence invalid, got %08lx wanted %08lx, args were %08x, %d, "
            "%08x, %08x",
            xh->time, *t, pos, num, prev ? *prev : -1, next ? *next : -1);
        return (1);
    } else if (t) {
        *t = xh->time;
    }

    if (next) {
        if (sender) {
            *next = xh->snext;
        } else {
            *next = xh->rnext;
        }
    }

    if (prev) {
        if (sender) {
            *prev = xh->sprev;
        } else {
            *prev = xh->rprev;
        }
    } else if (sender > 0) {
        return (1);
    }

    if (noshow) {
        return (0);
    }

    if (num) {
        checked_snprintf(nstr, sizeof(nstr), "(#%d) ", num);
    } else {
        strcpy(nstr, "(old) ");
    }

    if (client) {
        my_putchar(IAC);
        my_putchar(XMSG_S);
    }
    strcpy(name,
           sender > 0 ? getusername(xh->rnum, 1) : getusername(xh->snum, 1));

    my_printf("\n%s %s %s%s %s at %s %s\n",
              sender > 0 ? "---" : (xh->type == X_QUESTION ? "%%%" : "***"),
              xh->type == X_QUESTION ? "Question" : "Message", nstr,
              sender > 0 ? "to" : "from", name, formtime(6, xh->time),
              sender > 0 ? "---" : (xh->type == X_QUESTION ? "%%%" : "***"));
    s = (char *)(void *)(xh + 1);
    while (*s) {
        s += sprintf(X, "%c%s\n",
                     sender > 0 ? '-' : (xh->type == X_QUESTION ? '%' : '>'), s) -
             1;
        cleanup_strings(X);
        colorize(X);
    }
    colorize(BOLD_GREEN);

    if (client) {
        my_putchar(IAC);
        my_putchar(XMSG_E);
    }
    strcpy(xreply, name);
    return (0);
}

void checkx(int resetnox) {
    int i;
    int nox = mybtmp->nox;

    if (resetnox < 0) {
        locks(SEM_XMSG);
        unlocks(SEM_XMSG);
    }

    if (msg->lastbcast > lastbcast) {
        lastbcast = msg->lastbcast;
        displayx(msg->bcastpos, 0, NULL, NULL, NULL);
    }

    if (!resetnox) mybtmp->nox = 0;

    if (ouruser && ouruser->xseenpos) {
        if (!ouruser->f_nobeep) {
            my_putchar(BEL);
        }
        if (nox && !ouruser->f_xmsg) {
            my_printf(
                "\n\nThese X messages were held for you while you were busy:\n");
        }

        while (ouruser->xseenpos) {
            if (!(i = displayx(ouruser->xseenpos, xmsgnum, NULL, NULL,
                               &ouruser->xseenpos))) {
                xmsgnum++;
            }

            else if (i < 0) {
                my_printf(
                    "\n\nX message database corruption, old X's lost, sorry!\n\n");
                bbs_sleep(5);
                ouruser->xseenpos = ouruser->xminpos = ouruser->xmaxpos = 0;
                break;
            }
        }
        my_putchar('\n');
        fflush(stdout);
    }
}

void express(int which) {
    int i;
    char *name;
    struct btmp *buser = NULL;
    struct user *p;
    int override = ' ';
    struct btmp tuser;
    char send_string[XLENGTH][80];

    if (ouruser->f_newbie) {
        /*  Commenting this out because it duplicates the newuseraccess helpfile

            my_printf("\nSorry, you are not permitted to send X messages until your
           personal info is\ncorrect and you are fully validated.\n");
            flush_input(3);
        */
        help("newuseraccess", NO);
        flush_input(1);
        return;
    }

    if (ouruser->f_twit) {
        my_printf(
            "\nSorry, you may not send X messages while your BBS privileges are "
            "suspended.\nPlease Yell to the sysops for more information.\n");
        return;
    }

    if (which < 0) {
        if (!*xreply) {
            colorize(BOLD_RED "Who's that now?\n");
            return;
        }
        strcpy(to, xreply);
        my_printf("Reply eXpress\nRecipient: %s\n", to);
        if (!(p = getuser(to)) || p->f_invisible) {
            colorize(BOLD_RED "There is no user %s on this BBS.\n", to);
            if (p) {
                freeuser(p);
            }
            *to = 0;
            flush_input(1);
            return;
        }
    } else if (which >= 0 && which < 10) /* QuickX */
    {
        if (ouruser->quickx[which] == 0L) {
            my_printf("No user assigned to slot #%d\n", which);
            return;
        }
        p = finduser(NULL, ouruser->quickx[which], 0);
        if (!p || p->f_invisible) {
            colorize(BOLD_RED "That user no longer exists.\n");
            if (p) {
                freeuser(p);
            }
            locks(SEM_USER);
            ouruser->quickx[which] = 0L;
            unlocks(SEM_USER);
            flush_input(1);
            return;
        }
        strcpy(to, p->name);
        my_printf("QuickX to %s\n", p->name);
    } else { /* Normal X message */
        my_printf("Message eXpress\n");

        /* Get the user to send to with default of last user */
        if (to[0]) {
            my_printf("Recipient (%s): ", to);
        } else {
            my_printf("Recipient: ");
        }
        name = get_name("", 2);
        if (!*name && !to[0]) {
            return;
        }
        if (*name) {
            strcpy(to, name);
        }

        if (!(p = getuser(to)) || p->f_invisible) {
            colorize(BOLD_RED "There is no user %s on this BBS.\n", to);
            if (p) {
                freeuser(p);
            }
            *to = 0;
            flush_input(1);
            return;
        }
    }

    /* Go read the btmp file and get the destination record */
    if (!(buser = is_online(&tuser, p, NULL))) {
        freeuser(p);
        colorize(BOLD_RED "User is not online.\n");
        *to = 0;
        flush_input(1);
        return;
    }

    if (0 && p->f_twit) {
        freeuser(p);
        colorize(BOLD_RED "Sorry, you can't X a twit!\n");
        *to = 0;
        flush_input(1);
        return;
    }

    if (p->f_newbie && !(ouruser->f_elf && mybtmp->elf) && !ouruser->f_admin) {
        freeuser(p);
        if (ouruser->f_elf) {
            colorize(
                BOLD_RED
                "You can only X new or unvalidated users if your guide flag is "
                "on.\n");
        } else {
            colorize(BOLD_RED "Sorry, you can't X a new or unvalidated user!\n");
        }
        *to = 0;
        flush_input(1);
        return;
    }

    /* see if sender is on receiver's X message enable list */
    for (i = 0; i < NXCONF &&
                (p->xconf[i].usernum != ouruser->usernum || !p->xconf[i].which);
         i++)
        ;

    if (i < NXCONF || (ouruser->f_admin && p->f_admin)) {
        override = 'w';
    }

    if (tuser.xstat && !(p->f_twit)) {
        colorize(BOLD_RED "User has eXpress DISABLED.");
        if (ouruser->f_prog && override != 'w') {
            colorize(BOLD_GREEN " Do you wish to send the X anyway? -> ");
            if (yesno(-1) == YES) {
                override = 'W'; /* just a temp.  we change it in a minute.. */
            }
        }

        if (override != 'W') {
            if (override != 'w') {
                freeuser(p);
                my_putchar('\n');
                to[0] = 0;
                flush_input(1);
                return;
            } else if (i < NXCONF) {
                colorize("  You are on user's 'enable' list.\n" BOLD_GREEN);
            } else {
                colorize("  Luckily for you it just doesn't matter!\n" BOLD_GREEN);
            }
        } else
            override = 'w';
    }

    /* see if sender is on receiver's X message disable list */
    for (i = 0; i < NXCONF &&
                (p->xconf[i].usernum != ouruser->usernum || p->xconf[i].which);
         i++)
        ;

    if (i < NXCONF && !(p->f_twit)) {
        freeuser(p);
        my_printf("%s refuses to accept X messages or mail from you.\n", to);
        flush_input(1);
        return;
    }

    if (mybtmp->xstat) {
        for (i = 0; i < NXCONF && (ouruser->xconf[i].usernum != tuser.usernum ||
                                   !ouruser->xconf[i].which);
             i++)
            ;
        if (i == NXCONF && !(ouruser->f_admin && (p->f_admin || p->f_newbie))) {
            freeuser(p);
            my_printf(
                "You can't X someone not on your enable list while disabled!\n");
            flush_input(1);
            return;
        }
    }

    for (i = 0; i < NXCONF && (ouruser->xconf[i].usernum != tuser.usernum ||
                               ouruser->xconf[i].which);
         i++)
        ;
    if (i < NXCONF) {
        freeuser(p);
        my_printf("You can't X someone on your disable list!\n");
        flush_input(1);
        return;
    }

    /* Now get the message they want to send */
    if (client) {
        my_putchar(IAC);
        my_putchar(G_FIVE);
        my_putchar(1);
        my_putc((byte >> 16) & 255, stdout);
        my_putc((byte >> 8) & 255, stdout);
        my_putc(byte & 255, stdout);
        block = 1;
    }
    for (i = 0; i < XLENGTH && (!i || *send_string[i - 1]); i++) {
        get_new_string(client ? "" : ">", 78, send_string[i], i, XLENGTH);
        if (!strcmp(send_string[i], "ABORT")) {
            freeuser(p);
            colorize(BOLD_RED "eXpress message aborted.\n");
            return;
        }

        if (ouruser->f_beeps && !strcmp(send_string[0], "BEEPS"))
            override = 'b'; /* meta-x-auto-beep mode */
                            /* Finish out the for-loop */

        if (!strcmp(send_string[0], "PING")) {
            freeuser(p);
            override = 'p';
        }
    }
    if (!**send_string) override = 'p';

    if (override == 'p') {
        if (!(buser = is_online(NULL, p, NULL)) || buser->nox < 0) {
            my_printf("%s has logged out.\n", p->name);
        } else if (!buser->nox) {
            my_printf("%s is not busy", p->name);
            if (buser->sleeptimes > 4) {
                my_printf(", but is idle for %02d:%02d", buser->sleeptimes / 60, buser->sleeptimes % 60);
            }
            my_printf(".\n");
        } else {
            my_printf("%s is busy.\n", p->name);
        }
        freeuser(p);
        return;
    }

    sendx(buser, p, send_string, override);
    freeuser(p);
}

static void sendx(struct btmp *buser, struct user *touser,
                  char send_string[][80], int override) {
    struct xheader xh;
    time_t t;
    int i;
    int j;
    char *p;
    int32_t curpos;
    struct xheader *xhp;
    int wasbusy = 0;

    /* BEEPS */
    if (override == 'b') {
        if (kill(buser->pid, SIGUSR2) < 0) {
            my_printf("%s could not be beeped, sorry!\r\n", buser->name);
        } else {
            my_printf("%s has been beeped.\r\n", buser->name);
        }

        return;
    }

    t = msg->t = time(0);
    if (override != 'B') {
        j = (++xcount - 10) * 15;
        if (t - ouruser->time < j) {
            flush_input(j - t + ouruser->time);
            t = time(0);
        }
    }

    localtime(&t);
    xh.checkbit = 1;
    xh.rnum = touser ? touser->usernum : 0;
    xh.snum = ouruser->usernum;
    xh.time = t;
    xh.snext = 0;
    xh.rnext = 0;
    if (override == 'q') {
        xh.type = X_QUESTION;
    } else if (override == 'B') {
        xh.type = X_BROADCAST;
    } else {
        xh.type = X_NORMAL;
    }

    if (override != 'B' &&
        !((buser = is_online(NULL, touser, NULL)) && buser->nox >= 0)) {
        my_printf("Sorry, %s left before you could finish your message!\n",
                  touser->name);
        flush_input(1);
        return;
    }
    if (override == ' ' && buser->xstat && !(touser->f_twit)) {
        my_printf(
            "Sorry, %s turned off X messages before you finished your message!\n",
            touser->name);
        flush_input(1);
        return;
    }

    /* Touch to insure next page is in real memory, should use volatile */
    curpos = msg->xcurpos;
    if (curpos + 2048 >= msg->xmsgsize) {
        curpos = sizeof(int32_t);
    }
    foo = *((char *)xmsg + curpos);
    foo = ouruser->usernum;
    if (touser) {
        foo = touser->usernum;
    }

    locks(SEM_XMSG);

    if (override != 'B' && !buser->pid) {
        unlocks(SEM_XMSG);
        my_printf("Sorry, %s left before you could finish your message!\n",
                  touser->name);
        flush_input(1);
        return;
    }

    if (msg->xcurpos + 512 >= msg->xmsgsize || !msg->xcurpos) {
        msg->xcurpos = sizeof(int32_t);
    }
    curpos = msg->xcurpos;
    p = (char *)xmsg + curpos;
    memcpy(p, (const char *)&xh, sizeof xh);
    p += sizeof xh;
    // BUG? `j` is strlen, but we copy `j+2` bytes.
    for (i = 0; i < XLENGTH && (j = strlen(send_string[i])); i++, p += j + 1) {
        strncpy(p, send_string[i], j + 2);
    }
    msg->xcurpos =
        ((unsigned char *)p + sizeof(int32_t) - xmsg) & ~(sizeof(int32_t) - 1);

    if (override == 'B') {
        msg->lastbcast = t;
        msg->bcastpos = curpos;
    } else {
        xhp = (struct xheader *)(void *)(xmsg + curpos);
        xhp->sprev = ouruser->xmaxpos;
        if (ouruser->xmaxpos) {
            xhp = (struct xheader *)(void *)(xmsg + ouruser->xmaxpos);
            if (xhp->snum == ouruser->usernum) {
                xhp->snext = curpos;
            }
            if (xhp->rnum == ouruser->usernum) {
                xhp->rnext = curpos;
            }
        }

        if (buser->nox && !touser->f_xmsg) {
            wasbusy = 1;
        }
        xhp = (struct xheader *)(void *)(xmsg + curpos);
        xhp->rprev = touser->xmaxpos;
        if (touser->xmaxpos) {
            xhp = (struct xheader *)(void *)(xmsg + touser->xmaxpos);
            if (xhp->snum == touser->usernum) {
                xhp->snext = curpos;
            }
            if (xhp->rnum == touser->usernum) {
                xhp->rnext = curpos;
            }
        }

        if (!ouruser->xminpos) {
            ouruser->xminpos = curpos;
        }
        if (!touser->xminpos) {
            touser->xminpos = curpos;
        }
        ouruser->xmaxpos = touser->xmaxpos = curpos;
        if (!touser->xseenpos) {
            touser->xseenpos = touser->xmaxpos;
            i = buser->pid;
        } else {
            i = 0;
        }
    }

    unlocks(SEM_XMSG);
    if (override == 'B') {
        return;
    }

    if (ouruser != touser) {
        xmsgnum++;
        if (i && (!buser->nox || touser->f_xmsg)) {
            kill(i, SIGIO);
        }
    }
    (ouruser->totalx)++;

    if (wasbusy) {
        my_printf("%s is busy and will receive your %s when done.\n", touser->name,
                  override == 'q' ? "question" : "message");
    } else {
        my_printf("%s received by %s.\n", override == 'q' ? "Question" : "Message",
                  touser->name);
    }
}

void change_express(int cmd) {
    colorize("%s" BOLD_RED "eXpress messages %sABLED\n",
             cmd ? "Change eXpress status\n\n" : "",
             (mybtmp->xstat ^= 1) ? "DIS" : "EN");
}

void change_beeps(void) {
    locks(SEM_USER);
    colorize(BOLD_RED "eXpress beeps %sABLED\n",
             (ouruser->f_nobeep ^= 1) ? "DIS" : "EN");
    unlocks(SEM_USER);
}

void old_express(void) {
    char nstr[8];
    int32_t prev;
    int32_t next;
    time_t t = 0;
    int32_t pos;
    int32_t oldpos = 0;
    int i;
    int c = ' ';
    int dir = BACKWARD;
    int n = 0;
    int savedir = 0;

    for (;;) {
        pos = ouruser->xmaxpos;
        checkx(1);
        i = xmsgnum - 1;
        if (pos == ouruser->xmaxpos) {
            break;
        }
    }
    my_printf("Read old X messages");

    for (;;) {
        if (!n) {
            my_putchar('\n');
        }
        if (n < 0) {
            n = 0;
        }
        if (c) {
            if (!pos || displayx(n ? -pos : pos, i < 0 ? 0 : i,
                                 dir == BACKWARD ? &t : NULL, &prev, &next)) {
                if (!n) {
                    return;
                } else {
                    n = -1;
                    pos = oldpos;
                    dir = savedir;
                }
            }

            if (n) {
                if (n == i) {
                    n = -1;
                    dir = savedir;
                    continue;
                } else {
                    i += dir;
                    oldpos = pos;
                    if (dir == FORWARD) {
                        pos = next;
                    } else {
                        pos = prev;
                    }
                    continue;
                }
            }
        }

        my_printf("\nOld X message review  <N>ext (%s) <B>ack <S>top <#> -> ",
                  dir == BACKWARD ? "backward" : "forward");
        // c = 'N';
        c = get_single_quiet(" NB#SQ\n?/H");

        switch (c) {
            case 'N':
            case ' ':
                my_printf("Next");
                break;

            case 'B':
                my_printf("Change direction");
                dir = -dir;
                break;

            case '#':
                get_string("Select X message #\n\nX message number to move to -> ", 4,
                           nstr, -1);
                n = atoi(nstr);
                if (n > 0 && n < xmsgnum) {
                    savedir = dir;
                    dir = n > xmsgnum - n ? BACKWARD : FORWARD;
                    pos = dir == BACKWARD ? ouruser->xmaxpos : ouruser->xminpos;
                    i = dir == BACKWARD ? xmsgnum - 1 : 1;
                    t = 0;
                } else {
                    my_printf("\nInvalid X message number.");
                    n = c = 0;
                }
                continue;
                /* NOTREACHED */

            case 'S':
            case 'Q':
            case '\n':
                my_printf("Stop\n");
                return;

            case '?':
            case '/':
                my_printf("Help\n");
                help("oldexpressopt", NO);
                c = 0;
                continue;
                /* NOTREACHED */

            case 'H':
                my_printf("Help (not yet available)");
                c = 0;
                continue;
                /* NOTREACHED */

            default:
                break;
        }

        i += dir;
        oldpos = pos;
        if (dir == FORWARD) {
            pos = next;
            t = 0;
        } else
            pos = prev;
    }
}

void get_syself_help(int cmd) {
    char send_string[XLENGTH][80];
    struct btmp btmp;
    struct btmp *buser = NULL;
    struct user *p;
    int i;
    int n;
    time_t t;
    int diff, maxdiff = 0;
    int save = -1;

    if (cmd == 'q') {
        my_printf(
            "\n\nPlease hit shift 'Q' (capital 'Q' not lowercase 'q') if you have "
            "a question\nrelated to this BBS for a Guide to answer.\n");
        return;
    }

    if (ouruser->f_twit) {
        my_printf(
            "\n\nSorry, you may not use this function while your BBS privileges "
            "are suspended.\nPlease Yell to the sysops for more information.\n");
        return;
    }

    my_printf("\n\nAre you sure you want to ask a question? (Y/N) -> ");
    if (!yesno(-1)) {
        return;
    }
    if (mybtmp->xstat) {
        change_express(0);
    }

    if (!*curr_syself || !(buser = is_online(&btmp, NULL, curr_syself)) ||
        !btmp.elf || btmp.xstat) {
        if (*curr_syself) {
            my_printf(
                "\n%s is not available as a Guide at this moment.\nA new one will be "
                "selected for you...\n",
                curr_syself);
        }
        *curr_syself = 0;
        t = time(0);
        for (i = 0, n = (pid + t) % MAXUSERS; i < MAXUSERS;
             i++, n = (n == MAXUSERS - 1) ? 0 : n + 1) {
            if (bigbtmp->btmp[n].pid && bigbtmp->btmp[n].elf &&
                !bigbtmp->btmp[n].xstat && !bigbtmp->btmp[n].nox &&
                bigbtmp->btmp[n].pid != pid) {
                diff = 121 - abs(120 - (int)((t - bigbtmp->btmp[n].time) / 60));
                if (((bigbtmp->btmp[n].pid + i) % diff) < diff - 15) {
                    if (!syself_ok(bigbtmp->btmp[n].name)) {
                        continue;
                    }
                    save = n;
                    break;
                } else if (diff > maxdiff) {
                    if (!syself_ok(bigbtmp->btmp[n].name)) {
                        continue;
                    }
                    save = n;
                    maxdiff = diff;
                }
            }
        }
    }
    if (save >= 0) {
        buser = &bigbtmp->btmp[save];
        btmp = *buser;
    }
    if (save < 0 && !*curr_syself)
        my_printf(
            "\nI'm sorry, no Guides are available at the moment.  You can hit 'y' "
            "to Yell\nyour BBS related question to the Sysops, and it will be "
            "answered as soon\nas possible.\n");
    else {
        strcpy(curr_syself, btmp.name);
        my_printf("\nYour BBS related question is being sent to %s.\n", btmp.name);
        if (client) {
            my_putchar(IAC);
            my_putchar(G_FIVE);
            my_putchar(16);
            my_putc((byte >> 16) & 255, stdout);
            my_putc((byte >> 8) & 255, stdout);
            my_putc(byte & 255, stdout);
            block = 1;
        }
        for (i = 0; i < XLENGTH && (!i || *send_string[i - 1]); i++) {
            get_string(client ? "" : ">", 78, send_string[i], i);
            if (!strcmp(send_string[i], "ABORT")) {
                my_printf("Question aborted.\n");
                return;
            }
        }
        if (!**send_string) {
            colorize(BOLD_RED "No message given, so nothing was sent.\n");
        } else {
            if (!(p = getuser(curr_syself))) {
                my_printf("Error sending question, question not sent!\n");
                *curr_syself = 0;
            }
            sendx(buser, p, send_string, 'q');
            freeuser(p);
        }
    }
}

static int syself_ok(const char *name) {
    struct user *up;
    int i;

    if (!(up = getuser(name))) {
        return (0);
    }
    for (i = 0;
         i < NXCONF &&
         (ouruser->usernum != up->xconf[i].usernum || up->xconf[i].which) &&
         (up->usernum != ouruser->xconf[i].usernum || ouruser->xconf[i].which);
         i++)
        ;
    freeuser(up);
    return (i < NXCONF ? 0 : 1);
}

void xbroadcast(void) {
    char send_string[XLENGTH][80];
    int i;
    int j;
    char override = 'B';

    my_printf("\nEnter the message you wish to broadcast to ALL users...\n");
    if (client) {
        my_putchar(IAC);
        my_putchar(G_FIVE);
        my_putchar(3);
        my_putc((byte >> 16) & 255, stdout);
        my_putc((byte >> 8) & 255, stdout);
        my_putc(byte & 255, stdout);
        block = 1;
    }

    for (i = 0; i < XLENGTH && (!i || *send_string[i - 1]); i++) {
        get_string(client ? "" : ">", 78, send_string[i], i);
        if (!strcmp(send_string[i], "ABORT")) {
            colorize(BOLD_RED "Broadcast message aborted.\n");
            return;
        }

        if (ouruser->f_beeps && !strcmp(send_string[0], "BEEPS")) override = 'b';
    }
    if (!**send_string) {
        return;
    }

    if (override == 'B') {
        sendx(NULL, NULL, send_string, override);
        for (i = 0; i < MAXUSERS; i++) {
            if ((j = bigbtmp->btmp[i].pid)) {
                kill(j, SIGIO);
            }
        }
        my_printf("Message broadcast.\n");
    } else if (override == 'b') {
        for (i = 0; i < MAXUSERS; i++) {
            if ((j = bigbtmp->btmp[i].pid)) {
                kill(j, SIGUSR2);
            }
        }
        my_printf("Everyone has been beeped.  I hope you're happy now.\r\n");
    }
}

int xyell(struct user *up, unsigned char *p) {
    char nstr[8];
    int32_t pos = ouruser->xmaxpos;
    struct xheader *xh;
    int i;
    char *s;
    int num = xmsgnum - 1;
    int sender;
    uint32_t usernum;
    time_t t = 0;
    int found = 0;
    unsigned char *savep = p;

    usernum = up->usernum;

    for (xh = (struct xheader *)(void *)(xmsg + pos); pos; num--,
        (sender ? (pos = xh->sprev) : (pos = xh->rprev)),
        xh = (struct xheader *)(void *)(xmsg + pos)) {
        if (!xh->checkbit) {
            return (-1);
        }
        sender = 1;
        if (msg->xcurpos + (msg->xmsgsize >> 6) >
            (pos < msg->xcurpos ? pos + msg->xmsgsize : pos)) {
            break;
        }
        if (t && xh->time > t + 60) {
            break;
        } else {
            t = xh->time;
        }
        if (xh->snum != ouruser->usernum) {
            sender = 0;
            if (xh->rnum != ouruser->usernum) {
                return (-1);
            } else if (xh->snum != usernum) {
                continue;
            }
        } else if (xh->rnum != up->usernum) {
            continue;
        }

        found = 1;
        if (num > 0) {
            checked_snprintf(nstr, sizeof(nstr), "#%d", num);
        } else {
            strcpy(nstr, "old");
        }
        p += sprintf((char *)p, "\n%s %s (%s) from %s to %s at %s %s\n",
                     sender ? "---" : (xh->type == X_QUESTION ? "%%%" : "***"),
                     xh->type == X_QUESTION ? "Question" : "Message", nstr,
                     getusername(xh->snum, 1), getusername(xh->rnum, 1),
                     formtime(6, xh->time),
                     sender ? "---" : (xh->type == X_QUESTION ? "%%%" : "***"));

        for (s = (char *)(void *)(xh + 1); *s; p += i, s += i - 1) {
            i = sprintf((char *)p, "%c%s\n",
                        sender ? '-' : (xh->type == X_QUESTION ? '%' : '>'), s);
        }

        if (p - savep > 50000) {
            p += sprintf((char *)p,
                         "\n\n(Some X messages were not included due to message size "
                         "limitations)\n\n");
            my_printf(
                "\n\n(Some X messages were not included due to message size "
                "limitations)\n\n");
        }
    }

    return (found ? p - savep : 0);
}

void xinit(int reset) {
    ouruser->xseenpos = 0;

    if (reset) {
        ouruser->xmaxpos = 0;
        ouruser->xminpos = 0;
    }

    xmsgnum = 1;

    clean_xconf(ouruser);
}

void clean_xconf(struct user *tmpuser) {
    int i, j;
    int32_t num;

    locks(SEM_USER);
    for (i = 0; i < NXCONF && (num = tmpuser->xconf[i].usernum); i++) {
        if (!getusername(num, 0) || tmpuser->f_invisible) {
            for (j = i--; j < NXCONF - 1; j++) {
                tmpuser->xconf[j] = tmpuser->xconf[j + 1];
            }
            tmpuser->xconf[NXCONF - 1].usernum = 0;
        }
    }
    unlocks(SEM_USER);
}