pkg/server/microsub.go

@@ -188,10 +188,7 @@ func (h *microsubHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			if channel == "" {
 				feeds, err := h.backend.Search(query)
 				if err != nil {
-					respondJSON(w, map[string]interface{}{
-						"query": query,
-						"error": err.Error(),
-					})
+					http.Error(w, err.Error(), 500)
 					return
 				}
 				respondJSON(w, map[string][]microsub.Feed{
@@ -200,10 +197,7 @@ func (h *microsubHandler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 			} else {
 				items, err := h.backend.ItemSearch(channel, query)
 				if err != nil {
-					respondJSON(w, map[string]interface{}{
-						"query": query,
-						"error": err.Error(),
-					})
+					http.Error(w, err.Error(), 500)
 					return
 				}
 				respondJSON(w, map[string]interface{}{

pkg/timeline/postgres.go

@@ -217,6 +217,7 @@ ON CONFLICT ON CONSTRAINT "items_uid_key" DO NOTHING
 		return false, err
 	}
 
+	log.Printf("AddItem: rows affected %d\n", c)
 	return c > 0, nil
 }
 

pkg/timeline/timeline.go

@@ -31,6 +31,7 @@ type Backend interface {
 // Create creates a channel of the specified type. Return nil when the type
 // is not known.
 func Create(channel, timelineType string, pool *redis.Pool, db *sql.DB) Backend {
+	log.Printf("fetching timeline with type %s", timelineType)
 	if timelineType == "sorted-set" {
 		timeline := &redisSortedSetTimeline{channel: channel, pool: pool}
 		err := timeline.Init()