Changeset 15002 for gsdl/trunk/src/colservr/collectset.cpp

Timestamp:

2008-02-22T11:25:40+13:00 (16 years ago)

Author:

davidb

Message:

Collections can now be put in to "groups" i.e. can be located inside another collection, which is marked as "collectgroup" true. The top-level collection appears on the home page, and when clicked upon display a new "home page" with only the collections appearing within its folder displayed. To implement this, the main change is in collectset.cpp, which now runs "add_all_collection_groups" after it has added all the top-level collections. comtypes.h has been updated to include the new field, "isCollectGroup". Finally, pageaction.cpp has been updated so these changes are reflected in the home page generated.

File:

• gsdl/trunk/src/colservr/collectset.cpp (modified) (10 diffs)

gsdl/trunk/src/colservr/collectset.cpp

@@ -51 +51 @@
   // get gsdlhome (if we fail the error will be picked up later -- in
   // cgiwrapper)
+
   if (site_cfg_read (gsdlhome, httpdomain, httpprefix)) {
     if (!gsdlhome.empty() && directory_exists(gsdlhome)) {
@@ -66 +67 @@
       }
 
-      // read config file to see if built with mg, mgpp, or lucene
-      text_t buildtype = "mg"; // mg is default
-      text_tarray cfgline;
-      text_t key;
-      text_t filename = filename_cat(collectdir, *thiscol, "index" , "build.cfg");
-      ifstream confin(filename.getcstr());
-
-      if (confin) {
-        while (read_cfg_line(confin, cfgline) >= 0) {
-          if (cfgline.size() ==2 ) {
-        key = cfgline[0];
-        cfgline.erase(cfgline.begin());
-        if (key =="buildtype") {
-          buildtype = cfgline[0];
-          break;
-        }
-          }
-        }
-      }
-      
-      confin.close();
-
-      // this memory is created but never destroyed
-      // we're also not doing any error checking to make sure we didn't
-      // run out of memory
-      collectserver *cserver = new collectserver();
-      gdbmclass *gdbmhandler = new gdbmclass();
-    
-      // add a null filter
-      filterclass *filter = new filterclass ();
-      cserver->add_filter (filter);
-      
-      // add a browse filter
-      browsefilterclass *browsefilter = new browsefilterclass();
-      browsefilter->set_gdbmptr (gdbmhandler);
-      cserver->add_filter (browsefilter);
-      
-      if (buildtype == "mg") {
-        mgsearch = new mgsearchclass();
-        
-        // add a query filter
-        mgqueryfilterclass *queryfilter = new mgqueryfilterclass();
-        queryfilter->set_gdbmptr (gdbmhandler);
-        queryfilter->set_textsearchptr (mgsearch);
-        cserver->add_filter (queryfilter);
-        
-        // add a mg and gdbm source
-        mggdbmsourceclass *mggdbmsource = new mggdbmsourceclass ();
-        mggdbmsource->set_gdbmptr (gdbmhandler);
-        mggdbmsource->set_textsearchptr (mgsearch);
-        cserver->add_source (mggdbmsource);
-
-      }
-      else if (buildtype == "mgpp") {
-        
-        mgppsearch = new mgppsearchclass();
-                
-        // add a query filter
-        mgppqueryfilterclass *queryfilter = new mgppqueryfilterclass();
-        queryfilter->set_gdbmptr (gdbmhandler);
-        queryfilter->set_textsearchptr (mgppsearch);
-        cserver->add_filter (queryfilter);
-        
-        // add a mg and gdbm source
-        mggdbmsourceclass *mggdbmsource = new mggdbmsourceclass ();
-        mggdbmsource->set_gdbmptr (gdbmhandler);
-        mggdbmsource->set_textsearchptr (mgppsearch);
-        cserver->add_source (mggdbmsource);   
-      }
-      else if (buildtype == "lucene") {
-        lucenesearch = new lucenesearchclass();
-        lucenesearch->set_gsdlhome(gsdlhome);
-
-        // add a query filter
-        lucenequeryfilterclass *queryfilter = new lucenequeryfilterclass();
-        queryfilter->set_gdbmptr (gdbmhandler);
-        queryfilter->set_textsearchptr (lucenesearch);
-        cserver->add_filter (queryfilter);
-        
-        // add a lucene and gdbm source
-        lucenegdbmsourceclass *lucenegdbmsource = new lucenegdbmsourceclass ();
-        lucenegdbmsource->set_gdbmptr (gdbmhandler);
-        lucenegdbmsource->set_textsearchptr (lucenesearch);
-        cserver->add_source (lucenegdbmsource);   
-      }
-
-
-      // inform collection server and everything it contains about its
-      // collection name
-      cserver->configure ("collection", *thiscol);
-      // AZIZ: added on 10/10/00
-      //       the cserver object does not have a reference to gsdlhome
-      cserver->configure ("gsdlhome", gsdlhome);
-    
-      // GRB: removed    proto.add_collectserver (cserver);
-      // GRB: added to build our own cservers list
-      cservers.addcollectserver (cserver);
+      this->add_collection (*thiscol, gsdlhome);
 
       ++thiscol;
     }
