Initial community commit

1 files changed, 480 insertions, 0 deletions

diff --git a/Src/Wasabi/api/wac/compon.cpp b/Src/Wasabi/api/wac/compon.cpp
new file mode 100644
index 00000000..12f66313
--- /dev/null
+++ b/Src/Wasabi/api/wac/compon.cpp
@@ -0,0 +1,480 @@
+#include <precomp.h>
+
+#include <bfc/wasabi_std.h>
+
+#include "compon.h"
+//#include <api/wac/main.h> // CUT!
+
+#ifndef WASABINOMAINAPI
+#include <api/metadb/metadb.h>
+#include <api/wac/papi.h>
+#endif
+#include <api/script/objects/compoobj.h>
+#include <api/wndmgr/container.h>
+#include <api/skin/skinparse.h>
+#include <api/wac/wac.h>
+#include <api/script/objects/wacobj.h>
+#include <api/wnd/wndtrack.h>
+#include <api/script/objecttable.h>
+
+#include <api/config/items/cfgitemi.h>
+
+#include <bfc/loadlib.h>
+//#include <bfc/util/profiler.h>
+#include <api/locales/xlatstr.h>
+#include <bfc/file/recursedir.h>
+
+#include <api/service/svc_enum.h>
+#include <api/service/services.h>
+#include <api/service/servicei.h>
+#include <api/skin/skin.h>
+#include <api/script/scriptmgr.h>
+#include <bfc/parse/pathparse.h>
+
+#ifndef WASABINOMAINAPI
+#include <api/api1.h>
+#endif
+
+#include <api/application/wkc.h>
+#include <api/wndmgr/skinembed.h>
+#include <api/script/objects/compoobj.h>
+
+#include <api/wnd/usermsg.h>
+#include <bfc/util/inifile.h>
+
+class CShutdownCallback {
+  public:
+  virtual void rl_onShutdown()=0;
+};
+
+
+extern GUID baseGUID;
+
+static TList<GUID> loadlist, banlist;
+
+// compon.cpp : maintains the list of installed components, and installs
+// each one
+
+// keep a list of component pointers as well as instances
+class component_slot 
+{
+public:
+#ifndef WASABINOMAINAPI
+   component_slot(Library *_dll, WaComponent *_wac, ComponentAPI *_api, GUID g, const wchar_t *orig_path) 
+     : dll(_dll), wac(_wac), path(orig_path), guid(g), componentapi(_api) {
+#else
+   component_slot(Library *_dll, WaComponent *_wac, GUID g, const wchar_t *orig_path) 
+     : dll(_dll), wac(_wac), path(orig_path), guid(g) {
+#endif
+    int fnlen = wcslen(Wasabi::Std::filename(orig_path));
+    path.trunc(-fnlen);
+    postonregsvcs = 0;
+    postoncreate = 0;
+    loadearly = 0;	// will be filled in later
+  }
+  ~component_slot() {
+#ifndef WASABINOMAINAPI
+    if (dll != NULL) PAPI::destroyAPI(componentapi);
+#endif
+    delete dll;
+  }
+  void registerServices() {
+#ifndef WASABINOMAINAPI
+    if (!postonregsvcs) wac->registerServices(componentapi);
+#else
+    if (!postonregsvcs) wac->registerServices(WASABI_API_SVC);
+#endif
+    postonregsvcs = 1;
+  }
+  void onCreate() {
+    if (!postoncreate) wac->onCreate();
+    postoncreate = 1;
+  }
+
+  Library *dll;
+  WaComponent *wac; 	// we don't delete this
+  StringW path;
+  GUID guid;		// prevent spoofing
+#ifndef WASABINOMAINAPI
+  ComponentAPI *componentapi;
+#endif
+  int postoncreate;
+  int postonregsvcs;
+  int loadearly;
+};
+
+static PtrList<component_slot> components;
+
+/*static PtrList<cd_entry> cd_list;
+static PtrList<ComponentObject> co_list;*/
+
+// the minimum SDK version # we accept
+const int WA_COMPONENT_VER_MIN = WA_COMPONENT_VERSION;
+
+  static int postComponentCommand(GUID guid, const wchar_t *command, int p1, int p2, void *ptr, int ptrlen, int waitforanswer);
+
+class ComponPostEntry {
+public:
+  ComponPostEntry(GUID pguid, const wchar_t *pcommand, int pp1, int pp2, void *pptr, int pptrlen, int pwait) :
+    guid(pguid), command(pcommand), p1(pp1), p2(pp2), ptr(pptr), ptrlen(pptrlen), waitforanswer(pwait),
+      posted(0), result(0) { }
+  GUID guid;
+  StringW command;
+  int p1, p2;
+  void *ptr;
+  int ptrlen;
+  int waitforanswer;
+  int posted;
+  int result;
+};
+
+static PtrList<StringW> preloads;
+
+void ComponentManager::addStaticComponent(WaComponent *component) {
+  GUID guid = component->getGUID();
+  if (!checkGUID(guid)) return;	// guid check (banlist etc.)
+
+#ifndef WASABINOMAINAPI
+  // reuse main api *
+  components.addItem(new component_slot(NULL, component, api, guid, NULL));
+#else
+  components.addItem(new component_slot(NULL, component, guid, NULL));
+#endif
+}
+
+void ComponentManager::addPreloadComponent(const wchar_t *filename)
+{
+  foreach(preloads)
+    if (PATHEQL(filename, preloads.getfor()->getValue())) return;// no dups
+  endfor
+  preloads.addItem(new StringW(filename));
+}
+
+void ComponentManager::loadPreloads() {
+  foreach(preloads)
+    load(preloads.getfor()->getValue());
+  endfor
+  preloads.deleteAll();
+}
+
+void ComponentManager::load(const wchar_t *filename) {
+  // ensure no duplicate filenames
+  foreach(components)
+    if (PATHEQL(filename, components.getfor()->dll->getName())) return;
+  endfor
+
+  #ifdef WA3COMPATIBILITY
+  // let kernel controller test the file
+  WasabiKernelController *wkc = Main::getKernelController();
+  if (wkc && !wkc->testComponent(filename)) return;
+  #endif
+
+  // check if they have an ini (to get guid faster)
+  StringW inifile = filename;
+  const wchar_t *ext = Wasabi::Std::extension(inifile);
+	int len = wcslen(ext);
+  inifile.trunc(-len);
+  inifile.cat(L"ini");
+  IniFile ini(inifile);
+  GUID ini_guid = ini.getGuid(L"component", L"guid");
+  if (!checkGUID(ini_guid, TRUE)) return;
+
+//  PR_ENTER2("load component", filename);
+
+  // attach the DLL
+  Library *dll = new Library(filename);
+  if (!dll->load()) {
+    delete dll;
+    return;
+  }
+
+  // check the version of SDK it was compiled with
+  WACGETVERSION wac_get_version = (WACGETVERSION)dll->getProcAddress("WAC_getVersion");
+  if (wac_get_version == NULL) {
+    delete dll;
+    return;
+  }
+
+  int version = (*wac_get_version)();
+  if (version < WA_COMPONENT_VER_MIN ||	// defined above
+      version > WA_COMPONENT_VERSION) {	// from wac.h
+    delete dll;
+    return;
+  }
+
+  // init the dll itself
+  WACINIT wacinit = (WACINIT)dll->getProcAddress("WAC_init");
+  if (wacinit != NULL) (*wacinit)(dll->getHandle());
+
+  WACENUMCOMPONENT wec = (WACENUMCOMPONENT)dll->getProcAddress("WAC_enumComponent");
+  if (wec == NULL) {
+    delete dll;
+    return;
+  }
+
+  // fetch the pointer
+  WaComponent *wac = (*wec)(0);
+
+  GUID guid = wac->getGUID();
+
+  if (ini_guid != INVALID_GUID && guid != ini_guid) {
+    delete dll;
+    DebugString("guids didn't match! %s", filename);
+    return;
+  }
+
+  // check if we want to load this GUID
+  if (!checkGUID(guid)) {
+    delete dll;
+    return;
+  }
+
+#ifndef WASABINOMAINAPI
+  // allocate an api pointer bound to their GUID
+  ComponentAPI *newapi = PAPI::createAPI(wac, guid);
+  if (newapi == NULL) {
+    delete dll;
+    return;
+  }
+#endif
+
+  PathParserW pp(filename);
+  StringW path;
+  for (int i=0;i<pp.getNumStrings()-1;i++) 
+	{
+		path.AppendFolder(pp.enumString(i));
+  }
+
+  wac->setComponentPath(path);
+
+  // keep track of dll handles for shutdown
+  components.addItem(new component_slot(dll, wac, 
+#ifndef WASABINOMAINAPI
+  newapi, 
+#endif
+  guid, filename));
+
+//  PR_LEAVE();
+}
+
+const wchar_t *ComponentManager::getComponentPath(GUID g) {
+  foreach(components)
+    if (g == components.getfor()->guid) {
+      return components.getfor()->path;
+    }
+  endfor
+  return NULL;
+}
+
+void ComponentManager::startupDBs() {
+/*  for (int i=0;i<components.getNumItems();i++)
+    MetaDB::addComponentDB(components.enumItem(i)->wac);*/
+}
+
+void ComponentManager::shutdownDBs() {
+#ifndef WASABINOMAINAPI
+  for (int i = 0; i < components.getNumItems(); i++) {
+    //MetaDB::getBaseDB()->removeComponentDB(components[i]->wac);
+    (static_cast<ComponentAPI1 *>(components[i]->componentapi))->shutdownDB();
+  }
+#else
+//MULTIAPI-FIXME: solve the shutdownDB puzzle
+#endif
+}
+
+void ComponentManager::unloadAll() {
+  // cable out! let 'er go!
+//  deleteAllCD(); // deletes compwnds
+  foreach(components)
+    components.getfor()->wac->deregisterServices();
+  endfor
+  foreach(components)
+    components.getfor()->wac->onDestroy();
+  endfor
+  components.deleteAll();	// free the DLLs, and kill their API *'s
+}
+
+int ComponentManager::checkGUID(GUID &g, int invalid_ok) {
+  // no invalid guid
+  if (!invalid_ok && g == INVALID_GUID) return FALSE;
+
+  // check against banlist
+  if (banlist.haveItem(g)) return FALSE;
+
+  // check against load-only list
+  if (loadlist.getNumItems() && !loadlist.haveItem(g)) return FALSE;
+
+  // ensure no duplicate GUIDs
+  foreach(components)
+    if (g == components.getfor()->guid) {
+//CUT      StringPrintf s("%s and %s", components.getfor()->dll->getName(), filename);
+//CUT      Std::messageBox(s, "Duplicate component guid", MB_OK);
+      return FALSE;
+    }
+  endfor
+
+  // ok
+  return TRUE;
+}
+
+WaComponent *ComponentManager::enumComponent(int component) {
+  if (component < 0 || component >= components.getNumItems()) return NULL;
+  return components[component]->wac;
+}
+
+void ComponentManager::loadAll(const wchar_t *path) {
+
+#if 0//CUT
+  static const char *loadorder[] = {
+    "wasabi.system/pngload.wac",
+    "wasabi.player/core.wac",
+    "metrics.wac", // so metrics dialog appears before the splash screen
+    "winamp/winamp.wac", // so splash screen displays right after startup
+    "winamp/pledit.wac",
+    "winamp/library.wac",
+    "preferences.wac", // so prefs has the system groups at the top
+    "skinswitch.wac", // so skinswitch is the first non internal prefs screen, ignored if not present. fucko: need to modify prefs system so we don't need to load in any particular order
+    NULL
+  };
+
+  for (int i = 0; loadorder[i] != NULL; i++) {
+    StringPrintf fn("%s%s%s", WACDIR, DIRCHARSTR, loadorder[i]);
+    ComponentManager::load(fn);
+  }
+#endif
+	RecurseDir dir(path, L"*.*");// have to do *.* to get subdirs
+  while (dir.next()) {
+		StringPathCombine fn(dir.getPath(), dir.getFilename());
+    const wchar_t *ext = Wasabi::Std::extension(fn);
+    if (!WCSICMP(ext, L"wac"))
+      ComponentManager::load(fn);
+  }
+}
+
+void ComponentManager::postLoad(int f) { // two-level startup procedure
+  // note we're calling the slot, not the component directly
+
+  // allow punk-ass bitches to load early if need be
+  foreach(components)
+    if ((components.getfor()->loadearly = !!components.getfor()->wac->onNotify(WAC_NOTIFY_LOADEARLY))) {
+      components.getfor()->registerServices();
+    }
+  endfor
+
+  foreach(components)
+    if (!components.getfor()->loadearly)
+      components.getfor()->registerServices();
+  endfor
+  foreach(components)
+    components.getfor()->onCreate();
+  endfor
+  if (f) ObjectTable::loadExternalClasses();
+}
+
+void ComponentManager::broadcastNotify(int cmd, int param1, int param2) {
+  foreach(components)
+    if ((components.getfor()->loadearly = !!components.getfor()->wac->onNotify(WAC_NOTIFY_LOADEARLY, cmd, param1, param2)))
+      components.getfor()->wac->onNotify(cmd, param1, param2);
+  endfor
+  foreach(components)
+    if (!components.getfor()->loadearly)
+      components.getfor()->wac->onNotify(cmd, param1, param2);
+  endfor
+}
+
+void ComponentManager::sendNotify(GUID guid, int cmd, int param1, int param2) {
+  WaComponent *wac = getComponentFromGuid(guid);
+  if (wac)
+    wac->onNotify(cmd, param1, param2);
+}
+
+int ComponentManager::sendCommand(GUID guid, const wchar_t *command, int p1, int p2, void *ptr, int ptrlen) {
+  if (command == NULL) return 0;
+  WaComponent *wac = getComponentFromGuid(guid);
+  if (wac) return wac->onCommand(command, p1, p2, ptr, ptrlen);
+  return 0;
+}
+
+int ComponentManager::postCommand(GUID guid, const wchar_t *command, int p1, int p2, void *ptr, int ptrlen, int waitforanswer) {
+#ifdef WA3COMPATIBILITY // todo: make thread id part of application api
+  if(Std::getCurrentThreadId()==Main::getThreadId() && waitforanswer) {
+    // if it is already the main thread calling, just pass the command to sendCommand
+    return sendCommand(guid,command,p1,p2,ptr,ptrlen);
+  }
+#endif
+  ComponPostEntry *cpe=new ComponPostEntry(guid,command,p1,p2,ptr,ptrlen,waitforanswer);
+  componPostEntries.addItem(cpe);
+#ifdef WIN32
+#ifdef WA3COMPATIBILITY // todo: make this a call to application api
+  PostMessage(Main::gethWnd(),UMSG_COMPON_POSTMESSAGE,0,0); // ask the main thread to call mainthreadpostCommands();
+#endif
+#else
+  PostMessage(None,UMSG_COMPON_POSTMESSAGE,0,0); // ask the main thread to call mainthreadpostCommands();
+#endif
+  if(waitforanswer) {
+    while(!cpe->posted) Sleep(1);
+    int res=cpe->result;
+    componPostEntries.removeItem(cpe);
+    delete(cpe);
+    return res;
+  }
+  return 0; // cpe will get deleted by mainthreadpostCommands();
+}
+
+
+void ComponentManager::broadcastCommand(const wchar_t *command, int p1, int p2, void *ptr, int ptrlen) {
+  if (command == NULL) return;
+  for (int i = 0; i < components.getNumItems(); i++) {
+    components[i]->wac->onCommand(command, p1, p2, ptr, ptrlen);
+  }
+}
+
+int ComponentManager::getNumComponents() {
+  return components.getNumItems();
+}
+
+GUID ComponentManager::getComponentGUID(int c) {
+  if (c >= components.getNumItems()) return INVALID_GUID;
+  return components[c]->guid;
+}
+
+const wchar_t *ComponentManager::getComponentName(GUID g)
+{
+  WaComponent *wac = getComponentFromGuid(g);
+  if (wac)
+    return wac->getName();
+  return NULL;
+}
+
+CfgItem *ComponentManager::getCfgInterface(GUID g) {
+  WaComponent *wac = getComponentFromGuid(g);
+  if (wac == NULL) return NULL;
+  return wac->getCfgInterface(0);
+}
+
+WaComponent *ComponentManager::getComponentFromGuid(GUID g) {
+  if (g == INVALID_GUID) return NULL;
+  for (int i=0;i<components.getNumItems();i++) {
+    if (g == components[i]->guid)
+      return components[i]->wac;
+  }
+  return NULL;
+}
+
+void ComponentManager::mainThread_handlePostCommands() {
+  // critical section
+  for(int i=0;i<componPostEntries.getNumItems();i++) {
+    ComponPostEntry *cpe=componPostEntries[i];
+    if(!cpe->posted) {
+      sendCommand(cpe->guid,cpe->command.getValue(),cpe->p1,cpe->p2,cpe->ptr,cpe->ptrlen);
+      if(cpe->waitforanswer) cpe->posted=1;
+      else {
+        delete cpe;
+        componPostEntries.removeByPos(i);
+        i--;
+      }
+    }
+  }
+}
+
+PtrList<ComponPostEntry> ComponentManager::componPostEntries;