Function NewHTTPAdapter

sqlchain/adapter/server.go:37–64

NewHTTPAdapter creates adapter to service.

(listenAddr string, configFile string, adapterUseMirrorAddr string)

// NewHTTPAdapter creates adapter to service.
func NewHTTPAdapter(listenAddr string, configFile string, adapterUseMirrorAddr string) (adapter *HTTPAdapter, err error) {
	adapter = new(HTTPAdapter)

	// load config file
	var cfg *config.Config
	if cfg, err = config.LoadConfig(configFile); err != nil {
		return
	}

	if listenAddr != "" {
		cfg.ListenAddr = listenAddr
	}
	if adapterUseMirrorAddr != "" {
		cfg.MirrorServer = adapterUseMirrorAddr
	}
	// init server
	handler := handlers.CORS(
		handlers.AllowedHeaders([]string{"Content-Type"}),
	)(api.GetRouter())

	adapter.server = &http.Server{
		TLSConfig: cfg.TLSConfig,
		Addr:      cfg.ListenAddr,
		Handler:   handler,
	}

	return
}

// Serve defines adapter serve logic.
func (adapter *HTTPAdapter) Serve() (err error) {