main.go

package main

import (
	"fmt"
	"os"
	"time"

	"github.com/layer5io/gokit/logger"
	// "github.com/layer5io/gokit/tracing"
	"github.com/layer5io/gokit/utils"
	"github.com/layer5io/meshery-nginx/api/grpc"
	"github.com/layer5io/meshery-nginx/internal/config"
	"github.com/layer5io/meshery-nginx/nginx"
)

var (
	serviceName    = "nginx-adaptor"
	configProvider = "viper"
	kubeConfigPath = fmt.Sprintf("%s/.kube/config", utils.GetHome())
)

// main is the entrypoint of the adaptor
func main() {

	// Initialize Logger instance
	log, err := logger.New(serviceName)
	if err != nil {
		fmt.Println("Logger Init Failed", err.Error())
		os.Exit(1)
	}

	// Initialize application specific configs and dependencies
	// App and request config
	cfg, err := config.New(configProvider)
	if err != nil {
		log.Err("Config Init Failed", err.Error())
		os.Exit(1)
	}
	service := &grpc.Service{}
	_ = cfg.Server(&service)
	err = cfg.SetKey("kube-config-path", kubeConfigPath)
	if err != nil {
		log.Err("Cannot set kubeconfig path", err.Error())
		os.Exit(1)
	}

	// // Initialize Tracing instance
	// tracer, err := tracing.New(service.Name, service.TraceURL)
	// if err != nil {
	// 	log.Err("Tracing Init Failed", err.Error())
	// 	os.Exit(1)
	// }

	// Initialize Handler intance
	handler := nginx.New(cfg, log)
	handler = nginx.AddLogger(log, handler)
	service.Handler = handler
	service.Channel = make(chan interface{}, 100)
	service.StartedAt = time.Now()

	// Server Initialization
	log.Info(fmt.Sprintf("Adaptor Started at: %s", service.Port))
	err = grpc.Start(service)
	if err != nil {
		log.Err("adapter crashed!!", err.Error())
		os.Exit(1)
	}
}