added the removing while fetching

src/adapters/redis/redis.go

@@ -9,4 +9,5 @@ var (
 	ErrValueDoesntExist = errors.New("value doesn't exists in the db")
 	ErrFetchValue       = errors.New("failed to fetch data from db")
 	ErrDeserializeData  = errors.New("failed to deserialize data")
+	ErrRemove = errors.New("failed to delete the data")
 )

src/adapters/redis/repository.go

@@ -17,6 +17,7 @@ type repository struct {
 	client *redis.Client
 }
 
+
 func NewRepository(client *redis.Client) ports.Repository {
 	return &repository{
 		client: client,
@@ -49,10 +50,19 @@ func (r *repository) GetData(ctx context.Context, id uuid.UUID) (*domain.Data, e
 	if err != nil {
 		log.Error(err.Error())
 		if err == redis.Nil {
-			return nil,ErrValueDoesntExist
+			return nil, ErrValueDoesntExist
 		}
 		return nil, ErrFetchValue
 	}
 
 	return &data, nil
 }
+
+func (r *repository) RemoveData(ctx context.Context, id uuid.UUID) error {
+	err := r.client.Del(ctx,id.String()).Err()
+	if err != nil {
+		log.Error(err.Error())
+		return ErrRemove
+	}
+	return nil
+}

src/core/ports/repository.go

@@ -10,4 +10,5 @@ import (
 type Repository interface {
 	AddData(ctx context.Context, id uuid.UUID, data domain.Data) error
 	GetData(ctx context.Context, id uuid.UUID) (*domain.Data, error)
+	RemoveData(ctx context.Context, id uuid.UUID) error
 }

src/core/service/pbin_service.go

@@ -121,7 +121,13 @@ func (s *service) GetContent(ctx context.Context, dataRequest *domain.DataReques
 		log.Error(err.Error())
 		return nil, ErrDecrypting
 	}
-	// 4. return the content
+	// 4. remove the data from the db
+	err = s.repository.RemoveData(ctx,dataRequest.Id)
+	if err != nil {
+		log.Error(err.Error())
+	}
+
+	// 5. return the content
 	content := domain.Content(string(plainText))
 	return &content, nil
 }