Package oauth.signpost

Examples of oauth.signpost.OAuthConsumer


    /**
     * Request the request token and secret.
     * @return a Response object holding either the result in case of a success or the error
     */
    public Response retrieveRequestToken() {
        OAuthConsumer consumer = new DefaultOAuthConsumer(info.consumerKey, info.consumerSecret);
        String callbackURL = Request.current().getBase() + Request.current().url;
        try {
            provider.retrieveRequestToken(consumer, callbackURL);
        } catch (OAuthException e) {
            return Response.error(new Error(e));
        }
        return Response.success(consumer.getToken(), consumer.getTokenSecret());
    }
View Full Code Here


    public Response retrieveAccessToken(Response requestTokenResponse) {
        return retrieveAccessToken(requestTokenResponse.token, requestTokenResponse.secret);
    }

    public Response retrieveAccessToken(String token, String secret) {
         OAuthConsumer consumer = new DefaultOAuthConsumer(info.consumerKey, info.consumerSecret);
        consumer.setTokenWithSecret(token, secret);
        String verifier = Params.current().get("oauth_verifier");
        try {
            provider.retrieveAccessToken(consumer, verifier);
        } catch (OAuthException e) {
            return Response.error(new Error(e));
        }
        return Response.success(consumer.getToken(), consumer.getTokenSecret());
    }
View Full Code Here

                for (String key: this.headers.keySet()) {
                    connection.setRequestProperty(key, headers.get(key));
                }
                checkFileBody(connection);
                if (this.oauthToken != null && this.oauthSecret != null) {
                    OAuthConsumer consumer = new DefaultOAuthConsumer(oauthInfo.consumerKey, oauthInfo.consumerSecret);
                    consumer.setTokenWithSecret(oauthToken, oauthSecret);
                    consumer.sign(connection);
                }
                return connection;
            } catch(Exception e) {
                throw new RuntimeException(e);
            }
View Full Code Here

        OAuthProvider provider = new DefaultOAuthProvider(requestTokenUrl,
            accessTokenUrl != null ? accessTokenUrl : adapter.getAccessTokenUrl(),
            authorizationUrl != null ? authorizationUrl : adapter.getAuthorizationUrl());

        OAuthConsumer consumer = this.getConsumer(adapter);
        provider.setOAuth10a(true);
        String signedAuthorizationUrl;

        if (getLogger().isDebugEnabled())
        {
            getLogger().debug(
                String.format("Attempting to acquire a request token [consumer = %s] [consumerSecret = %s]",
                    consumer.getConsumerKey(), consumer.getConsumerSecret()));
        }

        try
        {

            signedAuthorizationUrl = provider.retrieveRequestToken(consumer, redirectUri,
                customOAuthParameters.toArray(new String[]{}));

            if (getLogger().isDebugEnabled())
            {
                getLogger().debug(
                    String.format("Request token acquired [requestToken = %s] [requestTokenSecret = %s]",
                        consumer.getToken(), consumer.getTokenSecret()));
            }
        }
        catch (OAuthMessageSignerException e)
        {
            throw new UnableToAcquireRequestTokenException(e);
        }
        catch (OAuthNotAuthorizedException e)
        {
            throw new UnableToAcquireRequestTokenException(e);
        }
        catch (OAuthExpectationFailedException e)
        {
            throw new UnableToAcquireRequestTokenException(e);
        }
        catch (OAuthCommunicationException e)
        {
            throw new UnableToAcquireRequestTokenException(e);
        }

        adapter.setRequestToken(consumer.getToken());
        adapter.setRequestTokenSecret(consumer.getTokenSecret());

        return signedAuthorizationUrl;
    }
