pronounsfu/backend/routes/v1/user/export.go

package user

import (
	"net/http"
	"time"

	"codeberg.org/pronounscc/pronouns.cc/backend/db"
	"codeberg.org/pronounscc/pronouns.cc/backend/log"
	"codeberg.org/pronounscc/pronouns.cc/backend/server"
	"emperror.dev/errors"
	"github.com/go-chi/render"
)

func (s *Server) startExport(w http.ResponseWriter, r *http.Request) error {
	ctx := r.Context()
	claims, _ := server.ClaimsFromContext(ctx)

	if claims.APIToken {
		return server.APIError{Code: server.ErrMissingPermissions, Details: "This endpoint cannot be used by API tokens"}
	}

	hasExport, err := s.DB.HasRecentExport(ctx, claims.UserID)
	if err != nil {
		log.Errorf("checking if user has recent export: %v", err)
		return server.APIError{Code: server.ErrInternalServerError}
	}
	if hasExport {
		return server.APIError{Code: server.ErrRecentExport}
	}

	req, err := http.NewRequestWithContext(ctx, "GET", s.ExporterPath+"/start/"+claims.UserID.String(), nil)
	if err != nil {
		log.Errorf("creating start export request: %v", err)
		return server.APIError{Code: server.ErrInternalServerError}
	}

	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		log.Errorf("executing start export request: %v", err)
		return server.APIError{Code: server.ErrInternalServerError}
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusAccepted {
		log.Errorf("got non-%v code: %v", http.StatusAccepted, resp.StatusCode)
		return server.APIError{
			Code: server.ErrInternalServerError,
		}
	}

	render.NoContent(w, r)
	return nil
}

type dataExportResponse struct {
	Path      string    `json:"path"`
	CreatedAt time.Time `json:"created_at"`
}

func (s *Server) getExport(w http.ResponseWriter, r *http.Request) error {
	ctx := r.Context()
	claims, _ := server.ClaimsFromContext(ctx)

	if claims.APIToken {
		return server.APIError{Code: server.ErrMissingPermissions, Details: "This endpoint cannot be used by API tokens"}
	}

	de, err := s.DB.UserExport(ctx, claims.UserID)
	if err != nil {
		if err == db.ErrNoExport {
			return server.APIError{Code: server.ErrNotFound}
		}

		log.Errorf("getting export for user %v: %v", claims.UserID, err)
		return errors.Wrap(err, "getting export")
	}

	render.JSON(w, r, dataExportResponse{
		Path:      de.Path(),
		CreatedAt: de.CreatedAt,
	})
	return nil
}