Text.ProtocolBuffers.WireMessage

Here are the serialization and deserialization functions.

This module cooperates with the generated code to implement the Wire instances. The encoding is mostly documented at http://code.google.com/apis/protocolbuffers/docs/encoding.html.

The user API functions are grouped into sections and documented. The rest are for internal use. The main functions are messageGet and messagePut (and messageSize). There are then several 'message*' variants which allow for finer control and for making delimited messages.

User API functions

Main encoding and decoding operations (non-delimited message encoding)

messageSize :: (ReflectDescriptor msg, Wire msg) => msg -> WireSize

This computes the size of the message's fields with tags on the wire with no initial tag or length (in bytes). This is also the length of the message as placed between group start and stop tags.

messagePut :: (ReflectDescriptor msg, Wire msg) => msg -> ByteString

This is runPut applied to messagePutM. It result in a ByteString with a length of messageSize bytes.

messageGet :: (ReflectDescriptor msg, Wire msg) => ByteString -> Either String (msg, ByteString)

This consumes the ByteString to decode a message. It assumes the ByteString is merely a sequence of the tagged fields of the message, and consumes until a group stop tag is detected or the entire input is consumed. Any ByteString past the end of the stop tag is returned as well.

This is runGetOnLazy applied to messageGetM.

messagePutM :: (ReflectDescriptor msg, Wire msg) => msg -> Put

This writes just the message's fields with tags to the wire. This Put monad can be composed and eventually executed with runPut.

This is actually wirePut 10 msg

messageGetM :: (ReflectDescriptor msg, Wire msg) => Get msg

This reads the tagged message fields until the stop tag or the end of input is reached.

This is actually wireGet 10 msg

These should agree with the length delimited message format of protobuf-2.10, where the message size preceeds the data.

messageWithLengthSize :: (ReflectDescriptor msg, Wire msg) => msg -> WireSize

This computes the size of the message fields as in messageSize and add the length of the encoded size to the total. Thus this is the the length of the message including the encoded length header, but without any leading tag.

messageWithLengthPut :: (ReflectDescriptor msg, Wire msg) => msg -> ByteString

This is runPut applied to messageWithLengthPutM. It results in a ByteString with a length of messageWithLengthSize bytes.

messageWithLengthGet :: (ReflectDescriptor msg, Wire msg) => ByteString -> Either String (msg, ByteString)

This runGetOnLazy applied to messageWithLengthGetM.

This first reads the encoded length of the message and will then succeed when it has consumed precisely this many additional bytes. The ByteString after this point will be returned.

messageWithLengthPutM :: (ReflectDescriptor msg, Wire msg) => msg -> Put

This writes the encoded length of the message's fields and then the message's fields with tags to the wire. This Put monad can be composed and eventually executed with runPut.

This is actually wirePut 11 msg

messageWithLengthGetM :: (ReflectDescriptor msg, Wire msg) => Get msg

This reads the encoded message length and then the message.

This is actually wireGet 11 msg

Encoding to write or read a single message field (good for delimited messages or incremental use)

messageAsFieldSize :: (ReflectDescriptor msg, Wire msg) => FieldId -> msg -> WireSize

This computes the size of the messageWithLengthSize and then adds the length an initial tag with the given FieldId.

messageAsFieldPutM :: (ReflectDescriptor msg, Wire msg) => FieldId -> msg -> Put

This writes an encoded wire tag with the given FieldId and then the encoded length of the message's fields and then the message's fields with tags to the wire. This Put monad can be composed and eventually executed with runPut.

messageAsFieldGetM :: (ReflectDescriptor msg, Wire msg) => Get (FieldId, msg)

This reads a wire tag (must be of type '2') to get the FieldId. Then the encoded message length is read, followed by the message itself. Both the FieldId and the message are returned.

This allows for incremental reading and processing.

The Put monad from the binary package, and a custom binary Get monad (Text.ProtocolBuffers.Get)

type Put = PutM ()

