Image

head

code

root

para

L<Examples| file:../examples/index.podlite>


L<Download |file:../download/index.podlite>


React

=begin React :component<HeaderCol> :id<menu> 
=para L<Documentation|/doc/introduction>
=para L<Modules| /mods>
=para L<Examples| file:../examples/index.podlite>
=para L<Download |file:../download/index.podlite>
=para L<About|file:../about/index.podlite>
=para 🔍 K<⌘K>/K<ctrl-K>
=end React


HEADER

FOOTER

README

unit module Cro::CBOR:auth<zef:japhb>:api<0>:ver<0.0.1>;


use Cro::BodyParser;
use Cro::HTTP::MimeTypes;
use Cro::HTTP::Message;
use Cro::HTTP::BodySerializers;
use Cro::HTTP::BodyParserSelectors;
use Cro::HTTP::BodySerializerSelectors;
use Cro::HTTP::Router::WebSocket;
use Cro::WebSocket::Message::Opcode;
use Cro::WebSocket::Client;

use CBOR::Simple;


# Make sure the CBOR MIME type is registered;
%mime<cbor> = 'application/cbor';


### HTTP PARSER AND SERIALIZER

class HTTP::BodyParser does Cro::BodyParser {
    method is-applicable(Cro::HTTP::Message $message --> Bool) {
        with $message.content-type {
            .type eq 'application' && .subtype eq 'cbor' || .suffix eq 'cbor'
        }
        else {
            False
        }
    }

    method parse(Cro::HTTP::Message $message --> Promise) {
        Promise(supply {
            my $payload = Blob.new;
            whenever $message.body-byte-stream -> $blob {
                $payload ~= $blob;
                LAST emit cbor-decode($payload);
            }
        })
    }
}


class HTTP::BodySerializer does Cro::HTTP::BodySerializer {
    method is-applicable(Cro::HTTP::Message $message, $body --> Bool) {
        with $message.content-type {
            .type eq 'application' && .subtype eq 'cbor' || .suffix eq 'cbor'
        }
        else {
            False
        }
    }

    method serialize(Cro::HTTP::Message $message, $body --> Supply) {
        my $cbor = cbor-encode($body);
        self!set-content-length($message, $cbor.bytes);
        supply { emit $cbor }
    }
}


### WEBSOCKET PARSER AND SERIALIZER

class WebSocket::BodyParser does Cro::BodyParser {
    method is-applicable($message) {
        # We presume that if this body parser has been installed, then we will
        # always be doing CBOR
        True
    }

    method parse($message) {
        $message.body-blob.then: -> $blob-promise {
            cbor-decode($blob-promise.result)
        }
    }
}


class WebSocket::BodySerializer does Cro::BodySerializer {
    method is-applicable($message, $body) {
        # We presume that if this body serializer has been installed, then we
        # will always be doing CBOR
        True
    }

    method serialize($message, $body) {
        $message.opcode = Binary;
        supply emit cbor-encode($body)
    }
}


### HTTP PARSER AND SERIALIZER SELECTORS

class HTTP::BodyParserSelector::Request
   is Cro::HTTP::BodyParserSelector::RequestDefault {
    method select(Cro::HTTP::Message $message --> Cro::BodyParser) {
        return HTTP::BodyParser if HTTP::BodyParser.is-applicable($message);
        callsame;
    }
}


class HTTP::BodyParserSelector::Response
   is Cro::HTTP::BodyParserSelector::ResponseDefault {
    method select(Cro::HTTP::Message $message --> Cro::BodyParser) {
        return HTTP::BodyParser if HTTP::BodyParser.is-applicable($message);
        callsame;
    }
}

class HTTP::BodySerializerSelector::Request
   is Cro::HTTP::BodySerializerSelector::RequestDefault {
    method select(Cro::HTTP::Message $message, $body --> Cro::HTTP::BodySerializer) {
        return HTTP::BodySerializer if HTTP::BodySerializer.is-applicable($message, $body);
        callsame;
    }
}

class HTTP::BodySerializerSelector::Response
   is Cro::HTTP::BodySerializerSelector::ResponseDefault {
    method select(Cro::HTTP::Message $message, $body --> Cro::HTTP::BodySerializer) {
        return HTTP::BodySerializer if HTTP::BodySerializer.is-applicable($message, $body);
        callsame;
    }
}


### ROUTER HELPERS

multi web-socket(&handler, :$cbor!) is export {
    web-socket(&handler, :body-parsers(WebSocket::BodyParser),
                         :body-serializers(WebSocket::BodySerializer))
}


### WEBSOCKET CLIENT

class WebSocket::Client is Cro::WebSocket::Client {
    multi method new(:$cbor!, :$uri, :@headers) {
        self.new(:$uri, :@headers, :body-parsers(WebSocket::BodyParser),
                                   :body-serializers(WebSocket::BodySerializer))
    }
}




