105 lines
2.6 KiB
JavaScript
105 lines
2.6 KiB
JavaScript
import { uniqueId, times, random } from 'lodash';
|
|
import elasticsearch from 'elasticsearch';
|
|
import constants from '../../lib/constants';
|
|
|
|
function Client() {
|
|
this.indices = {
|
|
create: () => Promise.resolve({ acknowledged: true }),
|
|
exists: () => Promise.resolve(false),
|
|
refresh: () => Promise.resolve(),
|
|
};
|
|
|
|
this.transport = {};
|
|
}
|
|
|
|
Client.prototype.index = function (params = {}) {
|
|
const shardCount = 2;
|
|
return Promise.resolve({
|
|
_index: params.index || 'index',
|
|
_type: params.type || constants.DEFAULT_SETTING_DOCTYPE,
|
|
_id: params.id || uniqueId('testDoc'),
|
|
_version: 1,
|
|
_shards: { total: shardCount, successful: shardCount, failed: 0 },
|
|
created: true
|
|
});
|
|
};
|
|
|
|
Client.prototype.ping = function () {
|
|
return Promise.resolve();
|
|
};
|
|
|
|
Client.prototype.get = function (params = {}, source = {}) {
|
|
if (params === elasticsearch.errors.NotFound) return elasticsearch.errors.NotFound;
|
|
|
|
const _source = Object.assign({
|
|
jobtype: 'jobtype',
|
|
created_by: false,
|
|
payload: {
|
|
id: 'sample-job-1',
|
|
now: 'Mon Apr 25 2016 14:13:04 GMT-0700 (MST)'
|
|
},
|
|
priority: 10,
|
|
timeout: 10000,
|
|
created_at: '2016-04-25T21:13:04.738Z',
|
|
attempts: 0,
|
|
max_attempts: 3,
|
|
status: 'pending'
|
|
}, source);
|
|
|
|
return Promise.resolve({
|
|
_index: params.index || 'index',
|
|
_type: params.type || constants.DEFAULT_SETTING_DOCTYPE,
|
|
_id: params.id || 'AVRPRLnlp7Ur1SZXfT-T',
|
|
_version: params.version || 1,
|
|
found: true,
|
|
_source: _source
|
|
});
|
|
};
|
|
|
|
Client.prototype.search = function (params = {}, count = 5, source = {}) {
|
|
const hits = times(count, () => {
|
|
return {
|
|
_index: params.index || 'index',
|
|
_type: params.type || constants.DEFAULT_SETTING_DOCTYPE,
|
|
_id: uniqueId('documentId'),
|
|
_version: random(1, 5),
|
|
_score: null,
|
|
_source: Object.assign({
|
|
created_at: new Date().toString(),
|
|
number: random(0, count, true)
|
|
}, source)
|
|
};
|
|
});
|
|
return Promise.resolve({
|
|
took: random(0, 10),
|
|
timed_out: false,
|
|
_shards: {
|
|
total: 5,
|
|
successful: 5,
|
|
failed: 0
|
|
},
|
|
hits: {
|
|
total: count,
|
|
max_score: null,
|
|
hits: hits
|
|
}
|
|
});
|
|
};
|
|
|
|
Client.prototype.update = function (params = {}) {
|
|
const shardCount = 2;
|
|
return Promise.resolve({
|
|
_index: params.index || 'index',
|
|
_type: params.type || constants.DEFAULT_SETTING_DOCTYPE,
|
|
_id: params.id || uniqueId('testDoc'),
|
|
_version: params.version + 1 || 2,
|
|
_shards: { total: shardCount, successful: shardCount, failed: 0 },
|
|
created: true
|
|
});
|
|
};
|
|
|
|
export default {
|
|
Client: Client,
|
|
errors: elasticsearch.errors
|
|
};
|