misccmd.cpp

/**************************************************************************/
/*                                                                        */
/*                              WWIV Version 5.x                          */
/*             Copyright (C)1998-2020, WWIV Software Services             */
/*                                                                        */
/*    Licensed  under the  Apache License, Version  2.0 (the "License");  */
/*    you may not use this  file  except in compliance with the License.  */
/*    You may obtain a copy of the License at                             */
/*                                                                        */
/*                http://www.apache.org/licenses/LICENSE-2.0              */
/*                                                                        */
/*    Unless  required  by  applicable  law  or agreed to  in  writing,   */
/*    software  distributed  under  the  License  is  distributed on an   */
/*    "AS IS"  BASIS, WITHOUT  WARRANTIES  OR  CONDITIONS OF ANY  KIND,   */
/*    either  express  or implied.  See  the  License for  the specific   */
/*    language governing permissions and limitations under the License.   */
/*                                                                        */
/**************************************************************************/
#include "bbs/misccmd.h"


#include "acs.h"
#include "bbs/bbs.h"
#include "common/com.h"
#include "bbs/confutil.h"
#include "common/datetime.h"
#include "bbs/defaults.h"
#include "bbs/email.h"
#include "bbs/execexternal.h"
#include "common/input.h"
#include "bbs/msgbase1.h"
#include "common/pause.h"
#include "bbs/read_message.h"
#include "bbs/sysoplog.h"
#include "bbs/utility.h"
#include "bbs/wqscn.h"
#include "core/strings.h"
#include "fmt/printf.h"
#include "local_io/keycodes.h"
#include "local_io/wconstants.h"
#include "sdk/filenames.h"
#include "sdk/names.h"
#include "sdk/status.h"
#include "sdk/user.h"
#include "sdk/usermanager.h"
#include "sdk/files/dirs.h"

#include <memory>
#include <string>

// from qwk.c
void qwk_menu();

using std::string;
using std::unique_ptr;
using namespace wwiv::core;
using namespace wwiv::sdk;
using namespace wwiv::strings;

