1 files changed, 62 insertions, 0 deletions
diff --git a/internal/parser/json.go b/internal/parser/json.go
new file mode 100644
index 0000000..3b8c2e8
--- /dev/null
+++ b/internal/parser/json.go
@@ -0,0 +1,62 @@
+package parser
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"io"
+	"time"
+
+	"epimetheus/internal/metrics"
+)
+
+// JSONParser parses metrics from JSON format
+type JSONParser struct{}
+
+// NewJSONParser creates a new JSON parser
+func NewJSONParser() *JSONParser {
+	return &JSONParser{}
+}
+
+type jsonSample struct {
+	Metric      string            `json:"metric"`
+	Labels      map[string]string `json:"labels"`
+	Value       float64           `json:"value"`
+	TimestampMs int64             `json:"timestamp_ms,omitempty"`
+}
+
+// Parse reads metrics from JSON format
+func (p *JSONParser) Parse(ctx context.Context, reader io.Reader) ([]metrics.Sample, error) {
+	var rawSamples []jsonSample
+
+	decoder := json.NewDecoder(reader)
+	if err := decoder.Decode(&rawSamples); err != nil {
+		return nil, fmt.Errorf("failed to parse JSON: %w", err)
+	}
+
+	samples := make([]metrics.Sample, 0, len(rawSamples))
+	for _, raw := range rawSamples {
+		select {
+		case <-ctx.Done():
+			return nil, ctx.Err()
+		default:
+		}
+
+		if raw.Metric == "" {
+			continue
+		}
+
+		timestamp := time.Now()
+		if raw.TimestampMs > 0 {
+			timestamp = time.UnixMilli(raw.TimestampMs)
+		}
+
+		if raw.Labels == nil {
+			raw.Labels = make(map[string]string)
+		}
+
+		samples = append(samples, metrics.NewSample(raw.Metric, raw.Labels, raw.Value, timestamp))
+	}
+
+	return samples, nil
+}