pipeline

type Combinations struct {
	IonosphereFree   *LinearCombination // ionosphere-free combination
	NarrowLane       *LinearCombination // narrow-lane combination
	WideLane         *LinearCombination // wide-lane combination
	GeometryFree     *LinearCombination // geometry-free combination
	MelbourneWubbena *float64           // Melbourne-Wübbena combination [m]
}

type Corrections struct {
	Troposphere  *float64 // tropospheric delay [m]
	Ionosphere   *float64 // ionospheric delay [m]
	Sagnac       *float64 // Sagnac effect [m]
	PhaseWindup  *float64 // carrier phase windup [cycles]
	Relativity   *float64 // relativistic clock correction [m]
	TidalLoading *float64 // solid earth tide displacement [m]
	OceanLoading *float64 // ocean loading displacement [m]
	PCV          *float64 // phase center variation [m]
	PCO          *float64 // phase center offset [m]
}

type EpochProcessor struct {
	// contains filtered or unexported fields
}

type Geometry struct {
	Azimuth   float64 // degrees, 0-360
	Elevation float64 // degrees, 0-90
	Range     float64 // geometric range in meters
}

type LinearCombination struct {
	Phase float64 // phase measurement [m]
	Range float64 // pseudorange measurement [m]
}

type Pipeline struct {
	// contains filtered or unexported fields
}

type Processor interface {
	// Process transforms the input SatelliteState and returns the modified state.
	// If processing fails, it returns an error but should not panic.
	// The context can be used for cancellation and timeout.
	Process(ctx context.Context, state *SatelliteState) error

	// Name returns a human-readable name for this processor, used in logging and error messages.
	Name() string
}

type QualityIndicators struct {
	HealthStatus     bool    // satellite health status from ephemeris
	ElevationMasked  bool    // true if below elevation mask
	CycleSlipL1      bool    // cycle slip detected on L1
	CycleSlipL2      bool    // cycle slip detected on L2
	MWSlipDetected   bool    // Melbourne-Wübbena slip detected
	SignalStrengthL1 float64 // SNR for L1 [dB-Hz]
	SignalStrengthL2 float64 // SNR for L2 [dB-Hz]

	// PPP-AR specific indicators
	AmbiguityFixed   bool    // true if integer ambiguity is fixed
	AmbiguityFloat   bool    // true if ambiguity is float (not fixed)
	ARValidationPass bool    // true if ambiguity resolution validation passed
	ARRatio          float64 // ratio test value for ambiguity resolution
}

type SatelliteState struct {
	// Core identifiers (always set)
	System      gnss.System
	SatelliteID int
	Time        time.Time

	// Raw observations (always set)
	Observations []observation.Observation

	// Ephemeris data (set by EphemerisProcessor)
	Ephemeris ephemeris.TypeSpecificEphemeris

	// Precise products (set by PreciseProductProcessor)
	PreciseOrbit *precise.OrbitRecord
	PreciseClock *precise.ClockRecord

	// Satellite position and clock (set by PositionProcessor)
	Position *ephemeris.SatPosition

	// Geometry relative to receiver (set by GeometryProcessor)
	Geometry *Geometry

	// Corrections (various processors can set these)
	Corrections Corrections

	// Linear combinations (various processors can set these)
	Combinations Combinations

	// Quality indicators
	Quality QualityIndicators
}