stuve-it
/
stuve-it-backend
8
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(emailApi): added live feedback of send status for frontend
Build and Push Docker image / build-and-push (push) Successful in 2m43s Details

This commit is contained in:
Valentin Kolb 2024-10-26 01:28:03 +02:00
parent a479cf343a
commit 7e566798dd
1 changed files with 18 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
emailApi/main.go
View File

@ -12,7 +12,7 @@ import (
"net/mail" "net/mail"
) )
// sendEmailToUser sends an email notification to the user // sendEmailToUser sends an email notification to a recipient of the email record
func sendEmailToUser(app *pocketbase.PocketBase, registry *template.Registry, recipient *models.Record, sender *models.Record, emailRecord *models.Record) error { func sendEmailToUser(app *pocketbase.PocketBase, registry *template.Registry, recipient *models.Record, sender *models.Record, emailRecord *models.Record) error {
// check if recipient and message are set and recipient is not the sender // check if recipient and message are set and recipient is not the sender
if recipient == nil || emailRecord == nil || sender == nil { if recipient == nil || emailRecord == nil || sender == nil {
@ -67,6 +67,7 @@ func sendEmailToUser(app *pocketbase.PocketBase, registry *template.Registry, re
return nil return nil
} }
// sendEmails sends an email notification to the recipients of the email record@
func sendEmails(app *pocketbase.PocketBase, emailRecord *models.Record) { func sendEmails(app *pocketbase.PocketBase, emailRecord *models.Record) {
registry := template.NewRegistry() registry := template.NewRegistry()
@ -94,14 +95,24 @@ func sendEmails(app *pocketbase.PocketBase, emailRecord *models.Record) {
// check if there was an error sending the email // check if there was an error sending the email
if err != nil { if err != nil {
logger.LogErrorF("%v", err) logger.LogErrorF("%v", err)
} else { continue
sendToIds = append(sendToIds, recipient.Id) }
// add recipient id to sendToIds
sendToIds = append(sendToIds, recipient.Id)
// update email sentTo field, this will be overwritten for each recipient
// we update it for every iteration to provide live feedback on the frontend
emailRecord.Set("sentTo", sendToIds)
// save email record
if err := app.Dao().SaveRecord(emailRecord); err != nil {
logger.LogErrorF("Error saving email record: %v", err)
} }
} }
// set email record fields // mark email as sent
emailRecord.Set("sentTo", sendToIds) emailRecord.Set("sentTo", sendToIds)
emailRecord.Set("wasSent", true)
// save email record // save email record
if err := app.Dao().SaveRecord(emailRecord); err != nil { if err := app.Dao().SaveRecord(emailRecord); err != nil {
@ -121,12 +132,12 @@ func InitEmailApi(app *pocketbase.PocketBase, _ *core.ServeEvent) error {
app.OnModelAfterCreate("emails").Add(func(e *core.ModelEvent) error { app.OnModelAfterCreate("emails").Add(func(e *core.ModelEvent) error {
// get created message record // get created message record
createdMessageRecord, err := app.Dao().FindRecordById("emails", e.Model.GetId()) createdEmailRecord, err := app.Dao().FindRecordById("emails", e.Model.GetId())
if err != nil { if err != nil {
return err return err
} }
go sendEmails(app, createdMessageRecord) go sendEmails(app, createdEmailRecord)
return nil return nil
}) })