+
+    this->add_all_collection_groups(gsdlhome);
       }
     }
@@ -198 +105 @@
       // are available to decode defaultindex, defaultsubcollection, and
       // defaultlanguage
+
+      bool failed_build_cfg = false;
       if (!build_cfg_read (*((*here).second.c), configinfo.gsdlhome,
                configinfo.collection)) {
+    failed_build_cfg = true;
+
     outconvertclass text_t2ascii;
     logout << text_t2ascii 
@@ -205 +116 @@
            << configinfo.collection << "\", gsdlhome=\""
            << configinfo.gsdlhome << "\"\n";
-    ++here;
-    continue;
-      }
-
+      }
+
+      bool failed_collect_cfg = false;
       if (!collect_cfg_read (*((*here).second.c), configinfo.gsdlhome,
                  configinfo.collection)) {
+    failed_collect_cfg = true;
     outconvertclass text_t2ascii;
     logout << text_t2ascii 
@@ -216 +127 @@
            << configinfo.collection << "\", gsdlhome=\"" 
            << configinfo.gsdlhome << "\"\n";
+      }
+
+      
+      bool is_colgroup = (*here).second.c->is_collection_group();
+
+      if (failed_collect_cfg) {
     ++here;
     continue;
       }
+
+      if (failed_build_cfg && (!is_colgroup)) {
+    ++here;
+    continue;
+      }
+      // let a failed build.cfg through if its 'collect.cfg' marks it as 'collectgroup true'
 
       if (!(*here).second.c->init (logout)) return false;
@@ -258 +181 @@
       ++thiscol;
     }
+
+    this->add_all_collection_groups(gsdlhome);
   }
 }
@@ -266 +191 @@
                  const text_t &gsdlhome) {
 
-  // if an old collection server exists for this collection we should
-  // delete it first
-  collectservermapclass::iterator here = cservers.begin();
-  collectservermapclass::iterator end = cservers.end();
-  while (here != end) {
-    if ((*here).second.c != NULL && (*here).first == collection) {
-      delete (*here).second.c;
-      cservers.erase (here);
-      break;
-    }
-    ++here;
-  }
-      
+  this->remove_collection(collection);
+  
   // read config file to see if built with mg, mgpp, or lucene
   // -- we can rely on the collection (and therefore the build.cfg)
@@ -371 +285 @@
   cserver->configure ("gsdlhome", gsdlhome);
 
-  /* Removed from add_collection 24/11/2000; already done elsewhere in collectset.  
-  // configure receptionist's collectinfo structure 
-  text_tarray colinfo;
-  colinfo.push_back (collection);
-  colinfo.push_back (gsdlhome);
-  colinfo.push_back (gdbmhome);
-  */
   cservers.addcollectserver (cserver);
 }
