memnix / memnix-rest

package user

import (

	"context"

	"github.com/dgraph-io/ristretto"

	"github.com/memnix/memnix-rest/domain"

	"github.com/memnix/memnix-rest/infrastructures"

	"github.com/memnix/memnix-rest/pkg/utils"

	"github.com/pkg/errors"

)

type RistrettoRepository struct {

	RistrettoCache *ristretto.Cache // RistrettoCache is the cache

}

func NewRistrettoCache(ristrettoCache *ristretto.Cache) IRistrettoRepository {

	return &RistrettoRepository{

		RistrettoCache: ristrettoCache,

	}

}

func (r *RistrettoRepository) Get(ctx context.Context, id uint) (domain.User, error) {

	_, span := infrastructures.GetTracerInstance().Tracer().Start(ctx, "GetByIDRistretto")

	defer span.End()

	ristrettoHit, ok := r.RistrettoCache.Get(keyPrefix + utils.ConvertUIntToStr(id))

	if !ok {

		return domain.User{}, errors.New("user not found")

	}

	switch ristrettoHit := ristrettoHit.(type) {

	case domain.User:

		return ristrettoHit, nil

	default:

		return domain.User{}, errors.New("user not found")

	}

}

func (r *RistrettoRepository) Set(ctx context.Context, user domain.User) error {

	_, span := infrastructures.GetTracerInstance().Tracer().Start(ctx, "SetByIDRistretto")

	defer span.End()

	r.RistrettoCache.Set(keyPrefix+utils.ConvertUIntToStr(user.ID), user, 0)

	r.RistrettoCache.Wait()

	return nil

}

func (r *RistrettoRepository) Delete(ctx context.Context, id uint) error {

	_, span := infrastructures.GetTracerInstance().Tracer().Start(ctx, "DeleteByIDRistretto")

	defer span.End()

	r.RistrettoCache.Del(keyPrefix + utils.ConvertUIntToStr(id))

	return nil

}