module ADP.Fusion.PointL.Term.Str where
import Data.Proxy
import Data.Strict.Tuple
import Debug.Trace
import GHC.Exts
import qualified Data.Vector.Fusion.Stream.Monadic as S
import qualified Data.Vector.Generic as VG
import Data.PrimitiveArray
import ADP.Fusion.Core
import ADP.Fusion.Core.Term.Str
import ADP.Fusion.PointL.Core
type instance LeftPosTy (IStatic d) (Str linked minSz maxSz v x) (PointL I) = IVariable d
type instance LeftPosTy (IVariable d) (Str linked minSz maxSz v x) (PointL I) = IVariable d
instance
forall pos posLeft m ls linked minSz maxSz v x i
. ( TermStream m (Z:.pos) (TermSymbol M (Str linked minSz maxSz v x))
(Elm (Term1 (Elm ls (PointL i))) (Z :. PointL i)) (Z:.PointL i)
, posLeft ~ LeftPosTy pos (Str linked minSz maxSz v x) (PointL i)
, TermStaticVar pos (Str linked minSz maxSz v x) (PointL i)
, MkStream m posLeft ls (PointL i)
)
⇒ MkStream m pos (ls :!: Str linked minSz maxSz v x) (PointL i) where
mkStream pos (ls :!: Str xs) grd us is
= S.map (\(ss,ee,ii) -> ElmStr ee ii ss)
. addTermStream1 pos (Str @v @x @linked @minSz @maxSz xs) us is
$ mkStream (Proxy ∷ Proxy posLeft) ls
(termStaticCheck pos (Str @v @x @linked @minSz @maxSz xs) us is grd)
us (termStreamIndex pos (Str @v @x @linked @minSz @maxSz xs) is)
{-# Inline mkStream #-}
instance
( TermStreamContext m ps ts s x0 i0 is (PointL I)
) ⇒ TermStream m (ps:.IStatic d) (TermSymbol ts (Str Nothing minSz Nothing v x)) s (is:.PointL I) where
termStream Proxy (ts:|Str xs) (us:..LtPointL u) (is:.PointL i)
= S.map (\(TState s ii ee) →
let RiPlI k = getIndex (getIdx s) (Proxy ∷ PRI is (PointL I))
in TState s (ii:.:RiPlI i) (ee:.VG.slice k (i-k) xs))
. termStream (Proxy ∷ Proxy ps) ts us is
{-# Inline termStream #-}
instance (KnownNat minSz)
⇒ TermStaticVar (IStatic d) (Str Nothing minSz Nothing v x) (PointL I) where
termStreamIndex Proxy (Str xs) (PointL j) = PointL $ j - fromIntegral (natVal (Proxy ∷ Proxy minSz))
termStaticCheck Proxy (Str xs) _ (PointL j) grd = grd
{-# Inline [0] termStreamIndex #-}
{-# Inline [0] termStaticCheck #-}