Merge pull request #68 from zenhack/module-stubs

Add .capnp.js stubs generated by capnpc-node-typescript.
Merge pull request #67 from zenhack/typescript-decl-fix
2020-12-16 21:52:36 -06:00 · 2020-12-14 16:53:50 -06:00 · 2020-12-12 02:29:24 -05:00 · 2020-12-12 02:00:08 -05:00 · 2020-12-12 01:54:15 -05:00 · 2020-12-07 13:39:16 -06:00
12 changed files with 249 additions and 142 deletions
@@ -49,9 +49,9 @@ On Debian/Ubuntu, you can install these like so:

    sudo apt-get install nodejs-dev nodejs-legacy capnproto-dev g++

-### Form source
+### From source

-    git clone git://github.com/kenton/node-capnp.git
+    git clone git://github.com/capnproto/node-capnp.git
    cd node-capnp
    npm install

@@ -118,6 +118,25 @@ we copied.)
    // object containing the results by name.
    promise.then(function(response) {
      console.log(response.namedResult);
+    })
+    // If the remote object throws an rpc exception, the promise will be
+    // rejected. The error returned will have a property `kjType`, which
+    // will be a string representation of the exception's `type` field.
+    .catch(function(error) {
+        switch(error.kjType) {
+        case 'failed':
+            console.log("A generic problem occurred:", error.message);
+            break;
+        case 'overloaded':
+            console.log("Resource overload on the remote end:", error.message);
+            break;
+        case 'disconnected':
+            // ...
+            break;
+        case 'unimplemented':
+            // ...
+            break;
+        }
    });

 ### Pipelining
@@ -196,6 +215,22 @@ then use that:
 In this case, the library only wraps `myFoo` as a capability once, and then
 calls `close()` once all copies of that reference have been dropped.

+If one of your methods throws an exception, or returns a promise which
+is subsequently rejected, it will be converted to a capnproto rpc
+exception. If the exception has a `kjType` property, that will be used
+for the exception's `type` field, otherwise the type will be `failed`.
+
+    var myBar = {
+        bar: function(foo) {
+            if(!bazAvailable()) {
+                var err = new Error("The baz is busy; try again later.");
+                err.kjType = 'overloaded';
+                throw(err);
+            }
+            // ...
+        }
+    }
+
 ### Exporting a bootstrap capability

    // Connect to another server and export `myFoo` as a bootstrap capability.
@@ -0,0 +1 @@
+capnp.node
@@ -72,10 +72,13 @@ if (!force) {

 // Build it
 function build() {
-	cp.spawn(
+	var sp = cp.spawn(
 		process.platform === 'win32' ? 'node-gyp.cmd' : 'node-gyp',
 		['rebuild'].concat(args),
-		{customFds: [0, 1, 2]})
+		{customFds: [0, 1, 2]});
+
+	sp
+	.on('close', function(){ afterBuild(); })
 	.on('exit', function(err) {
 		if (err) {
 			if (err === 127) {
@@ -88,8 +91,9 @@ function build() {
 			}
 			return process.exit(err);
 		}
-		afterBuild();
 	});
+	sp.stdout.pipe(process.stdout);
+	sp.stderr.pipe(process.stderr);
 }

 // Move it to expected location
@@ -0,0 +1 @@
+module.exports = require("capnp").importSystem("capnp/c++.capnp");
@@ -1,8 +1,11 @@
 {
  "name": "capnp",
-  "version": "0.3.1",
+  "version": "0.5.0",
  "description": "A wrapper for the C++ Cap'n Proto library",
-  "keywords": [ "capnproto", "serialization" ],
+  "keywords": [
+    "capnproto",
+    "serialization"
+  ],
  "homepage": "http://capnproto.org",
  "author": {
    "name": "Kenton Varda",
@@ -15,8 +18,8 @@
      "email": "jparyani@gmail.com"
    }
  ],
-
  "main": "src/node-capnp/capnp.js",
+  "types": "src/node-capnp/capnp.d.ts",
  "scripts": {
    "install": "node ./build.js",
    "test": "node src/node-capnp/capnp-test.js"
@@ -26,7 +29,7 @@
    "url": "git://github.com/kentonv/node-capnp.git"
  },
  "engines": {
-    "node": ">=8.0"
+    "node": ">=10.0"
  },
  "license": "MIT"
 }
@@ -0,0 +1 @@
+module.exports = require("capnp").importSystem("capnp/persistent.capnp");
@@ -0,0 +1 @@
+module.exports = require("capnp").importSystem("capnp/rpc-twoparty.capnp");
@@ -0,0 +1 @@
+module.exports = require("capnp").importSystem("capnp/rpc.capnp");
@@ -0,0 +1 @@
+module.exports = require("capnp").importSystem("capnp/schema.capnp");
@@ -194,7 +194,8 @@ private:
  }

  static void doRun(uv_timer_t* handle) {
-    UvEventPort* self = handle == nullptr ? nullptr : reinterpret_cast<UvEventPort*>(handle->data);
+    KJ_ASSERT(handle != nullptr);
+    UvEventPort* self = reinterpret_cast<UvEventPort*>(handle->data);
    self->run();
  }
 };
