first commit-

Netflix · Feb 12, 2015 · a2b7259 · a2b7259
commit a2b7259
Show file tree

Hide file tree

Showing 60 changed files with 24,065 additions and 0 deletions.
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,4 @@
+.idea
+falkor_node.iml
+node_modules
+data
diff --git a/Cache.js b/Cache.js
@@ -0,0 +1,308 @@
+var expiredTimestamp = Date.now() - 100;
+var Cache = function() {
+    return {
+        "$size": 1002,
+        "genreList": {
+            "$size": 81,
+            "-1": ["lists", "def"],
+            "0": ["lists", "abcd"],
+            "1": ["lists", "my-list"],
+            "2": ["lists", "error-list"],
+            "3": ["lists", "sentinel-list"],
+            "4": ["lists", "missing-list"],
+            "5": ["lists", "to-error-list"],
+            "6": ["lists", "to-missing-list"],
+            "7": ["lists", "to-sentinel-list"],
+            "8": ["lists", "expired-list"],
+            "9": ["lists", "to-expired-list"],
+            "10": ["videos", 1234, "summary"],
+            "11": ["lists", "expired-video-branch"],
+            "12": ["lists", "future-expired-list"],
+            "sentinel": {
+                "$size": 52,
+                "$type": "sentinel",
+                "value": ["lists", "to-sentinel-list"]
+            },
+            "branch-miss": ['does', 'not', 'exist']
+        },
+        "lists": {
+            "$size": 489,
+            "abcd": {
+                "$size": 8,
+                "-1": ["videos", 4422],
+                "0": ["videos", 1234],
+                "1": ["videos", 766],
+                "2": ["videos", 7531],
+                "3": ["videos", 6420]
+            },
+            "def": {
+                "$size": 6,
+                "0": ["videos", 888],
+                "1": ["videos", 999],
+                "2": ["videos", 542]
+            },
+            "sentinel-list": {
+                "$size": 104,
+                "0": {
+                    "$size": 52,
+                    "$type": "sentinel",
+                    "value": ["videos", 333]
+                },
+                "1": {
+                    "$size": 52,
+                    "$type": "sentinel",
+                    "value": ["videos", "sentinel"]
+                }
+            },
+            "sentinel-list-2": {
+                "$size": 52,
+                "0": {
+                    "$size": 52,
+                    "$type": "sentinel",
+                    "value": ["videos", 733]
+                }
+            },
+            "expired-video-branch": {
+                "$size": 3,
+                "0": ['videos', 'expiredBranchByTimestamp', 'summary']
+            },
+            "1x5x": {
+                "$size": 4,
+                "0": ["videos", 553],
+                "1": ["videos", 5522]
+            },
+            "my-list": ["lists", "1x5x"],
+            "error-list": {
+                "$size": 50,
+                "$type": "error",
+                "message": "Red is the new Black"
+            },
+            "error-list-2": {
+                "$size": 50,
+                "$type": "error",
+                "message": "House of Pain"
+            },
+            "expired-list": {
+                "$size": 51,
+                "$type": "sentinel",
+                "$expires": expiredTimestamp,
+                "value": {
+                    "0": ["videos", 333],
+                    "1": ["videos", "sentinel"]
+                }
+            },
+            "to-error-list": ["lists", "error-list-2"],
+            "to-missing-list": ["lists", "missing-list-2"],
+            "to-expired-list": {
+                "$size": 52,
+                "$type": "sentinel",
+                "$expires": expiredTimestamp,
+                "value": ['lists', 'expired-list']
+            },
+            "future-expired-list": {
+                "$type": "sentinel",
+                "$expires": Date.now() + 100000,
+                "$size": 51,
+                "value": {
+                    "0": ["videos", 1234]
+                }
+            },
+            "to-sentinel-list": {
+                "$size": 52,
+                "$type": "sentinel",
+                "value": ["lists", "sentinel-list-2"]
+            }
+        },
+        "videos": {
+            "$size": 432,
+            "1234": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "House of Cards",
+                    "url": "/movies/1234"
+                }
+            },
+            "333": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Terminator 2",
+                    "url": "/movies/333"
+                }
+            },
+            "733": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Total Recall (Without Colin Farrell)",
+                    "url": "/movies/733"
+                }
+            },
+            "553": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Running Man",
+                    "url": "/movies/553"
+                }
+            },
+            "766": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Terminator 3",
+                    "url": "/movies/766"
+                }
+            },
+            "888": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Terminator Salvation",
+                    "url": "/movies/888"
+                }
+            },
+            "999": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Jingle All the Way",
+                    "url": "/movies/999"
+                }
+            },
+            "4422": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Beverly Hills Ninja",
+                    "url": "/movies/4422"
+                }
+            },
+            "7531": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Kindergarten Cop",
+                    "url": "/movies/7531"
+                }
+            },
+            "5522": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Junior",
+                    "url": "/movies/5522"
+                }
+            },
+            "6420": {
+                "$size": 10,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Commando",
+                    "url": "/movies/6420"
+                }
+            },
+            "sentinel": {
+                "$size": 51,
+                "summary": {
+                    "$size": 51,
+                    "$type": "sentinel",
+                    "value": {
+                        "title": "Marco Polo",
+                        "url": "/movies/sentinel"
+                    }
+                }
+            },
+            "expiredLeafByTimestamp": {
+                "$size": 51,
+                "summary": {
+                    "$size": 51,
+                    "$expires": expiredTimestamp,
+                    "$type": "sentinel",
+                    "value": {
+                        "sad": "panda"
+                    }
+                }
+            },
+            "expiredLeafBy0": {
+                "$size": 51,
+                "summary": {
+                    "$expires": 0,
+                    "$size": 51,
+                    "$type": "sentinel",
+                    "value": {
+                        "sad": "tunafish"
+                    }
+                }
+            },
+            "expiredBranchByTimestamp": {
+                "$size": 51,
+                "$expires": expiredTimestamp,
+                "summary": {
+                    "$size": 51,
+                    "$type": "sentinel",
+                    "value": {
+                        "sad": "liger"
+                    }
+                }
+            },
+            "expiredBranchBy0": {
+                "$size": 51,
+                "$expires": 0,
+                "summary": {
+                    "$size": 51,
+                    "$type": "sentinel",
+                    "value": {
+                        "sad": "turtle"
+                    }
+                }
+            },
+            "errorBranch": {
+                "$size": 50,
+                "$type": "error",
+                "message": "I am yelling timber."
+            },
+            "542": {
+                "$size": 10,
+                "video-item": {
+                    "$size": 10,
+                    "summary": {
+                        "$size": 10,
+                        "$type": "leaf",
+                        "title": "Conan, The Barbarian",
+                        "url": "/movies/6420"
+                    }
+                }
+            },
+            "3355": {
+                "$size": 26,
+                "summary": {
+                    "$size": 10,
+                    "$type": "leaf",
+                    "title": "Conan, The Destroyer",
+                    "url": "/movies/3355"
+                },
+                "art": {
+                    "$size": 16,
+                    "$type": "leaf",
+                    "box-shot": "www.cdn.com/3355"
+                }
+            },
+            "missingValue": { "$type": "sentinel" }
+        }
+    };
+};
+
+module.exports = Cache;
diff --git a/assets/1585264.jpg b/assets/1585264.jpg
diff --git a/assets/1585360.jpg b/assets/1585360.jpg
diff --git a/assets/1641134.jpg b/assets/1641134.jpg
diff --git a/assets/1712289.jpg b/assets/1712289.jpg
diff --git a/assets/1829772.jpg b/assets/1829772.jpg
diff --git a/assets/2036766.jpg b/assets/2036766.jpg
diff --git a/assets/2086307.jpg b/assets/2086307.jpg
diff --git a/assets/2091847.jpg b/assets/2091847.jpg
diff --git a/assets/2171006.jpg b/assets/2171006.jpg
diff --git a/assets/2171910.jpg b/assets/2171910.jpg
diff --git a/assets/2187391.jpg b/assets/2187391.jpg
diff --git a/assets/2316690.jpg b/assets/2316690.jpg
diff --git a/assets/2324402.jpg b/assets/2324402.jpg
diff --git a/assets/2325775.jpg b/assets/2325775.jpg
diff --git a/assets/2365903.jpg b/assets/2365903.jpg
diff --git a/assets/2371520.jpg b/assets/2371520.jpg
diff --git a/assets/2372627.jpg b/assets/2372627.jpg
diff --git a/assets/822761.jpg b/assets/822761.jpg
diff --git a/assets/829299.jpg b/assets/829299.jpg
diff --git a/assets/829508.jpg b/assets/829508.jpg
diff --git a/assets/830288.jpg b/assets/830288.jpg
diff --git a/assets/840951.jpg b/assets/840951.jpg
diff --git a/assets/841112.jpg b/assets/841112.jpg
diff --git a/assets/841246.jpg b/assets/841246.jpg
diff --git a/assets/841257.jpg b/assets/841257.jpg
diff --git a/assets/841270.jpg b/assets/841270.jpg
diff --git a/assets/841271.jpg b/assets/841271.jpg
diff --git a/assets/841337.jpg b/assets/841337.jpg
diff --git a/assets/850831.jpg b/assets/850831.jpg
diff --git a/assets/851778.jpg b/assets/851778.jpg
diff --git a/assets/868813.jpg b/assets/868813.jpg
diff --git a/assets/868989.jpg b/assets/868989.jpg
diff --git a/assets/868992.jpg b/assets/868992.jpg
diff --git a/assets/868994.jpg b/assets/868994.jpg
diff --git a/assets/869023.jpg b/assets/869023.jpg
diff --git a/assets/869096.jpg b/assets/869096.jpg
diff --git a/assets/869203.jpg b/assets/869203.jpg
diff --git a/assets/869237.jpg b/assets/869237.jpg
diff --git a/assets/869380.jpg b/assets/869380.jpg
diff --git a/assets/869382.jpg b/assets/869382.jpg
diff --git a/assets/869386.jpg b/assets/869386.jpg
diff --git a/assets/869476.jpg b/assets/869476.jpg
diff --git a/assets/869508.jpg b/assets/869508.jpg
diff --git a/assets/869510.jpg b/assets/869510.jpg
diff --git a/assets/869516.jpg b/assets/869516.jpg
diff --git a/assets/869533.jpg b/assets/869533.jpg
diff --git a/assets/869541.jpg b/assets/869541.jpg
diff --git a/assets/869548.jpg b/assets/869548.jpg
diff --git a/assets/872532.jpg b/assets/872532.jpg
diff --git a/assets/925010.jpg b/assets/925010.jpg
diff --git a/assets/925077.jpg b/assets/925077.jpg
diff --git a/assets/928203.jpg b/assets/928203.jpg
diff --git a/assets/929016.jpg b/assets/929016.jpg
diff --git a/assets/930241.jpg b/assets/930241.jpg
diff --git a/index.js b/index.js
@@ -0,0 +1,49 @@
+var url = require('url');
+
+/**
+ * @param {JSONGModel} model
+ * @type {FalkorEndpoint}
+ */
+var FalkorEndpoint = function(model) {
+    this._model = model;
+};
+
+FalkorEndpoint.prototype = {
+    /**
+     * 
+     * @param {Object} context the context object which is the query parameters and any other
+     * useful information required by falkor
+     * @param {Function} [callback] The callback when done.
+     */
+    execute: function(context, callback) {
+        var obs;
+        try {
+            debugger;
+            if (context.method && context.path) {
+                if (typeof context.path === 'string') {
+                    context.path = JSON.parse(context.path);
+                }
+                var method = context.method;
+                if (method === 'call') {
+                } else {
+                    // no need to materialize since json always returns errors as values.
+                    obs = this._model[method](context.path).
+                        toJSONG();
+                }
+            } else {
+                throw 'Expected method and path to be defined in the context object.';
+            }
+        } catch (e) {
+            obs = Rx.Observable.throw(e);
+        }
+
+        obs.
+            subscribe(function(x) {
+                callback(null, JSON.stringify(x));
+            }, function(err) {
+                callback(err);
+            });
+    }
+};
+
+module.exports = FalkorEndpoint;