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]
	PCO          *float64 // phase center offset magnitude [m]

	// Applied tracks whether corrections have been applied to observations
	// This prevents double-application when processors run multiple times
	Applied bool
}

type CycleSlipInfo struct {
	Detected      bool     // True if a cycle slip was detected
	Method        string   // Detection method: "LLI", "MW", "TDCP"
	EstimatedSlip *float64 // Estimated slip magnitude in cycles (nil if not estimated)
	Confidence    float64  // Confidence score 0-1 (higher = more confident)
}

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 observation.SatelliteID
	Fcn         int8 // Frequency Channel Number (GLONASS only, 0 otherwise)
	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

	// TDCP velocity observable (set by TDCPObservableProcessor)
	Velocity *VelocityObservable

	// Cycle slip detection results (supports PPP/PPP-AR workflows)
	CycleSlip *CycleSlipInfo

	// Quality indicators
	Quality QualityIndicators
}

type VelocityObservable struct {
	DeltaPhase   float64       // Phase difference between epochs [meters]
	GeometryRow  [4]float64    // Geometry matrix row [dx/rho, dy/rho, dz/rho, 1]
	ModeledRange float64       // Modeled range change [meters]
	Weight       float64       // Elevation-based weight for least squares
	TimeDelta    time.Duration // Time between epochs
}