Nicolson

client.js

@@ -0,0 +1,60 @@
+// Meteor.subscribe("users",Meteor.userId());
+
+WI.find({}).observe({
+	"added": function(docs){
+		Unionize.onChangeClient(docs);
+	},
+	"changed": function(docs){
+		Unionize.onChangeClient(docs);
+	},
+	"removed": function(docs){
+		Unionize.onChangeClient(docs);		
+	}
+});
+
+Session.setDefault("inbox", []);
+Session.setDefault("outbox", []);
+Session.setDefault("follow", []);
+Session.setDefault("big", []);
+Unionize.onChangeFlag = false;
+Unionize.onChangeClient = function(doc){
+	if(Unionize.onChangeFlag)
+		return;
+	if(userId == doc._id){
+		if(doc.inbox && Session.get("inbox").length != doc.inbox.length)
+			Session.set("inbox",doc.inbox);
+		if(doc.outbox && Session.get("outbox").length != doc.outbox.length)
+			Session.set("outbox",doc.outbox);
+		if(doc.follow && Session.get("follow").length != doc.follow.length)
+			Session.set("follow",doc.follow);
+		if(doc.big && Session.get("big").length != doc.big.length)
+			Session.set("big",doc.big);
+	}
+	Unionize.onChangeFlag = false;
+}
+
+// WI.after.insert(function(userId, doc, fieldNames, modifier, options){
+
+// });
+
+// WI.after.update(function(userId, doc, fieldNames, modifier, options){
+// 		log("here too");
+// 	if(userId == window.userId){
+// 		log("here");
+// 		Session.set("inbox",doc.inbox);
+// 		Session.set("outbox",doc.outbox);
+// 		Session.set("follow",doc.follow);
+// 	}
+// });
+
+// WI.after.remove(function(userId, doc, fieldNames, modifier, options){
+// 	log("here too");
+// 	if(userId == window.userId){
+// 		log("here");
+// 		Session.set("inbox",doc.inbox);
+// 		Session.set("outbox",doc.outbox);
+// 		Session.set("follow",doc.follow);
+// 	}
+// });
+
+

lib.js

@@ -0,0 +1,112 @@
+var WIModel = function(options){
+	return {
+  "_id": options._id,
+  "inbox": [],
+  "outbox": [],
+  "follow": [],
+  "big": [],
+  "seen": [],
+  "vote": [],
+  "recommend": [],
+  "profile": {
+  	"profile_picture": "http://i.imgur.com/vaCjg.jpg"
+  }
+}
+}
+Unionize = {};
+WI = new Mongo.Collection("wi");
+W = new Mongo.Collection("w");
+log = console.log.bind(console);
+
+Unionize.getUTC = function(){
+	return new Date().getTime();
+}
+Unionize.exists = function(userId){
+	return WI.find(userId).count()
+}
+Unionize.prepare = function(userId){
+	if(Unionize.exists(userId) == 0){
+		var wiModel = new WIModel({"_id": userId});
+		WI.insert(wiModel);
+		return false;
+	}
+	return true;
+}
+Unionize.connect = function(docs){
+	if(!docs)
+		throw new new Meteor.Error("Please check information provided undefined", "404");
+	if(!docs.from_user){
+		throw new new Meteor.Error("Source is not defined from_user", "404");		
+	}
+	if(!docs.to_user)
+		throw new new Meteor.Error("Target is not defined to_user", "404");
+
+	Unionize.prepare(docs.from_user);
+
+  docs.startTime = Unionize.getUTC();
+	docs.journey = [{"onConnect": Unionize.getUTC()- docs.startTime}];
+	WI.update(docs.from_user,{$push: {"outbox": docs}});
+}
+
+
+// hooks
+
+Unionize.onWUpdateHook = function(userId, docs){
+  // log("Unionize.onWInsertHook");
+  // log(docs.clientUpdate,Meteor.isServer)
+  if(docs.clientUpdate && Meteor.isServer)
+   return docs;
+
+  if(Meteor.isClient){
+    if(!Unionize.exists(docs.to_user))
+      return docs;
+    docs.clientUpdate = true;
+  }
+
+  Unionize.prepare(docs.to_user);
+
+  docs.journey.push({"onWUpdateHook": Unionize.getUTC()- docs.startTime});
+
+  // console.log(docs._id,Meteor.isClient,Meteor.isServer)
+  W.insert(docs);
+
+  docs.journey.push({"onInsertW": Unionize.getUTC()- docs.startTime});
+
+
+
+  WI.update(docs.to_user,{$push: {"inbox": docs}});
+  docs.journey.push({"onInsertWIInbox": Unionize.getUTC()- docs.startTime});
+  // if(WI.find(docs.to_user).count()){
+  //   // log("to_user updated");
+  // }
+  return docs;
+
+  // replicated on W collection
+}
+
+// WI.insert.before(function(docs){
+
+// });
+
+// WI.insert.after(function(docs){
+
+// });
+
+// log(W.before.insert())
+// W.before.insert(function(userId, docs){
+//   // Unionize.onWInsertHook(userId, docs);
+// });
+
+
+WI.before.update(function(userId, doc, fieldNames, modifier, options){
+  // log(Meteor.isClient,Meteor.isServer)
+  if(fieldNames[0] == "outbox"){
+    modifier["$push"].outbox = Unionize.onWUpdateHook(userId, modifier["$push"].outbox);
+    var docs = modifier["$push"].outbox
+    docs.journey.push({"onInsertWIInbox": Unionize.getUTC() - docs.startTime});
+    // log(userId, doc, fieldNames, modifier, options)    
+  }
+});
+// W.after.update(function(){
+
+// });

