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.29 by root, Sat Nov 30 15:23:59 2013 UTC vs.
Revision 1.40 by root, Sun Jan 5 14:24:54 2014 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.25;
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
223This option does not affect C<encode> in any way - shared values and
224references will always be decoded properly if present.
225
210=item $cbor = $cbor->pack_strings ([$enable]) 226=item $cbor = $cbor->pack_strings ([$enable])
211 227
212=item $enabled = $cbor->get_pack_strings 228=item $enabled = $cbor->get_pack_strings
213 229
214If C<$enable> is true (or missing), then C<encode> will try not to encode 230If C<$enable> is true (or missing), then C<encode> will try not to encode
226the standard CBOR way. 242the standard CBOR way.
227 243
228This option does not affect C<decode> in any way - string references will 244This option does not affect C<decode> in any way - string references will
229always be decoded properly if present. 245always be decoded properly if present.
230 246
247=item $cbor = $cbor->validate_utf8 ([$enable])
248
249=item $enabled = $cbor->get_validate_utf8
250
251If C<$enable> is true (or missing), then C<decode> will validate that
252elements (text strings) containing UTF-8 data in fact contain valid UTF-8
253data (instead of blindly accepting it). This validation obviously takes
254extra time during decoding.
255
256The concept of "valid UTF-8" used is perl's concept, which is a superset
257of the official UTF-8.
258
259If C<$enable> is false (the default), then C<decode> will blindly accept
260UTF-8 data, marking them as valid UTF-8 in the resulting data structure
261regardless of whether thats true or not.
262
263Perl isn't too happy about corrupted UTF-8 in strings, but should
264generally not crash or do similarly evil things. Extensions might be not
265so forgiving, so it's recommended to turn on this setting if you receive
266untrusted CBOR.
267
268This option does not affect C<encode> in any way - strings that are
269supposedly valid UTF-8 will simply be dumped into the resulting CBOR
270string without checking whether that is, in fact, true or not.
271
231=item $cbor = $cbor->filter ([$cb->($tag, $value)]) 272=item $cbor = $cbor->filter ([$cb->($tag, $value)])
232 273
233=item $cb_or_undef = $cbor->get_filter 274=item $cb_or_undef = $cbor->get_filter
234 275
235Sets or replaces the tagged value decoding filter (when C<$cb> is 276Sets 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 330and you need to know where the first CBOR string ends amd the next one
290starts. 331starts.
291 332
292 CBOR::XS->new->decode_prefix ("......") 333 CBOR::XS->new->decode_prefix ("......")
293 => ("...", 3) 334 => ("...", 3)
335
336=back
337
338=head2 INCREMENTAL PARSING
339
340In some cases, there is the need for incremental parsing of JSON
341texts. While this module always has to keep both CBOR text and resulting
342Perl data structure in memory at one time, it does allow you to parse a
343CBOR stream incrementally, using a similar to using "decode_prefix" to see
344if a full CBOR object is available, but is much more efficient.
345
346It basically works by parsing as much of a CBOR string as possible - if
347the CBOR data is not complete yet, the pasrer will remember where it was,
348to be able to restart when more data has been accumulated. Once enough
349data is available to either decode a complete CBOR value or raise an
350error, a real decode will be attempted.
351
352A typical use case would be a network protocol that consists of sending
353and receiving CBOR-encoded messages. The solution that works with CBOR and
354about anything else is by prepending a length to every CBOR value, so the
355receiver knows how many octets to read. More compact (and slightly slower)
356would be to just send CBOR values back-to-back, as C<CBOR::XS> knows where
357a CBOR value ends, and doesn't need an explicit length.
358
359The following methods help with this:
360
361=over 4
362
363=item @decoded = $cbor->incr_parse ($buffer)
364
365This method attempts to decode exactly one CBOR value from the beginning
366of the given C<$buffer>. The value is removed from the C<$buffer> on
367success. When C<$buffer> doesn't contain a complete value yet, it returns
368nothing. Finally, when the C<$buffer> doesn't start with something
369that could ever be a valid CBOR value, it raises an exception, just as
370C<decode> would. In the latter case the decoder state is undefined and
371must be reset before being able to parse further.
372
373This method modifies the C<$buffer> in place. When no CBOR value can be
374decoded, the decoder stores the current string offset. On the next call,
375continues decoding at the place where it stopped before. For this to make
376sense, the C<$buffer> must begin with the same octets as on previous
377unsuccessful calls.
378
379You can call this method in scalar context, in which case it either
380returns a decoded value or C<undef>. This makes it impossible to
381distinguish between CBOR null values (which decode to C<undef>) and an
382unsuccessful decode, which is often acceptable.
383
384=item @decoded = $cbor->incr_parse_multiple ($buffer)
385
386Same as C<incr_parse>, but attempts to decode as many CBOR values as
387possible in one go, instead of at most one. Calls to C<incr_parse> and
388C<incr_parse_multiple> can be interleaved.
389
390=item $cbor->incr_reset
391
392Resets the incremental decoder. This throws away any saved state, so that
393subsequent calls to C<incr_parse> or C<incr_parse_multiple> start to parse
394a new CBOR value from the beginning of the C<$buffer> again.
395
396This method can be caled at any time, but it I<must> be called if you want
397to change your C<$buffer> or there was a decoding error and you want to
398reuse the C<$cbor> object for future incremental parsings.
294 399
295=back 400=back
296 401
297 402
298=head1 MAPPING 403=head1 MAPPING
704 809
705These tags are automatically created (and decoded) for serialisable 810These tags are automatically created (and decoded) for serialisable
706objects using the C<FREEZE/THAW> methods (the L<Types::Serialier> object 811objects using the C<FREEZE/THAW> methods (the L<Types::Serialier> object
707serialisation protocol). See L<OBJECT SERIALISATION> for details. 812serialisation protocol). See L<OBJECT SERIALISATION> for details.
708 813
709=item 28, 29 (sharable, sharedref, L <http://cbor.schmorp.de/value-sharing>) 814=item 28, 29 (shareable, sharedref, L <http://cbor.schmorp.de/value-sharing>)
710 815
711These tags are automatically decoded when encountered, resulting in 816These tags are automatically decoded when encountered (and they do not
817result in a cyclic data structure, see C<allow_cycles>), resulting in
712shared values in the decoded object. They are only encoded, however, when 818shared values in the decoded object. They are only encoded, however, when
713C<allow_sharable> is enabled. 819C<allow_sharing> is enabled.
820
821Not all shared values can be successfully decoded: values that reference
822themselves will I<currently> decode as C<undef> (this is not the same
823as a reference pointing to itself, which will be represented as a value
824that contains an indirect reference to itself - these will be decoded
825properly).
826
827Note that considerably more shared value data structures can be decoded
828than will be encoded - currently, only values pointed to by references
829will be shared, others will not. While non-reference shared values can be
830generated in Perl with some effort, they were considered too unimportant
831to be supported in the encoder. The decoder, however, will decode these
832values as shared values.
714 833
715=item 256, 25 (stringref-namespace, stringref, L <http://cbor.schmorp.de/stringref>) 834=item 256, 25 (stringref-namespace, stringref, L <http://cbor.schmorp.de/stringref>)
716 835
717These tags are automatically decoded when encountered. They are only 836These tags are automatically decoded when encountered. They are only
718encoded, however, when C<pack_strings> is enabled. 837encoded, however, when C<pack_strings> is enabled.
743perl core distribution (e.g. L<URI>), it is (currently) up to the user to 862perl core distribution (e.g. L<URI>), it is (currently) up to the user to
744provide these modules. The decoding usually fails with an exception if the 863provide these modules. The decoding usually fails with an exception if the
745required module cannot be loaded. 864required module cannot be loaded.
746 865
747=over 4 866=over 4
867
868=item 0, 1 (date/time string, seconds since the epoch)
869
870These tags are decoded into L<Time::Piece> objects. The corresponding
871C<Time::Piece::TO_CBOR> method always encodes into tag 1 values currently.
872
873The L<Time::Piece> API is generally surprisingly bad, and fractional
874seconds are only accidentally kept intact, so watch out. On the plus side,
875the module comes with perl since 5.10, which has to count for something.
748 876
749=item 2, 3 (positive/negative bignum) 877=item 2, 3 (positive/negative bignum)
750 878
751These tags are decoded into L<Math::BigInt> objects. The corresponding 879These tags are decoded into L<Math::BigInt> objects. The corresponding
752C<Math::BigInt::TO_CBOR> method encodes "small" bigints into normal CBOR 880C<Math::BigInt::TO_CBOR> method encodes "small" bigints into normal CBOR
886properly. Half precision types are accepted, but not encoded. 1014properly. Half precision types are accepted, but not encoded.
887 1015
888Strict mode and canonical mode are not implemented. 1016Strict mode and canonical mode are not implemented.
889 1017
890 1018
1019=head1 LIMITATIONS ON PERLS WITHOUT 64-BIT INTEGER SUPPORT
1020
1021On perls that were built without 64 bit integer support (these are rare
1022nowadays, even on 32 bit architectures), support for any kind of 64 bit
1023integer in CBOR is very limited - most likely, these 64 bit values will
1024be truncated, corrupted, or otherwise not decoded correctly. This also
1025includes string, array and map sizes that are stored as 64 bit integers.
1026
1027
891=head1 THREADS 1028=head1 THREADS
892 1029
893This module is I<not> guaranteed to be thread safe and there are no 1030This module is I<not> guaranteed to be thread safe and there are no
894plans to change this until Perl gets thread support (as opposed to the 1031plans to change this until Perl gets thread support (as opposed to the
895horribly slow so-called "threads" which are simply slow and bloated 1032horribly slow so-called "threads" which are simply slow and bloated
908service. I put the contact address into my modules for a reason. 1045service. I put the contact address into my modules for a reason.
909 1046
910=cut 1047=cut
911 1048
912our %FILTER = ( 1049our %FILTER = (
913 # 0 # rfc4287 datetime, utf-8 1050 0 => sub { # rfc4287 datetime, utf-8
914 # 1 # unix timestamp, any 1051 require Time::Piece;
1052 # Time::Piece::Strptime uses the "incredibly flexible date parsing routine"
1053 # from FreeBSD, which can't parse ISO 8601, RFC3339, RFC4287 or much of anything
1054 # else either. Whats incredibe over standard strptime totally escapes me.
1055 # doesn't do fractional times, either. sigh.
1056 # In fact, it's all a lie, it uses whatever strptime it wants, and of course,
1057 # they are all incomptible. The openbsd one simply ignores %z (but according to the
1058 # docs, it would be much more incredibly flexible indeed. If it worked, that is.).
1059 scalar eval {
1060 my $s = $_[1];
1061
1062 $s =~ s/Z$/+00:00/;
1063 $s =~ s/(\.[0-9]+)?([+-][0-9][0-9]):([0-9][0-9])$//
1064 or die;
1065
1066 my $b = $1 - ($2 * 60 + $3) * 60; # fractional part + offset. hopefully
1067 my $d = Time::Piece->strptime ($s, "%Y-%m-%dT%H:%M:%S");
1068
1069 Time::Piece::gmtime ($d->epoch + $b)
1070 } || die "corrupted CBOR date/time string ($_[0])";
1071 },
1072
1073 1 => sub { # seconds since the epoch, possibly fractional
1074 require Time::Piece;
1075 scalar Time::Piece::gmtime (pop)
1076 },
915 1077
916 2 => sub { # pos bigint 1078 2 => sub { # pos bigint
917 require Math::BigInt; 1079 require Math::BigInt;
918 Math::BigInt->new ("0x" . unpack "H*", pop) 1080 Math::BigInt->new ("0x" . unpack "H*", pop)
919 }, 1081 },
955} 1117}
956 1118
957sub URI::TO_CBOR { 1119sub URI::TO_CBOR {
958 my $uri = $_[0]->as_string; 1120 my $uri = $_[0]->as_string;
959 utf8::upgrade $uri; 1121 utf8::upgrade $uri;
960 CBOR::XS::tag 32, $uri 1122 tag 32, $uri
961} 1123}
962 1124
963sub Math::BigInt::TO_CBOR { 1125sub Math::BigInt::TO_CBOR {
964 if ($_[0] >= -2147483648 && $_[0] <= 2147483647) { 1126 if ($_[0] >= -2147483648 && $_[0] <= 2147483647) {
965 $_[0]->numify 1127 $_[0]->numify
966 } else { 1128 } else {
967 my $hex = substr $_[0]->as_hex, 2; 1129 my $hex = substr $_[0]->as_hex, 2;
968 $hex = "0$hex" if 1 & length $hex; # sigh 1130 $hex = "0$hex" if 1 & length $hex; # sigh
969 CBOR::XS::tag $_[0] >= 0 ? 2 : 3, pack "H*", $hex 1131 tag $_[0] >= 0 ? 2 : 3, pack "H*", $hex
970 } 1132 }
971} 1133}
972 1134
973sub Math::BigFloat::TO_CBOR { 1135sub Math::BigFloat::TO_CBOR {
974 my ($m, $e) = $_[0]->parts; 1136 my ($m, $e) = $_[0]->parts;
975 CBOR::XS::tag 4, [$e->numify, $m] 1137 tag 4, [$e->numify, $m]
1138}
1139
1140sub Time::Piece::TO_CBOR {
1141 tag 1, 0 + $_[0]->epoch
976} 1142}
977 1143
978XSLoader::load "CBOR::XS", $VERSION; 1144XSLoader::load "CBOR::XS", $VERSION;
979 1145
980=head1 SEE ALSO 1146=head1 SEE ALSO

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines