persist invitiation to store

Signed-off-by: Christian Richter <c.richter@opencloud.eu>

Author: dragonchaser

services/invitations/pkg/service/v0/errors.go

@@ -7,4 +7,7 @@ var (
 	ErrBadRequest   = errors.New("bad request")
 	ErrMissingEmail = errors.New("missing email address")
 	ErrBackend      = errors.New("backend error")
+
+	ErrSerialization = errors.New("serialization error")
+	ErrPersistence   = errors.New("persistence error")
 )

services/invitations/pkg/service/v0/service.go

@@ -2,6 +2,7 @@ package service
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 
 	"github.com/opencloud-eu/opencloud/pkg/log"
@@ -57,11 +58,13 @@ func New(opts ...Option) (Service, error) {
 		options.Config.Keycloak.InsecureSkipVerify,
 	)
 
-	return svc{
+	s := svc{
 		log:     options.Logger,
 		config:  options.Config,
 		backend: backend,
-	}, nil
+	}
+	s.persistance.Init()
+	return s, nil
 }
 
 type svc struct {
@@ -96,6 +99,19 @@ func (s svc) Invite(ctx context.Context, invitation *invitations.Invitation) (*i
 		}
 	}
 
+	// serialize invitation
+	invitationBytes, err := json.Marshal(invitation)
+	if err != nil {
+		return nil, fmt.Errorf("%w: %s", ErrSerialization, err)
+	}
+
+	// persist invitation
+	err = s.persistance.Write(&store.Record{Key: invitation.InvitedUserEmailAddress, Value: invitationBytes})
+
+	if err != nil {
+		return nil, fmt.Errorf("%w: %s", ErrPersistence, err)
+	}
+
 	return invitation, nil
 }