Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 | 6x 6x 6x 6x 6x 6x 44x 44x 6x 48x 48x 6x 22x 22x 22x 22x 22x 6x 26x 6x 48x 48x 48x 44x 44x 44x 22x 22x 22x 22x 22x 22x 22x 44x 34x 10x 8x 2x 48x 4x 4x 4x 4x 48x | /*! Copyright 2016 OCAD university Licensed under the New BSD license. You may not use this file except in compliance with this License. You may obtain a copy of the License at https://github.com/GPII/universal/blob/master/LICENSE.txt */ /* eslint-env browser */ /* eslint strict: ["error", "function"] */ var fluid = fluid || require("infusion"); var gpii = fluid.registerNamespace("gpii"); (function () { "use strict"; // This pouchDB data source is to support the in-browser testing that uses pouchDB as the backend data storage. // It overrides default setImpl() and getImpl() provided by "kettle.dataSource.URL" with gpii.pouch API calls. // Note: This component requires an instance of gpii.pouch (see https://github.com/the-t-in-rtf/gpii-pouchdb/blob/GPII-1897/docs/pouchdb.md) // to be instantiated beforehand. fluid.defaults("gpii.dataSource.pouchDB", { gradeNames: ["kettle.dataSource.URL"], dbViews: null, // Supplied by integrators readOnlyGrade: "gpii.dataSource.pouchDB", invokers: { getImpl: { funcName: "gpii.dataSource.pouchDB.handle", args: ["{that}", "{gpii.pouch}", "{arguments}.0", "{arguments}.1"] // options, directModel } }, listeners: { onRead: [{ funcName: "fluid.identity", namespace: "encoding" }] } }); fluid.defaults("gpii.dataSource.pouchDB.writable", { gradeNames: ["kettle.dataSource.URL.writable"], invokers: { setImpl: { funcName: "gpii.dataSource.pouchDB.handle", args: ["{that}", "{gpii.pouch}", "{arguments}.0", "{arguments}.1", "{arguments}.2"] // options, directModel, data } }, listeners: { onWrite: [{ funcName: "fluid.identity", namespace: "encoding" }] } }); /** * Match the url with the _id field of the view list to determine if this url is to query by a view or an document id * The string to match is "_design/views" in case of the views definition for the auth server */ gpii.dataSource.pouchDB.isQueryView = function (dbViews, url) { var viewIdentifier = dbViews[0]._id; return url.indexOf(viewIdentifier) !== -1; }; /** * The pouchDB data source handler to process the GET/SET requests to the pouchDB. * @param that {Object} An instance of gpii.dataSource.pouchDB * @param pouchDB {Object} An instance of gpii.pouch * @param options {Object} an options block that encodes: * operation {String}: "set"/"get" * notFoundIsEmpty {Boolean}: <code>true</code> if a missing file on read should count as a successful empty payload rather than a rejection * writeMethod {String}: "PUT"/ "POST" (option - if not provided will be defaulted by the concrete dataSource implementation) * @param directModel {Object} a model holding the coordinates of the data to be read or written * @param data {Object} [Optional] - the payload to be written by the SET operation * @return {Promise} a promise for the successful or failed data source operation */ gpii.dataSource.pouchDB.handle = function (that, pouchDB, options, directModel, data) { var url = that.resolveUrl(that.options.requestUrl, that.options.termMap, directModel); return gpii.dataSource.pouchDB.handle.pouchDB(that, pouchDB, options, url, data); }; /** * Decode the URL to find out the view/map function name and parameters for this function. * @param url {String} The URL to be decoded * @return {Object} The returned object is in the structure of: * { * viewName: {String}, * viewOptions: {Object} * } * Example: Decoding an URL: /_design/views/_view/findAuthorizationByAccessToken?key=%22firstDiscovery_access_token%22&include_docs=true * outputs an object: * { * viewName: "findAuthorizationByAccessToken", * viewOptions: { * key: "firstDiscovery_access_token", * include_docs: true * } * } */ gpii.dataSource.pouchDB.decodeView = function (url) { var match = url.match(/(.*)\/(.*)(\?(.*))?/); var view = match[2]; var splitView = view.match(/(.*)\?(.*)/); Eif (splitView) { return { viewName: splitView[1], viewOptions: gpii.express.querystring.decode(splitView[2]) }; } else { return { viewName: view }; } }; /** * Strips out the leading "/" to return the document id. * @param url {String} An URL path. * @return {String} A string with the leading "/" being stripped. * In an example of the input "/user-1", returns "user-1". */ gpii.dataSource.pouchDB.getDocId = function (url) { return url.substring(1); }; /** * Converts the RESTful requests to in-browser pouchDB API to get/set data. * @param that {Object} An instance of gpii.dataSource.pouchDB * @param pouchDB {Object} An instance of gpii.pouch * @param options {Object} an options block that encodes: * operation {String}: "set"/"get" * notFoundIsEmpty {Boolean}: <code>true</code> if a missing file on read should count as a successful empty payload rather than a rejection * writeMethod {String}: "PUT"/ "POST" (option - if not provided will be defaulted by the concrete dataSource implementation) * @param url {String} a URL that is sent to the pouchDB * @param data {Object} [Optional] - the payload to be written by SET operations to the pouchDB. This parameter only needs to be supplied when * using `gpii.dataSource.pouchDB.writable`. * @return {Promise} a promise for the successful or failed data source operation */ gpii.dataSource.pouchDB.handle.pouchDB = function (that, pouchDB, options, url, data) { var dbViews = that.options.dbViews; var promiseTogo = fluid.promise(); var id; // GET: Queries using a document id or view/map functions if (options.operation === "get") { var promiseQuery = fluid.promise(); // Find out if the query is via a view or directly by a document id var isQueryView = gpii.dataSource.pouchDB.isQueryView(dbViews, url); if (isQueryView) { // A query by a view var decodedViewInfo = gpii.dataSource.pouchDB.decodeView(url); var viewList = dbViews[0].views; var viewFunc = viewList[decodedViewInfo.viewName]; var viewOptions = decodedViewInfo.viewOptions || undefined; promiseQuery = pouchDB.query(viewFunc, viewOptions); } else { // A query by a document id id = gpii.dataSource.pouchDB.getDocId(url); promiseQuery = pouchDB.get(id); } // Handle the "notFoundIsEmpty" option to return undefined when no record is found promiseQuery.then(function (data) { promiseTogo.resolve(data); }, function (err) { if (options.notFoundIsEmpty && err.status === 404) { promiseTogo.resolve(undefined); } else { promiseTogo.reject(err); } }); } // SET: save/update records if (options.operation === "set") { id = gpii.dataSource.pouchDB.getDocId(url); Eif (!data._id) { fluid.extend(data, {_id: id}); } promiseTogo = pouchDB.put(data); } return promiseTogo; }; })(); |