From 2984a715b830410b6d6ce2a8aaa1fc8a2388ee99 Mon Sep 17 00:00:00 2001
From: Elizabeth Hunt <elizabeth.hunt@simponic.xyz>
Date: Sun, 5 Jan 2025 15:16:26 -0800
Subject: add ntfy integration

---
 adapters/messaging/db.go | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)
 create mode 100644 adapters/messaging/db.go

(limited to 'adapters/messaging/db.go')

diff --git a/adapters/messaging/db.go b/adapters/messaging/db.go
new file mode 100644
index 0000000..4cad3e2
--- /dev/null
+++ b/adapters/messaging/db.go
@@ -0,0 +1,29 @@
+package messaging
+
+import (
+	"database/sql"
+	"log"
+	"time"
+
+	"git.simponic.xyz/simponic/phoneof/database"
+)
+
+func PersistMessageContinuation(dbConn *sql.DB, frenId string, messageId string, sentAt time.Time, frenSent bool) Continuation {
+	return func(message Message) ContinuationChain {
+		log.Printf("persisting message %v %s %s %s %v", message, frenId, messageId, sentAt, frenSent)
+		return func(success Continuation, failure Continuation) ContinuationChain {
+			_, err := database.SaveMessage(dbConn, &database.Message{
+				Id:       messageId,
+				FrenId:   frenId,
+				Message:  message.Message,
+				Time:     sentAt,
+				FrenSent: frenSent,
+			})
+			if err != nil {
+				log.Printf("err when saving message %s", err)
+				return failure(message)
+			}
+			return success(message)
+		}
+	}
+}
-- 
cgit v1.3