Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
2 changed files
with
179 additions
and
177 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,178 @@ | ||
| // CouchDB specific code | ||
|
|
||
| // query plugin | ||
| (function($) { | ||
| // this is for the items handler | ||
| // var lastViewId, highKey, inFlight; | ||
| // this needs to key per elem | ||
| function newRows(elem, app, view, opts) { | ||
| // $.log("newRows", arguments); | ||
| // on success we'll set the top key | ||
| var thisViewId, successCallback = opts.success, full = false; | ||
| function successFun(resp) { | ||
| // $.log("newRows success", resp) | ||
| $$(elem).inFlight = false; | ||
| var JSONhighKey = JSON.stringify($$(elem).highKey); | ||
| resp.rows = resp.rows.filter(function(r) { | ||
| return JSON.stringify(r.key) != JSONhighKey; | ||
| }); | ||
| if (resp.rows.length > 0) { | ||
| if (opts.descending) { | ||
| $$(elem).highKey = resp.rows[0].key; | ||
| } else { | ||
| $$(elem).highKey = resp.rows[resp.rows.length -1].key; | ||
| } | ||
| }; | ||
| if (successCallback) {successCallback(resp, full)}; | ||
| }; | ||
| opts.success = successFun; | ||
|
|
||
| if (opts.descending) { | ||
| thisViewId = view + (opts.startkey ? JSON.stringify(opts.startkey) : ""); | ||
| } else { | ||
| thisViewId = view + (opts.endkey ? JSON.stringify(opts.endkey) : ""); | ||
| } | ||
| // $.log(["thisViewId",thisViewId]) | ||
| // for query we'll set keys | ||
| if (thisViewId == $$(elem).lastViewId) { | ||
| // we only want the rows newer than changesKey | ||
| var hk = $$(elem).highKey; | ||
| if (hk !== undefined) { | ||
| if (opts.descending) { | ||
| opts.endkey = hk; | ||
| // opts.inclusive_end = false; | ||
| } else { | ||
| opts.startkey = hk; | ||
| } | ||
| } | ||
| // $.log("add view rows", opts) | ||
| if (!$$(elem).inFlight) { | ||
| $$(elem).inFlight = true; | ||
| app.view(view, opts); | ||
| } | ||
| } else { | ||
| // full refresh | ||
| // $.log("new view stuff") | ||
| full = true; | ||
| $$(elem).lastViewId = thisViewId; | ||
| $$(elem).highKey = undefined; | ||
| $$(elem).inFlight = true; | ||
| app.view(view, opts); | ||
| } | ||
| }; | ||
|
|
||
| // only start one changes listener per db | ||
| function followChanges(app) { | ||
| var dbName = app.db.name, changeEvent = function(resp) { | ||
| $("body").trigger("evently-changes-"+dbName, [resp]); | ||
| }; | ||
| if (!$.evently.changesDBs[dbName]) { | ||
| if (app.db.changes) { | ||
| // new api in jquery.couch.js 1.0 | ||
| app.db.changes(null, $.evently.changesOpts).onChange(changeEvent); | ||
| } else { | ||
| // in case you are still on CouchDB 0.11 ;) deprecated. | ||
| connectToChanges(app, changeEvent); | ||
| } | ||
| $.evently.changesDBs[dbName] = true; | ||
| } | ||
| } | ||
| $.evently.followChanges = followChanges; | ||
| // deprecated. use db.changes() from jquery.couch.js | ||
| // this does not have an api for closing changes request. | ||
| function connectToChanges(app, fun, update_seq) { | ||
| function changesReq(seq) { | ||
| var url = app.db.uri+"_changes?heartbeat=10000&feed=longpoll&since="+seq; | ||
| if ($.evently.changesOpts.include_docs) { | ||
| url = url + "&include_docs=true"; | ||
| } | ||
| $.ajax({ | ||
| url: url, | ||
| contentType: "application/json", | ||
| dataType: "json", | ||
| complete: function(req) { | ||
| var resp = $.httpData(req, "json"); | ||
| fun(resp); | ||
| connectToChanges(app, fun, resp.last_seq); | ||
| } | ||
| }); | ||
| }; | ||
| if (update_seq) { | ||
| changesReq(update_seq); | ||
| } else { | ||
| app.db.info({success: function(db_info) { | ||
| changesReq(db_info.update_seq); | ||
| }}); | ||
| } | ||
| }; | ||
|
|
||
| function runQuery(me, h, args) { | ||
| // $.log("runQuery: args", args) | ||
| var app = $$(me).app; | ||
| var qu = $.evently.utils.rfun(me, h.query, args); | ||
| var qType = qu.type; | ||
| var viewName = qu.view; | ||
| var userSuccess = qu.success; | ||
| // $.log("qType", qType) | ||
|
|
||
| var q = {}; | ||
| $.forIn(qu, function(k, v) { | ||
| if (["type", "view"].indexOf(k) == -1) { | ||
| q[k] = v; | ||
| } | ||
| }); | ||
|
|
||
| if (qType == "newRows") { | ||
| q.success = function(resp) { | ||
| // $.log("runQuery newRows success", resp.rows.length, me, resp) | ||
| resp.rows.reverse().forEach(function(row) { | ||
| renderElement(me, h, [row].concat($.argsToArray(args)), true) | ||
| }); | ||
| if (userSuccess) userSuccess(resp); | ||
| }; | ||
| newRows(me, app, viewName, q); | ||
| } else { | ||
| q.success = function(resp) { | ||
| // $.log("runQuery success", resp) | ||
| renderElement(me, h, [resp].concat($.argsToArray(args)), true); | ||
| userSuccess && userSuccess(resp); | ||
| }; | ||
| // $.log(app) | ||
| app.view(viewName, q); | ||
| } | ||
| } | ||
|
|
||
|
|
||
| $.evently.fn.before.query = function(h, cb, args) { | ||
| var app = $$(this).app | ||
| , qu = $.evently.utils.rfun(this, h.query, args) | ||
| , qType = qu.type | ||
| , viewName = qu.view | ||
| , userSuccess = qu.success | ||
| , q = {} | ||
| ; | ||
| $.forIn(qu, function(k, v) { | ||
| if (["type", "view"].indexOf(k) == -1) { | ||
| q[k] = v; | ||
| } | ||
| }); | ||
| if (qType == "newRows") { | ||
| q.success = function(resp) { | ||
| // $.log("runQuery newRows success", resp.rows.length, me, resp) | ||
| resp.rows.reverse().forEach(cb); | ||
| if (userSuccess) userSuccess(resp); | ||
| }; | ||
| newRows(this, app, viewName, q); | ||
| } else { | ||
| q.success = function(resp) { | ||
| // $.log("runQuery success", resp) | ||
| cb(resp); | ||
| userSuccess && userSuccess(resp); | ||
| }; | ||
| app.view(viewName, q); | ||
| } | ||
| }; | ||
| })(jQuery); | ||
|
|
||
|
|
||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters