-
Notifications
You must be signed in to change notification settings - Fork 190
/
hit-count.js
66 lines (57 loc) · 1.7 KB
/
hit-count.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
63
64
65
66
import { Component } from 'react'
import fetch from 'isomorphic-unfetch'
import { object, string, number } from 'yup'
import Widget from '../../widget'
import Counter from '../../counter'
import { basicAuthHeader } from '../../../lib/auth'
const schema = object().shape({
url: string().url().required(),
index: string().required(),
query: string().required(),
interval: number(),
title: string()
})
export default class ElasticsearchHitCount extends Component {
static defaultProps = {
interval: 1000 * 60 * 5,
title: 'Elasticsearch Hit Count'
}
state = {
count: 0,
error: false,
loading: true
}
componentDidMount () {
schema.validate(this.props)
.then(() => this.fetchInformation())
.catch((err) => {
console.error(`${err.name} @ ${this.constructor.name}`, err.errors)
this.setState({ error: true, loading: false })
})
}
componentWillUnmount () {
clearTimeout(this.timeout)
}
async fetchInformation () {
const { authKey, index, query, url } = this.props
const opts = authKey ? { headers: basicAuthHeader(authKey) } : {}
try {
const res = await fetch(`${url}/${index}/_search?q=${query}`, opts)
const json = await res.json()
this.setState({ count: json.hits.total, error: false, loading: false })
} catch (error) {
this.setState({ error: true, loading: false })
} finally {
this.timeout = setTimeout(() => this.fetchInformation(), this.props.interval)
}
}
render () {
const { count, error, loading } = this.state
const { title } = this.props
return (
<Widget title={title} loading={loading} error={error}>
<Counter value={count} />
</Widget>
)
}
}