blob: 12f1339bb56bf8537320418b30c55d45d67f0bd4 [file] [log] [blame]
package apiGatewayDeploy
import (
"github.com/30x/apid"
"os"
"path"
)
const (
configBundleDirKey = "gatewaydeploy_bundle_dir"
)
var (
services apid.Services
log apid.LogService
data apid.DataService
bundlePath string
)
func init() {
apid.RegisterPlugin(initPlugin)
}
func initPlugin(s apid.Services) (apid.PluginData, error) {
services = s
log = services.Log().ForModule("apiGatewayDeploy")
log.Debug("start init")
config := services.Config()
config.SetDefault(configBundleDirKey, "bundles")
data = services.Data()
relativeBundlePath := config.GetString(configBundleDirKey)
storagePath := config.GetString("local_storage_path")
bundlePath = path.Join(storagePath, relativeBundlePath)
if err := os.MkdirAll(bundlePath, 0700); err != nil {
log.Panicf("Failed bundle directory creation: %v", err)
}
log.Infof("Bundle directory path is %s", bundlePath)
go distributeEvents()
initListener(services)
log.Debug("end init")
return pluginData, nil
}