Issue 5183 - Provide async interface for FileSystem

src/JsEngine.cpp

 /*
  * This file is part of Adblock Plus <https://adblockplus.org/>,
  * Copyright (C) 2006-2017 eyeo GmbH
  *
  * Adblock Plus is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License version 3 as
  * published by the Free Software Foundation.
  *
  * Adblock Plus is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  * GNU General Public License for more details.
  *
  * You should have received a copy of the GNU General Public License
  * along with Adblock Plus.  If not, see <http://www.gnu.org/licenses/>.
  */
 
 #include <AdblockPlus.h>
 #include "GlobalJsObject.h"
 #include "JsContext.h"
 #include "JsError.h"
 #include "Utils.h"
 #include "DefaultTimer.h"
+#include <libplatform/libplatform.h>
 
 namespace
 {
   v8::Handle<v8::Script> CompileScript(v8::Isolate* isolate,
     const std::string& source, const std::string& filename)
   {
     using AdblockPlus::Utils::ToV8String;
     const v8::Handle<v8::String> v8Source = ToV8String(isolate, source);
     if (filename.length())
     {
       const v8::Handle<v8::String> v8Filename = ToV8String(isolate, filename);
       return v8::Script::Compile(v8Source, v8Filename);
     }
     else
       return v8::Script::Compile(v8Source);
   }
 
   void CheckTryCatch(const v8::TryCatch& tryCatch)
   {
     if (tryCatch.HasCaught())
       throw AdblockPlus::JsError(tryCatch.Exception(), tryCatch.Message());
   }
 
   class V8Initializer
   {
     V8Initializer()
-    {
+      : platform(v8::platform::CreateDefaultPlatform())
+    {
+      v8::V8::InitializePlatform(platform);
       v8::V8::Initialize();
     }
 
     ~V8Initializer()
     {
       v8::V8::Dispose();
-    }
+      v8::V8::ShutdownPlatform();
+      delete platform;
+    }
+    v8::Platform* platform;
   public:
     static void Init()
     {
       // it's threadsafe since C++11 and it will be instantiated only once and
       // destroyed at the application exit
       static V8Initializer initializer;
     }
   };
 }
 
@@ skipping 10 matching lines @@
 }
 
 WebRequestPtr AdblockPlus::CreateDefaultWebRequest()
 {
   return WebRequestPtr(new DefaultWebRequest(std::make_shared<DefaultWebRequestSync>()));
 }
 
 AdblockPlus::ScopedV8Isolate::ScopedV8Isolate()
 {
   V8Initializer::Init();
-  isolate = v8::Isolate::New();
+  v8::Isolate::CreateParams isolateParams;
+  isolateParams.array_buffer_allocator = v8::ArrayBuffer::Allocator::NewDefaultAllocator();
+  isolate = v8::Isolate::New(isolateParams);
 }
 
 AdblockPlus::ScopedV8Isolate::~ScopedV8Isolate()
 {
   isolate->Dispose();
   isolate = nullptr;
 }
 
 JsEngine::JsWeakValuesList::~JsWeakValuesList()
 {
-  for (auto& value : values)
-    value->Dispose();
 }
 
 void JsEngine::NotifyLowMemory()
 {
   const JsContext context(*this);
-  v8::V8::LowMemoryNotification();
-}
-
-void JsEngine::ScheduleTimer(const v8::Arguments& arguments)
+  GetIsolate()->MemoryPressureNotification(v8::MemoryPressureLevel::kCritical);
+}
+
+void JsEngine::ScheduleTimer(const v8::FunctionCallbackInfo<v8::Value>& arguments)
 {
   auto jsEngine = FromArguments(arguments);
   if (arguments.Length() < 2)
     throw std::runtime_error("setTimeout requires at least 2 parameters");
 
   if (!arguments[0]->IsFunction())
     throw std::runtime_error("First argument to setTimeout must be a function");
 
   auto jsValueArguments = jsEngine->ConvertArguments(arguments);
   auto timerParamsID = jsEngine->StoreJsValues(jsValueArguments);
@@ skipping 29 matching lines @@
   TimerPtr timer, FileSystemPtr fileSystem, WebRequestPtr webRequest)
 {
   JsEnginePtr result(new JsEngine(std::move(timer),
                                   std::move(fileSystem),
                                   std::move(webRequest)));
 
   const v8::Locker locker(result->GetIsolate());
   const v8::Isolate::Scope isolateScope(result->GetIsolate());
   const v8::HandleScope handleScope(result->GetIsolate());
 
-  result->context.reset(new v8::Persistent<v8::Context>(result->GetIsolate(),
+  result->context.reset(new v8::Global<v8::Context>(result->GetIsolate(),
     v8::Context::New(result->GetIsolate())));
   auto global = result->GetGlobalObject();
   AdblockPlus::GlobalJsObject::Setup(*result, appInfo, global);
   return result;
 }
 
 AdblockPlus::JsValue AdblockPlus::JsEngine::GetGlobalObject()
 {
   JsContext context(*this);
   return JsValue(shared_from_this(), context.GetV8Context()->Global());
@@ skipping 38 matching lines @@
     auto it = eventCallbacks.find(eventName);
     if (it == eventCallbacks.end())
       return;
     callback = it->second;
   }
   callback(move(params));
 }
 
 void AdblockPlus::JsEngine::Gc()
 {
-  while (!v8::V8::IdleNotification());
+  while (!GetIsolate()->IdleNotification(1000));
 }
 
 AdblockPlus::JsValue AdblockPlus::JsEngine::NewValue(const std::string& val)
 {
   const JsContext context(*this);
   return JsValue(shared_from_this(), Utils::ToV8String(GetIsolate(), val));
 }
 
 AdblockPlus::JsValue AdblockPlus::JsEngine::NewValue(int64_t val)
 {
   const JsContext context(*this);
   return JsValue(shared_from_this(), v8::Number::New(GetIsolate(), val));
 }
 
 AdblockPlus::JsValue AdblockPlus::JsEngine::NewValue(bool val)
 {
   const JsContext context(*this);
-  return JsValue(shared_from_this(), v8::Boolean::New(val));
+  return JsValue(shared_from_this(), v8::Boolean::New(GetIsolate(), val));
 }
 
 AdblockPlus::JsValue AdblockPlus::JsEngine::NewObject()
 {
   const JsContext context(*this);
-  return JsValue(shared_from_this(), v8::Object::New());
+  return JsValue(shared_from_this(), v8::Object::New(GetIsolate()));
 }
 
 AdblockPlus::JsValue AdblockPlus::JsEngine::NewCallback(
-    const v8::InvocationCallback& callback)
+    const v8::FunctionCallback& callback)
 {
   const JsContext context(*this);
 
   // Note: we are leaking this weak pointer, no obvious way to destroy it when
   // it's no longer used
   std::weak_ptr<JsEngine>* data =
       new std::weak_ptr<JsEngine>(shared_from_this());
-  v8::Local<v8::FunctionTemplate> templ = v8::FunctionTemplate::New(callback,
-      v8::External::New(data));
+  v8::Local<v8::FunctionTemplate> templ = v8::FunctionTemplate::New(GetIsolate(), callback,
+      v8::External::New(GetIsolate(), data));
   return JsValue(shared_from_this(), templ->GetFunction());
 }
 
