-
Notifications
You must be signed in to change notification settings - Fork 1k
/
Copy pathdreyfus.js
62 lines (56 loc) · 2.11 KB
/
dreyfus.js
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
// Licensed under the Apache License, Version 2.0 (the "License"); you may not
// use this file except in compliance with the License. You may obtain a copy of
// the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
// License for the specific language governing permissions and limitations under
// the License.
var Dreyfus = (function() {
var index_results = []; // holds temporary emitted values during index
function handleIndexError(err, doc) {
if (err == "fatal_error") {
throw(["error", "map_runtime_error", "function raised 'fatal_error'"]);
} else if (err[0] == "fatal") {
throw(err);
}
var message = "function raised exception " + errstr(err);
if (doc) message += " with doc._id " + doc._id;
log(message);
};
return {
index: function(name, value, options) {
if (typeof name !== 'string') {
throw({name: 'TypeError', message: 'name must be a string not ' + typeof name});
}
if (name.substring(0, 1) === '_') {
throw({name: 'ReservedName', message: 'name must not start with an underscore'});
}
if (typeof value !== 'string' && typeof value !== 'number' && typeof value !== 'boolean') {
throw({name: 'TypeError', message: 'value must be a string, a number or boolean not ' + typeof value});
}
if (options && typeof options !== 'object') {
throw({name: 'TypeError', message: 'options must be an object not ' + typeof options});
}
index_results.push([name, value, options || {}]);
},
indexDoc: function(doc) {
Couch.recursivelySeal(doc);
var buf = [];
for (var fun in State.funs) {
index_results = [];
try {
State.funs[fun](doc);
buf.push(index_results);
} catch (err) {
handleIndexError(err, doc);
buf.push([]);
}
}
print(JSON.stringify(buf));
}
}
})();