View Full Code Here

            OAuthProvider provider = new DefaultOAuthProvider(requestTokenUrl,
                accessTokenUrl != null ? accessTokenUrl : adapter.getAccessTokenUrl(),
                authorizationUrl != null ? authorizationUrl : adapter.getAuthorizationUrl());
            provider.setOAuth10a(true);

            OAuthConsumer consumer = this.getConsumer(adapter);
            consumer.setTokenWithSecret(adapter.getRequestToken(), adapter.getRequestTokenSecret());

            if (getLogger().isDebugEnabled())
            {
                getLogger().debug("Retrieving access token...");
            }

            try
            {
                provider.retrieveAccessToken(consumer, adapter.getOauthVerifier());
            }
            catch (OAuthMessageSignerException e)
            {
                throw new UnableToAcquireAccessTokenException(e);
            }
            catch (OAuthNotAuthorizedException e)
            {
                throw new UnableToAcquireAccessTokenException(e);
            }
            catch (OAuthExpectationFailedException e)
            {
                throw new UnableToAcquireAccessTokenException(e);
            }
            catch (OAuthCommunicationException e)
            {
                throw new UnableToAcquireAccessTokenException(e);
            }

            adapter.setAccessToken(consumer.getToken());
            adapter.setAccessTokenSecret(consumer.getTokenSecret());

            if (getLogger().isDebugEnabled())
            {
                getLogger().debug(
                    String.format(
View Full Code Here

    @Override
    public void reset(OAuth1Adapter adapter)
    {
        adapter.setAccessToken(null);
        adapter.setAccessTokenSecret(null);
        OAuthConsumer consumer = adapter.getConsumer();
        if (consumer != null) {
            consumer.setTokenWithSecret(null, null);
        }
    }
View Full Code Here

        }
    }

    protected OAuthConsumer getConsumer(OAuth1Adapter adapter)
    {
        OAuthConsumer consumer = adapter.getConsumer();
       
        if (consumer == null)
        {
            consumer = new DefaultOAuthConsumer(adapter.getConsumerKey(), adapter.getConsumerSecret());
            consumer.setMessageSigner(adapter.getMessageSigner());
            consumer.setSigningStrategy(adapter.getSigningStrategy());
           
            adapter.setConsumer(consumer);
        }
       
        return consumer;
View Full Code Here

    public void testDummy() {}

    public void _testFlow() throws Exception {
        enableProxy();

        final OAuthConsumer consumer = new DefaultOAuthConsumer(CONSUMER_KEY, CONSUMER_SECRET);
        final OAuthProvider provider = new DefaultOAuthProvider(REQUEST_TOKEN_ENDPOINT_URL, ACCESS_TOKEN_ENDPOINT_URL, AUTHORIZATION_WEBSITE_URL);

        System.out.println("Fetching request token...");

        final String authUrl = provider.retrieveRequestToken(consumer, CALLBACK_URL);

        System.out.println("Request token: " + consumer.getToken());
        System.out.println("Token secret: " + consumer.getTokenSecret());

        System.out.println("Now visit:\n" + authUrl + "\n... and grant this app authorization");
        System.out.println("Enter the verification code and hit ENTER when you're done:");

        final BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        final String verificationCode = br.readLine();

        System.out.println("Fetching access token...");

        provider.retrieveAccessToken(consumer, verificationCode.trim());

        System.out.println("Access token: " + consumer.getToken());
        System.out.println("Token secret: " + consumer.getTokenSecret());

        // Subsequent calls to Salesforce will fail if verification code is set
        // after getting the access token, so remove it from additional parameters
        consumer.setAdditionalParameters(null);

        // Salesforce does not use the OAuth token directly for regular API calls.
        // You must first make a special login API call to get a serverUrl and sessionId
        final URL loginUrl = new URL(SFDC_LOGIN_URL);
        final HttpURLConnection request = (HttpURLConnection) loginUrl.openConnection();
        request.setRequestMethod("POST");

        consumer.sign(request);

        System.out.println("Sending request...");
        request.connect();

        System.out.println("Response: " + request.getResponseCode() + " " + request.getResponseMessage());
View Full Code Here

                for (String key : this.headers.keySet()) {
                    connection.setRequestProperty(key, headers.get(key));
                }

                if (this.oauthToken != null && this.oauthSecret != null) {
                    OAuthConsumer consumer = new DefaultOAuthConsumer(oauthInfo.consumerKey, oauthInfo.consumerSecret);
                    consumer.setTokenWithSecret(oauthToken, oauthSecret);
                    consumer.sign(connection);
                }
                checkFileBody(connection);
                return connection;
            } catch (Exception e) {
                throw new RuntimeException(e);
View Full Code Here

     * Request the request token and secret.
     * @param callbackURL the URL where the provider should redirect to
     * @return a Response object holding either the result in case of a success or the error
     */
    public Response retrieveRequestToken(String callbackURL) {
        OAuthConsumer consumer = new DefaultOAuthConsumer(info.consumerKey, info.consumerSecret);
        try {
            provider.retrieveRequestToken(consumer, callbackURL);
        } catch (OAuthException e) {
            return Response.error(new Error(e));
        }
        return Response.success(consumer.getToken(), consumer.getTokenSecret());
    }
View Full Code Here

TOP

Related Classes of oauth.signpost.OAuthConsumer

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.