Gleipnir/nidus-sync
4
0
Fork 0
Code Issues 18 Pull requests Projects Releases Packages Wiki Activity Actions

Update storage of reporter in contact

Browse source 
I failed to retrieve the data correctly before as part of the changeover
to contact records.

Issue: #13
This commit is contained in:
Eli Ribble 2026-05-21 16:59:44 +00:00
parent b9f2107c79
commit e3cc1e99d1
No known key found for this signature in database
9 changed files with 132 additions and 50 deletions
Download patch file Download diff file Expand all files Collapse all files

56
platform/publicreport/contact.go Normal file
View file

@ -0,0 +1,56 @@
package publicreport
import (
"context"
"fmt"
"source.gleipnir.technology/Gleipnir/nidus-sync/db"
querycomms "source.gleipnir.technology/Gleipnir/nidus-sync/db/query/comms"
"source.gleipnir.technology/Gleipnir/nidus-sync/platform/types"
)
func ContactSimplesFromIDs(ctx context.Context, txn db.Ex, contact_ids []int64) ([]types.ContactSimple, error) {
contacts, err := querycomms.ContactsFromIDs(ctx, txn, contact_ids)
if err != nil {
return nil, fmt.Errorf("contacts from ids: %w", err)
}
contact_emails, err := querycomms.ContactEmailByContactIDs(ctx, txn, contact_ids)
if err != nil {
return nil, fmt.Errorf("contact emails from ids: %w", err)
}
contact_phones, err := querycomms.ContactPhoneByContactIDs(ctx, txn, contact_ids)
if err != nil {
return nil, fmt.Errorf("contact phones from ids: %w", err)
}
results := make([]types.ContactSimple, len(contact_ids))
for i, contact := range contacts {
emails, ok := contact_emails[int64(contact.ID)]
if !ok {
return nil, fmt.Errorf("no emails for contact %d", contact.ID)
}
phones, ok := contact_phones[int64(contact.ID)]
if !ok {
return nil, fmt.Errorf("no phones for contact %d", contact.ID)
}
email_string := ""
if len(emails) > 0 {
email_string = emails[0].Address
}
phone_simple := types.PhoneSimple{}
if len(phones) > 0 {
phone := phones[0]
phone_simple = types.PhoneSimple{
CanSMS: phone.CanSms,
Number: phone.E164,
}
}
results[i] = types.ContactSimple{
Email: email_string,
ID: contact.ID,
Name: contact.Name,
Phone: phone_simple,
}
}
return results, nil
}

59
platform/publicreport/notification.go
View file

