added support for cached roster repository

CHANGELOG.md

@@ -9,6 +9,7 @@
 * [ENHANCEMENT] Cached Capabilities repository. #205
 * [ENHANCEMENT] Cached Private repository. #206
 * [ENHANCEMENT] Cached BlockList repository. #207 
+* [ENHANCEMENT] Cached Roster repository. #208
 * [CHANGE] Introduced measured repository transaction type. #200
 * [CHANGE] Use PgSQL locker. #201
 * [BUGFIX] Fix S2S db key check when nop KV is used. #199

pkg/router/router.go

@@ -17,12 +17,11 @@ package router
 import (
 	"context"
 
-	c2smodel "github.com/ortuman/jackal/pkg/model/c2s"
-
 	"github.com/jackal-xmpp/stravaganza/v2"
 	streamerror "github.com/jackal-xmpp/stravaganza/v2/errors/stream"
 	"github.com/jackal-xmpp/stravaganza/v2/jid"
 	"github.com/ortuman/jackal/pkg/host"
+	c2smodel "github.com/ortuman/jackal/pkg/model/c2s"
 	"github.com/ortuman/jackal/pkg/router/stream"
 )
 
@@ -33,10 +32,10 @@ type Router interface {
 	// (https://xmpp.org/rfcs/rfc3921.html#rules)
 	Route(ctx context.Context, stanza stravaganza.Stanza) (targets []jid.JID, err error)
 
-	// C2SRouter returns the underlying C2S router.
+	// C2S returns the underlying C2S router.
 	C2S() C2SRouter
 
-	// S2SRouter returns the underlying S2S router.
+	// S2S returns the underlying S2S router.
 	S2S() S2SRouter
 
 	// Start starts global router subsystem.

pkg/storage/cached/blocklist.go

@@ -55,9 +55,9 @@ type cachedBlockListRep struct {
 
 func (c *cachedBlockListRep) UpsertBlockListItem(ctx context.Context, item *blocklistmodel.Item) error {
 	op := updateOp{
-		c:           c.c,
-		namespace:   blockListNS(item.Username),
-		invalidKeys: []string{blockListItems},
+		c:              c.c,
+		namespace:      blockListNS(item.Username),
+		invalidateKeys: []string{blockListItems},
 		updateFn: func(ctx context.Context) error {
 			return c.rep.UpsertBlockListItem(ctx, item)
 		},
@@ -67,9 +67,9 @@ func (c *cachedBlockListRep) UpsertBlockListItem(ctx context.Context, item *bloc
 
 func (c *cachedBlockListRep) DeleteBlockListItem(ctx context.Context, item *blocklistmodel.Item) error {
 	op := updateOp{
-		c:           c.c,
-		namespace:   blockListNS(item.Username),
-		invalidKeys: []string{blockListItems},
+		c:              c.c,
+		namespace:      blockListNS(item.Username),
+		invalidateKeys: []string{blockListItems},
 		updateFn: func(ctx context.Context) error {
 			return c.rep.DeleteBlockListItem(ctx, item)
 		},