From 049233c0a190233181904fe27e5fee637cd24ece Mon Sep 17 00:00:00 2001
From: Berkeley Martinez <Berkeley@robotie.com>
Date: Sat, 20 Jun 2015 19:55:22 -0700
Subject: [PATCH] fix add server/utils/rx to commit

---
 server/utils/rx.js | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)
 create mode 100644 server/utils/rx.js

diff --git a/server/utils/rx.js b/server/utils/rx.js
new file mode 100644
index 0000000000..8a4003c00c
--- /dev/null
+++ b/server/utils/rx.js
@@ -0,0 +1,25 @@
+var Rx = require('rx');
+var debug = require('debug')('freecc:rxUtils');
+
+exports.saveUser = function saveUser(user) {
+  return new Rx.Observable.create(function(observer) {
+    if (!user || typeof user.save !== 'function') {
+      debug('no user or save method');
+      observer.onNext();
+      return observer.onCompleted();
+    }
+    user.save(function(err, savedUser) {
+      if (err) {
+        return observer.onError(err);
+      }
+      debug('user saved');
+      observer.onNext(savedUser);
+      observer.onCompleted();
+    });
+  });
+};
+
+exports.observableQueryFromModel =
+  function observableQueryFromModel(Model, method, query) {
+    return Rx.Observable.fromNodeCallback(Model[method], Model)(query);
+  };