scoped_ptr<V8ValueConverter> converter(new V8ValueConverterImpl());
- // process.emit('ATOM_INTERNAL_MESSAGE', 'message', process_id, routing_id);
+ // process.emit(channel, 'message', process_id, routing_id);
std::vector<v8::Handle<v8::Value>> arguments;
arguments.reserve(3 + args.GetSize());
arguments.push_back(v8::String::New(channel.c_str(), channel.size()));
node::MakeCallback(node::process, "emit", arguments.size(), &arguments[0]);
}
+void AtomBrowserBindings::OnRendererMessageSync(
+ int process_id,
+ int routing_id,
+ const std::string& channel,
+ const base::ListValue& args,
+ base::DictionaryValue* result) {
+ v8::HandleScope scope;
+
+ v8::Handle<v8::Context> context = v8::Context::GetCurrent();
+
+ scoped_ptr<V8ValueConverter> converter(new V8ValueConverterImpl());
+
+ v8::Handle<v8::Object> event = v8::Object::New();
+
+ // process.emit(channel, 'sync-message', event, process_id, routing_id);
+ std::vector<v8::Handle<v8::Value>> arguments;
+ arguments.reserve(3 + args.GetSize());
+ arguments.push_back(v8::String::New(channel.c_str(), channel.size()));
+ const base::Value* value;
+ if (args.Get(0, &value))
+ arguments.push_back(converter->ToV8Value(value, context));
+ arguments.push_back(event);
+ arguments.push_back(v8::Integer::New(process_id));
+ arguments.push_back(v8::Integer::New(routing_id));
+
+ for (size_t i = 1; i < args.GetSize(); i++) {
+ const base::Value* value;
+ if (args.Get(i, &value))
+ arguments.push_back(converter->ToV8Value(value, context));
+ }
+
+ node::MakeCallback(node::process, "emit", arguments.size(), &arguments[0]);
+
+ scoped_ptr<base::Value> base_event(converter->FromV8Value(event, context));
+ DCHECK(base_event && base_event->IsType(base::Value::TYPE_DICTIONARY));
+
+ result->Swap(static_cast<base::DictionaryValue*>(base_event.get()));
+}
+
} // namespace atom
#include "common/api/atom_bindings.h"
namespace base {
+class DictionaryValue;
class ListValue;
}
const std::string& channel,
const base::ListValue& args);
+ // Called when received a synchronous message from renderer.
+ void OnRendererMessageSync(int process_id,
+ int routing_id,
+ const std::string& channel,
+ const base::ListValue& args,
+ base::DictionaryValue* result);
+
// The require('atom').browserMainParts object.
v8::Handle<v8::Object> browser_main_parts() {
return browser_main_parts_;
constructor: ->
process.on 'ATOM_INTERNAL_MESSAGE', (args...) =>
@emit(args...)
+ process.on 'ATOM_INTERNAL_MESSAGE_SYNC', (args...) =>
+ @emit(args...)
send: (process_id, routing_id, args...) ->
@sendChannel(process_id, routing_id, 'message', args...)
ipc.send.apply(ipc, arguments);
});
+ipc.on('sync-message', function(event, process_id, routing_id) {
+ event.result = arguments;
+});
+
atom.browserMainParts.preMainMessageLoopRun = function() {
mainWindow = new Window({ width: 800, height: 600 });
mainWindow.url = 'file://' + __dirname + '/index.html';
bool handled = true;
IPC_BEGIN_MESSAGE_MAP(NativeWindow, message)
IPC_MESSAGE_HANDLER(AtomViewHostMsg_Message, OnRendererMessage)
+ IPC_MESSAGE_HANDLER(AtomViewHostMsg_Message_Sync, OnRendererMessageSync)
IPC_MESSAGE_UNHANDLED(handled = false)
IPC_END_MESSAGE_MAP()
args);
}
+void NativeWindow::OnRendererMessageSync(const std::string& channel,
+ const base::ListValue& args,
+ base::DictionaryValue* result) {
+ AtomBrowserMainParts::Get()->atom_bindings()->OnRendererMessageSync(
+ GetWebContents()->GetRenderProcessHost()->GetID(),
+ GetWebContents()->GetRoutingID(),
+ channel,
+ args,
+ result);
+}
+
} // namespace atom
void OnRendererMessage(const std::string& channel,
const base::ListValue& args);
+ void OnRendererMessageSync(const std::string& channel,
+ const base::ListValue& args,
+ base::DictionaryValue* result);
+
// Notification manager.
content::NotificationRegistrar registrar_;
std::string /* channel */,
ListValue /* arguments */)
+IPC_SYNC_MESSAGE_ROUTED2_1(AtomViewHostMsg_Message_Sync,
+ std::string /* channel */,
+ ListValue /* arguments */,
+ DictionaryValue /* result */)
+
IPC_MESSAGE_ROUTED2(AtomViewMsg_Message,
std::string /* channel */,
ListValue /* arguments */)
+
+IPC_SYNC_MESSAGE_ROUTED2_1(AtomViewMsg_Message_Sync,
+ std::string /* channel */,
+ ListValue /* arguments */,
+ DictionaryValue /* result */)
DCHECK(arguments && arguments->IsType(base::Value::TYPE_LIST));
- render_view->Send(new AtomViewHostMsg_Message(
+ bool success = render_view->Send(new AtomViewHostMsg_Message(
render_view->GetRoutingID(),
channel,
*static_cast<base::ListValue*>(arguments.get())));
+ if (!success)
+ return node::ThrowError("Unable to send AtomViewHostMsg_Message");
+
return v8::Undefined();
}
// static
+v8::Handle<v8::Value> RendererIPC::SendSync(const v8::Arguments &args) {
+ v8::HandleScope scope;
+
+ if (!args[0]->IsString())
+ return node::ThrowTypeError("Bad argument");
+
+ v8::Handle<v8::Context> context = v8::Context::GetCurrent();
+ std::string channel(*v8::String::Utf8Value(args[0]));
+
+ // Convert Arguments to Array, so we can use V8ValueConverter to convert it
+ // to ListValue.
+ v8::Local<v8::Array> v8_args = v8::Array::New(args.Length() - 1);
+ for (int i = 0; i < args.Length() - 1; ++i)
+ v8_args->Set(i, args[i + 1]);
+
+ scoped_ptr<V8ValueConverter> converter(V8ValueConverter::create());
+ scoped_ptr<base::Value> arguments(converter->FromV8Value(v8_args, context));
+
+ DCHECK(arguments && arguments->IsType(base::Value::TYPE_LIST));
+
+ RenderView* render_view = GetCurrentRenderView();
+
+ base::DictionaryValue result;
+ bool success = render_view->Send(new AtomViewHostMsg_Message_Sync(
+ render_view->GetRoutingID(),
+ channel,
+ *static_cast<base::ListValue*>(arguments.get()),
+ &result));
+
+ if (!success)
+ return node::ThrowError("Unable to send AtomViewHostMsg_Message_Sync");
+
+ return scope.Close(converter->ToV8Value(&result, context));
+}
+
+// static
void RendererIPC::Initialize(v8::Handle<v8::Object> target) {
node::SetMethod(target, "send", Send);
+ node::SetMethod(target, "sendSync", SendSync);
}
} // namespace api
private:
static v8::Handle<v8::Value> Send(const v8::Arguments &args);
+ static v8::Handle<v8::Value> SendSync(const v8::Arguments &args);
DISALLOW_IMPLICIT_CONSTRUCTORS(RendererIPC);
};
EventEmitter = require('events').EventEmitter
-send = process.atom_binding('ipc').send
+ipc = process.atom_binding('ipc')
class Ipc extends EventEmitter
constructor: ->
process.on 'ATOM_INTERNAL_MESSAGE', (args...) =>
@emit(args...)
+ process.on 'ATOM_INTERNAL_MESSAGE_SYNC', (args...) =>
+ @emit(args...)
send: (args...) ->
@sendChannel('message', args...)
sendChannel: (args...) ->
- send('ATOM_INTERNAL_MESSAGE', args...)
+ ipc.send('ATOM_INTERNAL_MESSAGE', args...)
+
+ sendSync: (args...) ->
+ ipc.sendSync('ATOM_INTERNAL_MESSAGE_SYNC', 'sync-message', args...).result
+
+ sendChannelSync: (args...) ->
+ ipc.sendSync('ATOM_INTERNAL_MESSAGE_SYNC', args...).result
module.exports = new Ipc