package webutility
  
  import (
  	"database/sql"
  	"fmt"
  	"net/http"
  
  	"git.to-net.rs/marko.tikvic/gologger"
  	"github.com/gorilla/mux"
  )
  
  type Server struct {
  	DB        *sql.DB
  	Router    *mux.Router
  	Logger    *gologger.Logger
  	Port      string
  	UTCOffset int64

  	DBs       map[string]*sql.DB

  }

  func NewODBCServer(dsn, port, logDir string, utcOffset int64) (s *Server, err error) {

  	s = new(Server)
  
  	s.Port = port
  
  	if s.DB, err = sql.Open("odbc", fmt.Sprintf("DSN=%s;", dsn)); err != nil {
  		return nil, err
  	}
  
  	s.Router = mux.NewRouter()
  
  	if s.Logger, err = gologger.New("err", logDir, gologger.MaxLogSize1MB); err != nil {
  		return nil, fmt.Errorf("can't create logger: %s", err.Error())
  	}
  
  	s.UTCOffset = utcOffset

  	s.DBs = make(map[string]*sql.DB)
  	s.DBs["default"] = s.DB

  	return s, nil
  }
  
  func (s *Server) Run() {
  	s.Logger.Print("Server listening on %s", s.Port)
  	s.Logger.PrintAndTrace(http.ListenAndServe(s.Port, s.Router).Error())
  }
  
  func (s *Server) Cleanup() {
  	if s.DB != nil {
  		s.DB.Close()
  	}
  
  	if s.Logger != nil {
  		s.Logger.Close()
  	}
  }
  
  func (s *Server) StartTransaction() (*sql.Tx, error) {
  	return s.DB.Begin()
  }
  
  func CommitChanges(tx *sql.Tx, err *error, opt ...error) {
  	if *err != nil {
  		tx.Rollback()
  		return
  	}
  
  	for _, e := range opt {
  		if e != nil {
  			tx.Rollback()
  			return
  		}
  	}
  
  	if *err = tx.Commit(); *err != nil {
  		tx.Rollback()
  	}
  }