Export Reversals

api/v1/reversals/reversals.go

@@ -1,6 +1,8 @@
 package reversals
 
 import (
+	"bytes"
+	"encoding/csv"
 	"encoding/json"
 	"net/http"
 	"net/url"
@@ -151,3 +153,71 @@ func listReversalsHandler(w http.ResponseWriter, r *http.Request) {
 		},
 	})
 }
+
+func exportReversals(w http.ResponseWriter, r *http.Request) {
+	factory, ok := r.Context().Value(middleware.FactoryContextKey).(repository.Factory)
+	if !ok {
+		render.Errorf(w, r, errors.InternalServerError, "missing factory from context")
+		return
+	}
+
+	defaultLimit := uint(10_000)
+	maxLimit := uint(50_000)
+
+	reversals, nextCursor, err := listReversals(factory, r.URL.Query(), defaultLimit, maxLimit)
+	if err != nil {
+		render.Error(w, r, err)
+		return
+	}
+
+	headers := []string{"id", "created_at", "updated_at", "steam_id", "marketplace_slug", "source", "related_steam_id", "reversed_at", "expunged_at"}
+	records := [][]string{headers}
+
+	for _, reversal := range reversals {
+		var source string
+		if reversal.Source != nil {
+			source = reversal.Source.String()
+		}
+
+		var relatedSteamID string
+		if reversal.RelatedSteamID != nil {
+			relatedSteamID = reversal.RelatedSteamID.String()
+		}
+
+		var expungedAt string
+		if reversal.ExpungedAt != nil {
+			expungedAt = strconv.FormatUint(*reversal.ExpungedAt, 10)
+		}
+
+		records = append(records, []string{
+			reversal.ID.String(),
+			strconv.FormatUint(reversal.CreatedAt, 10),
+			strconv.FormatUint(reversal.UpdatedAt, 10),
+			reversal.SteamID.String(),
+			reversal.MarketplaceSlug,
+			source,
+			relatedSteamID,
+			strconv.FormatUint(reversal.ReversedAt, 10),
+			expungedAt,
+		})
+	}
+
+	buf := &bytes.Buffer{}
+	writer := csv.NewWriter(buf)
+	if err := writer.WriteAll(records); err != nil {
+		render.Errorf(w, r, errors.InternalServerError, "failed to encode csv")
+		return
+	}
+
+	if nextCursor != nil {
+		encodedCursor, err := nextCursor.Encode()
+		if err != nil {
+			render.Errorf(w, r, errors.InternalServerError, "failed to encode cursor")
+			return
+		}
+		w.Header().Set("X-Next-Cursor", *encodedCursor)
+	}
+
+	w.Header().Set("Content-Type", "text/csv; charset=utf-8")
+	w.Write(buf.Bytes())
+}