mirror of
https://github.com/electron/electron.git
synced 2026-04-10 03:01:51 -04:00
ddeb970f18
* refactor: make ReplyChannel inherit from gin::Wrappable * chore: add kElectronReplyChannel to chore_add_electron_objects_to_wrappablepointertag.patch * fix: use gin::PerIsolateData::DisposeObserver * fix: lifetime issues * chore: rm perisolatedata hook in favor of prefinalizer --------- Co-authored-by: deepak1556 <hop2deep@gmail.com>
98 lines
3.0 KiB
C++
98 lines
3.0 KiB
C++
// Copyright (c) 2023 Salesforce, Inc.
|
|
// Use of this source code is governed by the MIT license that can be
|
|
// found in the LICENSE file.
|
|
|
|
#include "shell/common/gin_helper/reply_channel.h"
|
|
|
|
#include "gin/data_object_builder.h"
|
|
#include "gin/object_template_builder.h"
|
|
#include "shell/browser/javascript_environment.h"
|
|
#include "shell/common/gin_converters/blink_converter.h"
|
|
#include "shell/common/gin_helper/handle.h"
|
|
#include "v8/include/cppgc/allocation.h"
|
|
#include "v8/include/v8-cppgc.h"
|
|
|
|
namespace gin_helper::internal {
|
|
|
|
const gin::WrapperInfo ReplyChannel::kWrapperInfo = {
|
|
{gin::kEmbedderNativeGin},
|
|
gin::kElectronReplyChannel};
|
|
|
|
ReplyChannel::ReplyChannel(v8::Isolate* isolate, InvokeCallback callback)
|
|
: callback_{std::move(callback)} {}
|
|
|
|
ReplyChannel::~ReplyChannel() = default;
|
|
|
|
// static
|
|
void ReplyChannel::SendError(v8::Isolate* isolate,
|
|
InvokeCallback callback,
|
|
std::string_view const errmsg) {
|
|
if (!callback)
|
|
return;
|
|
|
|
// If there's no current context, it means we're shutting down,
|
|
// so we don't need to send an event.
|
|
v8::HandleScope scope{isolate};
|
|
if (isolate->GetCurrentContext().IsEmpty())
|
|
return;
|
|
|
|
SendReplyImpl(isolate, std::move(callback),
|
|
gin::DataObjectBuilder(isolate).Set("error", errmsg).Build());
|
|
}
|
|
|
|
// static
|
|
bool ReplyChannel::SendReplyImpl(v8::Isolate* isolate,
|
|
InvokeCallback callback,
|
|
v8::Local<v8::Value> arg) {
|
|
if (!callback)
|
|
return false;
|
|
|
|
blink::CloneableMessage msg;
|
|
if (!gin::ConvertFromV8(isolate, arg, &msg))
|
|
return false;
|
|
|
|
std::move(callback).Run(std::move(msg));
|
|
return true;
|
|
}
|
|
|
|
// static
|
|
ReplyChannel* ReplyChannel::Create(v8::Isolate* isolate,
|
|
InvokeCallback callback) {
|
|
return cppgc::MakeGarbageCollected<ReplyChannel>(
|
|
isolate->GetCppHeap()->GetAllocationHandle(), isolate,
|
|
std::move(callback));
|
|
}
|
|
|
|
const gin::WrapperInfo* ReplyChannel::wrapper_info() const {
|
|
return &kWrapperInfo;
|
|
}
|
|
|
|
const char* ReplyChannel::GetHumanReadableName() const {
|
|
return "Electron / ReplyChannel";
|
|
}
|
|
|
|
gin::ObjectTemplateBuilder ReplyChannel::GetObjectTemplateBuilder(
|
|
v8::Isolate* isolate) {
|
|
return gin::Wrappable<ReplyChannel>::GetObjectTemplateBuilder(isolate)
|
|
.SetMethod("sendReply", &ReplyChannel::SendReply);
|
|
}
|
|
|
|
bool ReplyChannel::SendReply(v8::Isolate* isolate, v8::Local<v8::Value> arg) {
|
|
return SendReplyImpl(isolate, std::move(callback_), std::move(arg));
|
|
}
|
|
|
|
void ReplyChannel::EnsureReplySent() {
|
|
v8::Isolate* isolate = v8::Isolate::GetCurrent();
|
|
if (callback_) {
|
|
DCHECK(isolate);
|
|
// Create a task since we cannot allocate on V8 heap during GC
|
|
// which is needed by ReplyChannel::SendError implementation.
|
|
base::SingleThreadTaskRunner::GetCurrentDefault()->PostTask(
|
|
FROM_HERE,
|
|
base::BindOnce(&ReplyChannel::SendError, isolate, std::move(callback_),
|
|
"reply was never sent"));
|
|
}
|
|
}
|
|
|
|
} // namespace gin_helper::internal
|