| Index: src/FileSystemJsObject.cpp |
| =================================================================== |
| --- a/src/FileSystemJsObject.cpp |
| +++ b/src/FileSystemJsObject.cpp |
| @@ -1,53 +1,45 @@ |
| #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 |
| @@ -59,37 +51,36 @@ namespace |
| { |
| 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 |
| { |
| @@ -101,35 +92,35 @@ namespace |
| { |
| 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 |
| { |
| @@ -139,35 +130,35 @@ namespace |
| { |
| 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 |
| { |
| @@ -177,34 +168,34 @@ namespace |
| { |
| 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 |
| @@ -215,156 +206,131 @@ namespace |
| { |
| 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); |
| } |