| 183 | } |
| 184 | |
| 185 | func (s *webhookTestServer) ServeHTTP(_ http.ResponseWriter, r *http.Request) { |
| 186 | data, err := webhook.Receive(r, s.provider) |
| 187 | if err != nil { |
| 188 | logger.Errorw("could not receive webhook", err) |
| 189 | return |
| 190 | } |
| 191 | |
| 192 | event := livekit.WebhookEvent{} |
| 193 | if err = protojson.Unmarshal(data, &event); err != nil { |
| 194 | logger.Errorw("could not unmarshal event", err) |
| 195 | return |
| 196 | } |
| 197 | |
| 198 | s.lock.Lock() |
| 199 | s.events[event.Event] = &event |
| 200 | s.lock.Unlock() |
| 201 | } |
| 202 | |
| 203 | func (s *webhookTestServer) GetEvent(name string) *livekit.WebhookEvent { |
| 204 | s.lock.Lock() |