Function TestStoreTransaction

modules/sentry/storage_test.go:179–288

(t *testing.T)

}

func TestStoreTransaction(t *testing.T) {
	db := setupTestDB(t)

	payload := json.RawMessage(`{
		"event_id": "txn-1",
		"type": "transaction",
		"transaction": "GET /api/users",
		"op": "http.server",
		"status": "ok",
		"start_timestamp": 1678272500.0,
		"timestamp": 1678272505.844,
		"environment": "production",
		"contexts": {"trace": {"trace_id": "aabbccdd11223344", "span_id": "root-span"}},
		"spans": [
			{
				"span_id": "span-1",
				"parent_span_id": "root-span",
				"trace_id": "aabbccdd11223344",
				"op": "db.query",
				"description": "SELECT * FROM users",
				"status": "ok",
				"start_timestamp": 1678272501.0,
				"timestamp": 1678272502.0,
				"data": {"server.address": "db.example.com", "db.name": "mydb"}
			},
			{
				"span_id": "span-2",
				"parent_span_id": "root-span",
				"trace_id": "aabbccdd11223344",
				"op": "http.client",
				"description": "POST https://api.example.com/notify",
				"status": "internal_error",
				"start_timestamp": 1678272503.0,
				"timestamp": 1678272504.5,
				"data": {"http.url": "https://api.example.com/notify"}
			}
		]
	}`)

	var txn Transaction
	if err := json.Unmarshal(payload, &txn); err != nil {
		t.Fatal(err)
	}

	id, err := storeTransaction(db, &txn, payload)
	if err != nil {
		t.Fatal(err)
	}
	if id == "" {
		t.Fatal("expected non-empty ID")
	}

	// Verify sentry_traces.
	var spanCount, errorCount int
	err = db.QueryRow(`SELECT span_count, error_count FROM sentry_traces WHERE trace_id = ?`, "aabbccdd11223344").Scan(&spanCount, &errorCount)
	if err != nil {
		t.Fatal(err)
	}