use Digest::HMAC;
use Digest;
use Digest::SHA;
use MIME::Base64;
use URI::Encode;
use URI;
use Cro::HTTP::Client;

unit class FanFou:ver<0.0.1>;

sub oauth_escape($s)           { return uri_encode_component($s.Str) }
sub oauth_timestamp()          { return time }
sub oauth_nonce($size=8)       { return ((1..9).pick for 1..$size).join("") }
sub oauth_query(%args)         { return (sprintf "%s=%s", $_, oauth_escape(~%args{$_}) for %args.keys.sort).join('&') }
sub oauth_normalized_url($url) { my URI $u .= new($url); return sprintf('%s://%s%s', $u.scheme, $u.host, $u.path)     }

class Auth {
    has %.oauth_consumer    is rw = {};
    has %.oauth_token       is rw = {};
    has $.callback          is rw = 'http://localhost:8080/callback';
    has $.auth_host         is rw = 'http://m.fanfou.com';
    has $.form_urlencoded   is rw = 'application/x-www-form-urlencoded';
    has $.base_api_url      is rw = 'http://api.fanfou.com%s.json';
    has $.access_token_url  is rw = 'http://fanfou.com/oauth/access_token';
    has $.request_token_url is rw = 'http://fanfou.com/oauth/request_token';
    has $.authorize_url     is rw = $!auth_host ~ '/oauth/authorize?oauth_token=%s&oauth_callback=%s';

    method HMAC_SHA1($key_string, $base_string) {
        return MIME::Base64.encode(hmac($key_string, $base_string, &sha1));
    }

    method oauth_signature($url, $method, %base_args) {
        my $normalized_url = oauth_normalized_url($url);
        my $query_items    = oauth_query(%base_args);
        my @base_elems     = ($method.uc, $normalized_url, $query_items);
        my $base_string    = (oauth_escape($_) for @base_elems).join("&");
        my @keys_elems     = (%.oauth_consumer{'secret'}, %.oauth_token{'secret'} // '');
        my $keys_string    = (oauth_escape($_) for @keys_elems).join("&");
        return self.HMAC_SHA1($keys_string, $base_string);
    }

    method oauth_header(%base_args, $realm='') {
        my $auth_header = 'OAuth realm="%s"'.sprintf($realm);
        for %base_args.keys.sort -> $key {
            if $key.starts-with('oauth_') or $key.starts-with('x_auth_') {
                $auth_header ~= ', %s="%s"'.sprintf($key, oauth_escape(%base_args{$key}));
            }
        }
        return {'Authorization' => $auth_header};
    }

    method oauth_request($url is copy, $method='GET', %args={}, %headers={}) {
        my %base_args =  'oauth_consumer_key'     => %!oauth_consumer{'key'},
                         'oauth_signature_method' => 'HMAC-SHA1',
                         'oauth_timestamp'        => oauth_timestamp(),
                         'oauth_nonce'            => oauth_nonce(),
                         'oauth_version'          => '1.0';

        %args = %args.clone;
        %headers = %headers.clone;
        %headers{'User-Agent'} = %headers{'User-Agent'} // 'Cro';

        if $url.starts-with('/') {
           if $url.contains(':') {
                 my ($path,$) = $url.split(':');
                 if %args{'id'} {
                     $url = $path ~ oauth_escape(%args{'id'});
                 } else {
                     $url = $path.chop;
                 }
           }
           $url = $!base_api_url.sprintf($url);
        }

        if $method eq 'POST' {
            %headers{'content-type'} = %headers{'content-type'} // self.form_urlencoded;
            (%headers{'content-type'} eq self.form_urlencoded) and (%base_args ,= %args);
        } else {
            %base_args ,= %args;
            $url = $url ~ '?' ~ oauth_query(%args);
        }

        self.oauth_token and %base_args ,= {'oauth_token' => self.oauth_token{'key'}};
        %base_args{'oauth_signature'} = self.oauth_signature($url, $method, %base_args);
        %headers ,= self.oauth_header(%base_args);

        my $resp;
        my $data = "";
        if (%headers{'content-type'} // '') eq self.form_urlencoded {
            $data = oauth_query(%args);
        } elsif (%headers{'content-type'} // '').contains('multipart/form-data') { # multipart/form-data
            $data = %args{'form-data'};
        } else { # GET
            $data = "";
        }

        my $client = Cro::HTTP::Client.new( headers => |%headers );
        if $data {
            $resp = await $client.post: $url,  body => |%args ;
        } else {
            $resp = await $client.get: $url;
        }
        return $resp;
    }
}

class OAuth is Auth {
    method request($url, $method='GET', %args={}, %headers={}) {
        return self.oauth_request($url, $method, %args, %headers);
    }

    method request_token() {
        my $resp = self.oauth_request(self.request_token_url, 'GET');
        my %oauth_token = (await $resp.body-text()).Str.split('&')».split('=').flat.hash;
        self.authorize_url = self.authorize_url.sprintf(%oauth_token{'oauth_token'}, self.callback);
        self.oauth_token = 'key' => %oauth_token{'oauth_token'}, 'secret' => %oauth_token{'oauth_token_secret'};
        return self.oauth_token;
    }

    method access_token(%oauth_token={},$oauth_verifier


class XAuth is Auth {
    has $.username is rw;
    has $.password is rw;
    has %.oauth_token is rw = self.xauth();

    method request($url, $method='GET', %args={}, %headers={}) {
        return self.oauth_request($url, $method, %args, %headers);
    }

    method xauth() {
        my %args =  'x_auth_username' => $!username,
                    'x_auth_password' => $!password,
                    'x_auth_mode'     => 'client_auth';

        my $resp = self.oauth_request(self.access_token_url, 'GET', %args);
        my %oauth_token = (await $resp.body-text()).Str.split('&')».split('=').flat.hash;
        return {'key' => %oauth_token{'oauth_token'}, 'secret' => %oauth_token{'oauth_token_secret'}};
    }

    method access_token() {
        return self.oauth_token;
    }
}



https://github.com/FanfouAPI/FanFouAPIDoc/wiki/Oauth


head

FanFou - Perl 6 oauth client for fanfou.com.


my %oauth_consumer = key => 'your_consumer_key', secret => 'your_secret_key';


# get fanfou client
my $client = FanFou::XAuth.new(oauth_consumer => %oauth_consumer, username => 'your_username', password => 'your_password');


# get response
my $resp = from-json await $client.request('/statuses/home_timeline', 'GET').body-text;
say $resp.perl;


# post a message
my %body = 'status' => 'Hi, fan, I'm a robot';
$client.request('/statuses/update', 'POST', %body);


FanFou is oauth client for http://fanfou.com


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


root

README

Values

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


FanFou

NAME

SYNOPSIS

DESCRIPTION

AUTHOR

COPYRIGHT AND LICENSE