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
|
package handlers
import (
"encoding/json"
"fmt"
"net/http"
"github.com/containers/libpod/pkg/api/handlers/utils"
"github.com/pkg/errors"
)
func GetEvents(w http.ResponseWriter, r *http.Request) {
query := struct {
Since string `json:"since"`
Until string `json:"until"`
Filters string `json:"filters"`
}{}
if err := decodeQuery(r, &query); err != nil {
utils.Error(w, "Failed to parse parameters", http.StatusBadRequest, errors.Wrapf(err, "Failed to parse parameters for %s", r.URL.String()))
}
var filters = map[string][]string{}
if found := hasVar(r, "filters"); found {
if err := json.Unmarshal([]byte(query.Filters), &filters); err != nil {
utils.BadRequest(w, "filters", query.Filters, err)
return
}
}
var libpodFilters = make([]string, len(filters))
for k, v := range filters {
libpodFilters = append(libpodFilters, fmt.Sprintf("%s=%s", k, v[0]))
}
libpodEvents, err := getRuntime(r).GetEvents(libpodFilters)
if err != nil {
utils.BadRequest(w, "filters", query.Filters, err)
return
}
var apiEvents = make([]*Event, len(libpodEvents))
for _, v := range libpodEvents {
apiEvents = append(apiEvents, EventToApiEvent(v))
}
utils.WriteJSON(w, http.StatusOK, apiEvents)
}
|