Cro::CBOR - Support CBOR in Cro for body parsing/serializing


=begin code :lang<raku>

use Cro::CBOR;

=end code


Cro::CBOR is a set of extensions to C<Cro::HTTP> and C<Cro::WebSocket> to
support using CBOR alongside JSON as a standard body serialization format.


This library is free software; you can redistribute it and/or modify it under
the Artistic License 2.0.


CBOR

use UUID;
unit role CRDT:ver<0.0.9>:auth<zef:FCO>;

has Str $.instance-id           = ~UUID.new;
has Supplier $!change-supplier .= new;
has Supply $.changed            = $!change-supplier.Supply;
has Supplier $!merge-supplier  .= new;
has Supply $.merged             = $!merge-supplier.Supply;

method !emit-change { $!change-supplier.emit: self.export }
method !emit-merge  { $!merge-supplier.emit:  self.export }

method merge(::T CRDT:D: $ --> T) { ... }
method copy(::T CRDT:D: --> T)    { ... }
method export                     { ... }

method DESTROY {
    $!change-supplier.done;
    $!merge-supplier.done;
}



CRDT - Conflict-free Replicated Data Type


=begin code :lang<raku>

use G-Counter;
use PN-Counter;
use G-Set;
use P2-Set;
use LWW-Element-Set;
use OR-Set;
use LWW-Register;

=end code


CRDT is L<https://en.wikipedia.org/wiki/Conflict-free_replicated_data_type>


Fernando Correa <fernando.correa@humanstate.com>


This library is free software; you can redistribute it and/or modify it under the Artistic License 2.0.


CRDT

The Raku Knowledge Base


=begin React :component<HeaderCol> :id<footer>  
=begin nested :!nested
=item1 B<Language>
    =item2 L<Get started|file:../getting-started/getting-started.podlite>
    =item2 L<Why Raku?|/doc/language/faq#Why-should-I-learn-Raku-What's-so-great-about-it>
    =item2 L<Try Raku|https://glot.io/new/raku>
    =item2 L<Raku cheat sheet|https://github.com/Raku/mu/blob/master/docs/Perl6/Cheatsheet/cheatsheet.txt>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<Raku on Exercism|https://exercism.org/tracks/raku>
    =item2 L<Wikipedia|https://en.wikipedia.org/wiki/Raku_(programming_language)>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>

=end nested
=begin nested :!nested

=item1 B<L<Documentation|/doc>>
    =item2 L<Getting started, Migration guides from other languages, & Tutorials | file:../doc/introduction.podlite>
    =item2 L<Language References|file:../doc/reference.podlite>
    =item2 L<Type Reference| file:../doc/types.podlite>
    =item2 L<Miscellaneous| file:../doc/miscellaneous.podlite>
    =item2 L<FAQs (Frequently Asked Questions)|/doc/language/faq>
    =item2 L<Community|/doc/language/community>
    =item2 L<The list of all documents|file:../doc/index.podlite>

=item1 B<Resources>
    =item2 L<The Raku Guide|https://raku.guide/>
    =item2 L<Books |https://perl6book.com/>
    =item2 L<Rosetta Code | https://www.raku.org/community/rosettacode>

=end nested
=begin nested :!nested

=item1 B<Resoures>
    =item2 L<Download | file:../download/index.podlite>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>

=item1 B<Learning>
    =item2 L<The Raku Guide|https://raku.guide/>
    =item2 L<Wikibook |https://en.wikibooks.org/wiki/Raku_Programming>
    =item2 L<Books |https://perl6book.com/>
    =item2 L<Rosetta Code | https://www.raku.org/community/rosettacode>
    =item2 L<Learn Raku in Y minutes|https://learnxinyminutes.com/docs/raku/>
    =item2 L<Golfing |https://github.com/AlexDaniel/raku-golf-cheatsheet>
=end nested
=begin nested :!nested

=item1 B<Explore>
    =item2 L<Raku Blog Aggregator|https://planet.raku.org/>
    =item2 L<Rakudo Weekly|https://rakudoweekly.blog/>
    =item2 L<The Weekly Challenge |https://perlweeklychallenge.org/>
    =item2 L<Raku Advent Calendar|https://raku-advent.blog/>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>
    =item2 L<empty|#>

=end nested
=end React


=begin React :component<CookieConsent> :id<CookieConsent> :buttonCaption("Got it!")
=para
This website uses cookies for analytics.
=end React


README

NAME

SYNOPSIS

DESCRIPTION

AUTHOR

COPYRIGHT AND LICENSE

CRDT v0.0.9

Authors

License

Dependencies

Test Dependencies

Provides

Documentation