github/bettercap
1
0
Fork 0
mirror of https://github.com/bettercap/bettercap synced 2025-08-19 13:09:49 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

new: new events.show command

Browse source
This commit is contained in:
evilsocket 2018-01-27 20:26:22 +01:00
commit da185c7785
1 changed files with 29 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

40
modules/events_stream.go
View file

@ -38,6 +38,12 @@ func NewEventsStream(s *session.Session) *EventsStream {
return stream.Stop() return stream.Stop()
})) }))
stream.AddHandler(session.NewModuleHandler("events.show", "",
"Show events stream.",
func(args []string) error {
return stream.Show()
}))
stream.AddHandler(session.NewModuleHandler("events.clear", "", stream.AddHandler(session.NewModuleHandler("events.clear", "",
"Clear events stream.", "Clear events stream.",
func(args []string) error { func(args []string) error {
@ -68,6 +74,20 @@ func (s *EventsStream) Configure() error {
return nil return nil
} }
func (s *EventsStream) dumpEvent(e session.Event) {
if s.filter == "" || strings.Contains(e.Tag, s.filter) {
tm := e.Time.Format("2006-01-02 15:04:05")
if e.Tag == "sys.log" {
fmt.Printf("[%s] [%s] (%s) %s\n", tm, core.Green(e.Tag), e.Label(), e.Data.(session.LogMessage).Message)
} else {
fmt.Printf("[%s] [%s] %v\n", tm, core.Green(e.Tag), e.Data)
}
s.Session.Refresh()
}
}
func (s *EventsStream) Start() error { func (s *EventsStream) Start() error {
if s.Running() == true { if s.Running() == true {
return session.ErrAlreadyStarted return session.ErrAlreadyStarted
@ -82,17 +102,7 @@ func (s *EventsStream) Start() error {
var e session.Event var e session.Event
select { select {
case e = <-s.Session.Events.NewEvents: case e = <-s.Session.Events.NewEvents:
if s.filter == "" || strings.Contains(e.Tag, s.filter) { s.dumpEvent(e)
tm := e.Time.Format("2006-01-02 15:04:05")
if e.Tag == "sys.log" {
fmt.Printf("[%s] [%s] (%s) %s\n", tm, core.Green(e.Tag), e.Label(), e.Data.(session.LogMessage).Message)
} else {
fmt.Printf("[%s] [%s] %v\n", tm, core.Green(e.Tag), e.Data)
}
s.Session.Refresh()
}
break break
case <-s.quit: case <-s.quit:
@ -104,6 +114,14 @@ func (s *EventsStream) Start() error {
return nil return nil
} }
func (s *EventsStream) Show() error {
for _, e := range s.Session.Events.Events() {
s.dumpEvent(e)
}
return nil
}
func (s *EventsStream) Stop() error { func (s *EventsStream) Stop() error {
if s.Running() == false { if s.Running() == false {
return session.ErrAlreadyStopped return session.ErrAlreadyStopped