44 lines
864 B
Go
44 lines
864 B
Go
package events
|
|
|
|
import (
|
|
"context"
|
|
"sync"
|
|
|
|
"github.com/hashicorp/golang-lru/arc/v2"
|
|
"github.com/ipfs/go-cid"
|
|
|
|
"github.com/filecoin-project/lotus/api"
|
|
)
|
|
|
|
type messageCache struct {
|
|
api EventAPI
|
|
|
|
blockMsgLk sync.Mutex
|
|
blockMsgCache *arc.ARCCache[cid.Cid, *api.BlockMessages]
|
|
}
|
|
|
|
func newMessageCache(a EventAPI) *messageCache {
|
|
blsMsgCache, _ := arc.NewARC[cid.Cid, *api.BlockMessages](500)
|
|
|
|
return &messageCache{
|
|
api: a,
|
|
blockMsgCache: blsMsgCache,
|
|
}
|
|
}
|
|
|
|
func (c *messageCache) ChainGetBlockMessages(ctx context.Context, blkCid cid.Cid) (*api.BlockMessages, error) {
|
|
c.blockMsgLk.Lock()
|
|
defer c.blockMsgLk.Unlock()
|
|
|
|
msgs, ok := c.blockMsgCache.Get(blkCid)
|
|
var err error
|
|
if !ok {
|
|
msgs, err = c.api.ChainGetBlockMessages(ctx, blkCid)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
c.blockMsgCache.Add(blkCid, msgs)
|
|
}
|
|
return msgs, nil
|
|
}
|