#if defined(__GLASGOW_HASKELL__) && __GLASGOW_HASKELL__ >= 704
#endif
#ifndef MIN_VERSION_base
#define MIN_VERSION_base(x,y,z) 1
#endif
module Data.Bytes.Serial
(
Serial(..)
, SerialEndian(..)
, Serial1(..)
, serialize1, deserialize1
, Serial2(..)
, serialize2, deserialize2
, store, restore
, GSerial(..)
, GSerialEndian(..)
, GSerial1(..)
) where
import Control.Applicative
import Control.Monad
import qualified Data.Foldable as F
import Data.Bytes.Get
import Data.Bytes.Put
import Data.Bytes.Signed
import Data.Bytes.VarInt
import Data.ByteString.Internal
import Data.ByteString.Lazy as Lazy
import Data.ByteString as Strict
import Data.Int
import Data.Bits
import Data.Monoid as Monoid
#if MIN_VERSION_base(4, 6, 0)
import Data.Ord (Down(..))
#endif
import Data.Functor.Identity as Functor
import Data.Functor.Constant as Functor
import Data.Functor.Product as Functor
import Data.Functor.Reverse as Functor
import Data.Time
import Data.Time.Clock.TAI
import qualified Data.IntMap as IMap
import qualified Data.IntSet as ISet
import qualified Data.Map as Map
import qualified Data.Sequence as Seq
import qualified Data.Set as Set
import Data.Text as SText
import Data.Text.Encoding as SText
import Data.Text.Lazy as LText
import Data.Text.Lazy.Encoding as LText
import Data.Version (Version(..))
import Data.Void
import Data.Word
import Data.Fixed
import Data.Ratio
import Foreign.ForeignPtr
import Foreign.Ptr
import Foreign.Storable
import GHC.Generics
import System.IO.Unsafe
foreign import ccall floatToWord32 :: Float -> Word32
foreign import ccall word32ToFloat :: Word32 -> Float
foreign import ccall doubleToWord64 :: Double -> Word64
foreign import ccall word64ToDouble :: Word64 -> Double
class SerialEndian a where
serializeBE :: MonadPut m => a -> m ()
#ifndef HLINT
default serializeBE :: (MonadPut m, GSerialEndian (Rep a), Generic a) => a -> m ()
serializeBE = gserializeBE . from
#endif
deserializeBE :: MonadGet m => m a
#ifndef HLINT
default deserializeBE :: (MonadGet m, GSerialEndian (Rep a), Generic a) => m a
deserializeBE = liftM to gdeserializeBE
#endif
serializeLE :: MonadPut m => a -> m ()
#ifndef HLINT
default serializeLE :: (MonadPut m, GSerialEndian (Rep a), Generic a) => a -> m ()
serializeLE = gserializeLE . from
#endif
deserializeLE :: MonadGet m => m a
#ifndef HLINT
default deserializeLE :: (MonadGet m, GSerialEndian (Rep a), Generic a) => m a
deserializeLE = liftM to gdeserializeLE
#endif
serializeHost :: MonadPut m => a -> m ()
deserializeHost :: MonadGet m => m a
#ifdef WORDS_BIGENDIAN
serializeHost = serializeBE
deserializeHost = deserializeBE
#else
serializeHost = serializeLE
deserializeHost = deserializeLE
#endif
instance SerialEndian Double where
serializeBE = serializeBE . doubleToWord64
deserializeBE = liftM word64ToDouble deserializeBE
serializeLE = serializeLE . doubleToWord64
deserializeLE = liftM word64ToDouble deserializeLE
instance SerialEndian Float where
serializeBE = serializeBE . floatToWord32
deserializeBE = liftM word32ToFloat deserializeBE
serializeLE = serializeLE . floatToWord32
deserializeLE = liftM word32ToFloat deserializeLE
instance SerialEndian Char where
serializeBE = putWord32be . fromIntegral . fromEnum
deserializeBE = liftM (toEnum . fromIntegral) getWord32be
serializeLE = putWord32le . fromIntegral . fromEnum
deserializeLE = liftM (toEnum . fromIntegral) getWord32le
instance SerialEndian Word64 where
serializeBE = putWord64be
deserializeBE = getWord64be
serializeLE = putWord64le
deserializeLE = getWord64le
instance SerialEndian Word32 where
serializeBE = putWord32be
deserializeBE = getWord32be
serializeLE = putWord32le
deserializeLE = getWord32le
instance SerialEndian Word16 where
serializeBE = putWord16be
deserializeBE = getWord16be
serializeLE = putWord16le
deserializeLE = getWord16le
instance SerialEndian Int64 where
serializeBE = putWord64be . fromIntegral
deserializeBE = liftM fromIntegral getWord64be
serializeLE = putWord64le . fromIntegral
deserializeLE = liftM fromIntegral getWord64le
instance SerialEndian Int32 where
serializeBE = putWord32be . fromIntegral
deserializeBE = liftM fromIntegral getWord32be
serializeLE = putWord32le . fromIntegral
deserializeLE = liftM fromIntegral getWord32le
instance SerialEndian Int16 where
serializeBE = putWord16be . fromIntegral
deserializeBE = liftM fromIntegral getWord16be
serializeLE = putWord16le . fromIntegral
deserializeLE = liftM fromIntegral getWord16le
class Serial a where
serialize :: MonadPut m => a -> m ()
#ifndef HLINT
default serialize :: (MonadPut m, GSerial (Rep a), Generic a) => a -> m ()
serialize = gserialize . from
#endif
deserialize :: MonadGet m => m a
#ifndef HLINT
default deserialize :: (MonadGet m, GSerial (Rep a), Generic a) => m a
deserialize = liftM to gdeserialize
#endif
instance Serial Strict.ByteString where
serialize bs = putWord32be (fromIntegral (Strict.length bs)) >> putByteString bs
deserialize = do
n <- getWord32be
getByteString (fromIntegral n)
instance Serial Lazy.ByteString where
serialize bs = putWord64be (fromIntegral (Lazy.length bs)) >> putLazyByteString bs
deserialize = do
n <- getWord64be
getLazyByteString (fromIntegral n)
instance Serial SText.Text where
serialize = serialize . SText.encodeUtf8
deserialize = SText.decodeUtf8 `fmap` deserialize
instance Serial LText.Text where
serialize = serialize . LText.encodeUtf8
deserialize = LText.decodeUtf8 `fmap` deserialize
instance Serial ()
instance Serial a => Serial [a]
instance Serial a => Serial (Maybe a)
instance (Serial a, Serial b) => Serial (Either a b)
instance (Serial a, Serial b) => Serial (a, b)
instance (Serial a, Serial b, Serial c) => Serial (a, b, c)
instance (Serial a, Serial b, Serial c, Serial d) => Serial (a, b, c, d)
instance (Serial a, Serial b, Serial c, Serial d, Serial e) => Serial (a, b, c, d, e)
instance Serial Bool
store :: (MonadPut m, Storable a) => a -> m ()
store a = putByteString bs
where bs = unsafePerformIO $ create (sizeOf a) $ \ p -> poke (castPtr p) a
restore :: forall m a. (MonadGet m, Storable a) => m a
restore = do
let required = sizeOf (undefined :: a)
PS fp o n <- getByteString required
unless (n >= required) $ fail "restore: Required more bytes"
return $ unsafePerformIO $ withForeignPtr fp $ \p -> peekByteOff p o
instance Serial Double where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Float where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Char where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Word where
serialize = putWordhost
deserialize = getWordhost
instance Serial Word64 where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Word32 where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Word16 where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Word8 where
serialize = putWord8
deserialize = getWord8
instance Serial Int where
serialize = putWordhost . fromIntegral
deserialize = liftM fromIntegral getWordhost
instance Serial Int64 where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Int32 where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Int16 where
serialize = serializeBE
deserialize = deserializeBE
instance Serial Int8 where
serialize = putWord8 . fromIntegral
deserialize = liftM fromIntegral getWord8
instance Serial Void where
serialize = absurd
deserialize = fail "I looked into the void."
instance Serial ISet.IntSet where
serialize = serialize . ISet.toAscList
deserialize = ISet.fromList `liftM` deserialize
instance Serial a => Serial (Seq.Seq a) where
serialize = serializeWith serialize
deserialize = deserializeWith deserialize
instance (Serial a, Ord a) => Serial (Set.Set a) where
serialize = serialize . Set.toAscList
deserialize = Set.fromList `liftM` deserialize
instance Serial v => Serial (IMap.IntMap v) where
serialize = serializeWith serialize
deserialize = deserializeWith deserialize
instance (Serial k, Serial v, Ord k) => Serial (Map.Map k v) where
serialize = serializeWith serialize
deserialize = deserializeWith deserialize
putVarInt :: (MonadPut m, Integral a, Bits a) => a -> m ()
putVarInt n
| n < 0x80 = putWord8 $ fromIntegral n
| otherwise = do
putWord8 $ setBit (fromIntegral n) 7
putVarInt $ shiftR n 7
getVarInt :: (MonadGet m, Num b, Bits b) => Word8 -> m b
getVarInt n
| testBit n 7 = do
VarInt m <- getWord8 >>= getVarInt
return $ shiftL m 7 .|. clearBit (fromIntegral n) 7
| otherwise = return $ fromIntegral n
instance (Bits n, Integral n, Bits (Unsigned n), Integral (Unsigned n)) => Serial (VarInt n) where
serialize (VarInt n) = putVarInt $ unsigned n
deserialize = getWord8 >>= getVarInt
instance Serial Integer where
serialize = serialize . VarInt
deserialize = unVarInt `liftM` deserialize
instance HasResolution a => Serial (Fixed a) where
serialize f =
serialize i
where
i :: Integer
i = truncate . (* r) $ f
r = fromInteger $ resolution f
deserialize =
(((flip (/)) (fromInteger $ resolution (undefined::Fixed a))) . fromInteger) `liftM` deserialize
instance Serial DiffTime where
serialize = serialize . (fromRational . toRational::DiffTime -> Pico)
deserialize = (fromRational . toRational::Pico -> DiffTime) `liftM` deserialize
instance Serial NominalDiffTime where
serialize = serialize . (fromRational . toRational::NominalDiffTime -> Pico)
deserialize = (fromRational . toRational::Pico -> NominalDiffTime) `liftM` deserialize
instance Serial Day where
serialize = serialize . toModifiedJulianDay
deserialize = ModifiedJulianDay `liftM` deserialize
instance Serial UTCTime where
serialize (UTCTime d t) = serialize (d, t)
deserialize = deserialize >>= (\(d, t) -> return $ UTCTime d t)
instance Serial AbsoluteTime where
serialize = serialize . ((flip diffAbsoluteTime) taiEpoch)
deserialize = ((flip addAbsoluteTime) taiEpoch) `liftM` deserialize
instance (Serial a, Integral a) => Serial (Ratio a) where
serialize r = serialize (numerator r, denominator r)
deserialize = (\(n, d) -> n % d) `liftM` deserialize
instance Serial UniversalTime where
serialize = serialize . getModJulianDate
deserialize = ModJulianDate `liftM` deserialize
instance Serial TimeZone where
serialize (TimeZone m s n) = serialize (m, s, n)
deserialize = (\(m, s, n) -> TimeZone m s n) `liftM` deserialize
instance Serial TimeOfDay where
serialize (TimeOfDay h m s) = serialize (h, m, s)
deserialize = (\(h, m, s) -> TimeOfDay h m s) `liftM` deserialize
instance Serial LocalTime where
serialize (LocalTime d t) = serialize (d, t)
deserialize = (\(d, t) -> LocalTime d t) `liftM` deserialize
instance Serial ZonedTime where
serialize (ZonedTime l z) = serialize (l, z)
deserialize = (\(l, z) -> ZonedTime l z) `liftM` deserialize
instance Serial Ordering where
serialize = serialize . (fromIntegral::Int -> Int8) . fromEnum
deserialize = (toEnum . (fromIntegral::Int8 -> Int)) `liftM` deserialize
#if MIN_VERSION_base(4, 6, 0)
instance Serial a => Serial (Down a) where
serialize (Down a) = serialize a
deserialize = Down `liftM` deserialize
#endif
instance Serial Version where
serialize (Version vb ts) = serialize (fmap VarInt vb, ts)
deserialize = do (vb,ts) <- deserialize
return $ Version (fmap unVarInt vb) ts
instance Serial a => Serial (ZipList a) where
serialize = serialize . getZipList
deserialize = ZipList <$> deserialize
instance Serial a => Serial (Identity a) where
serialize = serialize . runIdentity
deserialize = Identity `liftM` deserialize
instance Serial a => Serial (Constant a b) where
serialize = serialize . getConstant
deserialize = Constant `liftM` deserialize
instance (Serial (f a), Serial (g a)) => Serial (Functor.Product f g a) where
serialize (Pair f g) = serialize (f, g)
deserialize = uncurry Pair `liftM` deserialize
instance Serial (f a) => Serial (Reverse f a) where
serialize = serialize . getReverse
deserialize = Reverse `liftM` deserialize
instance Serial a => Serial (Dual a) where
serialize = serialize . getDual
deserialize = Dual `liftM` deserialize
instance Serial All where
serialize = serialize . getAll
deserialize = All `liftM` deserialize
instance Serial Any where
serialize = serialize . getAny
deserialize = Any `liftM` deserialize
instance Serial a => Serial (Sum a) where
serialize = serialize . getSum
deserialize = Sum `liftM` deserialize
instance Serial a => Serial (Monoid.Product a) where
serialize = serialize . getProduct
deserialize = Product `liftM` deserialize
instance Serial a => Serial (First a) where
serialize = serialize . getFirst
deserialize = First `liftM` deserialize
instance Serial a => Serial (Last a) where
serialize = serialize . getLast
deserialize = Last `liftM` deserialize
class GSerial f where
gserialize :: MonadPut m => f a -> m ()
gdeserialize :: MonadGet m => m (f a)
instance GSerial U1 where
gserialize U1 = return ()
gdeserialize = return U1
instance GSerial V1 where
gserialize _ = fail "I looked into the void."
gdeserialize = fail "I looked into the void."
instance (GSerial f, GSerial g) => GSerial (f :*: g) where
gserialize (f :*: g) = do
gserialize f
gserialize g
gdeserialize = liftM2 (:*:) gdeserialize gdeserialize
instance (GSerial f, GSerial g) => GSerial (f :+: g) where
gserialize (L1 x) = putWord8 0 >> gserialize x
gserialize (R1 y) = putWord8 1 >> gserialize y
gdeserialize = getWord8 >>= \a -> case a of
0 -> liftM L1 gdeserialize
1 -> liftM R1 gdeserialize
_ -> fail "Missing case"
instance GSerial f => GSerial (M1 i c f) where
gserialize (M1 x) = gserialize x
gdeserialize = liftM M1 gdeserialize
instance Serial a => GSerial (K1 i a) where
gserialize (K1 x) = serialize x
gdeserialize = liftM K1 deserialize
class GSerialEndian f where
gserializeBE :: MonadPut m => f a -> m ()
#ifndef HLINT
default gserializeBE :: (MonadPut m, GSerial f) => f a -> m ()
gserializeBE = gserialize
#endif
gdeserializeBE :: MonadGet m => m (f a)
#ifndef HLINT
default gdeserializeBE :: (MonadGet m, GSerial f) => m (f a)
gdeserializeBE = gdeserialize
#endif
gserializeLE :: MonadPut m => f a -> m ()
#ifndef HLINT
default gserializeLE :: (MonadPut m, GSerial f) => f a -> m ()
gserializeLE = gserialize
#endif
gdeserializeLE :: MonadGet m => m (f a)
#ifndef HLINT
default gdeserializeLE :: (MonadGet m, GSerial f) => m (f a)
gdeserializeLE = gdeserialize
#endif
instance SerialEndian a => GSerialEndian (K1 i a) where
gserializeBE (K1 x) = serializeBE x
gdeserializeBE = liftM K1 deserializeBE
gserializeLE (K1 x) = serializeLE x
gdeserializeLE = liftM K1 deserializeLE
class Serial1 f where
serializeWith :: MonadPut m => (a -> m ()) -> f a -> m ()
#ifndef HLINT
default serializeWith :: (MonadPut m, GSerial1 (Rep1 f), Generic1 f) => (a -> m ()) -> f a -> m ()
serializeWith f = gserializeWith f . from1
#endif
deserializeWith :: MonadGet m => m a -> m (f a)
#ifndef HLINT
default deserializeWith :: (MonadGet m, GSerial1 (Rep1 f), Generic1 f) => m a -> m (f a)
deserializeWith f = liftM to1 (gdeserializeWith f)
#endif
instance Serial1 [] where
serializeWith _ [] = putWord8 0
serializeWith f (x:xs) = putWord8 1 >> f x >> serializeWith f xs
deserializeWith m = getWord8 >>= \a -> case a of
0 -> return []
1 -> liftM2 (:) m (deserializeWith m)
_ -> error "[].deserializeWith: Missing case"
instance Serial1 Maybe where
serializeWith _ Nothing = putWord8 0
serializeWith f (Just a) = putWord8 1 >> f a
deserializeWith m = getWord8 >>= \a -> case a of
0 -> return Nothing
1 -> liftM Just m
_ -> error "Maybe.deserializeWith: Missing case"
instance Serial a => Serial1 (Either a) where
serializeWith = serializeWith2 serialize
deserializeWith = deserializeWith2 deserialize
instance Serial a => Serial1 ((,) a) where
serializeWith = serializeWith2 serialize
deserializeWith = deserializeWith2 deserialize
instance (Serial a, Serial b) => Serial1 ((,,) a b) where
serializeWith = serializeWith2 serialize
deserializeWith = deserializeWith2 deserialize
instance (Serial a, Serial b, Serial c) => Serial1 ((,,,) a b c) where
serializeWith = serializeWith2 serialize
deserializeWith = deserializeWith2 deserialize
instance (Serial a, Serial b, Serial c, Serial d) => Serial1 ((,,,,) a b c d) where
serializeWith = serializeWith2 serialize
deserializeWith = deserializeWith2 deserialize
instance Serial1 Seq.Seq where
serializeWith pv = serializeWith pv . F.toList
deserializeWith gv = Seq.fromList `liftM` deserializeWith gv
instance Serial1 IMap.IntMap where
serializeWith pv = serializeWith (serializeWith2 serialize pv)
. IMap.toAscList
deserializeWith gv = IMap.fromList
`liftM` deserializeWith (deserializeWith2 deserialize gv)
instance (Ord k, Serial k) => Serial1 (Map.Map k) where
serializeWith pv = serializeWith (serializeWith2 serialize pv)
. Map.toAscList
deserializeWith gv = Map.fromList
`liftM` deserializeWith (deserializeWith2 deserialize gv)
serialize1 :: (MonadPut m, Serial1 f, Serial a) => f a -> m ()
serialize1 = serializeWith serialize
deserialize1 :: (MonadGet m, Serial1 f, Serial a) => m (f a)
deserialize1 = deserializeWith deserialize
class GSerial1 f where
gserializeWith :: MonadPut m => (a -> m ()) -> f a -> m ()
gdeserializeWith :: MonadGet m => m a -> m (f a)
instance GSerial1 Par1 where
gserializeWith f (Par1 a) = f a
gdeserializeWith m = liftM Par1 m
instance Serial1 f => GSerial1 (Rec1 f) where
gserializeWith f (Rec1 fa) = serializeWith f fa
gdeserializeWith m = liftM Rec1 (deserializeWith m)
instance GSerial1 U1 where
gserializeWith _ U1 = return ()
gdeserializeWith _ = return U1
instance GSerial1 V1 where
gserializeWith _ = fail "I looked into the void."
gdeserializeWith _ = fail "I looked into the void."
instance (GSerial1 f, GSerial1 g) => GSerial1 (f :*: g) where
gserializeWith f (a :*: b) = gserializeWith f a >> gserializeWith f b
gdeserializeWith m = liftM2 (:*:) (gdeserializeWith m) (gdeserializeWith m)
instance (GSerial1 f, GSerial1 g) => GSerial1 (f :+: g) where
gserializeWith f (L1 x) = putWord8 0 >> gserializeWith f x
gserializeWith f (R1 y) = putWord8 1 >> gserializeWith f y
gdeserializeWith m = getWord8 >>= \a -> case a of
0 -> liftM L1 (gdeserializeWith m)
1 -> liftM R1 (gdeserializeWith m)
_ -> fail "Missing case"
instance (Serial1 f, GSerial1 g) => GSerial1 (f :.: g) where
gserializeWith f (Comp1 m) = serializeWith (gserializeWith f) m
gdeserializeWith m = Comp1 `liftM` deserializeWith (gdeserializeWith m)
instance GSerial1 f => GSerial1 (M1 i c f) where
gserializeWith f (M1 x) = gserializeWith f x
gdeserializeWith = liftM M1 . gdeserializeWith
instance Serial a => GSerial1 (K1 i a) where
gserializeWith _ (K1 x) = serialize x
gdeserializeWith _ = liftM K1 deserialize
class Serial2 f where
serializeWith2 :: MonadPut m => (a -> m ()) -> (b -> m ()) -> f a b -> m ()
deserializeWith2 :: MonadGet m => m a -> m b -> m (f a b)
serialize2 :: (MonadPut m, Serial2 f, Serial a, Serial b) => f a b -> m ()
serialize2 = serializeWith2 serialize serialize
deserialize2 :: (MonadGet m, Serial2 f, Serial a, Serial b) => m (f a b)
deserialize2 = deserializeWith2 deserialize deserialize
instance Serial2 Either where
serializeWith2 f _ (Left x) = putWord8 0 >> f x
serializeWith2 _ g (Right y) = putWord8 1 >> g y
deserializeWith2 m n = getWord8 >>= \a -> case a of
0 -> liftM Left m
1 -> liftM Right n
_ -> fail "Missing case"
instance Serial2 (,) where
serializeWith2 f g (a, b) = f a >> g b
deserializeWith2 m n = liftM2 (,) m n
instance Serial a => Serial2 ((,,) a) where
serializeWith2 f g (a, b, c) = serialize a >> f b >> g c
deserializeWith2 m n = liftM3 (,,) deserialize m n
instance (Serial a, Serial b) => Serial2 ((,,,) a b) where
serializeWith2 f g (a, b, c, d) = serialize a >> serialize b >> f c >> g d
deserializeWith2 m n = liftM4 (,,,) deserialize deserialize m n
instance (Serial a, Serial b, Serial c) => Serial2 ((,,,,) a b c) where
serializeWith2 f g (a, b, c, d, e) = serialize a >> serialize b >> serialize c >> f d >> g e
deserializeWith2 m n = liftM5 (,,,,) deserialize deserialize deserialize m n