From c8f88c5bb592b4de1a7ee096ff60ed4f36253521 Mon Sep 17 00:00:00 2001 From: John Shahid Date: Fri, 28 Mar 2014 13:00:19 -0400 Subject: [PATCH] use the ContinuousQuery structure instead of an interface --- src/api/http/api.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/api/http/api.go b/src/api/http/api.go index 3ba99dafd2..6ce65c3001 100644 --- a/src/api/http/api.go +++ b/src/api/http/api.go @@ -865,15 +865,16 @@ func (self *HttpServer) createDbContinuousQueries(w libhttp.ResponseWriter, r *l db := r.URL.Query().Get(":db") self.tryAsDbUserAndClusterAdmin(w, r, func(u User) (int, interface{}) { - var values interface{} body, err := ioutil.ReadAll(r.Body) if err != nil { return libhttp.StatusInternalServerError, err.Error() } - json.Unmarshal(body, &values) - query := values.(map[string]interface{})["query"].(string) - if err := self.coordinator.CreateContinuousQuery(u, db, query); err != nil { + // note: id isn't used when creating a new continuous query + values := &ContinuousQuery{} + json.Unmarshal(body, values) + + if err := self.coordinator.CreateContinuousQuery(u, db, values.Query); err != nil { return errorToStatusCode(err), err.Error() } return libhttp.StatusOK, nil