Put merely lifts Builder into a Writer monad, applied to ().

data Get a

Instances

Monad Get

Methods

(>>=) :: Get a -> (a -> Get b) -> Get b

(>>) :: Get a -> Get b -> Get b

return :: a -> Get a

fail :: String -> Get a

Functor Get

Methods

fmap :: (a -> b) -> Get a -> Get b

(<$) :: a -> Get b -> Get a

Applicative Get

Methods

pure :: a -> Get a

(<*>) :: Get (a -> b) -> Get a -> Get b

(*>) :: Get a -> Get b -> Get b

(<*) :: Get a -> Get b -> Get a

Alternative Get

Methods

empty :: Get a

(<|>) :: Get a -> Get a -> Get a

some :: Get a -> Get [a]

many :: Get a -> Get [a]

MonadPlus Get

Methods

mzero :: Get a

mplus :: Get a -> Get a -> Get a

MonadError String Get

Methods

throwError :: String -> Get a

catchError :: Get a -> (String -> Get a) -> Get a

runPut :: Put -> ByteString

Run the Put monad with a serialiser

runGet :: Get a -> ByteString -> Result a

runGet is the simple executor

runGetOnLazy :: Get r -> ByteString -> Either String (r, ByteString)

getFromBS :: Get r -> ByteString -> r

This is runGetOnLazy with the Left results converted to error calls and the trailing ByteString discarded. This use of runtime errors is discouraged, but may be convenient.

The Wire monad itself. Users should beware that passing an incompatible FieldType is a runtime error or fail

class Wire b where

The Wire class is for internal use, and may change. If there is a mis-match between the FieldType and the type of b then you will get a failure at runtime.

Users should stick to the message functions defined in Text.ProtocolBuffers.WireMessage and exported to use user by Text.ProtocolBuffers. These are less likely to change.

Minimal complete definition

wireSize, wirePut, wireGet

Methods

wireSize :: FieldType -> b -> WireSize

wirePut :: FieldType -> b -> Put

wireGet :: FieldType -> Get b

wireGetPacked :: FieldType -> Get (Seq b)

Instances

Wire Bool

Methods

wireSize :: FieldType -> Bool -> WireSize

wirePut :: FieldType -> Bool -> Put

wireGet :: FieldType -> Get Bool

wireGetPacked :: FieldType -> Get (Seq Bool)

Wire Double

Methods

wireSize :: FieldType -> Double -> WireSize

wirePut :: FieldType -> Double -> Put

wireGet :: FieldType -> Get Double

wireGetPacked :: FieldType -> Get (Seq Double)

Wire Float

Methods

wireSize :: FieldType -> Float -> WireSize

wirePut :: FieldType -> Float -> Put

wireGet :: FieldType -> Get Float

wireGetPacked :: FieldType -> Get (Seq Float)

Wire Int

Methods

wireSize :: FieldType -> Int -> WireSize

wirePut :: FieldType -> Int -> Put

wireGet :: FieldType -> Get Int

wireGetPacked :: FieldType -> Get (Seq Int)

Wire Int32

Methods

wireSize :: FieldType -> Int32 -> WireSize

wirePut :: FieldType -> Int32 -> Put

wireGet :: FieldType -> Get Int32

wireGetPacked :: FieldType -> Get (Seq Int32)

Wire Int64

Methods

wireSize :: FieldType -> Int64 -> WireSize

wirePut :: FieldType -> Int64 -> Put

wireGet :: FieldType -> Get Int64

wireGetPacked :: FieldType -> Get (Seq Int64)

Wire Word32

Methods

wireSize :: FieldType -> Word32 -> WireSize

wirePut :: FieldType -> Word32 -> Put

wireGet :: FieldType -> Get Word32

wireGetPacked :: FieldType -> Get (Seq Word32)

Wire Word64

Methods

wireSize :: FieldType -> Word64 -> WireSize

wirePut :: FieldType -> Word64 -> Put

wireGet :: FieldType -> Get Word64

