mirror of
https://github.com/ScuroNeko/mtg.git
synced 2026-09-01 10:44:02 +03:00
Rename EventTelegramTraffic back to EventTraffic
This commit is contained in:
+2
-2
@@ -21,7 +21,7 @@ func (c connTelegramTraffic) Read(b []byte) (int, error) {
|
||||
n, err := c.Conn.Read(b)
|
||||
|
||||
if n > 0 {
|
||||
c.stream.Send(c.ctx, EventTelegramTraffic{
|
||||
c.stream.Send(c.ctx, EventTraffic{
|
||||
CreatedAt: time.Now(),
|
||||
ConnID: c.connID,
|
||||
Traffic: uint(n),
|
||||
@@ -36,7 +36,7 @@ func (c connTelegramTraffic) Write(b []byte) (int, error) {
|
||||
n, err := c.Conn.Write(b)
|
||||
|
||||
if n > 0 {
|
||||
c.stream.Send(c.ctx, EventTelegramTraffic{
|
||||
c.stream.Send(c.ctx, EventTraffic{
|
||||
CreatedAt: time.Now(),
|
||||
ConnID: c.connID,
|
||||
Traffic: uint(n),
|
||||
|
||||
+3
-3
@@ -34,18 +34,18 @@ func (e EventConnectedToDC) Timestamp() time.Time {
|
||||
return e.CreatedAt
|
||||
}
|
||||
|
||||
type EventTelegramTraffic struct {
|
||||
type EventTraffic struct {
|
||||
CreatedAt time.Time
|
||||
ConnID string
|
||||
Traffic uint
|
||||
IsRead bool
|
||||
}
|
||||
|
||||
func (e EventTelegramTraffic) StreamID() string {
|
||||
func (e EventTraffic) StreamID() string {
|
||||
return e.ConnID
|
||||
}
|
||||
|
||||
func (e EventTelegramTraffic) Timestamp() time.Time {
|
||||
func (e EventTraffic) Timestamp() time.Time {
|
||||
return e.CreatedAt
|
||||
}
|
||||
|
||||
|
||||
@@ -46,8 +46,8 @@ func (suite *EventsTestSuite) TestEventConnectedToDC() {
|
||||
suite.WithinDuration(time.Now(), evt.Timestamp(), 10*time.Millisecond)
|
||||
}
|
||||
|
||||
func (suite *EventsTestSuite) TestEventTelegramTraffic() {
|
||||
evt := mtglib.EventTelegramTraffic{
|
||||
func (suite *EventsTestSuite) TestEventTraffic() {
|
||||
evt := mtglib.EventTraffic{
|
||||
CreatedAt: time.Now(),
|
||||
ConnID: "CONNID",
|
||||
Traffic: 3,
|
||||
|
||||
Reference in New Issue
Block a user