faraon/faraon.C

   1
   2  /*
   3   *   Copyright (C) 2007, Rus V. Brushkoff, All rights reserved.
   4   */
   5
   6 #include <faraon.H>
   7 #include <errno.h>
   8
   9 faraon_app *app;
  10 Fl_Preferences prefs(Fl_Preferences::USER, "Harbour", "Sfinx");
  11
  12 bool faraon_app::process_requests()
  13 {
  14  if (sfinx.read_packet()) {
  15    log("faraon:process", "Error reading sfinx request");
  16    return true;
  17  }
  18   sfinx_t *el;
  19   while ((el = sfinx.rx_elements.next())) {
  20    switch (el->tid()) {
  21      case SFINX_NOTES_MODULE_UNSORT_REPLY:
  22      case SFINX_NOTES_MODULE_UNLINK_REPLY:
  23      case SFINX_FILES_MODULE_SORTED_UNLINK_REPLY:
  24      case SFINX_FILES_MODULE_UNSORT_REPLY:
  25        break;
  26      case SFINX_NOTES_MODULE_EDIT_REPLY:
  27        ui()->notes_module_reply((sfinx_string_t *)el);
  28        break;
  29      case SFINX_NOTES_MODULE_EDIT_REQUEST:
  30        ui()->notes_module_edit((sfinx_note_t *)el);
  31        break;
  32      case SFINX_ELEMENT_SEARCH_RESULT:
  33        ui()->search_browser((sfinx_pair_vector_t *)el);
  34        break;
  35      case SFINX_FILES_MODULE_EDIT_REQUEST:
  36        ui()->files_module_edit((sfinx_file_t *)el);
  37        break;
  38      case SFINX_ALERT:
  39        ui()->alert((sfinx_string_t *)el);
  40        break;
  41      case SFINX_NOTES_MODULE_ADD_REPLY:
  42        ui()->notes_module_reply((sfinx_string_t *)el);
  43        break;
  44      case SFINX_FILES_MODULE_EDIT_REPLY:
  45      case SFINX_FILES_MODULE_CLASSIFY_REPLY:
  46        ui()->files_module_edit_reply((sfinx_string_t *)el);
  47        break;
  48      case SFINX_ELEMENT_PROGRESS:
  49        ui()->progress((sfinx_progress_t *)el);
  50        break;
  51 //     case SFINX_FILES_MODULE_SORTED_TREE:
  52      case SFINX_FILES_MODULE_UNSORTED_TREE:
  53        ui()->fill_unsorted_files_tree((sfinx_files_vector_t *)el);
  54        break;
  55      case SFINX_FILES_MODULE_CONF:
  56        files_module_conf.copy(el);
  57        ui()->fill_preferences();
  58        break;
  59      case SFINX_EDIT_SLICE:
  60        ui()->edit_slice((sfinx_slice_t *)el);
  61        break;
  62      case SFINX_OBJECTS_TREE:
  63        slices.copy((sfinx_slice_vector_t *)el);
  64        slices_need_update = false;
  65        ui()->fill_objects_tree();
  66        break;
  67      default:
  68        log("sfinx:process", "Unknown element id - %s", sfinx_cmd2str(el->tid()));
  69        break;
  70    }
  71  }
  72   return false;
  73 }
  74
  75 // main loop
  76 void faraon_app::main()
  77 {
  78  sfinx.send(SFINX_FILES_MODULE_CONF_REQUEST, (u8_t) 0);
  79  // after connecting get all objects info
  80  refresh_slices(1);
  81  while(1) {
  82   if (sfinx.pending()) {
  83     if (process_requests()) {
  84       log("faraon:main", "Bad sfinx message");
  85       sfinx.disconnect();
  86       break;
  87    }
  88  }
  89   idle();
  90  }
  91 }
  92
  93 int main(int argc, char **argv)
  94 {
  95  setlocale(LC_ALL, "");
  96  char version[16];
  97  sprintf(version, "v%0d.%0d.%0d", SFINX_VERSION_MAJOR, SFINX_VERSION_MINOR, SFINX_VERSION_PLEVEL);
  98  app = new faraon_app(argc, argv, "faraon", version, "Harbour <Harbour@Sfinx.Od.UA>", "GPL");
  99  app->start_ui(); // start ui
 100  app->read_preferences();
 101  while(1) {
 102    try {
 103      if (!app->connected()) {
 104        if (app->connect())
 105          Thread::sleep(1000);
 106      } else
 107          app->main();
 108   }
 109    catch (SockException *s) {
 110       app->ui()->log(SFINX_LOG_FATAL, "Socket exception to %s",
 111         app->server_name.c_str());
 112       app->sfinx.disconnect();
 113       Thread::sleep(1000);
 114   }
 115     catch (Socket *s) {
 116       app->ui()->log(SFINX_LOG_FATAL, "Error connecting to %s: (%d) \'%s\'",
 117         app->server_name.c_str(), s->getErrorNumber(), s->getErrorString());
 118       Thread::sleep(1000);
 119   }
 120    catch (...) {
 121       app->ui()->log(SFINX_LOG_WARN, "Unknown exeption while talking to %s",
 122         app->server_name.c_str());
 123       app->sfinx.disconnect();
 124       Thread::sleep(1000);
 125   }
 126  } // while(1)
 127  return 0;
 128 }
 129
 130 bool faraon_app::connect()
 131 {
 132  if (!server_name.size()) {
 133    ui()->log(SFINX_LOG_FATAL, "Sfinx server name is not set !");
 134    return 1;
 135  }
 136  ui()->log(SFINX_LOG_NOTICE, "Connecting to Sfinx server at %s", server_name.c_str());
 137  // ask username/pass or select auth_type
 138  if (!sfinx.connect(server_name)) {
 139    char b[1024], b1[128];
 140    sprintf(b, "Connected to server v%d.%d.%d, %lld crypt facilities [ ",
 141      sfinx.daemon_version->get(0), sfinx.daemon_version->get(1),
 142      sfinx.daemon_version->get(2), sfinx.packet_crypt_types->len());
 143    for (u32_t i = 0; i < sfinx.packet_crypt_types->len(); i++) {
 144      sprintf(b1, "%s%s", i ? ", " : "",
 145        sfinx_cmd2str(sfinx.packet_crypt_types->get(i)));
 146      strcat(b, b1);
 147   }
 148    sprintf(b1, " ], %lld auth level [ ", sfinx.min_auth_levels->len());
 149    strcat(b, b1);
 150    for (u32_t i = 0; i < sfinx.min_auth_levels->len(); i++) {
 151      sprintf(b1, "%s%s", i ? ", " : "", sfinx_cmd2str(sfinx.min_auth_levels->get(i)));
 152      strcat(b, b1);
 153   }
 154    strcat(b, " ]");
 155    ui()->log(SFINX_LOG_NOTICE, b);
 156    strcpy(b, "md5 server challenge [ ");
 157    for (u32_t i = 0; i < sfinx.md5_challenge->len(); i++) {
 158      sprintf(b1, "%02x", sfinx.md5_challenge->get(i));
 159      strcat(b, b1);
 160   }
 161    strcat(b, " ]");
 162    ui()->log(SFINX_LOG_NOTICE, b);
 163    return 0;
 164  }
 165   return 1;
 166 }
 167
 168 void faraon_app::read_preferences()
 169 {
 170   char buf[128];
 171   Fl_Preferences conn_prefs(prefs, "Connection" );
 172   conn_prefs.get("Sfinx Server Name", buf, "localhost", 100);
 173   server_name = buf;
 174   if (connected())
 175     sfinx.send(SFINX_FILES_MODULE_CONF_REQUEST, (u8_t) 0);
 176 }
 177
 178 void faraon_app::write_preferences()
 179 {
 180   Fl_Preferences conn_prefs(prefs, "Connection" );
 181   conn_prefs.set("Sfinx Server Name", server_name.c_str());
 182   conn_prefs.flush();
 183   if (connected())
 184     sfinx.send(files_module_conf);
 185 }
 186
 187 // move to libsfinx
 188 string time2str(sfinx_timestamp_t &t)
 189 {
 190  char buf[64];
 191  int year, month, day, hour, min, sec;
 192  t.GetDate(year, month, day);
 193  t.GetTime(hour, min, sec);
 194  sprintf(buf, "%02d/%02d/%04d %02d:%02d:%02d\n", day, month, year, hour, min, sec);
 195  return string(buf);
 196 }
 197
 198 void faraon_app::prepare_search_info(sfinx_t *el, string &inf)
 199 {
 200  sfinx_file_t *f;
 201  sfinx_slice_t *s;
 202  sfinx_note_t *n;
 203  switch (el->tid()) {
 204    case SFINX_ELEMENT_SLICE:
 205      s = (sfinx_slice_t *)el;
 206      inf = "\nType: Slice\n";
 207      inf.append("Name: " + s->name_ + "\n");
 208      inf.append("Description: " + s->description_ + "\n");
 209      inf.append("Create Entry Time: " + time2str(s->ctime));
 210      inf.append("Edit Entry Time: " + time2str(s->etime));
 211      inf.append("\n");
 212      break;
 213    case SFINX_ELEMENT_NOTE:
 214      n = (sfinx_note_t *)el;
 215      inf = "\nType: Note\n";
 216      inf.append("Name: " + n->name + "\n");
 217      inf.append("URL: " + n->url + "\n");
 218      inf.append("Text: " + n->text + "\n");
 219      inf.append("Create Entry Time: " + time2str(n->ctime));
 220      inf.append("Edit Entry Time: " + time2str(n->etime));
 221      inf.append("\n");
 222      break;
 223    case SFINX_ELEMENT_FILE:
 224      f = (sfinx_file_t *)el;
 225      inf = "\nType: File\n";
 226      inf.append("Name: " + f->name + "\n");
 227      inf.append("Slice Hierarchy: " + app->slice_hierarchy(f->mtag.slice_id) + "\n");
 228      if (f->tags.size()) {
 229        inf.append("Additional Tags : ");
 230        for (u32_t i = 0; i < f->tags.size(); i++) {
 231          if (i)
 232            inf.append(", ");
 233          inf.append(f->tags[i].name + " [ " + f->tags[i].description + " ]");
 234        }
 235         inf.append("\n");
 236     }
 237      inf.append("Title: " + f->title + "\n");
 238      inf.append("Authority: " + f->authority + "\n");
 239      inf.append("Description: " + f->description + "\n");
 240      inf.append("Comments: " + f->comments + "\n");
 241      char buf[64];
 242      sprintf(buf, "%llu bytes\n", f->fsize);
 243      inf.append("Size: ");
 244      inf.append(buf);
 245      if (f->csum.size())
 246              inf.append("Csum: " + f->csum + "\n");
 247      sprintf(buf, "%llu bytes\n", f->compressed_fsize);
 248      inf.append("Compressed Size: ");
 249      inf.append(buf);
 250      if (f->compressed_csum.size())
 251              inf.append("Compressed Csum: " + f->compressed_csum + "\n");
 252      inf.append("Create Entry Time: " + time2str(f->ctime));
 253      inf.append("Edit Entry Time: " + time2str(f->etime));
 254            inf.append("\n");
 255      break;
 256    default:
 257      debug("Can't fill element info !");
 258      bug();
 259   }
 260 }