Giter Club home page Giter Club logo

messagestream's Introduction

MessageStream

Overview

MessageStream, as the name suggests, is designed to send a series of messages. It's intended as a binary alternative to Json but should be simpler to use for serializing application defined classes and other custom types than MessagePack.

Usually this would be used with an agreed schema dictating how to serialize custom objects into MessageStream types and deserialize them back. For common data types such as python @dataclass and NamedTuple this schema can be very easily inferred by the library.

There so also a fallback way to read a message stream without first knowing the schema which will decompose the message into structures such as lists, dictionaries and sets. This is achieved by sending a rudimentary schema once for each type just before it's used for the first time. So unused types are never sent, and large arrays of the same type will only send the schema once. This gives MessageStream a significant size reduction over MessagePack.

Streams, Messages and Objects

A Stream is a sequence of messages in a strict order. If applications wish to send unordered (eg: over UDP) messages then this can be achieved by starting a new MessageStream for each message incurring a small overhead. See Unordered Messages.

Every message is represented by a single object which may itself contain other objects.

Top-level objects always start with a control-code indicating the encoding and type, the rest of the object's encoding follows as per the control-code's definition.

Out of Band Instructions

A necessary feature of this standard is to allow some additional meta-information to be conveyed. For example sending the schema for a type just before sending an object of that type. More precisely out of band control codes can be placed almost anywhere that another control code was expected. The planned list of these control codes is:

  • Defining a new custom type.
  • Flagging that the following object may be referred to later (anchor)
  • Enabling automatic anchors
  • Disabling automatic anchors
  • Defining an object which has been mentioned in a forward reference

Out of band control codes are effectively invisible to the expected structure. They do something and may require an augment, but they have no effect on the structure.

Inbuilt types

MessageStream defines types separately from encodings for types. Some types have multiple encodings.

  • Null (AKA python None)
  • Boolean (True / False)
  • Integer (Positive and negative)
  • Decimal (Floating point number which behaves as if calculated in base 10)
  • Floating point
  • String (Always UTF-8)
  • Date / Time
  • Raw Bytes
  • List
  • Key-Value map

Custom types

Custom types are achieved by first writing an out-of-band type definition.

The encoding for custom types may be defined either as a direct reference to an inbuilt type or a pre-defined structure built of custom types. Custom types SHOULD avoid the trap of just encoding everything to bytes and using "Raw Bytes" as it's encoding.

One specific rule on Integers is that when defining the custome type

Variable Byte Integers

Control-codes themselves and a few primative data types make use of Variable Byte Integers.

All variable byte integers are positive integers with a variable byte encoding containing 1, 2, 4, or 8 bytes. The number of bytes in the control number is dictated by the most significant 1 to 4 bits of the first byte.
All remaining bits represent an integer with the most significant bits first (Bigendian):

First Four Bits Number of bytes Min to Max value
0xxxxxxx 1 Byte 0 to 27-1 = 127
10xxxxxx 2 Bytes 128 to 214-1 = 16,383
110xxxxx 4 Bytes 16384 to 229-1 = 53,687,0911
1110xxxx 8 Bytes 53,687,0912 to 260-1

When encoding control numbers, encoding a control number below the minimum specified above is as Protcol Error. When decoding control numbers, it is at the decoder's descretion whether or not to allow it.

This means the decoder is not required to check, but the encoder MUST not bloat a message with unecessary bytes.

Alternative Encodings

Some inbuilt types have alternative encodings. Consiquently custom types will also have alternative encodings.
In all situations encoders are free to make their own decisions on which encoding to use for a type.
Even where an encoding is explicitly mentioned by a Custom Type, an encoder may use any suitable alternative for that type and a decoder MUST accept any alternative for the same type.

Control codes

This has changed and has not been updated here do not use this. The correct list of control codes can be found in base_schema.

