Changeset 488 in code for trunk/downstream.go
- Timestamp:
- Mar 31, 2021, 3:57:24 PM (4 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/downstream.go
r486 r488 351 351 // ackMsgID acknowledges that a message has been received. 352 352 func (dc *downstreamConn) ackMsgID(id string) { 353 netID, entity, _, err := parseMsgID(id)353 netID, entity, err := parseMsgID(id, nil) 354 354 if err != nil { 355 355 dc.logger.Printf("failed to ACK message ID %q: %v", id, err) … … 366 366 367 367 func (dc *downstreamConn) sendPing(msgID string) { 368 token := "soju-msgid-" + base64.RawURLEncoding.EncodeToString([]byte(msgID))368 token := "soju-msgid-" + msgID 369 369 dc.SendMessage(&irc.Message{ 370 370 Command: "PING", … … 378 378 return 379 379 } 380 token = strings.TrimPrefix(token, "soju-msgid-") 381 b, err := base64.RawURLEncoding.DecodeString(token) 382 if err != nil { 383 dc.logger.Printf("received malformed PONG token: %v", err) 384 return 385 } 386 msgID := string(b) 387 380 msgID := strings.TrimPrefix(token, "soju-msgid-") 388 381 dc.ackMsgID(msgID) 389 382 }
Note:
See TracChangeset
for help on using the changeset viewer.