legacy-libs/grpc/ext/byte_buffer.cc

   1 /*
   2  *
   3  * Copyright 2015 gRPC authors.
   4  *
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *     http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  */
  18
  19 #include <string.h>
  20
  21 #include <nan.h>
  22 #include <node.h>
  23 #include "grpc/byte_buffer_reader.h"
  24 #include "grpc/grpc.h"
  25 #include "grpc/slice.h"
  26
  27 #include "byte_buffer.h"
  28 #include "slice.h"
  29
  30 namespace grpc {
  31 namespace node {
  32
  33 using Nan::Callback;
  34 using Nan::MaybeLocal;
  35
  36 using v8::Function;
  37 using v8::Local;
  38 using v8::Object;
  39 using v8::Number;
  40 using v8::Value;
  41
  42 grpc_byte_buffer *BufferToByteBuffer(Local<Value> buffer) {
  43   Nan::HandleScope scope;
  44   grpc_slice slice = CreateSliceFromBuffer(buffer);
  45   grpc_byte_buffer *byte_buffer(grpc_raw_byte_buffer_create(&slice, 1));
  46   grpc_slice_unref(slice);
  47   return byte_buffer;
  48 }
  49
  50 namespace {
  51 void delete_buffer(char *data, void *hint) {
  52   grpc_slice *slice = static_cast<grpc_slice *>(hint);
  53   grpc_slice_unref(*slice);
  54   delete slice;
  55 }
  56 }
  57
  58 Local<Value> ByteBufferToBuffer(grpc_byte_buffer *buffer) {
  59   Nan::EscapableHandleScope scope;
  60   if (buffer == NULL) {
  61     return scope.Escape(Nan::Null());
  62   }
  63   grpc_byte_buffer_reader reader;
  64   if (!grpc_byte_buffer_reader_init(&reader, buffer)) {
  65     Nan::ThrowError("Error initializing byte buffer reader.");
  66     return scope.Escape(Nan::Undefined());
  67   }
  68   grpc_slice *slice = new grpc_slice;
  69   *slice = grpc_byte_buffer_reader_readall(&reader);
  70   grpc_byte_buffer_reader_destroy(&reader);
  71   char *result = reinterpret_cast<char *>(GRPC_SLICE_START_PTR(*slice));
  72   size_t length = GRPC_SLICE_LENGTH(*slice);
  73   Local<Value> buf =
  74       Nan::NewBuffer(result, length, delete_buffer, slice).ToLocalChecked();
  75   return scope.Escape(buf);
  76 }
  77
  78 }  // namespace node
  79 }  // namespace grpc