2018-07-07 16:10:42 +00:00
|
|
|
package aicra
|
2018-05-21 10:02:24 +00:00
|
|
|
|
|
|
|
import (
|
2019-05-01 19:30:16 +00:00
|
|
|
"io"
|
2019-04-30 22:02:28 +00:00
|
|
|
"log"
|
2019-05-01 11:44:45 +00:00
|
|
|
"os"
|
2019-04-30 22:02:28 +00:00
|
|
|
|
2018-10-07 09:40:35 +00:00
|
|
|
"git.xdrm.io/go/aicra/api"
|
2020-03-21 13:49:36 +00:00
|
|
|
"git.xdrm.io/go/aicra/datatype"
|
2018-10-01 15:43:18 +00:00
|
|
|
"git.xdrm.io/go/aicra/internal/config"
|
2018-05-21 10:02:24 +00:00
|
|
|
)
|
|
|
|
|
2019-05-01 11:44:45 +00:00
|
|
|
// Server represents an AICRA instance featuring: type checkers, services
|
2018-07-10 23:36:42 +00:00
|
|
|
type Server struct {
|
2020-03-21 13:49:36 +00:00
|
|
|
config *config.Server
|
2019-05-01 11:44:45 +00:00
|
|
|
handlers []*api.Handler
|
2018-07-10 23:36:42 +00:00
|
|
|
}
|
|
|
|
|
2018-07-08 22:32:19 +00:00
|
|
|
// New creates a framework instance from a configuration file
|
2020-03-21 13:49:36 +00:00
|
|
|
func New(configPath string, dtypes ...datatype.T) (*Server, error) {
|
2019-05-01 19:30:16 +00:00
|
|
|
var (
|
|
|
|
err error
|
|
|
|
configFile io.ReadCloser
|
|
|
|
)
|
2018-09-28 13:58:30 +00:00
|
|
|
|
2019-05-01 11:44:45 +00:00
|
|
|
// 1. init instance
|
2018-07-10 23:51:10 +00:00
|
|
|
var i = &Server{
|
2020-03-03 17:36:52 +00:00
|
|
|
config: nil,
|
2019-05-01 11:44:45 +00:00
|
|
|
handlers: make([]*api.Handler, 0),
|
2018-07-10 23:51:10 +00:00
|
|
|
}
|
2018-07-06 08:49:52 +00:00
|
|
|
|
2019-05-01 11:44:45 +00:00
|
|
|
// 2. open config file
|
2019-05-01 19:30:16 +00:00
|
|
|
configFile, err = os.Open(configPath)
|
2018-07-06 08:49:52 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
2019-05-01 11:44:45 +00:00
|
|
|
defer configFile.Close()
|
2018-07-06 08:49:52 +00:00
|
|
|
|
2019-05-01 11:44:45 +00:00
|
|
|
// 3. load configuration
|
2020-03-21 13:49:36 +00:00
|
|
|
i.config, err = config.Parse(configFile, dtypes...)
|
2019-05-01 11:44:45 +00:00
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
2018-10-01 17:27:38 +00:00
|
|
|
}
|
|
|
|
|
2019-09-26 17:03:37 +00:00
|
|
|
// 4. log configuration services
|
2019-11-19 18:19:55 +00:00
|
|
|
log.Printf("🔧 Reading configuration '%s'\n", configPath)
|
2020-03-21 13:49:36 +00:00
|
|
|
for _, service := range i.config.Services {
|
|
|
|
log.Printf(" ->\t%s\t'%s'\n", service.Method, service.Pattern)
|
|
|
|
}
|
2018-07-07 17:21:00 +00:00
|
|
|
|
2019-09-26 17:03:37 +00:00
|
|
|
return i, nil
|
2018-07-07 17:21:00 +00:00
|
|
|
|
|
|
|
}
|
|
|
|
|
2019-05-01 11:44:45 +00:00
|
|
|
// HandleFunc sets a new handler for an HTTP method to a path
|
|
|
|
func (s *Server) HandleFunc(httpMethod, path string, handlerFunc api.HandlerFunc) {
|
|
|
|
handler := api.NewHandler(httpMethod, path, handlerFunc)
|
|
|
|
s.handlers = append(s.handlers, handler)
|
|
|
|
}
|
2018-07-06 08:49:52 +00:00
|
|
|
|
2019-05-01 11:44:45 +00:00
|
|
|
// Handle sets a new handler
|
|
|
|
func (s *Server) Handle(handler *api.Handler) {
|
|
|
|
s.handlers = append(s.handlers, handler)
|
2018-07-06 08:49:52 +00:00
|
|
|
}
|
2019-09-26 17:03:37 +00:00
|
|
|
|
|
|
|
// HTTP converts the server to a http server
|
|
|
|
func (s Server) HTTP() httpServer {
|
|
|
|
|
|
|
|
// 1. log available handlers
|
2019-11-19 18:19:55 +00:00
|
|
|
log.Printf("🔗 Mapping handlers\n")
|
2019-09-26 17:03:37 +00:00
|
|
|
for i := 0; i < len(s.handlers); i++ {
|
2019-11-19 18:19:55 +00:00
|
|
|
log.Printf(" ->\t%s\t'%s'\n", s.handlers[i].GetMethod(), s.handlers[i].GetPath())
|
2019-09-26 17:03:37 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// 2. cast to http server
|
|
|
|
return httpServer(s)
|
|
|
|
}
|