taler-mailbox

Service for asynchronous wallet-to-wallet payment messages
Log | Files | Refs | Submodules | README | LICENSE

commit 58ce9b952b22f268275dabcf7feaaf2d0ecccb06
parent 0f39be86e2f1fba35263ffb0381b06b82f518b09
Author: Martin Schanzenbach <schanzen@gnunet.org>
Date:   Sun, 15 Feb 2026 11:16:32 +0100

formatting

Diffstat:
Mpkg/rest/db.go | 9---------
Mpkg/rest/mailbox.go | 2--
2 files changed, 0 insertions(+), 11 deletions(-)

diff --git a/pkg/rest/db.go b/pkg/rest/db.go @@ -88,7 +88,6 @@ type InboxEntry struct { HashedSigningKey string } - func InsertInboxEntryIntoDatabase(db *sql.DB, e *InboxEntry) error { query := `INSERT INTO taler_mailbox.inbox_entries VALUES (DEFAULT, $1, $2);` @@ -100,7 +99,6 @@ func InsertInboxEntryIntoDatabase(db *sql.DB, e *InboxEntry) error { return nil } - func InsertPendingRegistrationIntoDatabase(db *sql.DB, pr *PendingMailboxRegistration) error { query := `INSERT INTO taler_mailbox.pending_mailbox_registrations VALUES (DEFAULT, $1, $2, $3);` @@ -112,7 +110,6 @@ func InsertPendingRegistrationIntoDatabase(db *sql.DB, pr *PendingMailboxRegistr return nil } - func InsertMailboxRegistrationIntoDatabase(db *sql.DB, mb *MailboxMetadata) error { query := `INSERT INTO taler_mailbox.mailbox_metadata VALUES (DEFAULT, $1, $2, $3, $4, $5, $6, $7);` @@ -137,7 +134,6 @@ func UpdatePendingRegistrationOrderIdInDatabase(db *sql.DB, pr *PendingMailboxRe return nil } - func UpdateMailboxExpirationInDatabase(db *sql.DB, mb *MailboxMetadata) error { query := `UPDATE taler_mailbox.mailbox_metadata SET @@ -181,7 +177,6 @@ func GetPendingRegistrationFromDatabaseBySigningKey(db *sql.DB, pr *PendingMailb ) } - func GetMailboxMetadataFromDatabaseBySigningKey(db *sql.DB, mb *MailboxMetadata, hashedKey string) error { query := `SELECT "serial", @@ -300,7 +295,6 @@ func DeletePendingRegistrationFromDatabase(db *sql.DB, pr *PendingMailboxRegistr return rows, nil } - // DeleteInboxEntryFromSerialFromDatabase Deletes all entries starting from given serial func DeleteInboxEntryFromSerialFromDatabase(db *sql.DB, e *InboxEntry) (int64, error) { var ctx context.Context @@ -329,7 +323,6 @@ func DeleteInboxEntryFromSerialFromDatabase(db *sql.DB, e *InboxEntry) (int64, e return rows, nil } - // DeleteStaleRegstrationsFromDatabase purges stale registrations func DeleteStaleRegistrationsFromDatabase(db *sql.DB, registrationExpiration time.Time) (int64, error) { var ctx context.Context @@ -383,5 +376,3 @@ func DeleteStalePendingRegistrationsFromDatabase(db *sql.DB, registrationExpirat } return rows, nil } - - diff --git a/pkg/rest/mailbox.go b/pkg/rest/mailbox.go @@ -256,7 +256,6 @@ func GetMessagesCountFromDatabase(db *sql.DB, hashedKey string) (int64, error) { return res, nil } - // Get Hash-salted alias from database func GetMessagesFromDatabase(db *sql.DB, hashedKey string, limit int) ([]InboxEntry, error) { query := `SELECT @@ -290,7 +289,6 @@ func GetMessagesFromDatabase(db *sql.DB, hashedKey string, limit int) ([]InboxEn return entries, nil } - func (m *Mailbox) getMessagesResponse(w http.ResponseWriter, r *http.Request) { vars := mux.Vars(r) //to, toSet := vars["timeout_ms"]