From 396f2e0b9abf8c0f0342ee1978588a4c06becacf Mon Sep 17 00:00:00 2001 From: brettlangdon Date: Mon, 25 Jun 2012 08:23:38 -0400 Subject: [PATCH] cleaned up directory, added kafka and zookeeper module dependencies. starting fresh --- README.md | 3 --- lib/index.js | 2 +- package.json | 2 ++ src/consumer.cc | 39 --------------------------------------- src/consumer.h | 20 -------------------- src/franz.cc | 29 ----------------------------- src/producer.cc | 39 --------------------------------------- src/producer.h | 20 -------------------- wscript | 15 --------------- 9 files changed, 3 insertions(+), 166 deletions(-) delete mode 100644 src/consumer.cc delete mode 100644 src/consumer.h delete mode 100644 src/franz.cc delete mode 100644 src/producer.cc delete mode 100644 src/producer.h delete mode 100644 wscript diff --git a/README.md b/README.md index d1746ce..f04e412 100644 --- a/README.md +++ b/README.md @@ -3,6 +3,3 @@ franz Franz is a Kafka Client for Node.JS that includes support for Zookeeper -## TODO ## - -I intend to write this module in C++ so I can incorporate the already available Kafka and Zookeeper libraries available. \ No newline at end of file diff --git a/lib/index.js b/lib/index.js index ee24a83..7c6d6c7 100644 --- a/lib/index.js +++ b/lib/index.js @@ -1 +1 @@ -module.exports = require('../build/Release/franz'); \ No newline at end of file +module.exports = {} \ No newline at end of file diff --git a/package.json b/package.json index bcc4317..804e976 100644 --- a/package.json +++ b/package.json @@ -13,6 +13,8 @@ , "url": "github.com/brettlangdon/franz.git" } , "dependencies": { + "kafka": ">=0.2.1" + , "zookeeper":">=3.4.1-3" } , "main": "./lib/index.js" , "engines": { "node": ">= 0.6.0" } diff --git a/src/consumer.cc b/src/consumer.cc deleted file mode 100644 index 7871c93..0000000 --- a/src/consumer.cc +++ /dev/null @@ -1,39 +0,0 @@ -#define BUILDING_NODE_EXTENSION -#include -#include "consumer.h" - -using namespace v8; - -Consumer::Consumer() {}; -Consumer::~Consumer() {}; - -Persistent Consumer::constructor; - -void Consumer::Init() { - // Prepare constructor template - Local tpl = FunctionTemplate::New(New); - tpl->SetClassName(String::NewSymbol("Consumer")); - tpl->InstanceTemplate()->SetInternalFieldCount(1); - - - constructor = Persistent::New(tpl->GetFunction()); -} - -Handle Consumer::New(const Arguments& args) { - HandleScope scope; - - Consumer* obj = new Consumer(); - obj->Wrap(args.This()); - - return args.This(); -} - -Handle Consumer::NewInstance(const Arguments& args) { - HandleScope scope; - - const unsigned argc = 0; - Handle argv[argc] = {}; - Local instance = constructor->NewInstance(argc, argv); - - return scope.Close(instance); -} diff --git a/src/consumer.h b/src/consumer.h deleted file mode 100644 index 2bc381c..0000000 --- a/src/consumer.h +++ /dev/null @@ -1,20 +0,0 @@ -#define BUILDING_NODE_EXTENSION -#ifndef CONSUMER_H -#define CONSUMER_H - -#include - -class Consumer : public node::ObjectWrap { - public: - static void Init(); - static v8::Handle NewInstance(const v8::Arguments& args); - - private: - Consumer(); - ~Consumer(); - - static v8::Persistent constructor; - static v8::Handle New(const v8::Arguments& args); -}; - -#endif diff --git a/src/franz.cc b/src/franz.cc deleted file mode 100644 index 5dfb104..0000000 --- a/src/franz.cc +++ /dev/null @@ -1,29 +0,0 @@ -#define BUILDING_NODE_EXTENSION -#include -#include "producer.h" -#include "consumer.h" - -using namespace v8; - -Handle CreateProducer(const Arguments& args) { - HandleScope scope; - return scope.Close(Producer::NewInstance(args)); -} - -Handle CreateConsumer(const Arguments& args) { - HandleScope scope; - return scope.Close(Consumer::NewInstance(args)); -} - -void InitAll(Handle target) { - Producer::Init(); - Consumer::Init(); - - target->Set(String::NewSymbol("createProducer"), - FunctionTemplate::New(CreateProducer)->GetFunction()); - - target->Set(String::NewSymbol("createConsumer"), - FunctionTemplate::New(CreateConsumer)->GetFunction()); -} - -NODE_MODULE(franz, InitAll) diff --git a/src/producer.cc b/src/producer.cc deleted file mode 100644 index d1271ee..0000000 --- a/src/producer.cc +++ /dev/null @@ -1,39 +0,0 @@ -#define BUILDING_NODE_EXTENSION -#include -#include "producer.h" - -using namespace v8; - -Producer::Producer() {}; -Producer::~Producer() {}; - -Persistent Producer::constructor; - -void Producer::Init() { - // Prepare constructor template - Local tpl = FunctionTemplate::New(New); - tpl->SetClassName(String::NewSymbol("Producer")); - tpl->InstanceTemplate()->SetInternalFieldCount(1); - - - constructor = Persistent::New(tpl->GetFunction()); -} - -Handle Producer::New(const Arguments& args) { - HandleScope scope; - - Producer* obj = new Producer(); - obj->Wrap(args.This()); - - return args.This(); -} - -Handle Producer::NewInstance(const Arguments& args) { - HandleScope scope; - - const unsigned argc = 0; - Handle argv[argc] = {}; - Local instance = constructor->NewInstance(argc, argv); - - return scope.Close(instance); -} diff --git a/src/producer.h b/src/producer.h deleted file mode 100644 index 99aa7b9..0000000 --- a/src/producer.h +++ /dev/null @@ -1,20 +0,0 @@ -#define BUILDING_NODE_EXTENSION -#ifndef PRODUCER_H -#define PRODUCER_H - -#include - -class Producer : public node::ObjectWrap { - public: - static void Init(); - static v8::Handle NewInstance(const v8::Arguments& args); - - private: - Producer(); - ~Producer(); - - static v8::Persistent constructor; - static v8::Handle New(const v8::Arguments& args); -}; - -#endif diff --git a/wscript b/wscript deleted file mode 100644 index 76076dd..0000000 --- a/wscript +++ /dev/null @@ -1,15 +0,0 @@ -srcdir = '.' -blddir = 'build' -VERSION = '0.0.1' - -def set_options(opt): - opt.tool_options('compiler_cxx') - -def configure(conf): - conf.check_tool('compiler_cxx') - conf.check_tool('node_addon') - -def build(bld): - obj = bld.new_task_gen('cxx', 'shlib', 'node_addon') - obj.target = 'franz' - obj.source = ['src/consumer.cc','src/producer.cc','src/franz.cc'] \ No newline at end of file