[TASK] use logmania logging
This commit is contained in:
		
							parent
							
								
									ff20d7e388
								
							
						
					
					
						commit
						0ac8fcb908
					
				| 
						 | 
					@ -5,7 +5,7 @@ import (
 | 
				
			||||||
	"net/http"
 | 
						"net/http"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	libHTTP "github.com/genofire/golang-lib/http"
 | 
						libHTTP "github.com/genofire/golang-lib/http"
 | 
				
			||||||
	"github.com/genofire/golang-lib/log"
 | 
						"github.com/genofire/logmania/log"
 | 
				
			||||||
	xmpp "github.com/mattn/go-xmpp"
 | 
						xmpp "github.com/mattn/go-xmpp"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	"github.com/genofire/hook2xmpp/config"
 | 
						"github.com/genofire/hook2xmpp/config"
 | 
				
			||||||
| 
						 | 
					@ -37,14 +37,14 @@ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 | 
				
			||||||
	payload := body["payload"].(map[string]interface{})
 | 
						payload := body["payload"].(map[string]interface{})
 | 
				
			||||||
	vcsURL, ok := payload["vcs_url"].(string)
 | 
						vcsURL, ok := payload["vcs_url"].(string)
 | 
				
			||||||
	if !ok {
 | 
						if !ok {
 | 
				
			||||||
		log.Log.Error(r.Body)
 | 
							log.Error(r.Body)
 | 
				
			||||||
		http.Error(w, fmt.Sprintf("no readable payload"), http.StatusInternalServerError)
 | 
							http.Error(w, fmt.Sprintf("no readable payload"), http.StatusInternalServerError)
 | 
				
			||||||
		return
 | 
							return
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	hook, ok := h.hooks[vcsURL]
 | 
						hook, ok := h.hooks[vcsURL]
 | 
				
			||||||
	if !ok {
 | 
						if !ok {
 | 
				
			||||||
		log.Log.Errorf("No hook found for: '%s'", vcsURL)
 | 
							log.Errorf("No hook found for: '%s'", vcsURL)
 | 
				
			||||||
		http.Error(w, fmt.Sprintf("no configuration for circleci for url %s", vcsURL), http.StatusNotFound)
 | 
							http.Error(w, fmt.Sprintf("no configuration for circleci for url %s", vcsURL), http.StatusNotFound)
 | 
				
			||||||
		return
 | 
							return
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
| 
						 | 
					@ -55,6 +55,6 @@ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 | 
				
			||||||
	subject := payload["subject"].(string)
 | 
						subject := payload["subject"].(string)
 | 
				
			||||||
	msg := fmt.Sprintf("[%s] %s (%0.fs) - #%0.f: %s \n%s", vcsURL, status, buildTime/1000, buildNum, subject, buildURL)
 | 
						msg := fmt.Sprintf("[%s] %s (%0.fs) - #%0.f: %s \n%s", vcsURL, status, buildTime/1000, buildNum, subject, buildURL)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	log.Log.WithField("type", "circleci").Print(msg)
 | 
						log.New().AddField("type", "circleci").Info(msg)
 | 
				
			||||||
	ownXMPP.Notify(h.client, hook, msg)
 | 
						ownXMPP.Notify(h.client, hook, msg)
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -7,7 +7,9 @@ import (
 | 
				
			||||||
	"os/signal"
 | 
						"os/signal"
 | 
				
			||||||
	"syscall"
 | 
						"syscall"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	"github.com/genofire/golang-lib/log"
 | 
						"github.com/genofire/logmania/log"
 | 
				
			||||||
 | 
						logmania "github.com/genofire/logmania/log/hook/client"
 | 
				
			||||||
 | 
						_ "github.com/genofire/logmania/log/hook/output"
 | 
				
			||||||
	"github.com/mattn/go-xmpp"
 | 
						"github.com/mattn/go-xmpp"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	"github.com/genofire/hook2xmpp/circleci"
 | 
						"github.com/genofire/hook2xmpp/circleci"
 | 
				
			||||||
| 
						 | 
					@ -21,8 +23,13 @@ func main() {
 | 
				
			||||||
	flag.StringVar(&configFile, "config", configFile, "path of configuration file")
 | 
						flag.StringVar(&configFile, "config", configFile, "path of configuration file")
 | 
				
			||||||
	flag.Parse()
 | 
						flag.Parse()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	// load config
 | 
					 | 
				
			||||||
	config := configuration.ReadConfigFile(configFile)
 | 
						config := configuration.ReadConfigFile(configFile)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						if config.Logmania.Enable {
 | 
				
			||||||
 | 
							logmania.Init(config.Logmania.Address, config.Logmania.Token, log.LogLevel(config.Logmania.Level))
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						// load config
 | 
				
			||||||
	options := xmpp.Options{
 | 
						options := xmpp.Options{
 | 
				
			||||||
		Host:          config.XMPP.Host,
 | 
							Host:          config.XMPP.Host,
 | 
				
			||||||
		User:          config.XMPP.Username,
 | 
							User:          config.XMPP.Username,
 | 
				
			||||||
| 
						 | 
					@ -35,10 +42,10 @@ func main() {
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	client, err := options.NewClient()
 | 
						client, err := options.NewClient()
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
		log.Log.Panic(err)
 | 
							log.Panic(err)
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	log.Log.Infof("Started hock2xmpp with %s", client.JID())
 | 
						log.Infof("Started hock2xmpp with %s", client.JID())
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	client.SendHtml(xmpp.Chat{Remote: config.XMPP.StartupNotify, Type: "chat", Text: "startup of hock2xmpp"})
 | 
						client.SendHtml(xmpp.Chat{Remote: config.XMPP.StartupNotify, Type: "chat", Text: "startup of hock2xmpp"})
 | 
				
			||||||
	go ownXMPP.Start(client)
 | 
						go ownXMPP.Start(client)
 | 
				
			||||||
| 
						 | 
					@ -67,5 +74,5 @@ func main() {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	srv.Close()
 | 
						srv.Close()
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	log.Log.Info("received", sig)
 | 
						log.Info("received", sig)
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -5,10 +5,17 @@ import (
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	"github.com/BurntSushi/toml"
 | 
						"github.com/BurntSushi/toml"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	"github.com/genofire/golang-lib/log"
 | 
						"github.com/genofire/logmania/log"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
 | 
					
 | 
				
			||||||
type Config struct {
 | 
					type Config struct {
 | 
				
			||||||
 | 
						Logmania struct {
 | 
				
			||||||
 | 
							Enable  bool   `toml:"enable"`
 | 
				
			||||||
 | 
							Address string `toml:"address"`
 | 
				
			||||||
 | 
							Token   string `toml:"token"`
 | 
				
			||||||
 | 
							Level   int    `toml:"level"`
 | 
				
			||||||
 | 
						} `toml:"logmania"`
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	WebserverBind string `toml:"webserver_bind"`
 | 
						WebserverBind string `toml:"webserver_bind"`
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	XMPP struct {
 | 
						XMPP struct {
 | 
				
			||||||
| 
						 | 
					@ -37,10 +44,10 @@ func ReadConfigFile(path string) *Config {
 | 
				
			||||||
	config := &Config{}
 | 
						config := &Config{}
 | 
				
			||||||
	file, err := ioutil.ReadFile(path)
 | 
						file, err := ioutil.ReadFile(path)
 | 
				
			||||||
	if err != nil {
 | 
						if err != nil {
 | 
				
			||||||
		log.Log.Panic(err)
 | 
							log.Panic(err)
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
	if err := toml.Unmarshal(file, config); err != nil {
 | 
						if err := toml.Unmarshal(file, config); err != nil {
 | 
				
			||||||
		log.Log.Panic(err)
 | 
							log.Panic(err)
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	return config
 | 
						return config
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -4,7 +4,7 @@ import (
 | 
				
			||||||
	"net/http"
 | 
						"net/http"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	libHTTP "github.com/genofire/golang-lib/http"
 | 
						libHTTP "github.com/genofire/golang-lib/http"
 | 
				
			||||||
	"github.com/genofire/golang-lib/log"
 | 
						"github.com/genofire/logmania/log"
 | 
				
			||||||
	xmpp "github.com/mattn/go-xmpp"
 | 
						xmpp "github.com/mattn/go-xmpp"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	"github.com/genofire/hook2xmpp/config"
 | 
						"github.com/genofire/hook2xmpp/config"
 | 
				
			||||||
| 
						 | 
					@ -54,10 +54,10 @@ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	hook, ok := h.hooks[url]
 | 
						hook, ok := h.hooks[url]
 | 
				
			||||||
	if !ok {
 | 
						if !ok {
 | 
				
			||||||
		log.Log.Errorf("No hook found for: '%s'", url)
 | 
							log.Errorf("No hook found for: '%s'", url)
 | 
				
			||||||
		return
 | 
							return
 | 
				
			||||||
	}
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	log.Log.WithField("type", "git").Print(msg)
 | 
						log.New().AddField("type", "git").Info(msg)
 | 
				
			||||||
	ownXMPP.Notify(h.client, hook, msg)
 | 
						ownXMPP.Notify(h.client, hook, msg)
 | 
				
			||||||
}
 | 
					}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
| 
						 | 
					@ -1,8 +1,8 @@
 | 
				
			||||||
package xmpp
 | 
					package xmpp
 | 
				
			||||||
 | 
					
 | 
				
			||||||
import (
 | 
					import (
 | 
				
			||||||
	"github.com/genofire/golang-lib/log"
 | 
					 | 
				
			||||||
	"github.com/genofire/hook2xmpp/config"
 | 
						"github.com/genofire/hook2xmpp/config"
 | 
				
			||||||
 | 
						"github.com/genofire/logmania/log"
 | 
				
			||||||
 | 
					
 | 
				
			||||||
	xmpp "github.com/mattn/go-xmpp"
 | 
						xmpp "github.com/mattn/go-xmpp"
 | 
				
			||||||
)
 | 
					)
 | 
				
			||||||
| 
						 | 
					@ -16,7 +16,7 @@ func Start(client *xmpp.Client) {
 | 
				
			||||||
		switch v := m.(type) {
 | 
							switch v := m.(type) {
 | 
				
			||||||
		case xmpp.Chat:
 | 
							case xmpp.Chat:
 | 
				
			||||||
			if v.Type == "chat" {
 | 
								if v.Type == "chat" {
 | 
				
			||||||
				log.Log.Infof("from %s: %s", v.Remote, v.Text)
 | 
									log.Infof("from %s: %s", v.Remote, v.Text)
 | 
				
			||||||
			}
 | 
								}
 | 
				
			||||||
			if v.Type == "groupchat" {
 | 
								if v.Type == "groupchat" {
 | 
				
			||||||
			}
 | 
								}
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
		Reference in New Issue