void kill_old_email() {
  mailrec m{};
  mailrec m1{};
  User user;
  filestatusrec fsr{};

  bout << "|#5List mail starting at most recent? ";
  bool forward = bin.yesno();
  auto pFileEmail(OpenEmailFile(false));
  if (!pFileEmail->IsOpen()) {
    bout << "\r\nNo mail.\r\n";
    return;
  }
  auto max = static_cast<int>(pFileEmail->length() / sizeof(mailrec));
  int cur = 0;
  if (forward) {
    cur = max - 1;
  }

  bool done = false;
  do {
    pFileEmail->Seek(cur * sizeof(mailrec), File::Whence::begin);
    pFileEmail->Read(&m, sizeof(mailrec));
    while ((m.fromsys != 0 || m.fromuser != a()->usernum || m.touser == 0) && cur < max && cur >= 0) {
      if (forward) {
        --cur;
      } else {
        ++cur;
      }
      if (cur < max && cur >= 0) {
        pFileEmail->Seek(cur * sizeof(mailrec), File::Whence::begin);
        pFileEmail->Read(&m, sizeof(mailrec));
      }
    }
    if (m.fromsys != 0 || m.fromuser != a()->usernum || m.touser == 0 || cur >= max || cur < 0) {
      done = true;
    } else {
      pFileEmail->Close();

      bool done1 = false;
      do {
        bout.nl();
        bout << "|#1  To|#9: ";
        bout.Color(a()->GetMessageColor());

        if (m.tosys == 0) {
          a()->users()->readuser(&user, m.touser);
          string tempName = a()->names()->UserName(a()->usernum);
          if ((m.anony & (anony_receiver | anony_receiver_pp | anony_receiver_da))
              && ((a()->effective_slrec().ability & ability_read_email_anony) == 0)) {
            tempName = ">UNKNOWN<";
          }
          bout << tempName;
          bout.nl();
        } else {
          bout << "#" << m.tosys << " @" << m.tosys << wwiv::endl;
        }
        bout.bprintf("|#1Subj|#9: |#%d%60.60s\r\n", a()->GetMessageColor(), m.title);
        time_t lCurrentTime = time(nullptr);
        int nDaysAgo = static_cast<int>((lCurrentTime - m.daten) / SECONDS_PER_DAY);
        bout << "|#1Sent|#9: ";
        bout.Color(a()->GetMessageColor());
        bout << nDaysAgo << " days ago" << wwiv::endl;
        if (m.status & status_file) {
          File fileAttach(FilePath(a()->config()->datadir(), ATTACH_DAT));
          if (fileAttach.Open(File::modeBinary | File::modeReadOnly)) {
            bool found = false;
            auto l1 = fileAttach.Read(&fsr, sizeof(fsr));
            while (l1 > 0 && !found) {
              if (m.daten == static_cast<uint32_t>(fsr.id)) {
                bout << "|#1Filename|#0.... |#2" << fsr.filename << " (" << fsr.numbytes << " bytes)|#0" << wwiv::endl;
                found = true;
              }
              if (!found) {
                l1 = fileAttach.Read(&fsr, sizeof(fsr));
              }
            }
            if (!found) {
              bout << "|#1Filename|#0.... |#2Unknown or missing|#0\r\n";
            }
            fileAttach.Close();
          } else {
            bout << "|#1Filename|#0.... |#2Unknown or missing|#0\r\n";
          }
        }
        bout.nl();
        bout << "|#9(R)ead, (D)elete, (N)ext, (Q)uit : ";
        char ch = onek("QRDN");
        switch (ch) {
        case 'Q':
          done1   = true;
          done    = true;
          break;
        case 'N':
          done1 = true;
          if (forward) {
            --cur;
          } else {
            ++cur;
          }
          if (cur >= max || cur < 0) {
            done = true;
          }
          break;
        case 'D': {
          done1 = true;
          unique_ptr<File> delete_email_file(OpenEmailFile(true));
          delete_email_file->Seek(cur * sizeof(mailrec), File::Whence::begin);
          delete_email_file->Read(&m1, sizeof(mailrec));
          if (memcmp(&m, &m1, sizeof(mailrec)) == 0) {
            delmail(*delete_email_file.get(), cur);
            bool found = false;
            if (m.status & status_file) {
              File fileAttach(FilePath(a()->config()->datadir(), ATTACH_DAT));
              if (fileAttach.Open(File::modeBinary | File::modeReadWrite)) {
                auto l1 = fileAttach.Read(&fsr, sizeof(fsr));
                while (l1 > 0 && !found) {
                  if (m.daten == static_cast<uint32_t>(fsr.id)) {
                    found = true;
                    fsr.id = 0;
                    fileAttach.Seek(static_cast<long>(sizeof(filestatusrec)) * -1L, File::Whence::current);
                    fileAttach.Write(&fsr, sizeof(filestatusrec));
                    File::Remove(FilePath(a()->GetAttachmentDirectory(), fsr.filename));
                  } else {
                    l1 = fileAttach.Read(&fsr, sizeof(filestatusrec));
                  }
                }
                fileAttach.Close();
              }
            }
            bout.nl();
            if (found) {
              bout << "Mail and file deleted.\r\n\n";
              sysoplog() << "Deleted mail and attached file: " << fsr.filename;
            } else {
              bout << "Mail deleted.\r\n\n";
              const string username_num = a()->names()->UserName(m1.touser);
              sysoplog() << "Deleted mail sent to " << username_num;
            }
          } else {
            bout << "Mail file changed; try again.\r\n";
          }
          delete_email_file->Close();
        }
        break;
        case 'R': {
          bout.nl(2);
          Type2MessageData msg = read_type2_message(&m.msg, m.anony & 0x0f, false, "email", 0, 0);
          msg.title = m.title;
          msg.message_area = "Personal E-Mail";
          bool next = false;
          display_type2_message(msg, &next);
        }
        break;
        }
      } while (!a()->sess().hangup() && !done1);
      pFileEmail = OpenEmailFile(false);
      if (!pFileEmail->IsOpen()) {
        break;
      }
    }
  } while (!done && !a()->sess().hangup());
  pFileEmail->Close();
}

