118 lines
3.4 KiB
Go
118 lines
3.4 KiB
Go
package api
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/Gleipnir-Technology/bob"
|
|
"github.com/Gleipnir-Technology/bob/dialect/psql"
|
|
"github.com/Gleipnir-Technology/bob/dialect/psql/sm"
|
|
"github.com/Gleipnir-Technology/nidus-sync/config"
|
|
"github.com/Gleipnir-Technology/nidus-sync/db"
|
|
"github.com/Gleipnir-Technology/nidus-sync/db/models"
|
|
nhttp "github.com/Gleipnir-Technology/nidus-sync/http"
|
|
"github.com/google/uuid"
|
|
//"github.com/Gleipnir-Technology/nidus-sync/platform"
|
|
//"github.com/aarondl/opt/null"
|
|
"github.com/stephenafamo/scan"
|
|
)
|
|
|
|
type reporter struct {
|
|
HasEmail bool `json:"has_email"`
|
|
HasPhone bool `json:"has_phone"`
|
|
Name string `json:"name"`
|
|
}
|
|
type publicReport struct {
|
|
Address Address `json:"address"`
|
|
Images []string `json:"images"`
|
|
Reporter reporter `json:"reporter"`
|
|
}
|
|
type communication struct {
|
|
Created time.Time `json:"created"`
|
|
ID string `json:"id"`
|
|
PublicReport publicReport `json:"public_report"`
|
|
Type string `json:"type"`
|
|
}
|
|
type contentListCommunication struct {
|
|
Communications []communication `json:"communications"`
|
|
}
|
|
|
|
func listCommunication(ctx context.Context, r *http.Request, org *models.Organization, user *models.User, query queryParams) (*contentListCommunication, *nhttp.ErrorWithStatus) {
|
|
reports, err := models.PublicreportNuisances.Query(
|
|
models.SelectWhere.PublicreportNuisances.OrganizationID.EQ(org.ID),
|
|
).All(ctx, db.PGInstance.BobDB)
|
|
if err != nil {
|
|
return nil, nhttp.NewError("get reports: %w")
|
|
}
|
|
type _Row struct {
|
|
PublicID string `db:"nuisance_public_id"`
|
|
StorageUUID uuid.UUID `db:"storage_uuid"`
|
|
}
|
|
rows, err := bob.All(ctx, db.PGInstance.BobDB, psql.Select(
|
|
sm.Columns(
|
|
"n.public_id AS nuisance_public_id",
|
|
"i.storage_uuid AS storage_uuid",
|
|
),
|
|
sm.From("publicreport.nuisance").As("n"),
|
|
sm.InnerJoin("publicreport.nuisance_image").As("ni").OnEQ(
|
|
psql.Quote("n", "id"),
|
|
psql.Quote("ni", "nuisance_id"),
|
|
),
|
|
sm.InnerJoin("publicreport.image").As("i").OnEQ(
|
|
psql.Quote("ni", "image_id"),
|
|
psql.Quote("i", "id"),
|
|
),
|
|
sm.Where(psql.Quote("n", "organization_id").EQ(psql.Arg(org.ID))),
|
|
), scan.StructMapper[_Row]())
|
|
if err != nil {
|
|
return nil, nhttp.NewError("get images: %w")
|
|
}
|
|
id_to_images := make(map[string][]uuid.UUID, len(reports))
|
|
for _, row := range rows {
|
|
r, ok := id_to_images[row.PublicID]
|
|
if !ok {
|
|
r = make([]uuid.UUID, 0)
|
|
}
|
|
r = append(r, row.StorageUUID)
|
|
id_to_images[row.PublicID] = r
|
|
}
|
|
comms := make([]communication, len(reports))
|
|
for i, report := range reports {
|
|
comms[i] = communication{
|
|
PublicReport: publicReport{
|
|
Address: Address{
|
|
Country: report.AddressCountry,
|
|
Locality: report.AddressPlace,
|
|
//Number: report.Address
|
|
PostalCode: report.AddressPostcode,
|
|
Region: report.AddressRegion,
|
|
Street: report.AddressStreet,
|
|
},
|
|
Images: toImageURLs(id_to_images, report.PublicID),
|
|
Reporter: reporter{
|
|
Name: report.ReporterName.GetOr(""),
|
|
HasEmail: report.ReporterEmail.IsValue(),
|
|
HasPhone: report.ReporterPhone.IsValue(),
|
|
},
|
|
},
|
|
Created: report.Created,
|
|
ID: report.PublicID,
|
|
}
|
|
}
|
|
return &contentListCommunication{
|
|
Communications: comms,
|
|
}, nil
|
|
}
|
|
|
|
func toImageURLs(m map[string][]uuid.UUID, id string) []string {
|
|
uuids, ok := m[id]
|
|
if !ok {
|
|
return []string{}
|
|
}
|
|
urls := make([]string, len(uuids))
|
|
for _, u := range uuids {
|
|
urls = append(urls, config.MakeURLNidus("/api/image/%s", u.String()))
|
|
}
|
|
return urls
|
|
}
|