(id uuid.UUID)
| 219 | } |
| 220 | |
| 221 | func (c *core) node(id uuid.UUID) *Node { |
| 222 | c.mutex.Lock() |
| 223 | defer c.mutex.Unlock() |
| 224 | p := c.peers[id] |
| 225 | if p == nil || p.node == nil { |
| 226 | return nil |
| 227 | } |
| 228 | v1Node, err := ProtoToNode(p.node) |
| 229 | if err != nil { |
| 230 | c.logger.Critical(context.Background(), |
| 231 | "failed to convert node", slog.Error(err), slog.F("node", p.node)) |
| 232 | return nil |
| 233 | } |
| 234 | return v1Node |
| 235 | } |
| 236 | |
| 237 | func (c *core) handleRequest(ctx context.Context, p *peer, req *proto.CoordinateRequest) error { |
| 238 | c.mutex.Lock() |
no test coverage detected