(ctx context.Context, connID string)
| 123 | if err != nil { |
| 124 | return nil, err |
| 125 | } |
| 126 | var handshakes []Handshake |
| 127 | for _, msg := range resp.Messages { |
| 128 | if msg.MessageText != nil { |
| 129 | data, _ := base64.StdEncoding.DecodeString(*msg.MessageText) |
| 130 | handshakes = append(handshakes, Handshake{ID: *msg.MessageID + ":" + *msg.PopReceipt, Payload: data}) |
| 131 | } |
| 132 | } |
| 133 | return handshakes, nil |
| 134 | } |
| 135 | |
| 136 | func (p *queueDriver) DeleteHandshake(ctx context.Context, id string) error { |
| 137 | parts := strings.Split(id, ":") |
| 138 | if len(parts) != 2 { |
| 139 | return fmt.Errorf("invalid handshake id format") |
nothing calls this directly
no outgoing calls
no test coverage detected