methods.js

@@ -0,0 +1,7 @@
+// methods
+Meteor.methods({
+  "updateUserElement": function(find,update){
+    WI.update(find,
+        update)
+  }
+});

package.js

@@ -14,47 +14,75 @@ Package.describe({
 // add grounddb here
 Package.on_use(function (api) {
   api.versionsFrom('1.0.3.1');
-  api.use(['matb33:[email protected]','coffeescript'], ['client', 'server']);
+  api.use([
+    'matb33:collection-hooks',
+    'coffeescript',
+    'mongo',
+    'accounts-base',
+    'session',
+    ], ['client', 'server']);
 
-  // like Document W will be an extended coll..
-  api.export('Unionize');
+  api.export(["W","WI","Unionize"], ['client','server']);
 
   api.add_files([
-    'lib.coffee'
+    'lib.js'
   ], ['client','server']);
 
   api.add_files([
-    'client.coffee'
-  ], 'client');
+    'client.js'
+  ], ['client']);
 
   api.add_files([
-    'server.coffee', 'publish.coffee'
-  ], 'server');
+    'server.js',
+    'rules.js',
+    'methods.js',
+    'publish.js'
+  ], ['server']);
+
 });
 
 Package.on_test(function (api) {
-  api.versionsFrom('1.0.3.1');
-  api.use(['underscore','ground:[email protected]','aldeed:console-me','matb33:[email protected]','tracker', 'tinytest', 'test-helpers', 'coffeescript', 'insecure', 'accounts-base', 'accounts-password', 'underscore', 'random', 'pedrohenriquerls:reactjs'], ['client', 'server']);
-  api.add_files([
-    'lib.coffee',
-    'testUpdateClient.coffee',
-    'tests.coffee',
-  ], ['client', 'server']);
-
-  api.add_files([ 
-    'server.coffee',
-    'publish.coffee'
-  ], ['server']);
+  // api.versionsFrom('1.0.3.1');
+  api.use(
+    [
+      'underscore',
+      'ground:db',
+      'aldeed:console-me',
+      'matb33:collection-hooks',
+      'tracker', 
+      'tinytest', 
+      'test-helpers', 
+      'coffeescript', 
+      'insecure', 
+      'accounts-base', 
+      'accounts-password', 
+      'underscore', 
+      'random', 
+      'pedrohenriquerls:reactjs',
+      'mongo'
+    ], 
+    [
+      'client', 
+      'server'
+    ]);
+
+  api.export(["W","WI","Unionize"], ['client','server']);
 
   api.add_files([
-    'client.coffee'
-  ], ['client']);
-  
+    'lib.js'
+  ], ['client','server']);
+
   api.add_files([
-    'react_test.coffee'
+    'client.js'
   ], ['client']);