@@ -399 +306 @@
   }
   cservers.clear();
+}
+
+void collectset::add_collection_group(const text_t& collection, 
+                      const text_t& gsdlhome)
+{
+  text_tarray group;
+  text_t collect_group_dir = filename_cat (gsdlhome, "collect", collection);
+
+  // need to read collect.cfg for 'collectgroup' as class hasn't been initialised through 'init' yet
+  text_t is_collect_group;
+  text_tarray cfgline;
+  text_t key;
+  text_t build_cfg = filename_cat(gsdlhome, "collect", collection, "etc", "collect.cfg");
+  char *collect_cfgc = build_cfg.getcstr();
+  ifstream confin(collect_cfgc);
+
+  if (confin) {
+    while (read_cfg_line(confin, cfgline) >= 0) {
+      if (cfgline.size() == 2) {
+    key = cfgline[0];
+    cfgline.erase(cfgline.begin());
+    if (key == "collectgroup") {
+      is_collect_group = cfgline[0];
+      break;
+    }
+      }
+    }
+    confin.close();
+  }
+  delete []collect_cfgc;
+
+  if (is_collect_group == "true") {
+
+    if (read_dir (collect_group_dir, group)) {
+      
+      text_tarray::const_iterator thiscol = group.begin();
+      text_tarray::const_iterator endcol = group.end();
+      
+      while (thiscol != endcol) {
+    // ignore the modelcol
+    if (*thiscol == "etc") {
+      ++thiscol;
+      continue;
+    }
+    
+    this->add_collection (collection + "/" + *thiscol, gsdlhome);
+    
+    ++thiscol;
+      }
+    }
+  }
+}
+
+void collectset::add_all_collection_groups (const text_t& gsdlhome) 
+
+{
+  collectservermapclass::iterator here = cservers.begin();
+  collectservermapclass::iterator end = cservers.end();
+  
+  while (here != end) {
+    text_t collection = (*here).second.c->get_collection_name();
+    this->add_collection_group(collection,gsdlhome);
+
+    ++here;
+  }
+}
+
+
+// remove_collection deletes the collection server of collection.
+// This only needs to be called if a collectionserver is to be
+// removed while the library is running. The destructor function
+// cleans up all collectservers when the program exits.
+void collectset::remove_collection (const text_t &collection) {
+
+  // do nothing if no collection server exists for this collection 
+  if (cservers.getcollectserver(collection) == NULL) return;
+
+  // first unload any cached mg databases - we may need to do something
+  // similar to this for mgpp and lucene too
+  if (mgsearch != NULL) {
+    mgsearch->unload_database();
+  }
+
+  // now delete the collection server object
+  collectservermapclass::iterator here = cservers.begin();
+  collectservermapclass::iterator end = cservers.end();
+
+  while (here != end) {
+    if ((*here).second.c != NULL && (*here).first == collection) {
+      delete (*here).second.c;
+      cservers.erase (here);
+      return;
+    }
+    ++here;
+  }
 }
 
@@ -408 +410 @@
 void collectset::remove_collection (const text_t &collection, ostream &logout) {
 
-  // do nothing if no collection server exists for this collection 
-  if (cservers.getcollectserver(collection) == NULL) return;
-
-  // first unload any cached mg databases - we may need to do something
-  // similar to this for mgpp and lucene too
-  if (mgsearch != NULL) {
-    mgsearch->unload_database();
-  }
-
-  // now delete the collection server object
-  collectservermapclass::iterator here = cservers.begin();
-  collectservermapclass::iterator end = cservers.end();
-
-  while (here != end) {
-    if ((*here).second.c != NULL && (*here).first == collection) {
-      delete (*here).second.c;
-      cservers.erase (here);
-      return;
-    }
-    ++here;
-  }
+  remove_collection(collection);
+
   outconvertclass text_t2ascii;
   logout << text_t2ascii << "nullproto::remove_collection: failed to remove collectserver for "