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
|
package handlers
import (
"fmt"
"net/http"
"strings"
"time"
"github.com/containers/libpod/pkg/api/handlers/utils"
"github.com/pkg/errors"
)
func GetEvents(w http.ResponseWriter, r *http.Request) {
query := struct {
Since time.Time `schema:"since"`
Until time.Time `schema:"until"`
Filters map[string][]string `schema:"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 libpodFilters = []string{}
if _, found := r.URL.Query()["filters"]; found {
for k, v := range query.Filters {
libpodFilters = append(libpodFilters, fmt.Sprintf("%s=%s", k, v[0]))
}
}
libpodEvents, err := getRuntime(r).GetEvents(libpodFilters)
if err != nil {
utils.BadRequest(w, "filters", strings.Join(r.URL.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)
}
|
