99 lines
2.1 KiB
Go
99 lines
2.1 KiB
Go
package mapblockaccessor
|
|
|
|
import (
|
|
"mapserver/coords"
|
|
"mapserver/eventbus"
|
|
"mapserver/layer"
|
|
"mapserver/mapblockparser"
|
|
|
|
cache "github.com/patrickmn/go-cache"
|
|
"github.com/prometheus/client_golang/prometheus"
|
|
"github.com/sirupsen/logrus"
|
|
)
|
|
|
|
type FindMapBlocksByMtimeResult struct {
|
|
HasMore bool
|
|
LastPos *coords.MapBlockCoords
|
|
LastMtime int64
|
|
List []*mapblockparser.MapBlock
|
|
UnfilteredCount int
|
|
}
|
|
|
|
func (a *MapBlockAccessor) FindMapBlocksByMtime(lastmtime int64, limit int, layerfilter []*layer.Layer) (*FindMapBlocksByMtimeResult, error) {
|
|
|
|
fields := logrus.Fields{
|
|
"lastmtime": lastmtime,
|
|
"limit": limit,
|
|
}
|
|
logrus.WithFields(fields).Debug("FindMapBlocksByMtime")
|
|
|
|
timer := prometheus.NewTimer(dbGetMtimeDuration)
|
|
blocks, err := a.accessor.FindBlocksByMtime(lastmtime, limit)
|
|
timer.ObserveDuration()
|
|
|
|
changedBlockCount.Add(float64(len(blocks)))
|
|
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
result := FindMapBlocksByMtimeResult{}
|
|
|
|
mblist := make([]*mapblockparser.MapBlock, 0)
|
|
var newlastpos *coords.MapBlockCoords
|
|
result.HasMore = len(blocks) == limit
|
|
result.UnfilteredCount = len(blocks)
|
|
|
|
for _, block := range blocks {
|
|
newlastpos = block.Pos
|
|
if result.LastMtime < block.Mtime {
|
|
result.LastMtime = block.Mtime
|
|
}
|
|
|
|
inLayer := false
|
|
for _, l := range layerfilter {
|
|
if (block.Pos.Y*16) >= l.From && (block.Pos.Y*16) <= l.To {
|
|
inLayer = true
|
|
break
|
|
}
|
|
}
|
|
|
|
if !inLayer {
|
|
continue
|
|
}
|
|
|
|
fields := logrus.Fields{
|
|
"x": block.Pos.X,
|
|
"y": block.Pos.Y,
|
|
"z": block.Pos.Z,
|
|
}
|
|
logrus.WithFields(fields).Debug("mapblock")
|
|
|
|
key := getKey(block.Pos)
|
|
|
|
mapblock, err := mapblockparser.Parse(block.Data, block.Mtime, block.Pos)
|
|
if err != nil {
|
|
fields := logrus.Fields{
|
|
"x": block.Pos.X,
|
|
"y": block.Pos.Y,
|
|
"z": block.Pos.Z,
|
|
"err": err,
|
|
}
|
|
logrus.WithFields(fields).Error("parse error")
|
|
continue
|
|
}
|
|
|
|
a.Eventbus.Emit(eventbus.MAPBLOCK_RENDERED, mapblock)
|
|
|
|
a.blockcache.Set(key, mapblock, cache.DefaultExpiration)
|
|
cacheBlockCount.Inc()
|
|
mblist = append(mblist, mapblock)
|
|
|
|
}
|
|
|
|
result.LastPos = newlastpos
|
|
result.List = mblist
|
|
|
|
return &result, nil
|
|
}
|