void list_users(int mode) {
  subboard_t s = {};
  wwiv::sdk::files::directory_t d{};
  User user;
  char szFindText[21];

  if (a()->current_user_sub().subnum == -1 && mode == LIST_USERS_MESSAGE_AREA) {
    bout << "\r\n|#6No Message Sub Available!\r\n\n";
    return;
  }
  if (a()->current_user_dir().subnum == -1 && mode == LIST_USERS_FILE_AREA) {
    bout << "\r\n|#6 No Dirs Available.\r\n\n";
    return;
  }

  auto snum = a()->usernum;

  bout.nl();
  bout << "|#5Sort by user number? ";
  bool bSortByUserNumber = bin.yesno();
  bout.nl();
  bout << "|#5Search for a name or city? ";
  if (bin.yesno()) {
    bout.nl();
    bout << "|#5Enter text to find: ";
    bin.input(szFindText, 10, true);
  } else {
    szFindText[0] = '\0';
  }

  if (mode == LIST_USERS_MESSAGE_AREA) {
    s = a()->subs().sub(a()->current_user_sub().subnum);
  } else {
    d = a()->dirs()[a()->current_user_dir().subnum];
  }

  bool abort  = false;
  bool next   = false;
  int p       = 0;
  int num     = 0;
  bool found  = true;
  int count   = 0;
  int ncnm    = 0;
  int numscn  = 0;
  int color   = 3;
  a()->WriteCurrentUser();
  write_qscn(a()->usernum, a()->sess().qsc, false);
  a()->status_manager()->RefreshStatusCache();

  File userList(FilePath(a()->config()->datadir(), USER_LST));
  int nNumUserRecords = a()->users()->num_user_records();

  for (int i = 0; (i < nNumUserRecords) && !abort && !a()->sess().hangup(); i++) {
    a()->usernum = 0;
    if (ncnm > 5) {
      count++;
      bout.Color(color);
      bout << ".";
      if (count == NUM_DOTS) {
        bout.bputs("\r", &abort, &next);
        bout.bputs("|#2Searching ", &abort, &next);
        color++;
        count = 0;
        if (color == 4) {
          color++;
        }
        if (color == 7) {
          color = 0;
        }
      }
    }
    if (p == 0 && found) {
      bout.cls();
      auto title_line = StrCat(a()->config()->system_name(), " User Listing");
      if (okansi()) {
        bout.litebar(title_line);
      } else {
        int i1;
        for (i1 = 0; i1 < 78; i1++) {
          bout.bputch(45);
        }
        bout.nl();
        bout << "|#5" << title_line;
        bout.nl();
        for (i1 = 0; i1 < 78; i1++) {
          bout.bputch(45);
        }
        bout.nl();
      }
      bout.Color(FRAME_COLOR);
      bout.bpla("\xD5\xCD\xCD\xCD\xCD\xCD\xCD\xD1\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xD1\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xD1\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xD1\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xB8",
          &abort);
      found = false;
    }

    int user_number = (bSortByUserNumber) ? i + 1 : a()->names()->names_vector()[i].number;
    a()->users()->readuser(&user, user_number);
    read_qscn(user_number, a()->sess().qsc, false);
    changedsl();
    bool in_qscan = (a()->sess().qsc_q[a()->current_user_sub().subnum / 32] &
                     (1L << (a()->current_user_sub().subnum % 32)))
                        ? true
                        : false;
    bool ok = true;
    if (user.IsUserDeleted()) {
      ok = false;
    }
    if (mode == LIST_USERS_MESSAGE_AREA && !wwiv::bbs::check_acs(s.read_acs)) {
        ok = false;
    }
    if (mode == LIST_USERS_FILE_AREA && !wwiv::bbs::check_acs(d.acs)) {
      ok = false;
    }
    if (szFindText[0] != '\0') {
      char s5[ 41 ];
      strcpy(s5, user.GetCity());
      if (!strstr(user.GetName(), szFindText) &&
          !strstr(strupr(s5), szFindText) &&
          !strstr(user.GetState(), szFindText)) {
        ok = false;
      }
    }
    if (ok) {
      found = true;
      bout.clreol();
      if (user.GetLastBaudRate() > 32767 || user.GetLastBaudRate() < 300) {
        user.SetLastBaudRate(33600);
      }
      std::string city = "Unknown";
      if (user.GetCity()[0] != '\0') {
        city = fmt::format("{:.18}, {}", user.GetCity(), user.GetState());
      }
      auto properName = properize(user.GetName());
      const auto line = fmt::sprintf("|#%d\xB3|#9%5d |#%d\xB3|#6%c|#1%-20.20s|#%d\xB3|#2 "
                                     "%-24.24s|#%d\xB3 |#1%-9s |#%d\xB3  |#3%-5u  |#%d\xB3",
                                     FRAME_COLOR, user_number, FRAME_COLOR, in_qscan ? '*' : ' ',
                                     properName, FRAME_COLOR, city, FRAME_COLOR, user.GetLastOn(),
                                     FRAME_COLOR, user.GetLastBaudRate(), FRAME_COLOR);
      bout.bpla(line, &abort);
      num++;
      if (in_qscan) {
        numscn++;
      }
      ++p;
      if (p == static_cast<int>(a()->user()->GetScreenLines()) - 6) {
        //bout.backline();
        bout.clreol();
        bout.Color(FRAME_COLOR);
        bout.bpla("\xD4\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xBE",
            &abort);
        bout << "|#1[Enter] to continue or Q=Quit : ";
        char ch = onek("Q\r ");
        switch (ch) {
        case 'Q':
          abort = true;
          i = a()->status_manager()->GetUserCount();
          break;
        case SPACE:
        case RETURN:
          p = 0;
          break;
        }
      }
    } else {
      ncnm++;
    }
  }
  //bout.backline();
  bout.clreol();
  bout.Color(FRAME_COLOR);
  bout.bpla("\xD4\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCF\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xCD\xBE",
      &abort);
  if (!abort) {
    bout.nl(2);
    bout << "|#1" << num << " user(s) have access and " << numscn << " user(s) scan this subboard.";
    bout.nl();
    bout.pausescr();
  }
  a()->ReadCurrentUser(snum);
  read_qscn(snum, a()->sess().qsc, false);
  a()->usernum = snum;
  changedsl();
}


