feat: query UI (#1352)

* log insert

* fix display error

* refactor code

* shorten status strings

* remove comment

* apply suggestion

retrievalmarket/rtvllog/db.go

@@ -227,7 +227,7 @@ func (d *RetrievalLogDB) list(ctx context.Context, offset int, limit int, where
 
 		dealState.PayloadCID, err = cid.Parse(payloadCid.String)
 		if err != nil {
-			return nil, fmt.Errorf("parsing payload cid '%s': %w", payloadCid.String, err)
+			dealState.PayloadCID = cid.Undef
 		}
 
 		if pieceCid.Valid && pieceCid.String != "" {

retrievalmarket/rtvllog/retrieval_log.go

@@ -58,6 +58,33 @@ func (r *RetrievalLog) OnQueryEvent(evt retrievalmarket.ProviderQueryEvent) {
 		"status", evt.Response.Status,
 		"msg", evt.Response.Message,
 		"err", evt.Error)
+
+	// Log failures to DB
+	st := &RetrievalDealState{
+		UnsealPrice: evt.Response.UnsealPrice,
+		Message:     evt.Response.Message,
+	}
+	if evt.Error != nil {
+		st.Status = "Failed"
+		if evt.Response.Message == "" {
+			st.Message = evt.Error.Error()
+		}
+	} else {
+		if evt.Response.Status == retrievalmarket.QueryResponseUnavailable {
+			st.Status = "unavailable"
+		}
+		if evt.Response.Status == retrievalmarket.QueryResponseError {
+			st.Status = "errored"
+		}
+	}
+	if st.Status != "" {
+		r.dbUpdate(func() {
+			err := r.db.Insert(r.ctx, st)
+			if err != nil {
+				log.Errorw("failed to update retrieval deal logger db", "err", err)
+			}
+		})
+	}
 }
 
 // Called when there is a validation event.