Skip to content

Commit 1119b9c

Browse files
committed
make the trace output look nice
Signed-off-by: Stephan Ruloff <stephan.ruloff@gmail.com>
1 parent c37a0a2 commit 1119b9c

12 files changed

+27
-15
lines changed

packets/connack.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@ type ConnackPacket struct {
1515
}
1616

1717
func (ca *ConnackPacket) String() string {
18-
str := fmt.Sprintf("%s\n", ca.FixedHeader)
18+
str := fmt.Sprintf("%s", ca.FixedHeader)
19+
str += " "
1920
str += fmt.Sprintf("sessionpresent: %t returncode: %d", ca.SessionPresent, ca.ReturnCode)
2021
return str
2122
}

packets/connect.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,9 @@ type ConnectPacket struct {
2929
}
3030

3131
func (c *ConnectPacket) String() string {
32-
str := fmt.Sprintf("%s\n", c.FixedHeader)
33-
str += fmt.Sprintf("protocolversion: %d protocolname: %s cleansession: %t willflag: %t WillQos: %d WillRetain: %t Usernameflag: %t Passwordflag: %t keepalive: %d\nclientId: %s\nwilltopic: %s\nwillmessage: %s\nUsername: %s\nPassword: %s\n", c.ProtocolVersion, c.ProtocolName, c.CleanSession, c.WillFlag, c.WillQos, c.WillRetain, c.UsernameFlag, c.PasswordFlag, c.Keepalive, c.ClientIdentifier, c.WillTopic, c.WillMessage, c.Username, c.Password)
32+
str := fmt.Sprintf("%s", c.FixedHeader)
33+
str += " "
34+
str += fmt.Sprintf("protocolversion: %d protocolname: %s cleansession: %t willflag: %t WillQos: %d WillRetain: %t Usernameflag: %t Passwordflag: %t keepalive: %d clientId: %s willtopic: %s willmessage: %s Username: %s Password: %s", c.ProtocolVersion, c.ProtocolName, c.CleanSession, c.WillFlag, c.WillQos, c.WillRetain, c.UsernameFlag, c.PasswordFlag, c.Keepalive, c.ClientIdentifier, c.WillTopic, c.WillMessage, c.Username, c.Password)
3435
return str
3536
}
3637

packets/disconnect.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ type DisconnectPacket struct {
1212
}
1313

1414
func (d *DisconnectPacket) String() string {
15-
str := fmt.Sprintf("%s\n", d.FixedHeader)
15+
str := fmt.Sprintf("%s", d.FixedHeader)
1616
return str
1717
}
1818

packets/puback.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,9 @@ type PubackPacket struct {
1313
}
1414

1515
func (pa *PubackPacket) String() string {
16-
str := fmt.Sprintf("%s\n", pa.FixedHeader)
17-
str += fmt.Sprintf("messageID: %d", pa.MessageID)
16+
str := fmt.Sprintf("%s", pa.FixedHeader)
17+
str += " "
18+
str += fmt.Sprintf("MessageID: %d", pa.MessageID)
1819
return str
1920
}
2021

packets/pubcomp.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@ type PubcompPacket struct {
1313
}
1414

1515
func (pc *PubcompPacket) String() string {
16-
str := fmt.Sprintf("%s\n", pc.FixedHeader)
16+
str := fmt.Sprintf("%s", pc.FixedHeader)
17+
str += " "
1718
str += fmt.Sprintf("MessageID: %d", pc.MessageID)
1819
return str
1920
}

packets/publish.go

+5-3
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,11 @@ type PublishPacket struct {
1616
}
1717

1818
func (p *PublishPacket) String() string {
19-
str := fmt.Sprintf("%s\n", p.FixedHeader)
20-
str += fmt.Sprintf("topicName: %s MessageID: %d\n", p.TopicName, p.MessageID)
21-
str += fmt.Sprintf("payload: %s\n", string(p.Payload))
19+
str := fmt.Sprintf("%s", p.FixedHeader)
20+
str += " "
21+
str += fmt.Sprintf("topicName: %s MessageID: %d", p.TopicName, p.MessageID)
22+
str += " "
23+
str += fmt.Sprintf("payload: %s", string(p.Payload))
2224
return str
2325
}
2426

packets/pubrec.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@ type PubrecPacket struct {
1313
}
1414

1515
func (pr *PubrecPacket) String() string {
16-
str := fmt.Sprintf("%s\n", pr.FixedHeader)
16+
str := fmt.Sprintf("%s", pr.FixedHeader)
17+
str += " "
1718
str += fmt.Sprintf("MessageID: %d", pr.MessageID)
1819
return str
1920
}

packets/pubrel.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@ type PubrelPacket struct {
1313
}
1414

1515
func (pr *PubrelPacket) String() string {
16-
str := fmt.Sprintf("%s\n", pr.FixedHeader)
16+
str := fmt.Sprintf("%s", pr.FixedHeader)
17+
str += " "
1718
str += fmt.Sprintf("MessageID: %d", pr.MessageID)
1819
return str
1920
}

packets/suback.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@ type SubackPacket struct {
1515
}
1616

1717
func (sa *SubackPacket) String() string {
18-
str := fmt.Sprintf("%s\n", sa.FixedHeader)
18+
str := fmt.Sprintf("%s", sa.FixedHeader)
19+
str += " "
1920
str += fmt.Sprintf("MessageID: %d", sa.MessageID)
2021
return str
2122
}

packets/subscribe.go

+1
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ type SubscribePacket struct {
1717

1818
func (s *SubscribePacket) String() string {
1919
str := fmt.Sprintf("%s", s.FixedHeader)
20+
str += " "
2021
str += fmt.Sprintf("MessageID: %d topics: %s", s.MessageID, s.Topics)
2122
return str
2223
}

packets/unsuback.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@ type UnsubackPacket struct {
1313
}
1414

1515
func (ua *UnsubackPacket) String() string {
16-
str := fmt.Sprintf("%s\n", ua.FixedHeader)
16+
str := fmt.Sprintf("%s", ua.FixedHeader)
17+
str += " "
1718
str += fmt.Sprintf("MessageID: %d", ua.MessageID)
1819
return str
1920
}

packets/unsubscribe.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,8 @@ type UnsubscribePacket struct {
1515
}
1616

1717
func (u *UnsubscribePacket) String() string {
18-
str := fmt.Sprintf("%s\n", u.FixedHeader)
18+
str := fmt.Sprintf("%s", u.FixedHeader)
19+
str += " "
1920
str += fmt.Sprintf("MessageID: %d", u.MessageID)
2021
return str
2122
}

0 commit comments

Comments
 (0)