void time_bank() {
  char s[81], bc[81];
  int i;
  long nsln;

  bout.nl();
  // TODO(rushfan): We use 10 as a proxy for unvalidated.
  // We should come up with a better way or just remove this
  // and set it in the menu ACS.
  if (a()->user()->GetSl() <= 10) {
    bout << "|#6You must be validated to access the timebank.\r\n";
    return;
  }
  if (a()->user()->GetTimeBankMinutes() > a()->effective_slrec().time_per_logon) {
    a()->user()->SetTimeBankMinutes(a()->effective_slrec().time_per_logon);
  }

  if (okansi()) {
    strcpy(bc, "Ú¿ÀÙijÂÃÅ´Á");
  } else {
    strcpy(bc, "++++-|+++++");
  }

  bool done = false;
  do {
    bout.cls();
    bout << "|#5WWIV TimeBank\r\n";
    bout.nl();
    bout << "|#2D|#9)eposit Time\r\n";
    bout << "|#2W|#9)ithdraw Time\r\n";
    bout << "|#2Q|#9)uit\r\n";
    bout.nl();
    bout << "|#9Balance: |#2" << a()->user()->GetTimeBankMinutes() << "|#9 minutes\r\n";
    bout << "|#9Time Left: |#2" << static_cast<int>(nsl() / 60) << "|#9 minutes\r\n";
    bout.nl();
    bout << "|#9(|#2Q|#9=|#1Quit|#9) [|#2Time Bank|#9] Enter Command: |#2";
    bout.mpl(1);
    char c = onek("QDW");
    switch (c) {
    case 'D':
      bout.nl();
      bout << "|#1Deposit how many minutes: ";
      bin.input(s, 3, true);
      i = to_number<int>(s);
      if (i > 0) {
        nsln = nsl();
        if ((i + a()->user()->GetTimeBankMinutes()) > a()->config()->sl(
              a()->sess().effective_sl()).time_per_logon) {
          i = a()->effective_slrec().time_per_logon - a()->user()->GetTimeBankMinutes();
        }
        if (i > (nsln / SECONDS_PER_MINUTE)) {
          i = static_cast<int>(nsln / SECONDS_PER_MINUTE);
        }
        a()->user()->SetTimeBankMinutes(a()->user()->GetTimeBankMinutes() +
            static_cast<uint16_t>(i));
        a()->user()->add_extratime(std::chrono::minutes(i));
        a()->tleft(false);
      }
      break;
    case 'W':
      bout.nl();
      if (a()->user()->GetTimeBankMinutes() == 0) {
        break;
      }
      bout << "|#1Withdraw How Many Minutes: ";
      bin.input(s, 3, true);
      i = to_number<int>(s);
      if (i > 0) {
        nsln = nsl();
        if (i > a()->user()->GetTimeBankMinutes()) {
          i = a()->user()->GetTimeBankMinutes();
        }
        a()->user()->SetTimeBankMinutes(a()->user()->GetTimeBankMinutes() -
            static_cast<uint16_t>(i));
        a()->user()->add_extratime(std::chrono::minutes(i));
        a()->tleft(false);
      }
      break;
    case 'Q':
      done = true;
      break;
    }
  } while (!done && !a()->sess().hangup());
}

int getnetnum(const std::string& network_name) {
  for (int i = 0; i < wwiv::stl::ssize(a()->nets()); i++) {
    if (iequals(a()->nets()[i].name, network_name)) {
      return i;
    }
  }
  return -1;
}

int getnetnum_by_type(network_type_t type) {
  const auto& n = a()->nets().networks();
  for (auto i = 0; i < wwiv::stl::ssize(a()->nets()); i++) {
    if (n[i].type == type) {
      return i;
    }
  }
  return -1;
}

void Packers() {
  qwk_menu();
}