use v6.e.PREVIEW;
# https://cloud.google.com/storage/docs/uploading-objects
# This module implements JSON API multipart upload.
unit class WWW::GCloud::API::Storage::Upload::Simple;

use Cro::HTTP::BodySerializers;
use WWW::GCloud::API::Storage::Upload;
use WWW::GCloud::Utils;

also does WWW::GCloud::API::Storage::Upload;

has Str:D $.upload-type is built(False) = "multipart";

subset BodyData of Any where Any:U | Str:D | Blob:D;

has BodyData $.body;

submethod TWEAK {
    if $!body ~~ Str:D {
        $!body .= encode("latin-1");
    }

    with $!body {
        with $!meta.size {
            if $!body.bytes != $_ {
                WWW::GCloud::API::Storage::X::SizeMismatch.new(
                    :name($!meta.name), :expected($!meta.size), :got($!body.bytes),
                    where => "provided body blob object"
                ).throw
            }
        }
        else {
            $!meta .= clone( size => $!body.bytes )
        }
    }
}

proto method upload(|) {*}
multi method upload(::AS WWW::GCloud::Record :as($) is raw = WWW::GCloud::R::Storage::Object --> Promise:D) {
    my $boundary = gen-mime-boundary;
    my $body-boundary = '--' ~ $boundary;

    %!query<name>:delete;

    my sub blobify(*@s) {
        @s.join("\r\n").encode("latin-1")
    }

    my Blob[uint8] $body-start = blobify( $body-boundary,
                                          "Content-Type: application/json; charset

",
                                          "",
                                          $.meta.to-json,
                                          "",
                                          $body-boundary,
                                          "Content-Type: " ~ $.meta.content-type,
                                          "\r\n" );
    my $start-bytes = $body-start.bytes;
    my Blob[uint8] $body-end = blobify("", $body-boundary, "");


UTF-8


    my $body-length = ($body-start.bytes + $body-end.bytes + $!meta.size);

    my constant AS-SUPPLY = True;

    my $body;

    with $!body {
        my Buf[uint8] $body-blob .= allocate($body-length);

        # Store the generated body parts.
        $body-blob.subbuf-rw(0, $start-bytes) = $body-start;
        $body-blob.subbuf-rw($start-bytes, $!meta.size) = $!body;
        $body-blob.subbuf-rw($start-bytes + $!meta.size, $body-end.bytes) = $body-end;

        $body = $body-blob;
    }
    elsif $.segmented {
        $body = supply {
            emit $body-start;

            whenever self.segmented-read(:from(0)) -> $buf {
                emit $buf;
                LAST emit $body-end;
            }

        }
    }
    else {
        my Buf[uint8] $body-blob .= allocate($body-length);

        # Store the generated body parts.
        $body-blob.subbuf-rw(0, $start-bytes) = $body-start;
        $body-blob.subbuf-rw($start-bytes + $!meta.size, $body-end.bytes) = $body-end;

        my $offset = $start-bytes;

        $body = self.fill-buffer($body-blob, :offset($start-bytes));
    }

    $.http-client.post(
        $.url,
        headers => [
            $.gcloud.http-auth-header,
            |@.headers,
            'Content-Type' => 'multipart/related; boundary=' ~ $boundary,
            'Content-Length' => ($body-start.bytes + $body-end.bytes + $!meta.size),
        ],
        :%!query,
        :$body )
    .andthen({
        self.succeeded: .result, AS
    })
    .orelse({
        $!completed-vow.break(my $cause = .cause);
        $cause.rethrow
    })
}

root

README

Storage

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


=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


Simple

UTF-8

WWW::GCloud::API::Storage v0.0.1

Authors

License

Dependencies

Test Dependencies

Provides

Documentation