-AdblockPlus::JsEnginePtr AdblockPlus::JsEngine::FromArguments(const v8::Arguments& arguments)
+AdblockPlus::JsEnginePtr AdblockPlus::JsEngine::FromArguments(const v8::FunctionCallbackInfo<v8::Value>& arguments)
 {
   const v8::Local<const v8::External> external =
       v8::Local<const v8::External>::Cast(arguments.Data());
   std::weak_ptr<JsEngine>* data =
       static_cast<std::weak_ptr<JsEngine>*>(external->Value());
   JsEnginePtr result = data->lock();
   if (!result)
     throw std::runtime_error("Oops, our JsEngine is gone, how did that happen?");
   return result;
 }
 
 JsEngine::JsWeakValuesID JsEngine::StoreJsValues(const JsValueList& values)
 {
   JsWeakValuesLists::iterator it;
   {
     std::lock_guard<std::mutex> lock(jsWeakValuesListsMutex);
     it = jsWeakValuesLists.emplace(jsWeakValuesLists.end());
   }
   {
     JsContext context(*this);
     for (const auto& value : values)
     {
-      it->values.emplace_back(new v8::Persistent<v8::Value>(GetIsolate(), value.UnwrapValue()));
+      it->values.emplace_back(GetIsolate(), value.UnwrapValue());
     }
   }
   JsWeakValuesID retValue;
   retValue.iterator = it;
   return retValue;
 }
 
 JsValueList JsEngine::TakeJsValues(const JsWeakValuesID& id)
 {
   JsValueList retValue;
   {
     JsContext context(*this);
     for (const auto& v8Value : id.iterator->values)
     {
-      retValue.emplace_back(JsValue(shared_from_this(), v8::Local<v8::Value>::New(GetIsolate(), *v8Value)));
+      retValue.emplace_back(JsValue(shared_from_this(), v8::Local<v8::Value>::New(GetIsolate(), v8Value)));
     }
   }
   {
     std::lock_guard<std::mutex> lock(jsWeakValuesListsMutex);
     jsWeakValuesLists.erase(id.iterator);
   }
   return retValue;
 }
 
-AdblockPlus::JsValueList AdblockPlus::JsEngine::ConvertArguments(const v8::Arguments& arguments)
+AdblockPlus::JsValueList AdblockPlus::JsEngine::ConvertArguments(const v8::FunctionCallbackInfo<v8::Value>& arguments)
 {
   const JsContext context(*this);
   JsValueList list;
   for (int i = 0; i < arguments.Length(); i++)
     list.push_back(JsValue(shared_from_this(), arguments[i]));
   return list;
 }
 
-AdblockPlus::FileSystemPtr AdblockPlus::JsEngine::GetFileSystem() const
+AdblockPlus::FileSystemPtr AdblockPlus::JsEngine::GetAsyncFileSystem() const
 {
   return fileSystem;
+}
+
+void AdblockPlus::JsEngine::SetFileSystem(const AdblockPlus::FileSystemSyncPtr& val)
+{
+  if (!val)
+    throw std::runtime_error("FileSystem cannot be null");
+
+  fileSystem.reset(new DefaultFileSystem(val));
 }
 
 void AdblockPlus::JsEngine::SetWebRequest(const AdblockPlus::WebRequestSharedPtr& val)
 {
   if (!val)
     throw std::runtime_error("WebRequest cannot be null");
 
   webRequestLegacy = val;
 }
 
@@ skipping 10 matching lines @@
   logSystem = val;
 }
 
 
 void AdblockPlus::JsEngine::SetGlobalProperty(const std::string& name,
                                               const AdblockPlus::JsValue& value)
 {
   auto global = GetGlobalObject();
   global.SetProperty(name, value);
 }