From 1c8b13b31e4e5fda69a6dc9c9df172ac1009a119 Mon Sep 17 00:00:00 2001 From: Eli Ribble Date: Sat, 16 May 2026 18:12:01 +0000 Subject: [PATCH] Restore accidentally removed platform mailer by ID func Needed by the mailer resource --- db/query/public/mailer.go | 4 +++- platform/mailer.go | 3 +++ resource/mailer.go | 2 +- 3 files changed, 7 insertions(+), 2 deletions(-) diff --git a/db/query/public/mailer.go b/db/query/public/mailer.go index 1d43bb12..8e6f8ba0 100644 --- a/db/query/public/mailer.go +++ b/db/query/public/mailer.go @@ -46,7 +46,9 @@ func mailerBaseQuery() postgres.SelectStatement { ), ) } -func MailerFromPublicID(ctx context.Context, txn db.Ex, org_id int64, id int64) (*types.Mailer, error) { + +// func MailerFromPublicID(ctx context.Context, txn db.Ex, org_id int64, id int64) (*types.Mailer, error) { +func MailerFromID(ctx context.Context, txn db.Ex, org_id int64, id int64) (*types.Mailer, error) { statement := mailerBaseQuery().WHERE( table.ComplianceReportRequest.ID.EQ(postgres.Int(id)).AND( table.Site.OrganizationID.EQ(postgres.Int(org_id))), diff --git a/platform/mailer.go b/platform/mailer.go index eace089e..20031d6f 100644 --- a/platform/mailer.go +++ b/platform/mailer.go @@ -13,6 +13,9 @@ import ( "github.com/Gleipnir-Technology/nidus-sync/platform/types" ) +func MailerByID(ctx context.Context, user User, id int32) (*types.Mailer, error) { + return querypublic.MailerFromID(ctx, db.PGInstance.PGXPool, int64(user.Organization.ID), int64(id)) +} func MailerList(ctx context.Context, user User, limit int) ([]types.Mailer, error) { return querypublic.MailersFromOrganizationID(ctx, db.PGInstance.PGXPool, int64(user.Organization.ID), int64(limit)) } diff --git a/resource/mailer.go b/resource/mailer.go index 7b600339..88a81add 100644 --- a/resource/mailer.go +++ b/resource/mailer.go @@ -35,7 +35,7 @@ func (res *mailerR) ByIDGet(ctx context.Context, r *http.Request, user platform. } return mailer, nil } -func (res *mailerR) List(ctx context.Context, r *http.Request, user platform.User, query QueryParams) ([]*types.Mailer, *nhttp.ErrorWithStatus) { +func (res *mailerR) List(ctx context.Context, r *http.Request, user platform.User, query QueryParams) ([]types.Mailer, *nhttp.ErrorWithStatus) { limit := 1000 if query.Limit != nil { limit = *query.Limit