small fixes

broker/src/asapo_broker/server/process_request.go

@@ -110,7 +110,7 @@ func processRequest(w http.ResponseWriter, r *http.Request, op string, extra_par
 		var ansStats StatsStruct
 		err = json.Unmarshal(answer, &ansStats)
 		if err == nil {
-			delay := (uint64(time.Now().UnixNano()) / uint64(time.Millisecond)) - ansStats.Timestamp
+			delay := (uint64(time.Now().UnixNano()) - ansStats.Timestamp) / uint64(time.Millisecond)
 			switch op {
 			case "next":
 				fallthrough

monitoring/monitoring_server/src/asapo_monitoring_server/server/QueryServer.go

@@ -692,7 +692,7 @@ func (s *QueryServer) GetGroupDelay(ctx context.Context, query *pb.GroupDelayQue
 	result, err := s.dbQueryApi.Query(ctx, "from(bucket: \""+s.settings.InfluxDbDatabase+"\")"+
 		" |> range(start: "+startTime+", stop: "+endTime+")"+
 		" |> filter(fn: (r) => r._measurement == \""+dbMeasurementBrokerFileRequests+"\""+" and r.brokerCommand == \"next\")"+
-		" |> filter(fn: (r) => r.beamtime == \""+query.BeamtimeFilter+"\" r._field == \"delayMs\""+
+		" |> filter(fn: (r) => r.beamtime == \""+query.BeamtimeFilter+"\" and r._field == \"delayMs\""+
 		" |> group(columns: [\"groupId\"])"+
 		" |> last()"+
 		" |> keep(columns: [\"groupId\", \"_value\"])"+