modify checking of obj to only include endpoint

dependencies/db/default.go

@@ -20,7 +20,7 @@ type db[T any] struct {
 
 type DB[T any] interface {
 	DeleteObject(T) error
-	DoesObjExist(T) (*bool, error)
+	DoesKeyExist(map[string]types.AttributeValue) (*bool, error)
 	GetObjects() (*[]T, error)
 	SaveObject(T) (error)
 }
@@ -49,19 +49,12 @@ func getTableName() (name string, err error) {
 	return name, err
 }
 
-// DoesObjExist returns whether an object found in the DB according to the given searchObj or an error. The searchObj is the desired object in the DB. It does not need to be complete, but should include the primary key in the database.
-func (c db[T]) DoesObjExist(searchObj T) (*bool, error) {
-	slog.Default().Debug("marshalling", "obj", searchObj)
-	attributeValueObj, err := attributevalue.MarshalMap(searchObj)
-	if err != nil {
-		return nil, err
-	}
-	slog.Default().Debug("marshalled", "obj", attributeValueObj)
-
+// DoesObjExist returns whether an object found in the DB according to the given searchObj or an error. The searchObj is the desired object in the DB. It does not need to be complete, but should include the primary key in the database. 
+func (c db[T]) DoesKeyExist(searchObj map[string]types.AttributeValue) (*bool, error) {
 	slog.Default().Debug("getting item")
 	res, err := c.DynamoDbClient.GetItem(context.TODO(), &dynamodb.GetItemInput{
 		TableName: aws.String(c.TableName),
-		Key:       attributeValueObj,
+		Key:       searchObj,
 	})
 	if err != nil {
 		return nil, err

services/notifications/default.go

@@ -13,6 +13,8 @@ import (
 	"sync"
 
 	webpush "github.com/SherClockHolmes/webpush-go"
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
 	"github.com/will-lol/personalWebsiteAwesome/dependencies/db"
 )
 
@@ -191,7 +193,11 @@ func (n notificationsService) Subscribe(sub Subscription) error {
 	n.Log.Debug("url valid")
 
 	n.Log.Debug("checking if obj exists")
-	alreadyExists, err := n.db.DoesObjExist(sub)
+	alreadyExists, err := n.db.DoesKeyExist(map[string]types.AttributeValue{
+		"Endpoint": &types.AttributeValueMemberS{
+			Value: sub.Endpoint,
+		},
+	})
 	if err != nil {
 		return err
 	}