package notifier

import (
	"github.com/jouir/pgterminate/base"
	"github.com/jouir/pgterminate/log"
)

// Console notifier structure
type Console struct {
	format   string
	sessions chan *base.Session
}

// NewConsole creates a console notifier
func NewConsole(format string, sessions chan *base.Session) Notifier {
	return &Console{
		format:   format,
		sessions: sessions,
	}
}

// Run starts console notifier
func (c *Console) Run() {
	log.Info("Starting console notifier")
	for session := range c.sessions {
		log.Info(session.Format(c.format))
	}
}

// Reload for handling SIGHUP signals
func (c *Console) Reload() {
	log.Info("Reloading console notifier")
}