ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/CBOR-XS/XS.pm
(Generate patch)

Comparing CBOR-XS/XS.pm (file contents):
Revision 1.28 by root, Thu Nov 28 16:09:04 2013 UTC vs.
Revision 1.44 by root, Mon Apr 27 20:21:53 2015 UTC

48Regarding compactness, C<CBOR::XS>-encoded data structures are usually 48Regarding compactness, C<CBOR::XS>-encoded data structures are usually
49about 20% smaller than the same data encoded as (compact) JSON or 49about 20% smaller than the same data encoded as (compact) JSON or
50L<Storable>. 50L<Storable>.
51 51
52In addition to the core CBOR data format, this module implements a 52In addition to the core CBOR data format, this module implements a
53number of extensions, to support cyclic and shared data structures (see 53number of extensions, to support cyclic and shared data structures
54C<allow_sharing>), string deduplication (see C<pack_strings>) and scalar 54(see C<allow_sharing> and C<allow_cycles>), string deduplication (see
55references (always enabled). 55C<pack_strings>) and scalar references (always enabled).
56 56
57The primary goal of this module is to be I<correct> and the secondary goal 57The primary goal of this module is to be I<correct> and the secondary goal
58is to be I<fast>. To reach the latter goal it was written in C. 58is to be I<fast>. To reach the latter goal it was written in C.
59 59
60See MAPPING, below, on how CBOR::XS maps perl values to CBOR values and 60See MAPPING, below, on how CBOR::XS maps perl values to CBOR values and
64 64
65package CBOR::XS; 65package CBOR::XS;
66 66
67use common::sense; 67use common::sense;
68 68
69our $VERSION = '1.0'; 69our $VERSION = 1.3;
70our @ISA = qw(Exporter); 70our @ISA = qw(Exporter);
71 71
72our @EXPORT = qw(encode_cbor decode_cbor); 72our @EXPORT = qw(encode_cbor decode_cbor);
73 73
74use Exporter; 74use Exporter;
180reference to the earlier value. 180reference to the earlier value.
181 181
182This means that such values will only be encoded once, and will not result 182This means that such values will only be encoded once, and will not result
183in a deep cloning of the value on decode, in decoders supporting the value 183in a deep cloning of the value on decode, in decoders supporting the value
184sharing extension. This also makes it possible to encode cyclic data 184sharing extension. This also makes it possible to encode cyclic data
185structures. 185structures (which need C<allow_cycles> to ne enabled to be decoded by this
186module).
186 187
187It is recommended to leave it off unless you know your 188It is recommended to leave it off unless you know your
188communication partner supports the value sharing extensions to CBOR 189communication partner supports the value sharing extensions to CBOR
189(L<http://cbor.schmorp.de/value-sharing>), as without decoder support, the 190(L<http://cbor.schmorp.de/value-sharing>), as without decoder support, the
190resulting data structure might be unusable. 191resulting data structure might be unusable.
191 192
192Detecting shared values incurs a runtime overhead when values are encoded 193Detecting shared values incurs a runtime overhead when values are encoded
193that have a reference counter large than one, and might unnecessarily 194that have a reference counter large than one, and might unnecessarily
194increase the encoded size, as potentially shared values are encode as 195increase the encoded size, as potentially shared values are encode as
195sharable whether or not they are actually shared. 196shareable whether or not they are actually shared.
196 197
197At the moment, only targets of references can be shared (e.g. scalars, 198At the moment, only targets of references can be shared (e.g. scalars,
198arrays or hashes pointed to by a reference). Weirder constructs, such as 199arrays or hashes pointed to by a reference). Weirder constructs, such as
199an array with multiple "copies" of the I<same> string, which are hard but 200an array with multiple "copies" of the I<same> string, which are hard but
200not impossible to create in Perl, are not supported (this is the same as 201not impossible to create in Perl, are not supported (this is the same as
205structures cannot be encoded in this mode. 206structures cannot be encoded in this mode.
206 207
207This option does not affect C<decode> in any way - shared values and 208This option does not affect C<decode> in any way - shared values and
208references will always be decoded properly if present. 209references will always be decoded properly if present.
209 210
211=item $cbor = $cbor->allow_cycles ([$enable])
212
213=item $enabled = $cbor->get_allow_cycles
214
215If C<$enable> is true (or missing), then C<decode> will happily decode
216self-referential (cyclic) data structures. By default these will not be
217decoded, as they need manual cleanup to avoid memory leaks, so code that
218isn't prepared for this will not leak memory.
219
220If C<$enable> is false (the default), then C<decode> will throw an error
221when it encounters a self-referential/cyclic data structure.
222
223FUTURE DIRECTION: the motivation behind this option is to avoid I<real>
224cycles - future versions of this module might chose to decode cyclic data
225structures using weak references when this option is off, instead of
226throwing an error.
227
228This option does not affect C<encode> in any way - shared values and
229references will always be encoded properly if present.
230
210=item $cbor = $cbor->pack_strings ([$enable]) 231=item $cbor = $cbor->pack_strings ([$enable])
211 232
212=item $enabled = $cbor->get_pack_strings 233=item $enabled = $cbor->get_pack_strings
213 234
214If C<$enable> is true (or missing), then C<encode> will try not to encode 235If C<$enable> is true (or missing), then C<encode> will try not to encode
226the standard CBOR way. 247the standard CBOR way.
227 248
228This option does not affect C<decode> in any way - string references will 249This option does not affect C<decode> in any way - string references will
229always be decoded properly if present. 250always be decoded properly if present.
230 251
252=item $cbor = $cbor->validate_utf8 ([$enable])
253
254=item $enabled = $cbor->get_validate_utf8
255
256If C<$enable> is true (or missing), then C<decode> will validate that
257elements (text strings) containing UTF-8 data in fact contain valid UTF-8
258data (instead of blindly accepting it). This validation obviously takes
259extra time during decoding.
260
261The concept of "valid UTF-8" used is perl's concept, which is a superset
262of the official UTF-8.
263
264If C<$enable> is false (the default), then C<decode> will blindly accept
265UTF-8 data, marking them as valid UTF-8 in the resulting data structure
266regardless of whether thats true or not.
267
268Perl isn't too happy about corrupted UTF-8 in strings, but should
269generally not crash or do similarly evil things. Extensions might be not
270so forgiving, so it's recommended to turn on this setting if you receive
271untrusted CBOR.
272
273This option does not affect C<encode> in any way - strings that are
274supposedly valid UTF-8 will simply be dumped into the resulting CBOR
275string without checking whether that is, in fact, true or not.
276
231=item $cbor = $cbor->filter ([$cb->($tag, $value)]) 277=item $cbor = $cbor->filter ([$cb->($tag, $value)])
232 278
233=item $cb_or_undef = $cbor->get_filter 279=item $cb_or_undef = $cbor->get_filter
234 280
235Sets or replaces the tagged value decoding filter (when C<$cb> is 281Sets or replaces the tagged value decoding filter (when C<$cb> is
289and you need to know where the first CBOR string ends amd the next one 335and you need to know where the first CBOR string ends amd the next one
290starts. 336starts.
291 337
292 CBOR::XS->new->decode_prefix ("......") 338 CBOR::XS->new->decode_prefix ("......")
293 => ("...", 3) 339 => ("...", 3)
340
341=back
342
343=head2 INCREMENTAL PARSING
344
345In some cases, there is the need for incremental parsing of JSON
346texts. While this module always has to keep both CBOR text and resulting
347Perl data structure in memory at one time, it does allow you to parse a
348CBOR stream incrementally, using a similar to using "decode_prefix" to see
349if a full CBOR object is available, but is much more efficient.
350
351It basically works by parsing as much of a CBOR string as possible - if
352the CBOR data is not complete yet, the pasrer will remember where it was,
353to be able to restart when more data has been accumulated. Once enough
354data is available to either decode a complete CBOR value or raise an
355error, a real decode will be attempted.
356
357A typical use case would be a network protocol that consists of sending
358and receiving CBOR-encoded messages. The solution that works with CBOR and
359about anything else is by prepending a length to every CBOR value, so the
360receiver knows how many octets to read. More compact (and slightly slower)
361would be to just send CBOR values back-to-back, as C<CBOR::XS> knows where
362a CBOR value ends, and doesn't need an explicit length.
363
364The following methods help with this:
365
366=over 4
367
368=item @decoded = $cbor->incr_parse ($buffer)
369
370This method attempts to decode exactly one CBOR value from the beginning
371of the given C<$buffer>. The value is removed from the C<$buffer> on
372success. When C<$buffer> doesn't contain a complete value yet, it returns
373nothing. Finally, when the C<$buffer> doesn't start with something
374that could ever be a valid CBOR value, it raises an exception, just as
375C<decode> would. In the latter case the decoder state is undefined and
376must be reset before being able to parse further.
377
378This method modifies the C<$buffer> in place. When no CBOR value can be
379decoded, the decoder stores the current string offset. On the next call,
380continues decoding at the place where it stopped before. For this to make
381sense, the C<$buffer> must begin with the same octets as on previous
382unsuccessful calls.
383
384You can call this method in scalar context, in which case it either
385returns a decoded value or C<undef>. This makes it impossible to
386distinguish between CBOR null values (which decode to C<undef>) and an
387unsuccessful decode, which is often acceptable.
388
389=item @decoded = $cbor->incr_parse_multiple ($buffer)
390
391Same as C<incr_parse>, but attempts to decode as many CBOR values as
392possible in one go, instead of at most one. Calls to C<incr_parse> and
393C<incr_parse_multiple> can be interleaved.
394
395=item $cbor->incr_reset
396
397Resets the incremental decoder. This throws away any saved state, so that
398subsequent calls to C<incr_parse> or C<incr_parse_multiple> start to parse
399a new CBOR value from the beginning of the C<$buffer> again.
400
401This method can be caled at any time, but it I<must> be called if you want
402to change your C<$buffer> or there was a decoding error and you want to
403reuse the C<$cbor> object for future incremental parsings.
294 404
295=back 405=back
296 406
297 407
298=head1 MAPPING 408=head1 MAPPING
465 575
466=back 576=back
467 577
468=head2 OBJECT SERIALISATION 578=head2 OBJECT SERIALISATION
469 579
580This module implements both a CBOR-specific and the generic
581L<Types::Serialier> object serialisation protocol. The following
582subsections explain both methods.
583
584=head3 ENCODING
585
470This module knows two way to serialise a Perl object: The CBOR-specific 586This module knows two way to serialise a Perl object: The CBOR-specific
471way, and the generic way. 587way, and the generic way.
472 588
473Whenever the encoder encounters a Perl object that it cnanot serialise 589Whenever the encoder encounters a Perl object that it cannot serialise
474directly (most of them), it will first look up the C<TO_CBOR> method on 590directly (most of them), it will first look up the C<TO_CBOR> method on
475it. 591it.
476 592
477If it has a C<TO_CBOR> method, it will call it with the object as only 593If it has a C<TO_CBOR> method, it will call it with the object as only
478argument, and expects exactly one return value, which it will then 594argument, and expects exactly one return value, which it will then
484 600
485The C<FREEZE> method can return any number of values (i.e. zero or 601The C<FREEZE> method can return any number of values (i.e. zero or
486more). These will be encoded as CBOR perl object, together with the 602more). These will be encoded as CBOR perl object, together with the
487classname. 603classname.
488 604
605These methods I<MUST NOT> change the data structure that is being
606serialised. Failure to comply to this can result in memory corruption -
607and worse.
608
489If an object supports neither C<TO_CBOR> nor C<FREEZE>, encoding will fail 609If an object supports neither C<TO_CBOR> nor C<FREEZE>, encoding will fail
490with an error. 610with an error.
491 611
612=head3 DECODING
613
492Objects encoded via C<TO_CBOR> cannot be automatically decoded, but 614Objects encoded via C<TO_CBOR> cannot (normally) be automatically decoded,
493objects encoded via C<FREEZE> can be decoded using the following protocol: 615but objects encoded via C<FREEZE> can be decoded using the following
616protocol:
494 617
495When an encoded CBOR perl object is encountered by the decoder, it will 618When an encoded CBOR perl object is encountered by the decoder, it will
496look up the C<THAW> method, by using the stored classname, and will fail 619look up the C<THAW> method, by using the stored classname, and will fail
497if the method cannot be found. 620if the method cannot be found.
498 621
499After the lookup it will call the C<THAW> method with the stored classname 622After the lookup it will call the C<THAW> method with the stored classname
500as first argument, the constant string C<CBOR> as second argument, and all 623as first argument, the constant string C<CBOR> as second argument, and all
501values returned by C<FREEZE> as remaining arguments. 624values returned by C<FREEZE> as remaining arguments.
502 625
503=head4 EXAMPLES 626=head3 EXAMPLES
504 627
505Here is an example C<TO_CBOR> method: 628Here is an example C<TO_CBOR> method:
506 629
507 sub My::Object::TO_CBOR { 630 sub My::Object::TO_CBOR {
508 my ($obj) = @_; 631 my ($obj) = @_;
691 814
692These tags are automatically created (and decoded) for serialisable 815These tags are automatically created (and decoded) for serialisable
693objects using the C<FREEZE/THAW> methods (the L<Types::Serialier> object 816objects using the C<FREEZE/THAW> methods (the L<Types::Serialier> object
694serialisation protocol). See L<OBJECT SERIALISATION> for details. 817serialisation protocol). See L<OBJECT SERIALISATION> for details.
695 818
696=item 28, 29 (sharable, sharedref, L <http://cbor.schmorp.de/value-sharing>) 819=item 28, 29 (shareable, sharedref, L <http://cbor.schmorp.de/value-sharing>)
697 820
698These tags are automatically decoded when encountered, resulting in 821These tags are automatically decoded when encountered (and they do not
822result in a cyclic data structure, see C<allow_cycles>), resulting in
699shared values in the decoded object. They are only encoded, however, when 823shared values in the decoded object. They are only encoded, however, when
700C<allow_sharable> is enabled. 824C<allow_sharing> is enabled.
825
826Not all shared values can be successfully decoded: values that reference
827themselves will I<currently> decode as C<undef> (this is not the same
828as a reference pointing to itself, which will be represented as a value
829that contains an indirect reference to itself - these will be decoded
830properly).
831
832Note that considerably more shared value data structures can be decoded
833than will be encoded - currently, only values pointed to by references
834will be shared, others will not. While non-reference shared values can be
835generated in Perl with some effort, they were considered too unimportant
836to be supported in the encoder. The decoder, however, will decode these
837values as shared values.
701 838
702=item 256, 25 (stringref-namespace, stringref, L <http://cbor.schmorp.de/stringref>) 839=item 256, 25 (stringref-namespace, stringref, L <http://cbor.schmorp.de/stringref>)
703 840
704These tags are automatically decoded when encountered. They are only 841These tags are automatically decoded when encountered. They are only
705encoded, however, when C<pack_strings> is enabled. 842encoded, however, when C<pack_strings> is enabled.
730perl core distribution (e.g. L<URI>), it is (currently) up to the user to 867perl core distribution (e.g. L<URI>), it is (currently) up to the user to
731provide these modules. The decoding usually fails with an exception if the 868provide these modules. The decoding usually fails with an exception if the
732required module cannot be loaded. 869required module cannot be loaded.
733 870
734=over 4 871=over 4
872
873=item 0, 1 (date/time string, seconds since the epoch)
874
875These tags are decoded into L<Time::Piece> objects. The corresponding
876C<Time::Piece::TO_CBOR> method always encodes into tag 1 values currently.
877
878The L<Time::Piece> API is generally surprisingly bad, and fractional
879seconds are only accidentally kept intact, so watch out. On the plus side,
880the module comes with perl since 5.10, which has to count for something.
735 881
736=item 2, 3 (positive/negative bignum) 882=item 2, 3 (positive/negative bignum)
737 883
738These tags are decoded into L<Math::BigInt> objects. The corresponding 884These tags are decoded into L<Math::BigInt> objects. The corresponding
739C<Math::BigInt::TO_CBOR> method encodes "small" bigints into normal CBOR 885C<Math::BigInt::TO_CBOR> method encodes "small" bigints into normal CBOR
873properly. Half precision types are accepted, but not encoded. 1019properly. Half precision types are accepted, but not encoded.
874 1020
875Strict mode and canonical mode are not implemented. 1021Strict mode and canonical mode are not implemented.
876 1022
877 1023
1024=head1 LIMITATIONS ON PERLS WITHOUT 64-BIT INTEGER SUPPORT
1025
1026On perls that were built without 64 bit integer support (these are rare
1027nowadays, even on 32 bit architectures, as all major Perl distributions
1028are built with 64 bit integer support), support for any kind of 64 bit
1029integer in CBOR is very limited - most likely, these 64 bit values will
1030be truncated, corrupted, or otherwise not decoded correctly. This also
1031includes string, array and map sizes that are stored as 64 bit integers.
1032
1033
878=head1 THREADS 1034=head1 THREADS
879 1035
880This module is I<not> guaranteed to be thread safe and there are no 1036This module is I<not> guaranteed to be thread safe and there are no
881plans to change this until Perl gets thread support (as opposed to the 1037plans to change this until Perl gets thread support (as opposed to the
882horribly slow so-called "threads" which are simply slow and bloated 1038horribly slow so-called "threads" which are simply slow and bloated
895service. I put the contact address into my modules for a reason. 1051service. I put the contact address into my modules for a reason.
896 1052
897=cut 1053=cut
898 1054
899our %FILTER = ( 1055our %FILTER = (
900 # 0 # rfc4287 datetime, utf-8 1056 0 => sub { # rfc4287 datetime, utf-8
901 # 1 # unix timestamp, any 1057 require Time::Piece;
1058 # Time::Piece::Strptime uses the "incredibly flexible date parsing routine"
1059 # from FreeBSD, which can't parse ISO 8601, RFC3339, RFC4287 or much of anything
1060 # else either. Whats incredibe over standard strptime totally escapes me.
1061 # doesn't do fractional times, either. sigh.
1062 # In fact, it's all a lie, it uses whatever strptime it wants, and of course,
1063 # they are all incomptible. The openbsd one simply ignores %z (but according to the
1064 # docs, it would be much more incredibly flexible indeed. If it worked, that is.).
1065 scalar eval {
1066 my $s = $_[1];
1067
1068 $s =~ s/Z$/+00:00/;
1069 $s =~ s/(\.[0-9]+)?([+-][0-9][0-9]):([0-9][0-9])$//
1070 or die;
1071
1072 my $b = $1 - ($2 * 60 + $3) * 60; # fractional part + offset. hopefully
1073 my $d = Time::Piece->strptime ($s, "%Y-%m-%dT%H:%M:%S");
1074
1075 Time::Piece::gmtime ($d->epoch + $b)
1076 } || die "corrupted CBOR date/time string ($_[0])";
1077 },
1078
1079 1 => sub { # seconds since the epoch, possibly fractional
1080 require Time::Piece;
1081 scalar Time::Piece::gmtime (pop)
1082 },
902 1083
903 2 => sub { # pos bigint 1084 2 => sub { # pos bigint
904 require Math::BigInt; 1085 require Math::BigInt;
905 Math::BigInt->new ("0x" . unpack "H*", pop) 1086 Math::BigInt->new ("0x" . unpack "H*", pop)
906 }, 1087 },
942} 1123}
943 1124
944sub URI::TO_CBOR { 1125sub URI::TO_CBOR {
945 my $uri = $_[0]->as_string; 1126 my $uri = $_[0]->as_string;
946 utf8::upgrade $uri; 1127 utf8::upgrade $uri;
947 CBOR::XS::tag 32, $uri 1128 tag 32, $uri
948} 1129}
949 1130
950sub Math::BigInt::TO_CBOR { 1131sub Math::BigInt::TO_CBOR {
951 if ($_[0] >= -2147483648 && $_[0] <= 2147483647) { 1132 if ($_[0] >= -2147483648 && $_[0] <= 2147483647) {
952 $_[0]->numify 1133 $_[0]->numify
953 } else { 1134 } else {
954 my $hex = substr $_[0]->as_hex, 2; 1135 my $hex = substr $_[0]->as_hex, 2;
955 $hex = "0$hex" if 1 & length $hex; # sigh 1136 $hex = "0$hex" if 1 & length $hex; # sigh
956 CBOR::XS::tag $_[0] >= 0 ? 2 : 3, pack "H*", $hex 1137 tag $_[0] >= 0 ? 2 : 3, pack "H*", $hex
957 } 1138 }
958} 1139}
959 1140
960sub Math::BigFloat::TO_CBOR { 1141sub Math::BigFloat::TO_CBOR {
961 my ($m, $e) = $_[0]->parts; 1142 my ($m, $e) = $_[0]->parts;
962 CBOR::XS::tag 4, [$e->numify, $m] 1143 tag 4, [$e->numify, $m]
1144}
1145
1146sub Time::Piece::TO_CBOR {
1147 tag 1, 0 + $_[0]->epoch
963} 1148}
964 1149
965XSLoader::load "CBOR::XS", $VERSION; 1150XSLoader::load "CBOR::XS", $VERSION;
966 1151
967=head1 SEE ALSO 1152=head1 SEE ALSO

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines