nidus-sync/platform/report/notification.go

package report

import (
	"context"
	"fmt"
	"time"

	"github.com/Gleipnir-Technology/bob"
	"github.com/Gleipnir-Technology/nidus-sync/db"
	"github.com/Gleipnir-Technology/nidus-sync/db/models"
	"github.com/Gleipnir-Technology/nidus-sync/platform/email"
	"github.com/Gleipnir-Technology/nidus-sync/platform/text"
	"github.com/Gleipnir-Technology/nidus-sync/platform/types"
	"github.com/aarondl/opt/omit"
	"github.com/aarondl/opt/omitnull"
	//"github.com/rs/zerolog/log"
)

func DistrictForReport(ctx context.Context, report_id string) (*models.Organization, error) {
	report, err := reportByPublicID(ctx, db.PGInstance.BobDB, report_id)
	if err != nil {
		return nil, fmt.Errorf("Failed to find report %s: %w", report_id, err)
	}
	result, e := models.FindOrganization(ctx, db.PGInstance.BobDB, report.OrganizationID)
	if e != nil {
		return nil, fmt.Errorf("Failed to load organization %d: %w", report.OrganizationID, e)
	}
	return result, nil
}

func RegisterNotificationEmail(ctx context.Context, txn bob.Executor, report_id string, destination string) error {
	report, e := reportByPublicID(ctx, db.PGInstance.BobDB, report_id)
	if e != nil {
		return fmt.Errorf("Failed to find report: %w", e)
	}
	e = email.EnsureInDB(ctx, destination)
	if e != nil {
		return fmt.Errorf("Failed to ensure phone is in DB: %w", e)
	}
	err := addNotificationEmail(ctx, txn, report, destination)
	if err != nil {
		return err
	}
	email.SendReportConfirmation(ctx, destination, report_id)
	return nil
}

func RegisterNotificationPhone(ctx context.Context, txn bob.Executor, report_id string, phone types.E164) error {
	report, e := reportByPublicID(ctx, db.PGInstance.BobDB, report_id)
	if e != nil {
		return fmt.Errorf("Failed to find report: %w", e)
	}
	e = text.EnsureInDB(ctx, db.PGInstance.BobDB, phone)
	if e != nil {
		return fmt.Errorf("Failed to ensure phone is in DB: %w", e)
	}
	err := addNotificationPhone(ctx, txn, report, phone)
	if err != nil {
		return err
	}
	text.ReportSubscriptionConfirmationText(ctx, db.PGInstance.BobDB, phone, report.PublicID)
	return nil
}

func RegisterSubscriptionEmail(ctx context.Context, txn bob.Executor, destination string) error {
	e := email.EnsureInDB(ctx, destination)
	if e != nil {
		return fmt.Errorf("Failed to ensure email is in DB: %w", e)
	}
	setter := models.PublicreportSubscribeEmailSetter{
		Created: omit.From(time.Now()),
		Deleted: omitnull.FromPtr[time.Time](nil),
		//DistrictID:   omit.FromPtr[int32](nil),
		EmailAddress: omit.From(destination),
	}
	_, err := models.PublicreportSubscribeEmails.Insert(&setter).Exec(ctx, txn)
	if err != nil {
		return fmt.Errorf("Failed to save new subscription email row: %w", err)
	}

	return nil
}
func RegisterSubscriptionPhone(ctx context.Context, txn bob.Executor, phone types.E164) error {
	e := text.EnsureInDB(ctx, db.PGInstance.BobDB, phone)
	if e != nil {
		return fmt.Errorf("Failed to ensure phone is in DB: %w", e)
	}
	setter := models.PublicreportSubscribePhoneSetter{
		Created: omit.From(time.Now()),
		Deleted: omitnull.FromPtr[time.Time](nil),
		//DistrictID:   omitnull.FromPtr[int32](nil),
		PhoneE164: omit.From(phone.PhoneString()),
	}
	_, err := models.PublicreportSubscribePhones.Insert(&setter).Exec(ctx, txn)
	if err != nil {
		return fmt.Errorf("Failed to save new subscription phone row: %w", err)
	}
	return nil
}

func SaveReporter(ctx context.Context, txn bob.Executor, report_id string, name string, email string, phone *types.E164, has_consent bool) error {
	report, e := reportByPublicID(ctx, db.PGInstance.BobDB, report_id)
	if e != nil {
		return fmt.Errorf("Failed to find report: %w", e)
	}
	if name != "" {
		err := updateReporterName(ctx, txn, report, name)
		if err != nil {
			return err
		}
	}
	if phone != nil {
		err := updateReporterPhone(ctx, txn, report, *phone)
		if err != nil {
			return err
		}
	}
	if email != "" {
		err := updateReporterEmail(ctx, txn, report, email)
		if err != nil {
			return err
		}
	}
	err := updateReporterConsent(ctx, txn, report, has_consent)
	if err != nil {
		return err
	}
	return nil
}
func reportByPublicID(ctx context.Context, txn bob.Executor, public_id string) (*models.PublicreportReport, error) {
	return models.PublicreportReports.Query(
		models.SelectWhere.PublicreportReports.PublicID.EQ(public_id),
	).One(ctx, txn)
}
func addNotificationEmail(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, email string) error {
	setter := models.PublicreportNotifyEmailSetter{
		Created:      omit.From(time.Now()),
		Deleted:      omitnull.FromPtr[time.Time](nil),
		EmailAddress: omit.From(email),
		ReportID:     omit.From(report.ID),
	}
	_, err := models.PublicreportNotifyEmails.Insert(&setter).Exec(ctx, txn)
	if err != nil {
		return fmt.Errorf("Failed to save new notification email row: %w", err)
	}
	return nil
}
func addNotificationPhone(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, phone types.E164) error {
	var err error
	setter := models.PublicreportNotifyPhoneSetter{
		Created:   omit.From(time.Now()),
		Deleted:   omitnull.FromPtr[time.Time](nil),
		PhoneE164: omit.From(phone.PhoneString()),
		ReportID:  omit.From(report.ID),
	}
	_, err = models.PublicreportNotifyPhones.Insert(&setter).Exec(ctx, txn)
	if err != nil {
		return fmt.Errorf("Failed to save new notification phone row: %w", err)
	}
	return nil
}
func updateReporterConsent(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, has_consent bool) error {
	return updateReportCol(ctx, txn, report, &models.PublicreportReportSetter{
		ReporterContactConsent: omitnull.From(has_consent),
	})
}
func updateReporterEmail(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, email string) error {
	return updateReportCol(ctx, txn, report, &models.PublicreportReportSetter{
		ReporterEmail: omit.From(email),
	})
}
func updateReporterName(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, name string) error {
	return updateReportCol(ctx, txn, report, &models.PublicreportReportSetter{
		ReporterName: omit.From(name),
	})
}
func updateReportCol(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, setter *models.PublicreportReportSetter) error {
	err := report.Update(ctx, txn, setter)
	if err != nil {
		return fmt.Errorf("Failed to update nuisance report in the database: %w", err)
	}
	return nil
}
func updateReporterPhone(ctx context.Context, txn bob.Executor, report *models.PublicreportReport, phone types.E164) error {
	err := report.Update(ctx, txn, &models.PublicreportReportSetter{
		ReporterPhone: omit.From(phone.PhoneString()),
	})
	if err != nil {
		return fmt.Errorf("Failed to update report: %w", err)
	}
	return nil
}