-});
 
+  api.add_files([
+    'server.js'
+  ], ['server']);
 
+  api.add_files([
+    'test.js'
+  ], ['client','server']);
 
 
+});

publish.js

@@ -0,0 +1,6 @@
+Meteor.publish(null,function(){
+	return WI.find({});
+});
+Meteor.publish(null,function(){
+	return W.find({});
+});

react_package.coffee

@@ -0,0 +1,38 @@
+@userId = 'wiber' unless Meteor.userId()
+
+
+@FeedList = React.createClass
+  "getInitialState": ()->
+    {feeds: WI.findOne 
+      "_id": userId}
+  "componentDidMount": ()->
+    self = @
+    Tracker.autorun ()->
+      feed = WI.findOne({"_id": userId})   
+      self.setState({"feeds": feed})
+  "render": ()->
+    feedsList = []
+    # console.log(this.state.feeds)
+    if(this.state.feeds and this.state.feeds.outbox)
+      outbox = this.state.feeds.outbox
+      feedsList = outbox.map (feed)->
+        # console.log(feed)
+        # React.DOM.div(null,"Something is returned")
+        Feed({"feed": feed})
+    # console.error(feedsList)
+    return React.DOM.div(null,"",feedsList)
+
+@Feed = React.createClass({
+  "render": ()->
+    # console.error(this.props.feed)
+    feed = this.props.feed
+
+    React.DOM.div(null,{},
+      feed.from
+      # [
+      #   React.DOM.div(null,{},feed.from),
+      #   React.DOM.div(null,{},feed.to)    
+      # ]
+    )
+    # React.DOM.div(null,"Something is returning")
+})

react_test.coffee

@@ -1,26 +1,25 @@
 
-# doesn't need to be asyn
-
-Tinytest.add 'reactjs - 5 dom element equals to data', (test, next) ->
-  testingRecommend = { from: 'another1', to: 'wiber6' }
-  connect(testingRecommend)
-  intervalId = null
-  intervalId = setInterval(()->
-    domString = React.renderComponentToString(feedItems(null))
-    if domString.match(testingRecommend.from + testingRecommend.to)
-      test.equal(true,true)
-      next()
-      clearInterval(intervalId)
-  , 500)
 
+# Tinytest.addAsync 'reactjs - dom element equals to data', (test, next) ->
+#   testingRecommend = { from: 'another1', to: 'wiber6' }
+#   connect(testingRecommend)
+#   intervalId = null
+#   intervalId = setInterval(()->
+#     domString = React.renderComponentToString(feedItems(null))
+#     if domString.match(testingRecommend.from + testingRecommend.to)
+#       test.equal(true,true)
+#       next()
+#       clearInterval(intervalId)
+#   , 500)
+
   # @feedItems = React.createClass
   #   "getInitialState": ()->
   #     {feeds: WI.findOne 
-  #       "_id": user}
+  #       "_id": myWI}
   #   "componentDidMount": ()->
   #     self = @
   #     Tracker.autorun ()->
-  #       feed = WI.findOne({"_id": user})   
+  #       feed = WI.findOne({"_id": myWI})   
   #       self.setState({"feeds": feed})
   #   "render": ()->
   #     # console.error(this.state.feeds)
@@ -38,4 +37,23 @@ Tinytest.add 'reactjs - 5 dom element equals to data', (test, next) ->
   #       test.equal(this.state.feeds.sending.length,feedsList.length)
   #       next()
   #     return React.DOM.div(null,feedsList)
-  # React.renderComponentToString(@feedItems(null))
+  # React.renderComponentToString(@feedItems(null))
+
+smite = ()->
+  #nothing here yet.
+
+
+
+aNewReact = React.createClass({
+  "onClick": ()->
+  ,
+  "render": ()->
+    # return <div> </div>
+    return React.DOM.div(null,{
+      "onClick": this.onClick
+    })
+  ,
+  "event": ()->
+    #changes
+})
+