diff --git a/broker/src/asapo_broker/server/get_commands_test.go b/broker/src/asapo_broker/server/get_commands_test.go index 3508bcbd050e81ac72404250a9e7bac0837aaeeb..c667ab9b4f4c524f13687d186a43aa26cadce21e 100644 --- a/broker/src/asapo_broker/server/get_commands_test.go +++ b/broker/src/asapo_broker/server/get_commands_test.go @@ -53,7 +53,7 @@ var testsGetCommand = []struct { expectedGroupID + "/next", "&resend_nacks=true&delay_ms=10000&resend_attempts=3", "{\"id_key\":\"_id\",\"resend\":true,\"delay_ms\":10000,\"resend_attempts\":3}"}, {"size", expectedSource, expectedStream, "", expectedStream + "/size", "", ""}, {"size", expectedSource, expectedStream, "", expectedStream + "/size", "&incomplete=true", "true"}, - {"streams", expectedSource, "0", "", "0/streams", "", "{\"from\":\"\",\"filter\":\"\",\"detailed\":\"\"}"}, + {"streams", expectedSource, "0", "", "0/streams", "", "{\"from\":\"\",\"filter\":\"\",\"detailed\":\"true\"}"}, {"lastack", expectedSource, expectedStream, expectedGroupID, expectedStream + "/" + expectedGroupID + "/lastack", "", ""}, {"datasources", expectedSource, "0", "", "0/sources", "", ""}, } diff --git a/broker/src/asapo_broker/server/get_streams.go b/broker/src/asapo_broker/server/get_streams.go index abbf0b4e20b6d9cb3af13f2e5a0473ce95f5c0f0..13d02bae68b8e91ead5e6c58ce4d41c3ebe6c7f9 100644 --- a/broker/src/asapo_broker/server/get_streams.go +++ b/broker/src/asapo_broker/server/get_streams.go @@ -10,9 +10,14 @@ type GetStreamsParams = database.GetStreamsParams func routeGetStreams(w http.ResponseWriter, r *http.Request) { keys := r.URL.Query() + // Use true as for back compatibility + detailed := keys.Get("detailed") + if detailed == "" { + detailed = "true" + } extraParams := GetStreamsParams{From: keys.Get("from"), Filter: keys.Get("filter"), - Detailed: keys.Get("detailed")} + Detailed: detailed} encoded, _ := json.Marshal(extraParams) processRequest(w, r, "streams", string(encoded), false) }