Some refactoring of global JavaScript objects

src/FileSystemJsObject.cpp

 #include <AdblockPlus/FileSystem.h>
 #include <stdexcept>
 #include <sstream>
 #include <vector>
 
+#include <AdblockPlus/JsEngine.h>
+#include <AdblockPlus/JsValue.h>
 #include "FileSystemJsObject.h"
 #include "Utils.h"
 #include "Thread.h"
 #include "Utils.h"
 
 using namespace AdblockPlus;
 
 namespace
 {
   class IoThread : public Thread
   {
   public:
-    IoThread(FileSystem& fileSystem, v8::Handle<v8::Function> callback)
-      : isolate(v8::Isolate::GetCurrent()),
-        context(v8::Persistent<v8::Context>::New(isolate,
-                                                 v8::Context::GetCurrent())),
-        fileSystem(fileSystem),
-        callback(v8::Persistent<v8::Function>::New(isolate, callback))
+    IoThread(JsEngine& jsEngine, JsValuePtr callback)
+      : jsEngine(jsEngine), fileSystem(jsEngine.GetFileSystem()),
+        callback(callback)
     {
     }
 
-    virtual ~IoThread()
-    {
-      callback.Dispose(isolate);
-      context.Dispose(isolate);
-    }
-
   protected:
-    v8::Isolate* const isolate;
-    v8::Persistent<v8::Context> context;
+    JsEngine& jsEngine;
     FileSystem& fileSystem;
-    v8::Persistent<v8::Function> callback;
+    JsValuePtr callback;
   };
 
   class ReadThread : public IoThread
   {
   public:
-    ReadThread(FileSystem& fileSystem, v8::Handle<v8::Function> callback,
+    ReadThread(JsEngine& jsEngine, JsValuePtr callback,
                const std::string& path)
-      : IoThread(fileSystem, callback), path(path)
+      : IoThread(jsEngine, callback), path(path)
     {
     }
 
     void Run()
     {
       std::string content;
       std::string error;
       try
       {
         std::tr1::shared_ptr<std::istream> stream = fileSystem.Read(path);
         content = Utils::Slurp(*stream);
       }
       catch (std::exception& e)
       {
         error = e.what();
       }
       catch (...)
       {
         error =  "Unknown error while reading from " + path;
       }
 
-      const v8::Locker locker(isolate);
-      const v8::HandleScope handleScope;
-      const v8::Context::Scope contextScope(context);
-      v8::Handle<v8::Object> result = v8::Object::New();
-      result->Set(v8::String::New("content"), Utils::ToV8String(content));
-      result->Set(v8::String::New("error"), Utils::ToV8String(error));
-      callback->Call(callback, 1,
-                     reinterpret_cast<v8::Handle<v8::Value>*>(&result));
+      const JsEngine::Context context(jsEngine);
+      JsValuePtr result = jsEngine.NewObject();
+      result->SetProperty("content", content);
+      result->SetProperty("error", error);
+      JsValueList params;
+      params.push_back(result);
+      callback->Call(params);
       delete this;
     }
 
   private:
     std::string path;
   };
 
   class WriteThread : public IoThread
   {
   public:
-    WriteThread(FileSystem& fileSystem, v8::Handle<v8::Function> callback,
+    WriteThread(JsEngine& jsEngine, JsValuePtr callback,
                 const std::string& path, const std::string& content)
-      : IoThread(fileSystem, callback), path(path), content(content)
+      : IoThread(jsEngine, callback), path(path), content(content)
     {
     }
 
     void Run()
     {
       std::string error;
       try
       {
         std::tr1::shared_ptr<std::ostream> stream(new std::stringstream);
         *stream << content;
         fileSystem.Write(path, stream);
       }
       catch (std::exception& e)
       {
         error = e.what();
       }
       catch (...)
       {
         error = "Unknown error while writing to " + path;
       }
 
-      const v8::Locker locker(isolate);
-      const v8::HandleScope handleScope;
-      const v8::Context::Scope contextScope(context);
-      v8::Handle<v8::Value> errorValue = Utils::ToV8String(error);
-      callback->Call(callback, 1, &errorValue);
+      const JsEngine::Context context(jsEngine);
+      JsValuePtr errorValue = jsEngine.NewValue(error);
+      JsValueList params;
+      params.push_back(errorValue);
+      callback->Call(params);
       delete this;
     }
 
   private:
     std::string path;
     std::string content;
   };
 
   class MoveThread : public IoThread
   {
   public:
-    MoveThread(FileSystem& fileSystem, v8::Handle<v8::Function> callback,
+    MoveThread(JsEngine& jsEngine, JsValuePtr callback,
                const std::string& fromPath, const std::string& toPath)
-      : IoThread(fileSystem, callback), fromPath(fromPath), toPath(toPath)
+      : IoThread(jsEngine, callback), fromPath(fromPath), toPath(toPath)
     {
     }
 
     void Run()
     {
       std::string error;
       try
       {
         fileSystem.Move(fromPath, toPath);
       }
       catch (std::exception& e)
       {
         error = e.what();
       }
       catch (...)
       {
         error = "Unknown error while moving " + fromPath + " to " + toPath;
       }
 
-      const v8::Locker locker(isolate);
-      const v8::HandleScope handleScope;
-      const v8::Context::Scope contextScope(context);
-      v8::Handle<v8::Value> errorValue = Utils::ToV8String(error);
-      callback->Call(callback, 1, &errorValue);
+      const JsEngine::Context context(jsEngine);
+      JsValuePtr errorValue = jsEngine.NewValue(error);
+      JsValueList params;
+      params.push_back(errorValue);
+      callback->Call(params);
       delete this;
     }
 
   private:
     std::string fromPath;
     std::string toPath;
   };
 
   class RemoveThread : public IoThread
   {
   public:
-    RemoveThread(FileSystem& fileSystem, v8::Handle<v8::Function> callback,
+    RemoveThread(JsEngine& jsEngine, JsValuePtr callback,
                  const std::string& path)
-      : IoThread(fileSystem, callback), path(path)
+      : IoThread(jsEngine, callback), path(path)
     {
     }
 
     void Run()
     {
       std::string error;
       try
       {
         fileSystem.Remove(path);
       }
       catch (std::exception& e)
       {
         error = e.what();
       }
       catch (...)
       {
         error = "Unknown error while removing " + path;
       }
 
-      const v8::Locker locker(isolate);
-      const v8::HandleScope handleScope;
-      const v8::Context::Scope contextScope(context);
-      v8::Handle<v8::Value> errorValue = Utils::ToV8String(error);
-      callback->Call(callback, 1, &errorValue);
+      const JsEngine::Context context(jsEngine);
+      JsValuePtr errorValue = jsEngine.NewValue(error);
+      JsValueList params;
+      params.push_back(errorValue);
+      callback->Call(params);
       delete this;
     }
 
   private:
     std::string path;
   };
 
   class StatThread : public IoThread
   {
   public:
-    StatThread(FileSystem& fileSystem, v8::Handle<v8::Function> callback,
+    StatThread(JsEngine& jsEngine, JsValuePtr callback,
                const std::string& path)
-      : IoThread(fileSystem, callback), path(path)
+      : IoThread(jsEngine, callback), path(path)
     {
     }
 
     void Run()
     {
       std::string error;
       FileSystem::StatResult statResult;
       try
       {
         statResult = fileSystem.Stat(path);
       }
       catch (std::exception& e)
       {
         error = e.what();
       }
       catch (...)
       {
         error = "Unknown error while calling stat on " + path;
       }
 
-      const v8::Locker locker(isolate);
-      const v8::HandleScope handleScope;
-      const v8::Context::Scope contextScope(context);
-      v8::Handle<v8::Object> result = v8::Object::New();
-      result->Set(v8::String::New("exists"),
-                  v8::Boolean::New(statResult.exists));
-      result->Set(v8::String::New("isFile"),
-                  v8::Boolean::New(statResult.isFile));
-      result->Set(v8::String::New("isDirectory"),
-                  v8::Boolean::New(statResult.isDirectory));
-      result->Set(v8::String::New("lastModified"),
-                  v8::Integer::New(statResult.lastModified));
-      result->Set(v8::String::New("error"), Utils::ToV8String(error));
-      callback->Call(callback, 1,
-                     reinterpret_cast<v8::Handle<v8::Value>*>(&result));
+      const JsEngine::Context context(jsEngine);
+      JsValuePtr result = jsEngine.NewObject();
+      result->SetProperty("exists", statResult.exists);
+      result->SetProperty("isFile", statResult.isFile);
+      result->SetProperty("isDirectory", statResult.isDirectory);
+      result->SetProperty("lastModified", statResult.lastModified);
+      result->SetProperty("error", error);
+
+      JsValueList params;
+      params.push_back(result);
+      callback->Call(params);
       delete this;
     }
 
   private:
     std::string path;
   };
 
   v8::Handle<v8::Value> ReadCallback(const v8::Arguments& arguments)
   {
-    const v8::Handle<const v8::External> external =
-      v8::Handle<const v8::External>::Cast(arguments.Data());
-    FileSystem* const fileSystem = static_cast<FileSystem*>(external->Value());
-    if (arguments.Length() != 2)
+    AdblockPlus::JsEngine& jsEngine = AdblockPlus::JsEngine::FromArguments(arguments);
+    AdblockPlus::JsValueList converted = jsEngine.ConvertArguments(arguments);
+
+    if (converted.size() != 2)
       return v8::ThrowException(v8::String::New(
         "_fileSystem.read requires 2 parameters"));
-    const std::string path = Utils::FromV8String(arguments[0]);
-    v8::Handle<v8::Value> callbackValue = arguments[1];
-    if (!callbackValue->IsFunction())
+    if (!converted[1]->IsFunction())
       return v8::ThrowException(v8::String::New(
         "Second argument to _fileSystem.read must be a function"));
-    v8::Handle<v8::Function> callback =
-      v8::Handle<v8::Function>::Cast(callbackValue);
-    ReadThread* const readThread = new ReadThread(*fileSystem, callback, path);
+    ReadThread* const readThread = new ReadThread(jsEngine, converted[1],
+        converted[0]->AsString());
     readThread->Start();
     return v8::Undefined();
   }
 
   v8::Handle<v8::Value> WriteCallback(const v8::Arguments& arguments)
   {
-    const v8::Handle<const v8::External> external =
-      v8::Handle<const v8::External>::Cast(arguments.Data());
-    FileSystem* const fileSystem = static_cast<FileSystem*>(external->Value());
-    if (arguments.Length() != 3)
+    AdblockPlus::JsEngine& jsEngine = AdblockPlus::JsEngine::FromArguments(arguments);
+    AdblockPlus::JsValueList converted = jsEngine.ConvertArguments(arguments);
+
+    if (converted.size() != 3)
       return v8::ThrowException(v8::String::New(
         "_fileSystem.write requires 3 parameters"));
-    const std::string path = Utils::FromV8String(arguments[0]);
-    const std::string content = Utils::FromV8String(arguments[1]);
-    v8::Handle<v8::Value> callbackValue = arguments[2];
-    if (!callbackValue->IsFunction())
+    if (!converted[2]->IsFunction())
       return v8::ThrowException(v8::String::New(
         "Third argument to _fileSystem.write must be a function"));
-    v8::Handle<v8::Function> callback =
-      v8::Handle<v8::Function>::Cast(callbackValue);
-    WriteThread* const writeThread = new WriteThread(*fileSystem, callback,
-                                                     path, content);
+    WriteThread* const writeThread = new WriteThread(jsEngine, converted[2],
+        converted[0]->AsString(), converted[1]->AsString());
     writeThread->Start();
     return v8::Undefined();
   }
 
   v8::Handle<v8::Value> MoveCallback(const v8::Arguments& arguments)
   {
-    const v8::Handle<const v8::External> external =
-      v8::Handle<const v8::External>::Cast(arguments.Data());
-    FileSystem* const fileSystem = static_cast<FileSystem*>(external->Value());
-    if (arguments.Length() != 3)
+    AdblockPlus::JsEngine& jsEngine = AdblockPlus::JsEngine::FromArguments(arguments);
+    AdblockPlus::JsValueList converted = jsEngine.ConvertArguments(arguments);
+
+    if (converted.size() != 3)
       return v8::ThrowException(v8::String::New(
         "_fileSystem.move requires 3 parameters"));
-    const std::string fromPath = Utils::FromV8String(arguments[0]);
-    const std::string toPath = Utils::FromV8String(arguments[1]);
-    v8::Handle<v8::Value> callbackValue = arguments[2];
-    if (!callbackValue->IsFunction())
+    if (!converted[2]->IsFunction())
       return v8::ThrowException(v8::String::New(
         "Third argument to _fileSystem.move must be a function"));
-    v8::Handle<v8::Function> callback =
-      v8::Handle<v8::Function>::Cast(callbackValue);
-    MoveThread* const moveThread = new MoveThread(*fileSystem, callback,
-                                                  fromPath, toPath);
+    MoveThread* const moveThread = new MoveThread(jsEngine, converted[2],
+        converted[0]->AsString(), converted[1]->AsString());
     moveThread->Start();
     return v8::Undefined();
   }
 
   v8::Handle<v8::Value> RemoveCallback(const v8::Arguments& arguments)
   {
-    const v8::Handle<const v8::External> external =
-      v8::Handle<const v8::External>::Cast(arguments.Data());
-    FileSystem* const fileSystem = static_cast<FileSystem*>(external->Value());
-    if (arguments.Length() != 2)
+    AdblockPlus::JsEngine& jsEngine = AdblockPlus::JsEngine::FromArguments(arguments);
+    AdblockPlus::JsValueList converted = jsEngine.ConvertArguments(arguments);
+
+    if (converted.size() != 2)
       return v8::ThrowException(v8::String::New(
         "_fileSystem.remove requires 2 parameters"));
-    const std::string path = Utils::FromV8String(arguments[0]);
-    v8::Handle<v8::Value> callbackValue = arguments[1];
-    if (!callbackValue->IsFunction())
+    if (!converted[1]->IsFunction())
       return v8::ThrowException(v8::String::New(
         "Second argument to _fileSystem.remove must be a function"));
-    v8::Handle<v8::Function> callback =
-      v8::Handle<v8::Function>::Cast(callbackValue);
-    RemoveThread* const removeThread = new RemoveThread(*fileSystem, callback,
-                                                        path);
+    RemoveThread* const removeThread = new RemoveThread(jsEngine, converted[1],
+        converted[0]->AsString());
     removeThread->Start();
     return v8::Undefined();
   }
 
   v8::Handle<v8::Value> StatCallback(const v8::Arguments& arguments)
   {
-    const v8::Handle<const v8::External> external =
-      v8::Handle<const v8::External>::Cast(arguments.Data());
-    FileSystem* const fileSystem = static_cast<FileSystem*>(external->Value());
-    if (arguments.Length() != 2)
+    AdblockPlus::JsEngine& jsEngine = AdblockPlus::JsEngine::FromArguments(arguments);
+    AdblockPlus::JsValueList converted = jsEngine.ConvertArguments(arguments);
+
+    if (converted.size() != 2)
       return v8::ThrowException(v8::String::New(
         "_fileSystem.stat requires 2 parameters"));
-    const std::string path = Utils::FromV8String(arguments[0]);
-    v8::Handle<v8::Value> callbackValue = arguments[1];
-    if (!callbackValue->IsFunction())
+    if (!converted[1]->IsFunction())
       return v8::ThrowException(v8::String::New(
         "Second argument to _fileSystem.stat must be a function"));
-    v8::Handle<v8::Function> callback =
-      v8::Handle<v8::Function>::Cast(callbackValue);
-    StatThread* const statThread = new StatThread(*fileSystem, callback, path);
+    StatThread* const statThread = new StatThread(jsEngine, converted[1],
+        converted[0]->AsString());
     statThread->Start();
     return v8::Undefined();
   }
 }
 
 v8::Handle<v8::ObjectTemplate>
-FileSystemJsObject::Create(FileSystem& fileSystem)
+FileSystemJsObject::Create(JsEngine& jsEngine)
 {
-  const v8::Locker locker(v8::Isolate::GetCurrent());
   v8::HandleScope handleScope;
-  const v8::Handle<v8::ObjectTemplate> file = v8::ObjectTemplate::New();
-  const v8::Local<v8::External> fileSystemExternal =
-    v8::External::New(&fileSystem);
+  const v8::Local<v8::ObjectTemplate> file = v8::ObjectTemplate::New();
+  const v8::Local<v8::External> jsEngineExternal =
+    v8::External::New(&jsEngine);
   file->Set(v8::String::New("read"),
-            v8::FunctionTemplate::New(ReadCallback, fileSystemExternal));
+            v8::FunctionTemplate::New(ReadCallback, jsEngineExternal));
   file->Set(v8::String::New("write"),
-            v8::FunctionTemplate::New(WriteCallback, fileSystemExternal));
+            v8::FunctionTemplate::New(WriteCallback, jsEngineExternal));
   file->Set(v8::String::New("move"),
-            v8::FunctionTemplate::New(MoveCallback, fileSystemExternal));
+            v8::FunctionTemplate::New(MoveCallback, jsEngineExternal));
   file->Set(v8::String::New("remove"),
-            v8::FunctionTemplate::New(RemoveCallback, fileSystemExternal));
+            v8::FunctionTemplate::New(RemoveCallback, jsEngineExternal));
   file->Set(v8::String::New("stat"),
-            v8::FunctionTemplate::New(StatCallback, fileSystemExternal));
+            v8::FunctionTemplate::New(StatCallback, jsEngineExternal));
   return handleScope.Close(file);
 }