Type Code Name Description
0 Stop Code
1 Skip Code (Skips an element of a structure and uses the default
2 Strict Struct Type Definition
3 Flexible Struct Type Definition
1 Reference Anchor
2 Enable Anchorless References After this point in the stream, every object is automatically assigned an anchor
3 Disable Anchorless references Used after 2 to stop assigning anchors in the stream.
4 Back Reference Used in place of any other object to refer back to a fully described object.
5 Forward Reference Used in place of any other object to refer to a partially described object.
6 Complete forward reference Out of band op-code to write an arbitrary object. This is useful if a forward reference has been used and there's no good palce to put the forward reference object.
9 Skip code Skip structure element and use the default
None 10 Null Null AKA None none python.
bool 11 False Boolean false
bool 12 True Boolean true
int 13 One byte Int Signed
int 14 Two byte Int Signed Bigendian
int 15 Four byte Int Signed Bigendian
int 16 Eight byte Int Signed Bigendian
int 17 Multi byte integer Control-code is followed by a variable byte integer stating how many bytes and the that number of bytes representing the integer as Signed Bigendian
bytes 18 Raw Bytes Variable byte in indicating how many bytes, followed by that number of bytes
str 19 Single Character "String" Non-python libraries should encode and may decode this as "char"
str 20 Empty String The empty string
str 21 Variable byte String multi byte character followed by that number of bytes representing a UTF-8 string. Invalid to include null char.
decimal 22 Positive Decimal Complex encoding, records 1 byte per two significant figures
decimal 23 Negative Decimal Complex encoding, records 1 byte per two significant figures
tuple 22 Tuple Variable byte integer stating how many elements follwed by that number of elements
list 23 List Variable byte integer stating how many elements followed by that many elements
dict 24 Dictionary variable byte int stating how many (key, value) pairs followed by that many pairs of elements

Anchors and References

MessageStream supports reusing objects. An object needs to be flagged with an anchor and then it may be referenced with either a forward or backward reference.

  • Backward references are used at a point in the message where the referenced object is fully defined.
  • Forward references are used when the referenced object is not yet completely defined. Note that this definition does not care about linked or contained objects, it's the referenced object itself that matters.

For this purpose, any object can be prefixed with an anchor control code, or anchorless references can be enabled. The effect of enabling anchorless references is to implicitly add an anchor to every following object and these anchors remain usable even after anchorless references have been disabled.

All anchors only survive for a message (other wise recipients would have to store every anchored ovbject they'd ever seen).

If the implementation maps a type to a mutable object then it MUST implement references to that type as a reference to the same mutable object and not a carbon copy.

Datetimes

MessageStream has in-built support for python datetime:

  • datetime with no timezone (timezone unaware) will be serialized and de-serialzed with no timezone
  • datetime with fixed timezone will be serialized and de-serialzed with the same fixed timezone
  • datetime with a pytz (IANA) timezones will be serialized with both a fixed timezone and their IANA location name.

Warning: timezones are tricky

From time to time locations change their timezone, often for political reasons. Software with an out of date IANA database will encode in the wrong time fixed time-zone. When they do, system's may not agree and the results are bad.

MessageStream works on the assumption that, at worst, the encoder knows the correct time in UTC for the datetime it encodes. It encodes the timestamp, a fixed offset for the timestamp from UTC and the IANA location name for the timestamp's origin. Thus while encoding, both the timestamp in local time and timestamp in UTC are safely preserved.

When decoding back, MessageStream will re-localize the timestamp. So the local time that was sent may not match the local time that was written if either encoder or decoder have an out of date timezone database.

Protocol Error

Throughout this standard, there are numberous errors to Protocol Errors. Decoders are required to check for all protocol errors unless otherwise sepcified. If a protocol error is found while decoding, the decoder must stop decoding and abandon any partially parsed message. There is no way to re-sync decoding after a protocol error so any remaining bytes in the stream must also be abandoned without processing.

Note: When encountering a Protocol Error on a two-way communications protocol it would be usual to return an error back to the client before closing the connection. Specification of such behaviour is beyond the scope of this standard.

Control-code definitions

Type Definition

The Stop code is is used as an end marker

Considderations

Unordered Messages

Recommend Projects

  • React photo React

    A declarative, efficient, and flexible JavaScript library for building user interfaces.

  • Vue.js photo Vue.js

    ๐Ÿ–– Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.

  • Typescript photo Typescript

    TypeScript is a superset of JavaScript that compiles to clean JavaScript output.

  • TensorFlow photo TensorFlow

    An Open Source Machine Learning Framework for Everyone

  • Django photo Django

    The Web framework for perfectionists with deadlines.

  • D3 photo D3

    Bring data to life with SVG, Canvas and HTML. ๐Ÿ“Š๐Ÿ“ˆ๐ŸŽ‰

Recommend Topics

  • javascript

    JavaScript (JS) is a lightweight interpreted programming language with first-class functions.

  • web

    Some thing interesting about web. New door for the world.

  • server

    A server is a program made to process requests and deliver data to clients.

  • Machine learning

    Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.

  • Game

    Some thing interesting about game, make everyone happy.

Recommend Org

  • Facebook photo Facebook

    We are working to build community through open source technology. NB: members must have two-factor auth.

  • Microsoft photo Microsoft

    Open source projects and samples from Microsoft.

  • Google photo Google

    Google โค๏ธ Open Source for everyone.

  • D3 photo D3

    Data-Driven Documents codes.