nidus-sync/resource/publicreport.go

package resource

import (
	"context"
	"fmt"
	"net/http"

	"github.com/Gleipnir-Technology/nidus-sync/html"
	nhttp "github.com/Gleipnir-Technology/nidus-sync/http"
	"github.com/Gleipnir-Technology/nidus-sync/platform"
	"github.com/Gleipnir-Technology/nidus-sync/platform/types"
	"github.com/gorilla/mux"
	"github.com/rs/zerolog/log"
)

type publicreportR struct {
	router *router
}

func Publicreport(r *router) *publicreportR {
	return &publicreportR{
		router: r,
	}
}

func (res *publicreportR) ByID(ctx context.Context, w http.ResponseWriter, r *http.Request, u platform.User) *nhttp.ErrorWithStatus {
	vars := mux.Vars(r)
	public_id := vars["id"]
	if public_id == "" {
		return nhttp.NewBadRequest("You must provide an ID")
	}
	report_type, err := platform.PublicReportTypeByID(ctx, public_id)
	if err != nil {
		return nhttp.NewError("get report '%s': %w", public_id, err)
	}
	path, err := reportURI(res.router, report_type, public_id)
	if err != nil {
		return nhttp.NewError("get uri '%s': %w", public_id, err)
	}
	http.Redirect(w, r, path, http.StatusFound)
	return nil
}
func (res *publicreportR) ByIDPublic(ctx context.Context, w http.ResponseWriter, r *http.Request) *nhttp.ErrorWithStatus {
	vars := mux.Vars(r)
	public_id := vars["id"]
	if public_id == "" {
		return nhttp.NewBadRequest("You must provide an ID")
	}
	report_type, err := platform.PublicReportTypeByID(ctx, public_id)
	if err != nil {
		return nhttp.NewError("get report '%s': %w", public_id, err)
	}
	path, err := reportURIPublic(res.router, report_type, public_id)
	if err != nil {
		return nhttp.NewError("get uri '%s': %w", public_id, err)
	}
	http.Redirect(w, r, path, http.StatusFound)
	return nil
}

type image struct {
	Status string `json:"status"`
}

func (res *publicreportR) ImageCreate(ctx context.Context, r *http.Request, n nuisanceForm) (*image, *nhttp.ErrorWithStatus) {
	vars := mux.Vars(r)
	public_id := vars["id"]
	if public_id == "" {
		return nil, nhttp.NewBadRequest("You must provide an ID")
	}

	uploads, err := html.ExtractImageUploads(r)
	log.Info().Int("len", len(uploads)).Msg("report image uploads")
	if err != nil {
		return nil, nhttp.NewError("Failed to extract image uploads: %w", err)
	}

	err = platform.PublicReportImageCreate(ctx, public_id, uploads)
	if err != nil {
		return nil, nhttp.NewError("Failed to created image: %w", err)
	}
	return &image{Status: "ok"}, nil
}

func populateDistrictURI(report *types.PublicReport, r *router) error {
	var district_uri string
	var err error
	if report.DistrictID != nil {
		district_uri, err = r.IDToURI("district.ByIDGet", int(*report.DistrictID))
		if err != nil {
			return nhttp.NewError("district uri: %w", err)
		}
	}
	report.District = &district_uri
	return nil
}
func populateReportURI(report *types.PublicReport, r *router, is_public bool) error {
	var err error
	var uri string
	if is_public {
		uri, err = reportURIPublic(r, report.Type, report.PublicID)
	} else {
		uri, err = reportURI(r, report.Type, report.PublicID)
	}
	if err != nil {
		return fmt.Errorf("report uri: %w", err)
	}
	report.URI = uri
	return nil
}
func reportURI(r *router, report_type string, public_id string) (string, error) {
	var route_name string
	switch report_type {
	case "compliance":
		route_name = "publicreport.compliance.ByIDGet"
	case "nuisance":
		route_name = "publicreport.nuisance.ByIDGet"
	case "water":
		route_name = "publicreport.water.ByIDGet"
	default:
		return "", fmt.Errorf("Unrecognized report type '%s'", report_type)
	}
	uri, err := r.IDStrToURI(route_name, public_id)
	if err != nil {
		return "", fmt.Errorf("id str to uri '%s' '%s': %w", route_name, public_id, err)
	}
	return uri, nil
}
func reportURIPublic(r *router, report_type string, public_id string) (string, error) {
	var route_name string
	switch report_type {
	case "compliance":
		route_name = "publicreport.compliance.ByIDGetPublic"
	case "nuisance":
		route_name = "publicreport.nuisance.ByIDGetPublic"
	case "water":
		route_name = "publicreport.water.ByIDGetPublic"
	default:
		return "", fmt.Errorf("Unrecognized report type '%s'", report_type)
	}
	uri, err := r.IDStrToURI(route_name, public_id)
	if err != nil {
		return "", fmt.Errorf("id str to uri '%s' '%s': %w", route_name, public_id, err)
	}
	return uri, nil
}