Method processPayload

modules/vardumper/handler.go:42–79

(base64Payload string)

}

func (h *tcpHandler) processPayload(base64Payload string) {
	result, err := h.php.Parse(base64Payload)
	if err != nil {
		slog.Error("vardumper: parse error", "err", err)
		return
	}

	// Build event payload matching the PHP Buggregator format.
	payload := map[string]any{
		"payload": map[string]any{
			"type":  result.Type,
			"value": result.Value,
			"label": result.Label,
		},
		"context": json.RawMessage(result.Context),
	}

	if result.Language != nil {
		payload["payload"].(map[string]any)["language"] = *result.Language
	}

	b, _ := json.Marshal(payload)

	project := ""
	if result.Project != nil {
		project = *result.Project
	}

	inc := &event.Incoming{
		Type:    "var-dump",
		Payload: json.RawMessage(b),
		Project: project,
	}

	if err := h.eventService.HandleIncoming(context.Background(), inc); err != nil {
		slog.Error("vardumper: failed to store event", "err", err)
	}
}