118 lines
3.4 KiB
C++
118 lines
3.4 KiB
C++
/*!
|
|
* ws: a node.js websocket client
|
|
* Copyright(c) 2011 Einar Otto Stangvik <einaros@gmail.com>
|
|
* MIT Licensed
|
|
*/
|
|
|
|
#include <v8.h>
|
|
#include <node.h>
|
|
#include <node_buffer.h>
|
|
#include <node_object_wrap.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <wchar.h>
|
|
#include <stdio.h>
|
|
#include "nan.h"
|
|
|
|
using namespace v8;
|
|
using namespace node;
|
|
|
|
class BufferUtil : public ObjectWrap
|
|
{
|
|
public:
|
|
|
|
static void Initialize(v8::Handle<v8::Object> target)
|
|
{
|
|
NanScope();
|
|
Local<FunctionTemplate> t = FunctionTemplate::New(New);
|
|
t->InstanceTemplate()->SetInternalFieldCount(1);
|
|
NODE_SET_METHOD(t, "unmask", BufferUtil::Unmask);
|
|
NODE_SET_METHOD(t, "mask", BufferUtil::Mask);
|
|
NODE_SET_METHOD(t, "merge", BufferUtil::Merge);
|
|
target->Set(String::NewSymbol("BufferUtil"), t->GetFunction());
|
|
}
|
|
|
|
protected:
|
|
|
|
static NAN_METHOD(New)
|
|
{
|
|
NanScope();
|
|
BufferUtil* bufferUtil = new BufferUtil();
|
|
bufferUtil->Wrap(args.This());
|
|
NanReturnValue(args.This());
|
|
}
|
|
|
|
static NAN_METHOD(Merge)
|
|
{
|
|
NanScope();
|
|
Local<Object> bufferObj = args[0]->ToObject();
|
|
char* buffer = Buffer::Data(bufferObj);
|
|
Local<Array> array = Local<Array>::Cast(args[1]);
|
|
unsigned int arrayLength = array->Length();
|
|
size_t offset = 0;
|
|
unsigned int i;
|
|
for (i = 0; i < arrayLength; ++i) {
|
|
Local<Object> src = array->Get(i)->ToObject();
|
|
size_t length = Buffer::Length(src);
|
|
memcpy(buffer + offset, Buffer::Data(src), length);
|
|
offset += length;
|
|
}
|
|
NanReturnValue(True());
|
|
}
|
|
|
|
static NAN_METHOD(Unmask)
|
|
{
|
|
NanScope();
|
|
Local<Object> buffer_obj = args[0]->ToObject();
|
|
size_t length = Buffer::Length(buffer_obj);
|
|
Local<Object> mask_obj = args[1]->ToObject();
|
|
unsigned int *mask = (unsigned int*)Buffer::Data(mask_obj);
|
|
unsigned int* from = (unsigned int*)Buffer::Data(buffer_obj);
|
|
size_t len32 = length / 4;
|
|
unsigned int i;
|
|
for (i = 0; i < len32; ++i) *(from + i) ^= *mask;
|
|
from += i;
|
|
switch (length % 4) {
|
|
case 3: *((unsigned char*)from+2) = *((unsigned char*)from+2) ^ ((unsigned char*)mask)[2];
|
|
case 2: *((unsigned char*)from+1) = *((unsigned char*)from+1) ^ ((unsigned char*)mask)[1];
|
|
case 1: *((unsigned char*)from ) = *((unsigned char*)from ) ^ ((unsigned char*)mask)[0];
|
|
case 0:;
|
|
}
|
|
NanReturnValue(True());
|
|
}
|
|
|
|
static NAN_METHOD(Mask)
|
|
{
|
|
NanScope();
|
|
Local<Object> buffer_obj = args[0]->ToObject();
|
|
Local<Object> mask_obj = args[1]->ToObject();
|
|
unsigned int *mask = (unsigned int*)Buffer::Data(mask_obj);
|
|
Local<Object> output_obj = args[2]->ToObject();
|
|
unsigned int dataOffset = args[3]->Int32Value();
|
|
unsigned int length = args[4]->Int32Value();
|
|
unsigned int* to = (unsigned int*)(Buffer::Data(output_obj) + dataOffset);
|
|
unsigned int* from = (unsigned int*)Buffer::Data(buffer_obj);
|
|
unsigned int len32 = length / 4;
|
|
unsigned int i;
|
|
for (i = 0; i < len32; ++i) *(to + i) = *(from + i) ^ *mask;
|
|
to += i;
|
|
from += i;
|
|
switch (length % 4) {
|
|
case 3: *((unsigned char*)to+2) = *((unsigned char*)from+2) ^ *((unsigned char*)mask+2);
|
|
case 2: *((unsigned char*)to+1) = *((unsigned char*)from+1) ^ *((unsigned char*)mask+1);
|
|
case 1: *((unsigned char*)to ) = *((unsigned char*)from ) ^ *((unsigned char*)mask);
|
|
case 0:;
|
|
}
|
|
NanReturnValue(True());
|
|
}
|
|
};
|
|
|
|
extern "C" void init (Handle<Object> target)
|
|
{
|
|
NanScope();
|
|
BufferUtil::Initialize(target);
|
|
}
|
|
|
|
NODE_MODULE(bufferutil, init)
|
|
|