| 159 | for _, msg := range resp.Messages { |
| 160 | if msg.MessageText != nil && strings.HasPrefix(*msg.MessageText, connID+":") { |
| 161 | return base64.StdEncoding.DecodeString(strings.TrimPrefix(*msg.MessageText, connID+":")) |
| 162 | } |
| 163 | } |
| 164 | return nil, ErrNoData |
| 165 | } |
| 166 | |
| 167 | func (p *queueDriver) DeleteToken(ctx context.Context, connID string) error { |
| 168 | if val, ok := p.receipts.LoadAndDelete(connID); ok { |
| 169 | parts := strings.Split(val.(string), ":") |
| 170 | _, err := p.tokenQueue.DeleteMessage(ctx, parts[0], parts[1], nil) |
| 171 | return err |
| 172 | } |
| 173 | return nil |
| 174 | } |
| 175 | |
| 176 | func (p *queueDriver) makeSAS(name string, permissions sas.QueuePermissions) (string, error) { |
| 177 | start, end := p.cfg.SASTimes() |