apiclient.xyz/elasticsearch
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(core): update

Browse Source
This commit is contained in:
Philipp Kunz
2018-11-25 22:02:57 +01:00
parent 5d3bc13126
commit 63713f4cd2
4 changed files with 172 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
ts/elasticsearch.classes.elasticindex.ts
View File

@ -15,6 +15,7 @@ export class ElasticIndex {
public async ensureIndex(indexArg: string) {
const done = plugins.smartpromise.defer();
if (this.stringmap.checkString(indexArg)) {
done.resolve();
return;
}
this.elasticSearchRef.client.cat.indices(
@ -28,18 +29,20 @@ export class ElasticIndex {
return indexObjectArg.index.startsWith('smartlog');
});
const filteredIndexNames = filteredIndices.map(indexObjectArg => {
return indexObjectArg.name;
return indexObjectArg.index;
});
const todayAsUnix: number = Date.now();
const rententionPeriodAsUnix: number = plugins.smarttime.units.days(
this.elasticSearchRef.indexRetention
);
console.log(filteredIndexNames);
for (const indexName of filteredIndexNames) {
const regexResult = /^smartlog-([0-9]*)\.([0-9]*)\.([0-9]*)$/;
const regexResult = /^smartlog-([0-9]*)\.([0-9]*)\.([0-9]*)$/.exec(indexName);
const dateAsUnix: number = new Date(
`${regexResult[1]}-${regexResult[2]}-${regexResult[3]}`
).getTime();
if (todayAsUnix - rententionPeriodAsUnix > dateAsUnix) {
console.log(`found old index ${indexName}`);
const done2 = plugins.smartpromise.defer();
this.elasticSearchRef.client.indices.delete({
index: indexName
@ -47,7 +50,8 @@ export class ElasticIndex {
if(err2) {
console.log(err2);
}
done.resolve();
console.log(`deleted ${indexName}`);
done2.resolve();
});
await done2.promise;
}

3
ts/elasticsearch.plugins.ts
View File

@ -1,7 +1,8 @@
import * as elasticsearch from 'elasticsearch';
import * as lik from '@pushrocks/lik';
import * as smartdelay from '@pushrocks/smartdelay';
import * as smartlogInterfaces from '@pushrocks/smartlog-interfaces';
import * as smartpromise from '@pushrocks/smartpromise';
import * as smarttime from '@pushrocks/smarttime';
export { elasticsearch, smartdelay, smartlogInterfaces, smartpromise, smarttime };
export { elasticsearch, lik, smartdelay, smartlogInterfaces, smartpromise, smarttime };