@ -78,30 +78,45 @@ func RegisterSubscriptionPhone(ctx context.Context, txn db.Ex, contact modelcomm
return nil
}
func SaveReporter(ctx context.Context, txn db.Ex, report modelpublicreport.Report, name string) (contact modelcomms.Contact, err error) {
if report.ReporterContactID == nil {
contact = modelcomms.Contact{
Created: time.Now(),
Name: name,
OrganizationID: report.OrganizationID,
}
contact, err = querycomms.ContactInsert(ctx, txn, contact)
func SaveReporter(ctx context.Context, txn db.Ex, report modelpublicreport.Report, name string, email_address string, phone *types.E164, can_sms bool) (contact modelcomms.Contact, err error) {
contact, err = querycomms.ContactFromID(ctx, txn, int64(report.ReporterContactID))
if err != nil {
return contact, fmt.Errorf("contact query: %w", err)
}
log.Debug().Str("name", name).Str("old name", contact.Name).Int32("id", contact.ID).Msg("contact updated")
if name != "" && contact.Name != name {
err = querycomms.ContactUpdateName(ctx, txn, int64(contact.ID), name)
if err != nil {
return contact, fmt.Errorf("contact insert: %w", err)
}
log.Debug().Str("name", name).Int32("id", contact.ID).Msg("new contact inserted")
} else {
contact, err = querycomms.ContactFromID(ctx, txn, int64(*report.ReporterContactID))
if err != nil {
return contact, fmt.Errorf("contact query: %w", err)
}
log.Debug().Str("name", name).Str("old name", contact.Name).Int32("id", contact.ID).Msg("contact updated")
if name != "" && contact.Name != name {
err = querycomms.ContactUpdateName(ctx, txn, int64(contact.ID), name)
if err != nil {
return contact, fmt.Errorf("contact update name: %w", err)
}
return contact, fmt.Errorf("contact update name: %w", err)
}
}
if email_address != "" {
e, err := querycomms.ContactEmailInsert(ctx, txn, modelcomms.ContactEmail{
Address: email_address,
Confirmed: false,
ContactID: contact.ID,
//ID
IsSubscribed: false,
})
if err != nil {
return contact, fmt.Errorf("contact add email: %w", err)
}
log.Info().Str("address", e.Address).Msg("Created contact email")
}
if phone != nil {
p, err := querycomms.ContactPhoneInsert(ctx, txn, modelcomms.ContactPhone{
CanSms: can_sms,
ConfirmedMessageID: nil,
ContactID: contact.ID,
E164: phone.PhoneString(),
IsSubscribed: false,
StopMessageID: nil,
})
if err != nil {
return contact, fmt.Errorf("contact add phone: %w", err)
}
log.Info().Str("e164", p.E164).Msg("Created contact phone")
}
return contact, nil
}

29
platform/publicreport/report.go
View file

@ -79,9 +79,12 @@ func byID(ctx context.Context, public_id string, is_public bool) (*types.PublicR
return &reports[0], nil
}
func reportQueryToRows(ctx context.Context, reports []modelpublicreport.Report, is_public bool) ([]types.PublicReport, error) {
txn := db.PGInstance.PGXPool
address_ids := make([]int64, 0)
contact_ids := make([]int64, len(reports))
report_ids := make([]int32, len(reports))
for i, report := range reports {
contact_ids[i] = int64(report.ReporterContactID)
report_ids[i] = report.ID
if report.AddressID != nil {
address_ids = append(address_ids, int64(*report.AddressID))
@ -97,7 +100,7 @@ func reportQueryToRows(ctx context.Context, reports []modelpublicreport.Report,
if err != nil {
return nil, fmt.Errorf("log entries for reports: %w", err)
}
addresses, err := querypublic.AddressesFromIDs(ctx, db.PGInstance.PGXPool, address_ids)
addresses, err := querypublic.AddressesFromIDs(ctx, txn, address_ids)
if err != nil {
return nil, fmt.Errorf("addresses for reports: %w", err)
}
@ -105,6 +108,14 @@ func reportQueryToRows(ctx context.Context, reports []modelpublicreport.Report,
for _, address := range addresses {
addresses_by_id[int64(address.ID)] = address
}
contacts, err := ContactSimplesFromIDs(ctx, txn, contact_ids)
if err != nil {
return nil, fmt.Errorf("contact simples from ids: %w", err)
}
contact_by_id := make(map[int64]types.ContactSimple, 0)
for _, contact := range contacts {
contact_by_id[int64(contact.ID)] = contact
}
results := make([]types.PublicReport, len(reports))
for i, row := range reports {
@ -137,6 +148,7 @@ func reportQueryToRows(ctx context.Context, reports []modelpublicreport.Report,
Raw: row.AddressRaw,
}
}
contact := contact_by_id[int64(row.ReporterContactID)]
results[i] = types.PublicReport{
Address: *address,
Concerns: nil,
@ -148,17 +160,10 @@ func reportQueryToRows(ctx context.Context, reports []modelpublicreport.Report,
DistrictID: &row.OrganizationID,
District: nil,
PublicID: row.PublicID,
Reporter: types.ContactSimple{
Email: row.ReporterEmail,
Name: row.ReporterName,
Phone: types.PhoneSimple{
CanSMS: row.ReporterPhoneCanSms,
Number: row.ReporterPhone,
},
},
Status: row.Status.String(),
Type: row.ReportType.String(),
URI: "",
Reporter: contact,
Status: row.Status.String(),
Type: row.ReportType.String(),
URI: "",
}
}
return results, nil