forked from MTSR/mapserver
148 lines
3.1 KiB
Go
148 lines
3.1 KiB
Go
package app
|
|
|
|
import (
|
|
"mapserver/colormapping"
|
|
"mapserver/db/postgres"
|
|
"mapserver/db/sqlite"
|
|
"mapserver/eventbus"
|
|
"mapserver/mapblockaccessor"
|
|
"mapserver/mapblockrenderer"
|
|
postgresobjdb "mapserver/mapobjectdb/postgres"
|
|
sqliteobjdb "mapserver/mapobjectdb/sqlite"
|
|
"mapserver/params"
|
|
"mapserver/settings"
|
|
"mapserver/tiledb"
|
|
"mapserver/tilerenderer"
|
|
"mapserver/worldconfig"
|
|
"time"
|
|
|
|
"io/ioutil"
|
|
"os"
|
|
|
|
"github.com/sirupsen/logrus"
|
|
|
|
"errors"
|
|
)
|
|
|
|
func Setup(p params.ParamsType, cfg *Config) *App {
|
|
a := App{}
|
|
a.Params = p
|
|
a.Config = cfg
|
|
a.WebEventbus = eventbus.New()
|
|
|
|
//Parse world config
|
|
a.Worldconfig = worldconfig.Parse("world.mt")
|
|
logrus.WithFields(logrus.Fields{"version": Version}).Info("Starting mapserver")
|
|
|
|
var err error
|
|
|
|
switch a.Worldconfig[worldconfig.CONFIG_BACKEND] {
|
|
case worldconfig.BACKEND_SQLITE3:
|
|
a.Blockdb, err = sqlite.New("map.sqlite")
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
case worldconfig.BACKEND_POSTGRES:
|
|
a.Blockdb, err = postgres.New(a.Worldconfig[worldconfig.CONFIG_PSQL_CONNECTION])
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
default:
|
|
panic(errors.New("map-backend not supported: " + a.Worldconfig[worldconfig.CONFIG_BACKEND]))
|
|
}
|
|
|
|
//migrate block db
|
|
err = a.Blockdb.Migrate()
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
//mapblock accessor
|
|
expireDuration, err := time.ParseDuration(cfg.MapBlockAccessorCfg.Expiretime)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
purgeDuration, err := time.ParseDuration(cfg.MapBlockAccessorCfg.Purgetime)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
a.BlockAccessor = mapblockaccessor.NewMapBlockAccessor(
|
|
a.Blockdb,
|
|
expireDuration, purgeDuration,
|
|
cfg.MapBlockAccessorCfg.MaxItems)
|
|
|
|
//color mapping
|
|
a.Colormapping = colormapping.NewColorMapping()
|
|
|
|
//load default colors
|
|
count, err := a.Colormapping.LoadVFSColors(false, "/colors.txt")
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
logrus.WithFields(logrus.Fields{"count": count}).Info("Loaded default colors")
|
|
|
|
//load provided colors, if available
|
|
info, err := os.Stat("colors.txt")
|
|
if info != nil && err == nil {
|
|
logrus.WithFields(logrus.Fields{"filename": "colors.txt"}).Info("Loading colors from filesystem")
|
|
|
|
data, err := ioutil.ReadFile("colors.txt")
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
count, err = a.Colormapping.LoadBytes(data)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
logrus.WithFields(logrus.Fields{"count": count}).Info("Loaded custom colors")
|
|
|
|
}
|
|
|
|
//mapblock renderer
|
|
a.Mapblockrenderer = mapblockrenderer.NewMapBlockRenderer(a.BlockAccessor, a.Colormapping)
|
|
|
|
//mapserver database
|
|
if a.Worldconfig[worldconfig.CONFIG_PSQL_MAPSERVER] != "" {
|
|
a.Objectdb, err = postgresobjdb.New(a.Worldconfig[worldconfig.CONFIG_PSQL_MAPSERVER])
|
|
} else {
|
|
a.Objectdb, err = sqliteobjdb.New("mapserver.sqlite")
|
|
}
|
|
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
//migrate object database
|
|
err = a.Objectdb.Migrate()
|
|
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
//create tiledb
|
|
a.TileDB, err = tiledb.New("./mapserver.tiles")
|
|
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
//settings
|
|
a.Settings = settings.New(a.Objectdb)
|
|
|
|
//setup tile renderer
|
|
a.Tilerenderer = tilerenderer.NewTileRenderer(
|
|
a.Mapblockrenderer,
|
|
a.TileDB,
|
|
a.Blockdb,
|
|
a.Config.Layers,
|
|
)
|
|
|
|
return &a
|
|
}
|