wireGetPacked :: FieldType -> Get (Seq Word64)

Wire ByteString

Methods

wireSize :: FieldType -> ByteString -> WireSize

wirePut :: FieldType -> ByteString -> Put

wireGet :: FieldType -> Get ByteString

wireGetPacked :: FieldType -> Get (Seq ByteString)

Wire Utf8

Methods

wireSize :: FieldType -> Utf8 -> WireSize

wirePut :: FieldType -> Utf8 -> Put

wireGet :: FieldType -> Get Utf8

wireGetPacked :: FieldType -> Get (Seq Utf8)

The internal exports, for use by generated code and the Text.ProtcolBuffer.Extensions module

size'WireTag :: WireTag -> Int64

toWireType :: FieldType -> WireType

toWireTag :: FieldId -> FieldType -> WireTag

toPackedWireTag :: FieldId -> WireTag

mkWireTag :: FieldId -> WireType -> WireTag

prependMessageSize :: WireSize -> WireSize

Used in generated code.

putSize :: WireSize -> Put

Used in generated code.

putVarUInt :: (Integral a, Bits a) => a -> Put

getVarInt :: (Show a, Integral a, Bits a) => Get a

putLazyByteString :: ByteString -> Put

Write a lazy ByteString efficiently, simply appending the lazy ByteString chunks to the output buffer

splitWireTag :: WireTag -> (FieldId, WireType)

fieldIdOf :: WireTag -> FieldId

wireSizeReq :: Wire v => Int64 -> FieldType -> v -> Int64

Used in generated code.

wireSizeOpt :: Wire v => Int64 -> FieldType -> Maybe v -> Int64

Used in generated code.

wireSizeRep :: Wire v => Int64 -> FieldType -> Seq v -> Int64

Used in generated code.

wireSizePacked :: Wire v => Int64 -> FieldType -> Seq v -> Int64

Used in generated code.

wirePutReq :: Wire v => WireTag -> FieldType -> v -> Put

Used in generated code.

wirePutOpt :: Wire v => WireTag -> FieldType -> Maybe v -> Put

Used in generated code.

wirePutRep :: Wire v => WireTag -> FieldType -> Seq v -> Put

Used in generated code.

wirePutPacked :: Wire v => WireTag -> FieldType -> Seq v -> Put

Used in generated code.

wireSizeErr :: Typeable a => FieldType -> a -> WireSize

wirePutErr :: Typeable a => FieldType -> a -> Put

wireGetErr :: Typeable a => FieldType -> Get a

getMessageWith :: (Default message, ReflectDescriptor message) => (WireTag -> message -> Get message) -> Get message

getBareMessageWith :: (Default message, ReflectDescriptor message) => (WireTag -> message -> Get message) -> Get message

Used by generated code getBareMessageWith assumes the wireTag for the message, if it existed, has already been read. getBareMessageWith assumes that it does needs to read the Varint encoded length of the message. getBareMessageWith will consume the entire ByteString it is operating on, or until it finds any STOP_GROUP tag (wireType == 4)

wireGetEnum :: (Typeable e, Enum e) => (Int -> Maybe e) -> Get e

wireGetPackedEnum :: (Typeable e, Enum e) => (Int -> Maybe e) -> Get (Seq e)

unknownField :: Typeable a => a -> FieldId -> Get a

unknown :: (Typeable a, ReflectDescriptor a) => FieldId -> WireType -> a -> Get a

wireGetFromWire :: FieldId -> WireType -> Get ByteString

This reads in the raw bytestring corresponding to an field known only through the wiretag's FieldId and WireType.

castWord64ToDouble :: Word64 -> Double

castWord32ToFloat :: Word32 -> Float

castDoubleToWord64 :: Double -> Word64

castFloatToWord32 :: Float -> Word32

zzEncode64 :: Int64 -> Word64

zzEncode32 :: Int32 -> Word32

zzDecode64 :: Word64 -> Int64

zzDecode32 :: Word32 -> Int32