@@ -696,12 +697,12 @@ class OwnHandle {
 public:
  OwnHandle() = default;
  KJ_DISALLOW_COPY(OwnHandle);
-  inline OwnHandle(const v8::Handle<T>& other)
+  inline OwnHandle(const v8::Local<T>& other)
      : handle(v8::Isolate::GetCurrent(), other) {}
  inline OwnHandle(OwnHandle&& other) = default;

  inline OwnHandle& operator=(OwnHandle&& other) = default;
-  inline OwnHandle& operator=(const v8::Handle<T>& other) {
+  inline OwnHandle& operator=(const v8::Local<T>& other) {
    handle.Reset(v8::Isolate::GetCurrent(), other);
    return *this;
  }
@@ -710,7 +711,7 @@ public:
  inline bool operator!=(decltype(nullptr)) { return !handle.IsEmpty(); }
  inline T* operator->() const { return get().operator->(); }

-  inline const v8::Handle<T> get() const {
+  inline const v8::Local<T> get() const {
    return v8::Local<T>::New(v8::Isolate::GetCurrent(), handle);
  }

@@ -718,16 +719,16 @@ private:
  v8::Global<T> handle;
 };

-kj::String toKjString(v8::Handle<v8::String> handle) {
-  auto buf = kj::heapArray<char>(handle->Utf8Length() + 1);
-  handle->WriteUtf8(buf.begin(), buf.size());
+kj::String toKjString(v8::Local<v8::String> handle) {
+  auto buf = kj::heapArray<char>(handle->Utf8Length(v8::Isolate::GetCurrent()) + 1);
+  handle->WriteUtf8(v8::Isolate::GetCurrent(), buf.begin(), buf.size());
  buf[buf.size() - 1] = 0;
  return kj::String(kj::mv(buf));
 }

-kj::String toKjString(v8::Handle<v8::Value> handle) {
+kj::String toKjString(v8::Local<v8::Value> handle) {
  v8::HandleScope scope(v8::Isolate::GetCurrent());
-  return toKjString(handle->ToString());
+  return toKjString(handle->ToString(v8::Isolate::GetCurrent()));
 }

 #define KJV8_STACK_STR(name, handle, sizeHint) \
@@ -735,16 +736,16 @@ kj::String toKjString(v8::Handle<v8::Value> handle) {
  kj::Array<char> name##_heap; \
  kj::StringPtr name; \
  { \
-    v8::Handle<v8::String> v8str = handle->ToString(); \
+    v8::Local<v8::String> v8str = handle->ToString(v8::Isolate::GetCurrent()); \
    char* ptr; \
-    size_t len = v8str->Utf8Length(); \
+    size_t len = v8str->Utf8Length(v8::Isolate::GetCurrent()); \
    if (len < sizeHint) { \
      ptr = name##_buf; \
    } else { \
      name##_heap = kj::heapArray<char>(len + 1); \
      ptr = name##_heap.begin(); \
    } \
-    v8str->WriteUtf8(ptr, len); \
+    v8str->WriteUtf8(v8::Isolate::GetCurrent(), ptr, len); \
    ptr[len] = '\0'; \
    name = kj::StringPtr(ptr, len); \
  }
@@ -774,14 +775,14 @@ v8::Local<v8::Value> toJsException(kj::Exception&& exception) {
  return result;
 }

-kj::Exception fromJsException(v8::Handle<v8::Value> exception) {
+kj::Exception fromJsException(v8::Local<v8::Value> exception) {
  kj::Exception::Type type = kj::Exception::Type::FAILED;
  kj::String description;

  if (exception->IsObject()) {
    v8::HandleScope scope(v8::Isolate::GetCurrent());
    v8::Object* obj = v8::Object::Cast(*exception);
-    v8::Handle<v8::Value> value = obj->Get(newSymbol("kjType"));
+    v8::Local<v8::Value> value = obj->Get(newSymbol("kjType"));
    if (!value.IsEmpty() && !value->IsUndefined()) {
      auto name = toKjString(value);
      if (name == "overloaded") {
@@ -793,7 +794,7 @@ kj::Exception fromJsException(v8::Handle<v8::Value> exception) {
      }
    }

-    v8::Handle<v8::Value> stack = obj->Get(newSymbol("stack"));
+    v8::Local<v8::Value> stack = obj->Get(newSymbol("stack"));
    if (!stack.IsEmpty() && !stack->IsUndefined()) {
      description = toKjString(stack);
    } else {
@@ -891,7 +892,9 @@ class Wrapper {
 public:
  template <typename T>
  v8::Local<v8::Object> wrap(T* ptr) {
-    v8::Local<v8::Object> obj = getFunctionTemplate<T>()->GetFunction()->NewInstance();
+    v8::Local<v8::Object> obj = getFunctionTemplate<T>()
+        ->GetFunction(v8::Isolate::GetCurrent()->GetCurrentContext()).ToLocalChecked()->NewInstance(v8::Isolate::GetCurrent()->GetCurrentContext())
+        .ToLocalChecked();
    obj->SetAlignedPointerInInternalField(0, new WrappedObject<T>(obj, ptr));
    return obj;
  }
@@ -902,15 +905,15 @@ public:
  }

  template <typename T>
-  static kj::Maybe<T&> tryUnwrap(v8::Handle<v8::Value> hdl) {
+  static kj::Maybe<T&> tryUnwrap(v8::Local<v8::Value> hdl) {
    if (!hdl->IsObject()) return nullptr;

-    v8::Handle<v8::Object> obj(v8::Handle<v8::Object>::Cast(hdl));
+    v8::Local<v8::Object> obj(v8::Local<v8::Object>::Cast(hdl));
    if (getFunctionTemplate<T>()->HasInstance(obj)) {
      return *reinterpret_cast<WrappedObject<T>*>(obj->GetAlignedPointerFromInternalField(0))->ptr;
    } else {
      v8::Isolate* isolate = v8::Isolate::GetCurrent();
-      v8::Handle<v8::Value> native;
+      v8::Local<v8::Value> native;
      if (obj->GetPrivate(isolate->GetCurrentContext(),
              v8::Private::ForApi(isolate, newSymbol("capnp::native"))).ToLocal(&native) &&
          !native->IsUndefined()) {
@@ -922,7 +925,7 @@ public:
  }

  template <typename T>
-  static kj::Maybe<T&> unwrap(v8::Handle<v8::Value> hdl) {
+  static kj::Maybe<T&> unwrap(v8::Local<v8::Value> hdl) {
    KJ_IF_MAYBE(result, tryUnwrap<T>(hdl)) {
      return *result;
    } else {
@@ -939,7 +942,7 @@ private:
  }

  template <typename T>
-  static v8::Handle<v8::FunctionTemplate> getFunctionTemplate() {
+  static v8::Local<v8::FunctionTemplate> getFunctionTemplate() {
    // Get the singleton FunctionTemplate for some wrapped type T.

    // We allocate on the heap in order to prevent the destructor from running on shutdown, when
@@ -951,9 +954,9 @@ private:
  }

  template <typename T>
-  static v8::Handle<v8::FunctionTemplate> newFunctionTemplate() {
+  static v8::Local<v8::FunctionTemplate> newFunctionTemplate() {
    const std::type_info& type = typeid(T);
-    v8::Handle<v8::FunctionTemplate> result = v8::FunctionTemplate::New(v8::Isolate::GetCurrent());
+    v8::Local<v8::FunctionTemplate> result = v8::FunctionTemplate::New(v8::Isolate::GetCurrent());
    result->InstanceTemplate()->SetInternalFieldCount(1);

    // TODO(someday):  Make stuff work with -fno-rtti?  node itself is compiled without RTTI...
@@ -971,7 +974,7 @@ private:
  if (name##_maybe == nullptr) KJV8_TYPE_ERROR(name, type); \
  type& name KJ_UNUSED = KJ_ASSERT_NONNULL(name##_maybe)

-kj::Maybe<kj::ArrayPtr<const byte>> unwrapBuffer(v8::Handle<v8::Value> value) {
+kj::Maybe<kj::ArrayPtr<const byte>> unwrapBuffer(v8::Local<v8::Value> value) {
  if (!node::Buffer::HasInstance(value)) {
    return nullptr;
  }
@@ -991,7 +994,7 @@ void deleteArray(char*, void* hint) {
 }

 template <typename T>
-v8::Handle<v8::Value> wrapBuffer(kj::Array<T>&& array) {
+v8::Local<v8::Value> wrapBuffer(kj::Array<T>&& array) {
  char* data = reinterpret_cast<char*>(array.begin());
  size_t size = array.size() * sizeof(T);
  return node::Buffer::New(v8::Isolate::GetCurrent(), data, size, &deleteArray<T>,
@@ -1041,11 +1044,11 @@ void setNative(const v8::FunctionCallbackInfo<v8::Value>& args) {
  }
 }

-v8::Handle<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Reader value,
-                                capnp::Type type, v8::Handle<v8::Value> capConstructor);
+v8::Local<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Reader value,
+                                capnp::Type type, v8::Local<v8::Value> capConstructor);

-v8::Handle<v8::Value> schemaToObject(capnp::ParsedSchema schema, CapnpContext& context,
-                                     v8::Handle<v8::Value> wrappedContext) {
+v8::Local<v8::Value> schemaToObject(capnp::ParsedSchema schema, CapnpContext& context,
+                                     v8::Local<v8::Value> wrappedContext) {
  auto proto = schema.getProto();
  if (proto.isConst()) {
    auto c = schema.asConst();
@@ -1084,7 +1087,7 @@ void import(const v8::FunctionCallbackInfo<v8::Value>& args) {
    return;
  }

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    kj::Array<kj::String> searchPath;
    kj::Array<kj::StringPtr> searchPathPtrs;
    if (!args[2]->IsUndefined()) {
@@ -1092,7 +1095,7 @@ void import(const v8::FunctionCallbackInfo<v8::Value>& args) {
      searchPath = kj::heapArray<kj::String>(arr->Length());
      searchPathPtrs = kj::heapArray<kj::StringPtr>(searchPath.size());
      for (uint i: kj::indices(searchPath)) {
-        searchPath[i] = toKjString(arr->Get(i)->ToString());
+        searchPath[i] = toKjString(arr->Get(i)->ToString(v8::Isolate::GetCurrent()));
        searchPathPtrs[i] = searchPath[i];
      }
    }
@@ -1111,7 +1114,7 @@ void import(const v8::FunctionCallbackInfo<v8::Value>& args) {
  });
 }

-void enumerateMethods(capnp::InterfaceSchema schema, v8::Handle<v8::Object> methodMap,
+void enumerateMethods(capnp::InterfaceSchema schema, v8::Local<v8::Object> methodMap,
                      CapnpContext& context, std::set<uint64_t>& seen) {
  auto proto = schema.getProto();
  if (seen.insert(proto.getId()).second) {
@@ -1135,7 +1138,7 @@ void methods(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP(capnp::Schema, schema, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    auto proto = schema.getProto();
    KJ_REQUIRE(proto.isInterface(), "not an interface type", proto.getDisplayName());

@@ -1173,7 +1176,7 @@ struct ServerResults: public kj::Refcounted {
  // Becomes null when call returns.
 };

-kj::Maybe<capnp::DynamicStruct::Builder> unwrapBuilder(v8::Handle<v8::Value> handle) {
+kj::Maybe<capnp::DynamicStruct::Builder> unwrapBuilder(v8::Local<v8::Value> handle) {
  // We accept either StructBuilder or Request<DynamicStruct, DynamicStruct>.
  capnp::DynamicStruct::Builder builder;
  KJ_IF_MAYBE(request, Wrapper::tryUnwrap<ClientRequest>(handle)) {
@@ -1244,7 +1247,7 @@ struct ServerRequest {
  // Becomes non-null when getResults() is first called.  Subsequent calls return the same object.
 };

-kj::Maybe<capnp::DynamicStruct::Reader> unwrapReader(v8::Handle<v8::Value> handle) {
+kj::Maybe<capnp::DynamicStruct::Reader> unwrapReader(v8::Local<v8::Value> handle) {
  // We accept any builder as well as Response<DynamicStruct>.
  KJ_IF_MAYBE(response, Wrapper::tryUnwrap<ClientResponse>(handle)) {
    return response->response.map(
@@ -1280,7 +1283,7 @@ void newBuilder(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP(capnp::Schema, schema, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    KJ_REQUIRE(schema.getProto().isStruct(),
        "not a struct type", schema.getProto().getDisplayName());

@@ -1296,7 +1299,7 @@ void copyBuilder(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP_READER(reader, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return context.wrapper.wrap(new StructBuilder(reader));
  });
 }
@@ -1309,7 +1312,7 @@ void structToString(const v8::FunctionCallbackInfo<v8::Value>& args) {

  KJV8_UNWRAP_READER(reader, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return newString(kj::str(reader.getSchema().getProto().getDisplayName(), reader).cStr());
  });
 }
@@ -1318,36 +1321,36 @@ void structToString(const v8::FunctionCallbackInfo<v8::Value>& args) {

 struct FromJsConverter {
  CapnpContext& context;
-  v8::Handle<v8::Value> contextHandle;
-  v8::Handle<v8::Function> localCapType;
+  v8::Local<v8::Value> contextHandle;
+  v8::Local<v8::Function> localCapType;

  capnp::DynamicCapability::Client fromLocalCap(
-      capnp::InterfaceSchema schema, v8::Handle<v8::Object> object);
+      capnp::InterfaceSchema schema, v8::Local<v8::Object> object);

-  capnp::Orphan<capnp::DynamicValue> int64FromJs(v8::Handle<v8::Value> js) {
+  capnp::Orphan<capnp::DynamicValue> int64FromJs(v8::Local<v8::Value> js) {
    if (js->IsNumber()) {
-      return js->IntegerValue();
+      return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
    } else {
      KJV8_STACK_STR(text, js, 32);
      char* end;
      int64_t result = strtoll(text.cStr(), &end, 0);
      if (text.size() == 0 || *end != '\0') {
-        return js->IntegerValue();
+        return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
      } else {
        return result;
      }
    }
  }

-  capnp::Orphan<capnp::DynamicValue> uint64FromJs(v8::Handle<v8::Value> js) {
+  capnp::Orphan<capnp::DynamicValue> uint64FromJs(v8::Local<v8::Value> js) {
    if (js->IsNumber()) {
-      return js->IntegerValue();
+      return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
    } else {
      KJV8_STACK_STR(text, js, 32);
      char* end;
      uint64_t result = strtoull(text.cStr(), &end, 0);
      if (text.size() == 0 || *end != '\0') {
-        return js->IntegerValue();
+        return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
      } else {
        return result;
      }
@@ -1356,30 +1359,30 @@ struct FromJsConverter {

  capnp::Orphan<capnp::DynamicValue> orphanFromJs(
      capnp::StructSchema::Field field, capnp::Orphanage orphanage,
-      capnp::Type type, v8::Handle<v8::Value> js) {
+      capnp::Type type, v8::Local<v8::Value> js) {
    switch (type.which()) {
      case capnp::schema::Type::VOID:
        // Accept any false-y value.
-        if (!js->BooleanValue()) {
+        if (!js->BooleanValue(v8::Isolate::GetCurrent())) {
          return capnp::VOID;
        }
        break;
-      case capnp::schema::Type::BOOL:    return js->BooleanValue();
-      case capnp::schema::Type::INT8:    return js->IntegerValue();
-      case capnp::schema::Type::INT16:   return js->IntegerValue();
-      case capnp::schema::Type::INT32:   return js->IntegerValue();
+      case capnp::schema::Type::BOOL:    return js->BooleanValue(v8::Isolate::GetCurrent());
+      case capnp::schema::Type::INT8:    return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
+      case capnp::schema::Type::INT16:   return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
+      case capnp::schema::Type::INT32:   return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
      case capnp::schema::Type::INT64:   return int64FromJs(js);
-      case capnp::schema::Type::UINT8:   return js->IntegerValue();
-      case capnp::schema::Type::UINT16:  return js->IntegerValue();
-      case capnp::schema::Type::UINT32:  return js->IntegerValue();
+      case capnp::schema::Type::UINT8:   return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
+      case capnp::schema::Type::UINT16:  return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
+      case capnp::schema::Type::UINT32:  return js->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
      case capnp::schema::Type::UINT64:  return uint64FromJs(js);
-      case capnp::schema::Type::FLOAT32: return js->NumberValue();
-      case capnp::schema::Type::FLOAT64: return js->NumberValue();
+      case capnp::schema::Type::FLOAT32: return js->NumberValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
+      case capnp::schema::Type::FLOAT64: return js->NumberValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();
      case capnp::schema::Type::TEXT: {
        v8::HandleScope scope(v8::Isolate::GetCurrent());
-        auto str = js->ToString();
-        capnp::Orphan<capnp::Text> orphan = orphanage.newOrphan<capnp::Text>(str->Utf8Length());
-        str->WriteUtf8(orphan.get().begin());
+        auto str = js->ToString(v8::Isolate::GetCurrent());
+        capnp::Orphan<capnp::Text> orphan = orphanage.newOrphan<capnp::Text>(str->Utf8Length(v8::Isolate::GetCurrent()));
+        str->WriteUtf8(v8::Isolate::GetCurrent(), orphan.get().begin(), orphan.get().size());
        return kj::mv(orphan);
      }
      case capnp::schema::Type::DATA:
@@ -1437,7 +1440,7 @@ struct FromJsConverter {
        KJ_IF_MAYBE(enumerant, schema.findEnumerantByName(name)) {
          return capnp::DynamicEnum(*enumerant);
        } else if (js->IsUint32()) {
-          return capnp::DynamicEnum(schema, js->Uint32Value());
+          return capnp::DynamicEnum(schema, js->Uint32Value(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked());
        }
        break;
      }
@@ -1463,8 +1466,10 @@ struct FromJsConverter {
        } else KJ_IF_MAYBE(cap, Wrapper::tryUnwrap<capnp::DynamicCapability::Client>(js)) {
          return orphanage.newOrphanCopy(*cap);
        } else if (!localCapType.IsEmpty()) {
-          v8::Handle<v8::Value> arg = js;
-          auto wrapped = localCapType->NewInstance(1, &arg);
+          v8::Local<v8::Value> arg = js;
+          auto wrapped = localCapType->NewInstance(
+              v8::Isolate::GetCurrent()->GetCurrentContext(), 1, &arg)
+              .ToLocalChecked();
          if (!wrapped.IsEmpty()) {
            auto cap = fromLocalCap(schema, wrapped);
            return orphanage.newOrphanCopy(cap);
@@ -1481,8 +1486,10 @@ struct FromJsConverter {
          } else KJ_IF_MAYBE(cap, Wrapper::tryUnwrap<capnp::DynamicCapability::Client>(js)) {
            return orphanage.newOrphanCopy(*cap);
          } else if (!localCapType.IsEmpty()) {
-            v8::Handle<v8::Value> arg = js;
-            auto wrapped = localCapType->NewInstance(1, &arg);
+            v8::Local<v8::Value> arg = js;
+            auto wrapped = localCapType->NewInstance(
+                v8::Isolate::GetCurrent()->GetCurrentContext(), 1, &arg)
+                .ToLocalChecked();
            if (!wrapped.IsEmpty()) {
              auto cap = fromLocalCap(capnp::Schema::from<capnp::Capability>(), wrapped);
              return orphanage.newOrphanCopy(cap);
@@ -1517,7 +1524,7 @@ struct FromJsConverter {
  }

  bool fieldFromJs(capnp::DynamicStruct::Builder builder, capnp::StructSchema::Field field,
-                   v8::Handle<v8::Value> js) {
+                   v8::Local<v8::Value> js) {
    if ((js->IsNull() || js->IsUndefined()) && !field.getType().isVoid()) {
      return true;
    }
@@ -1552,12 +1559,12 @@ struct FromJsConverter {
    auto schema = builder.getSchema();
  //  for (auto field: schema.getFields()) {
  //    kj::StringPtr name = field.getProto().getName();
-  //    v8::Handle<v8::Value> value = js->Get(newSymbol(name.begin(), name.size()));
+  //    v8::Local<v8::Value> value = js->Get(newSymbol(name.begin(), name.size()));
  //    if (!value.IsEmpty() && !value->IsUndefined()) {
  //      fieldFromJs(builder, field, value);
  //    }
  //  }
-    v8::Local<v8::Array> fieldNames = js->GetPropertyNames();
+    v8::Local<v8::Array> fieldNames = js->GetPropertyNames(v8::Isolate::GetCurrent()->GetCurrentContext()).ToLocalChecked();
    for (uint i: kj::range(0u, fieldNames->Length())) {
      auto jsName = fieldNames->Get(i);
      KJV8_STACK_STR(fieldName, jsName, 32);
@@ -1586,11 +1593,11 @@ void fromJs(const v8::FunctionCallbackInfo<v8::Value>& args) {

  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP_BUILDER(builder, args[0]);
-  v8::Handle<v8::Value> jsValue = args[1];
+  v8::Local<v8::Value> jsValue = args[1];

-  v8::Handle<v8::Function> localCapType = emptyHandle;
+  v8::Local<v8::Function> localCapType = emptyHandle;
  if (args[2]->IsFunction()) {
-    localCapType = v8::Handle<v8::Function>::Cast(args[2]);
+    localCapType = v8::Local<v8::Function>::Cast(args[2]);
  }

  liftKj(args, [&]() -> void {
@@ -1619,12 +1626,12 @@ void fromJs(const v8::FunctionCallbackInfo<v8::Value>& args) {

 // -----------------------------------------------------------------------------

-bool fieldToJs(CapnpContext& context, v8::Handle<v8::Object> object,
+bool fieldToJs(CapnpContext& context, v8::Local<v8::Object> object,
               capnp::DynamicStruct::Reader reader, capnp::StructSchema::Field field,
-               v8::Handle<v8::Value> capConstructor);
+               v8::Local<v8::Value> capConstructor);

-v8::Handle<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Reader value,
-                                capnp::Type type, v8::Handle<v8::Value> capConstructor) {
+v8::Local<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Reader value,
+                                capnp::Type type, v8::Local<v8::Value> capConstructor) {
  switch (value.getType()) {
    case capnp::DynamicValue::UNKNOWN:
      return v8::Undefined(v8::Isolate::GetCurrent());
@@ -1707,11 +1714,13 @@ v8::Handle<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Read
      v8::EscapableHandleScope scope(v8::Isolate::GetCurrent());
      auto cap = value.as<capnp::DynamicCapability>();
      capnp::Schema schema = cap.getSchema();
-      v8::Handle<v8::Value> result = context.wrapper.wrapCopy(kj::mv(cap));
+      v8::Local<v8::Value> result = context.wrapper.wrapCopy(kj::mv(cap));
      if (capConstructor->IsFunction()) {
        v8::Function* func = v8::Function::Cast(*capConstructor);
-        v8::Handle<v8::Value> args[2] = { result, context.wrapper.wrapCopy(schema) };
-        result = func->NewInstance(kj::size(args), args);
+        v8::Local<v8::Value> args[2] = { result, context.wrapper.wrapCopy(schema) };
+        result = func->NewInstance(
+            v8::Isolate::GetCurrent()->GetCurrentContext(), kj::size(args), args)
+            .ToLocalChecked();
        if (result.IsEmpty()) {
          return emptyHandle;
        }
@@ -1723,11 +1732,13 @@ v8::Handle<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Read
        v8::EscapableHandleScope scope(v8::Isolate::GetCurrent());
        auto cap = value.as<capnp::AnyPointer>().getAs<capnp::Capability>();
        capnp::DynamicCapability::Client dynamicCap(kj::mv(cap));
-        v8::Handle<v8::Value> result = context.wrapper.wrapCopy(kj::mv(dynamicCap));
+        v8::Local<v8::Value> result = context.wrapper.wrapCopy(kj::mv(dynamicCap));
        if (capConstructor->IsFunction()) {
          v8::Function* func = v8::Function::Cast(*capConstructor);
-          v8::Handle<v8::Value> args[1] = { result };
-          result = func->NewInstance(kj::size(args), args);
+          v8::Local<v8::Value> args[1] = { result };
+          result = func->NewInstance(
+            v8::Isolate::GetCurrent()->GetCurrentContext(), kj::size(args), args)
+            .ToLocalChecked();
          if (result.IsEmpty()) {
            return emptyHandle;
          }
@@ -1744,11 +1755,11 @@ v8::Handle<v8::Value> valueToJs(CapnpContext& context, capnp::DynamicValue::Read
  KJ_FAIL_ASSERT("Unimplemented DynamicValue type.");
 }

-bool fieldToJs(CapnpContext& context, v8::Handle<v8::Object> object,
+bool fieldToJs(CapnpContext& context, v8::Local<v8::Object> object,
               capnp::DynamicStruct::Reader reader, capnp::StructSchema::Field field,
-               v8::Handle<v8::Value> capConstructor) {
+               v8::Local<v8::Value> capConstructor) {
  auto proto = field.getProto();
-  v8::Handle<v8::Value> fieldValue;
+  v8::Local<v8::Value> fieldValue;
  switch (proto.which()) {
    case capnp::schema::Field::SLOT:
      fieldValue = valueToJs(context, reader.get(field), field.getType(), capConstructor);
@@ -1779,7 +1790,7 @@ void toJs(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP_READER(reader, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return valueToJs(context, reader, reader.getSchema(), args[1]);
  });
 }
@@ -1793,7 +1804,7 @@ void toJsParams(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP_READER(reader, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    auto schema = reader.getSchema();
    if (schema.getProto().getScopeId() == 0) {
      // This appears to be a parameter set.
@@ -1821,10 +1832,10 @@ void expectedSizeFromPrefix(const v8::FunctionCallbackInfo<v8::Value>& args) {

  KJV8_UNWRAP(CapnpContext, context, args.Data());

-  v8::Handle<v8::Value> bufferHandle = args[0];
+  v8::Local<v8::Value> bufferHandle = args[0];
  KJV8_UNWRAP_BUFFER(buffer, bufferHandle);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    kj::ArrayPtr<const capnp::word> words;
    kj::Array<capnp::word> copy;
    if (reinterpret_cast<uintptr_t>(buffer.begin()) % sizeof(capnp::word) != 0) {
@@ -1847,7 +1858,7 @@ void fromBytes(const v8::FunctionCallbackInfo<v8::Value>& args) {

  KJV8_UNWRAP(CapnpContext, context, args.Data());

-  v8::Handle<v8::Value> bufferHandle = args[0];
+  v8::Local<v8::Value> bufferHandle = args[0];
  KJV8_UNWRAP_BUFFER(buffer, bufferHandle);

  KJV8_UNWRAP(capnp::Schema, schema, args[1]);
@@ -1859,10 +1870,10 @@ void fromBytes(const v8::FunctionCallbackInfo<v8::Value>& args) {
    KJV8_TYPE_ERROR(obj, v8::Object);
  }

-  return liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  return liftKj(args, [&]() -> v8::Local<v8::Value> {
    auto options = args[2].As<v8::Object>();
-    bool packed = options->Get(newSymbol("packed"))->BooleanValue();
-    bool flat = options->Get(newSymbol("flat"))->BooleanValue();
+    bool packed = options->Get(newSymbol("packed"))->BooleanValue(v8::Isolate::GetCurrent());
+    bool flat = options->Get(newSymbol("flat"))->BooleanValue(v8::Isolate::GetCurrent());

    v8::Local<v8::Object> wrapper;

@@ -1917,10 +1928,10 @@ void toBytes(const v8::FunctionCallbackInfo<v8::Value>& args) {
    KJV8_TYPE_ERROR(obj, v8::Object);
  }

-  return liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  return liftKj(args, [&]() -> v8::Local<v8::Value> {
    auto options = args[1].As<v8::Object>();
-    bool packed = options->Get(newSymbol("packed"))->BooleanValue();
-    bool flat = options->Get(newSymbol("flat"))->BooleanValue();
+    bool packed = options->Get(newSymbol("packed"))->BooleanValue(v8::Isolate::GetCurrent());
+    bool flat = options->Get(newSymbol("flat"))->BooleanValue(v8::Isolate::GetCurrent());

    if (flat) {
      // Write whole message to flat array.
@@ -2006,7 +2017,7 @@ void connect(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_STACK_STR(address, args[0], 64);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    kj::Maybe<capnp::Capability::Client> bootstrap =
        Wrapper::tryUnwrap<capnp::DynamicCapability::Client>(args[1]);

@@ -2031,9 +2042,9 @@ void connectUnixFd(const v8::FunctionCallbackInfo<v8::Value>& args) {
  // the existing socket.

  KJV8_UNWRAP(CapnpContext, context, args.Data());
-  int fd = args[0]->IntegerValue();
+  int fd = args[0]->IntegerValue(v8::Isolate::GetCurrent()->GetCurrentContext()).ToChecked();

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    int fdPair[2];
    KJ_SYSCALL(socketpair(AF_UNIX, SOCK_STREAM, 0, fdPair));
    kj::AutoCloseFd clientEnd(fdPair[0]);
@@ -2108,7 +2119,7 @@ void restore(const v8::FunctionCallbackInfo<v8::Value>& args) {
  auto ref = toKjString(args[1]);  // TODO(soon):  Allow struct reader.
  KJV8_UNWRAP(capnp::Schema, schema, args[2]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    KJ_REQUIRE(schema.getProto().isInterface(),
        "not an interface type", schema.getProto().getDisplayName());

@@ -2130,7 +2141,7 @@ void castAs(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(capnp::DynamicCapability::Client, cap, args[0]);
  KJV8_UNWRAP(capnp::Schema, schema, args[1]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    KJ_REQUIRE(schema.getProto().isInterface(),
        "not an interface type", schema.getProto().getDisplayName());
    return context.wrapper.wrapCopy(cap.castAs<capnp::DynamicCapability>(schema.asInterface()));
@@ -2146,7 +2157,7 @@ void schemaFor(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP(capnp::DynamicCapability::Client, cap, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return context.wrapper.wrapCopy(capnp::Schema(cap.getSchema()));
  });
 }
@@ -2189,7 +2200,7 @@ void dupCap(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP(capnp::DynamicCapability::Client, cap, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return context.wrapper.wrapCopy(cap);
  });
 }
@@ -2219,32 +2230,32 @@ void request(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(capnp::DynamicCapability::Client, cap, args[0]);
  KJV8_UNWRAP(capnp::InterfaceSchema::Method, method, args[1]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return context.wrapper.wrapCopy(ClientRequest { cap.newRequest(method) });
  });
 }

 void pipelineToJs(CapnpContext& context, capnp::DynamicStruct::Pipeline&& pipeline,
-                  v8::Handle<v8::Object> js, v8::Handle<v8::Value> capConstructor);
+                  v8::Local<v8::Object> js, v8::Local<v8::Value> capConstructor);

-v8::Handle<v8::Object> pipelineStructFieldToJs(CapnpContext& context,
+v8::Local<v8::Object> pipelineStructFieldToJs(CapnpContext& context,
                                               capnp::DynamicStruct::Pipeline& pipeline,
                                               capnp::StructSchema::Field field,
-                                               v8::Handle<v8::Value> capConstructor) {
-  v8::Handle<v8::Object> fieldValue = v8::Object::New(v8::Isolate::GetCurrent());
+                                               v8::Local<v8::Value> capConstructor) {
+  v8::Local<v8::Object> fieldValue = v8::Object::New(v8::Isolate::GetCurrent());
  pipelineToJs(context, pipeline.get(field).releaseAs<capnp::DynamicStruct>(),
               fieldValue, capConstructor);
  return fieldValue;
 }

 void pipelineToJs(CapnpContext& context, capnp::DynamicStruct::Pipeline&& pipeline,
-                  v8::Handle<v8::Object> js, v8::Handle<v8::Value> capConstructor) {
+                  v8::Local<v8::Object> js, v8::Local<v8::Value> capConstructor) {
  v8::HandleScope scope(v8::Isolate::GetCurrent());
  capnp::StructSchema schema = pipeline.getSchema();

  for (capnp::StructSchema::Field field: schema.getNonUnionFields()) {
    auto proto = field.getProto();
-    v8::Handle<v8::Object> fieldValue;
+    v8::Local<v8::Object> fieldValue;

    switch (proto.which()) {
      case capnp::schema::Field::SLOT: {
@@ -2265,9 +2276,11 @@ void pipelineToJs(CapnpContext& context, capnp::DynamicStruct::Pipeline&& pipeli
            fieldValue = context.wrapper.wrapCopy(kj::mv(cap));
            if (!capConstructor->IsUndefined() && capConstructor->IsFunction()) {
              v8::Function* func = v8::Function::Cast(*capConstructor);
-              v8::Handle<v8::Value> args[2] = { fieldValue,
+              v8::Local<v8::Value> args[2] = { fieldValue,
                  context.wrapper.wrapCopy(kj::mv(capSchema)) };
-              fieldValue = func->NewInstance(kj::size(args), args);
+              fieldValue = func->NewInstance(
+                  v8::Isolate::GetCurrent()->GetCurrentContext(), kj::size(args), args)
+                  .ToLocalChecked();
            }
            break;
          }
@@ -2315,9 +2328,9 @@ void send(const v8::FunctionCallbackInfo<v8::Value>& args) {
    return;
  }

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
-    OwnHandle<v8::Function> callback = v8::Handle<v8::Function>::Cast(args[1]);
-    OwnHandle<v8::Function> errorCallback = v8::Handle<v8::Function>::Cast(args[2]);
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
+    OwnHandle<v8::Function> callback = v8::Local<v8::Function>::Cast(args[1]);
+    OwnHandle<v8::Function> errorCallback = v8::Local<v8::Function>::Cast(args[2]);

    auto promise = KJ_REQUIRE_NONNULL(request.request, "Request already sent.").send();
    request.request = nullptr;
@@ -2327,7 +2340,7 @@ void send(const v8::FunctionCallbackInfo<v8::Value>& args) {
    auto canceler = kj::refcounted<Canceler>();
    canceler->fulfiller = kj::mv(cancelerPaf.fulfiller);

-    v8::Handle<v8::Object> result = context.wrapper.wrapCopy(kj::addRef(*canceler));
+    v8::Local<v8::Object> result = context.wrapper.wrapCopy(kj::addRef(*canceler));

    // Wait for results and call the callback.  Note that we can safely capture `context` by
    // reference because if the context is destroyed, the event loop will stop running.
@@ -2337,7 +2350,7 @@ void send(const v8::FunctionCallbackInfo<v8::Value>& args) {
          [&context](OwnHandle<v8::Function>&& callback,
                     capnp::Response<capnp::DynamicStruct>&& response) {
      v8::HandleScope scope(v8::Isolate::GetCurrent());
-      v8::Handle<v8::Value> args[1] = {
+      v8::Local<v8::Value> args[1] = {
        context.wrapper.wrapCopy(ClientResponse { kj::mv(response) })
      };
      // TODO(cleanup):  Call() demands an Object parameter but `undefined` is not an object.  So
@@ -2348,7 +2361,7 @@ void send(const v8::FunctionCallbackInfo<v8::Value>& args) {
          [&context](OwnHandle<v8::Function>&& errorCallback,
                     kj::Exception&& exception) {
      v8::HandleScope scope(v8::Isolate::GetCurrent());
-      v8::Handle<v8::Value> args[1] = { toJsException(kj::mv(exception)) };
+      v8::Local<v8::Value> args[1] = { toJsException(kj::mv(exception)) };
      node::MakeCallback(scope.GetIsolate(), v8::Object::New(scope.GetIsolate()),
                         errorCallback.get(), 1, args);
    }));
@@ -2377,8 +2390,8 @@ void cancel(const v8::FunctionCallbackInfo<v8::Value>& args) {

 class LocalCap final: public capnp::DynamicCapability::Server {
 public:
-  LocalCap(capnp::InterfaceSchema schema, v8::Handle<v8::Object> object,
-           CapnpContext& capnpContext, v8::Handle<v8::Value> capnpContextHandle)
+  LocalCap(capnp::InterfaceSchema schema, v8::Local<v8::Object> object,
+           CapnpContext& capnpContext, v8::Local<v8::Value> capnpContextHandle)
      : capnp::DynamicCapability::Server(schema),
        object(object), capnpContext(capnpContext), capnpContextHandle(capnpContextHandle) {}

@@ -2390,7 +2403,7 @@ public:

    auto jsMethod = object->Get(newSymbol("close"));
    if (jsMethod->IsFunction()) {
-      auto func = v8::Handle<v8::Function>::Cast(jsMethod);
+      auto func = v8::Local<v8::Function>::Cast(jsMethod);
      node::MakeCallback(scope.GetIsolate(), object.get(), func, 0, nullptr);
    }
  }
@@ -2406,7 +2419,7 @@ public:
      KJ_FAIL_ASSERT("Method not implemented.", name) { break; }
      return kj::READY_NOW;
    }
-    auto func = v8::Handle<v8::Function>::Cast(jsMethod);
+    auto func = v8::Local<v8::Function>::Cast(jsMethod);

    auto paf = kj::newPromiseAndFulfiller<void>();

@@ -2415,7 +2428,7 @@ public:
    request.context = context;
    request.params = context.getParams();

-    v8::Handle<v8::Value> arg = capnpContext.wrapper.wrapCopy(kj::mv(request));
+    v8::Local<v8::Value> arg = capnpContext.wrapper.wrapCopy(kj::mv(request));
    node::MakeCallback(scope.GetIsolate(), object.get(), func, 1, &arg);
    return kj::mv(paf.promise);
  }
@@ -2427,7 +2440,7 @@ private:
 };

 capnp::DynamicCapability::Client FromJsConverter::fromLocalCap(
-    capnp::InterfaceSchema schema, v8::Handle<v8::Object> object) {
+    capnp::InterfaceSchema schema, v8::Local<v8::Object> object) {
  return kj::heap<LocalCap>(schema, object, context, contextHandle);
 }

@@ -2449,10 +2462,10 @@ void newCap(const v8::FunctionCallbackInfo<v8::Value>& args) {
    KJV8_TYPE_ERROR(obj, v8::Object);
  }

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return context.wrapper.wrapCopy(capnp::DynamicCapability::Client(
        kj::heap<LocalCap>(schema.asInterface(),
-                           v8::Handle<v8::Object>::Cast(args[1]),
+                           v8::Local<v8::Object>::Cast(args[1]),
                           context, args.Data())));
  });
 }
@@ -2469,7 +2482,7 @@ void newPromisedCap(const v8::FunctionCallbackInfo<v8::Value>& args) {
    KJV8_TYPE_ERROR(schema, capnp::InterfaceSchema);
  }

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    auto paf = kj::newPromiseAndFulfiller<capnp::Capability::Client>();

    v8::Local<v8::Object> result = v8::Object::New(v8::Isolate::GetCurrent());
@@ -2523,7 +2536,7 @@ void isCap(const v8::FunctionCallbackInfo<v8::Value>& args) {
  //
  // If `value` is a capability, return true.

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    return v8::Boolean::New(v8::Isolate::GetCurrent(),
        Wrapper::tryUnwrap<capnp::DynamicCapability::Client>(args[0]) != nullptr);
  });
@@ -2553,7 +2566,7 @@ void getResults(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP(CapnpContext, context, args.Data());
  KJV8_UNWRAP(ServerRequest, request, args[0]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    kj::Own<ServerResults> results;
    KJ_IF_MAYBE(existing, request.results) {
      results = kj::addRef(**existing);
@@ -2758,7 +2771,7 @@ void matchPowerboxQuery(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP_BUFFER(queryBuffer, args[0]);
  KJV8_UNWRAP_BUFFER(candidateBuffer, args[1]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    AlignedWords queryWords(queryBuffer);
    AlignedWords candidateWords(candidateBuffer);

@@ -2779,7 +2792,7 @@ void chacha20(const v8::FunctionCallbackInfo<v8::Value>& args) {
  KJV8_UNWRAP_BUFFER(nonce, args[1]);
  KJV8_UNWRAP_BUFFER(key, args[2]);

-  liftKj(args, [&]() -> v8::Handle<v8::Value> {
+  liftKj(args, [&]() -> v8::Local<v8::Value> {
    KJ_REQUIRE(key.size() == crypto_stream_chacha20_KEYBYTES);
    KJ_REQUIRE(nonce.size() == crypto_stream_chacha20_NONCEBYTES);

@@ -2827,14 +2840,14 @@ void catchSegfaults() {

 // -----------------------------------------------------------------------------

-void init(v8::Handle<v8::Object> exports) {
+void init(v8::Local<v8::Object> exports) {
  CapnpContext* context = new CapnpContext;
  auto wrappedContext = context->wrapper.wrap(context);

  auto mapFunction = [&](const char* name, v8::FunctionCallback callback) {
    exports->Set(newSymbol(name),
        v8::FunctionTemplate::New(v8::Isolate::GetCurrent(), callback, wrappedContext)
-            ->GetFunction());
+            ->GetFunction(v8::Isolate::GetCurrent()->GetCurrentContext()).ToLocalChecked());
  };

  mapFunction("setNative", setNative);
@@ -0,0 +1,45 @@
+declare module Capnp {
+  type Id = string;
+
+  abstract class StructSchema<Builder, Reader> {
+    // A schema for a struct type. The `Builder` parameter is what users of
+    // the library specify in order to create a value; it may be missing fields,
+    // which will be filled in with defaults. A `Reader` is what is is returned
+    // when parsing a value, and is guaranteed to have all known fields set.
+
+    typeId: Id;
+  }
+
+  abstract class InterfaceSchema<Server, Client> {
+    // A schema for an interface type. Similarly to `StructSchema`, the `Server`
+    // and `Client` parameters represent objects which may have missing
+    // methods (for servers), and ones which do not (for clients, though calling
+    // the method may still throw unimplemented).
+
+    typeId: Id;
+  }
+
+  interface AnyServer {
+    close?: () => void;
+  }
+
+  interface AnyClient {
+    close(): void;
+    closed: boolean;
+    castAs<Server, Client>(schema: InterfaceSchema<Server, Client>): Client;
+  }
+
+  const Capability: {
+    new<Server, Client>(server: Server, schema: InterfaceSchema<Server, Client>): Client;
+  }
+
+  abstract class Connection {
+    restore<Server, Client>(exportName: string, type: InterfaceSchema<Server, Client>): Client;
+    close(): void;
+  }
+
+  function parse<Builder, Reader>(type: StructSchema<Builder, Reader>, buffer: Buffer): Reader;
+  function serialize<Builder, Reader>(type: StructSchema<Builder, Reader>, builder: Builder): Buffer;
+  function connect(addr: string): Connection;
+}
+export default Capnp;
@@ -0,0 +1 @@
+module.exports = require("capnp").importSystem("capnp/stream.capnp");
Author	SHA1	Message	Date
Kenton Varda	a2ed298d34	Merge pull request #68 from zenhack/module-stubs Add .capnp.js stubs generated by capnpc-node-typescript.	2020-12-16 21:52:36 -06:00
Kenton Varda	8509161f7c	Merge pull request #67 from zenhack/typescript-decl-fix Small fix in the typescript declarations, and add some comments.	2020-12-14 16:53:50 -06:00
Ian Denhardt	b88ab5a305	Add .capnp.js stubs generated by capnpc-node-typescript. Per discussion in #62, this allows importing modules to use "normal" imports, which is important for typescript since it doesn't understand `capnp.importSystem()` and friends. We could also merge in the type declarations themselves, but that isn't strictly necessary, since typescript is built around being able to supply your own stubs for other libraries. I may do something in that vein in a follow-on pr, but I want to think a bit about how this will all fit together.	2020-12-12 02:29:24 -05:00
Ian Denhardt	ac4c2574a6	ts declarations: Add comments describing how the type parameters work.	2020-12-12 02:00:08 -05:00
Ian Denhardt	0ba69aec95	Fix a mistake in the type declaration file. The argument to serialize() should be a builder, not a reader.	2020-12-12 01:54:15 -05:00
Kenton Varda	7ef8da3d79	Merge pull request #66 from zenhack/gitignore-capnp.node Add capnp.node to .gitignore	2020-12-07 13:39:16 -06:00
Ian Denhardt	0e9376071e	Add capnp.node to .gitignore	2020-12-07 10:42:43 -05:00
Kenton Varda	d75642d0e8	Merge pull request #62 from zenhack/typescript-declaration-file Add a typescript declaration file.	2020-11-30 16:05:15 -06:00
Ian Denhardt	6eb94df293	Add a typescript declaration file. This covers most of the API that is documented in the README, though I see that there are some things exposed in `capnp.js` but not documented -- the declaration file does not currently cover those. This is designed to work with the output of: https://github.com/zenhack/capnpc-node-typescript ...which is nearing completion.	2020-10-28 16:30:22 -04:00
Kenton Varda	544bf09271	Merge pull request #60 from ocdtrekkie/patch-1 Readme typos	2020-06-08 09:53:11 -05:00
Jacob Weisz	b45f75c8f9	Readme typos	2020-06-08 07:38:12 -05:00
Kenton Varda	752d3cdffd	Merge pull request #59 from zenhack/null-handle-cleanup More defensive/sensible handling of a case that probably can't happen.	2020-05-11 10:03:05 -05:00
Ian Denhardt	0371c68bcd	More defensive/sensible handling of a case that probably can't happen. I found this by running clang-analyzer. With the previous version of the code, if `handler` is null, then we assign `self = nullptr` and then immediately call a method on it. I'm pretty sure this can't actually happen -- I don't think `uv_timer_start` will ever pass nullptr to the callback -- but the logic is obviously bogus so let's replace it with something defensive.	2020-05-09 23:56:19 -04:00
Kenton Varda	ae6f591602	Merge pull request #58 from zenhack/version-bump Bump version in package.json	2020-03-24 13:03:16 -05:00
Ian Denhardt	81aeebf181	Bump version in package.json I just published this to the npm registry, we should probably update the version in the git repo too. It seems to work on node 12, though node 10 is still failing. I actually can reproduce the failures locally if: - I start a fresh npm project and do `npm install `/path/to/node-canpnp/src` - The working directory for `node-capnp` is clean. I may try to troubleshoot this more later. Perhaps we should unpublish, but having a version that works on node 12 is possibly an improvement, so maybe not... Npm insisted that 0.4.0 already existed and was refusing to re-publish it (I assume there was a deleted failed attempt), so I had to bump the version to get it to work.	2020-03-23 16:01:04 -04:00
Kenton Varda	0cc5054ea2	Merge branch 'node8' into node10	2020-03-14 18:24:46 -05:00
Kenton Varda	cdda439e4a	Merge pull request #57 from redsift/node12 Node12 support	2020-03-14 17:25:45 -05:00
Kenton Varda	932e589f36	Merge pull request #55 from zenhack/exception-docs Document how exceptions work.	2020-01-08 17:50:15 -06:00
Ian Denhardt	46fd0a8b6e	Document how exceptions work. Fixes #53.	2020-01-08 17:53:10 -05:00
Kenton Varda	5e8c4c0b1b	Merge pull request #51 from redsift/fix/build Fix the build process.	2020-01-07 10:56:44 -06:00
Deepak Prabhakara	7ab91af445	pipe stdout and stderr from child process so we can see the logs	2019-12-22 23:32:31 +00:00
Deepak Prabhakara	05644ec31b	v8 and nan compilation fixes for node12	2019-12-22 23:26:49 +00:00
Christos Vontas	28de5052c0	Merge pull request #1 from redsift/fix/build afterBuild needs to run after all IO has finished	2019-12-11 13:50:24 +00:00
Christos Vontas	c720781a5f	afterBuild needs to run after all IO has finished	2019-12-11 13:42:05 +00:00
Kenton Varda	eae9c1c54b	Update for Node 10.	2019-01-07 13:44:26 -08:00
				`@@ -0,0 +1 @@`
				`module.exports = require("capnp").importSystem("capnp/c++.capnp");`