github/bettercap
1
0
Fork 0
mirror of https://github.com/bettercap/bettercap synced 2025-08-14 02:36:57 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

new: can.fuzz command

Browse source
This commit is contained in:
Simone Margaritelli 2024-08-16 13:30:26 +02:00
commit 6f1920f478
5 changed files with 160 additions and 42 deletions
Download patch file Download diff file Expand all files Collapse all files

88
modules/can/can_recon.go
View file

@ -1,7 +1,6 @@
package can
import (
"context"
"errors"
"fmt"
"os"
@ -57,7 +56,7 @@ func (mod *CANModule) Configure() error {
mod.Warning("no can.dbc_path specified, messages won't be parsed")
}
if mod.conn, err = socketcan.DialContext(context.Background(), mod.transport, mod.deviceName); err != nil {
if mod.conn, err = socketcan.Dial(mod.transport, mod.deviceName); err != nil {
return err
}
@ -67,6 +66,52 @@ func (mod *CANModule) Configure() error {
return nil
}
func (mod *CANModule) onFrame(frame can.Frame) {
msg := Message{
Frame: frame,
}
// if we have a DBC database
if mod.dbc != nil {
// if the database contains this message id
if message, found := mod.dbc.Message(frame.ID); found {
msg.Name = message.Name
// find source full info in DBC nodes
sourceName := message.SenderNode
sourceDesc := ""
if sender, found := mod.dbc.Node(message.SenderNode); found {
sourceName = sender.Name
sourceDesc = sender.Description
}
// add CAN source if new
_, msg.Source = mod.Session.CAN.AddIfNew(sourceName, sourceDesc, frame.Data[:])
msg.Signals = make(map[string]string)
// parse signals
for _, signal := range message.Signals {
var value string
if signal.Length <= 32 && signal.IsFloat {
value = fmt.Sprintf("%f", signal.UnmarshalFloat(frame.Data))
} else if signal.Length == 1 {
value = fmt.Sprintf("%v", signal.UnmarshalBool(frame.Data))
} else if signal.IsSigned {
value = fmt.Sprintf("%d", signal.UnmarshalSigned(frame.Data))
} else {
value = fmt.Sprintf("%d", signal.UnmarshalUnsigned(frame.Data))
}
msg.Signals[signal.Name] = str.Trim(fmt.Sprintf("%s %s", value, signal.Unit))
}
}
}
mod.Session.Events.Add("can.message", msg)
}
func (mod *CANModule) Start() error {
if err := mod.Configure(); err != nil {
return err
@ -77,44 +122,7 @@ func (mod *CANModule) Start() error {
for mod.recv.Receive() {
frame := mod.recv.Frame()
msg := Message{
Frame: frame,
}
if mod.dbc != nil {
if message, found := mod.dbc.Message(frame.ID); found {
msg.Name = message.Name
sourceName := message.SenderNode
sourceDesc := ""
if sender, found := mod.dbc.Node(message.SenderNode); found {
sourceName = sender.Name
sourceDesc = sender.Description
}
_, msg.Source = mod.Session.CAN.AddIfNew(sourceName, sourceDesc, frame.Data[:])
msg.Signals = make(map[string]string)
for _, signal := range message.Signals {
var value string
if signal.Length <= 32 && signal.IsFloat {
value = fmt.Sprintf("%f", signal.UnmarshalFloat(frame.Data))
} else if signal.Length == 1 {
value = fmt.Sprintf("%v", signal.UnmarshalBool(frame.Data))
} else if signal.IsSigned {
value = fmt.Sprintf("%d", signal.UnmarshalSigned(frame.Data))
} else {
value = fmt.Sprintf("%d", signal.UnmarshalUnsigned(frame.Data))
}
msg.Signals[signal.Name] = str.Trim(fmt.Sprintf("%s %s", value, signal.Unit))
}
}
}
mod.Session.Events.Add("can.message", msg)
mod.onFrame(frame)
}
})
}