Package org.jets3t.service.security

Examples of org.jets3t.service.security.AWSCredentials


        assertEquals(expected, authorizationHeaderValue);

        // The whole request
        SignatureUtils.awsV4SignRequestAuthorizationHeader(
            this.requestSignatureVersion, httpGet,
            new AWSCredentials(this.awsAccessKey, this.awsSecretAccessKey),
            requestPayloadHexSHA256Hash, this.region);
        assertEquals(expected, httpGet.getFirstHeader("Authorization").getValue());
    }
View Full Code Here


        assertEquals(expected, authorizationHeaderValue);

        // The whole request
        SignatureUtils.awsV4SignRequestAuthorizationHeader(
            this.requestSignatureVersion, httpGet,
            new AWSCredentials(this.awsAccessKey, this.awsSecretAccessKey),
            requestPayloadHexSHA256Hash, this.region);
        assertEquals(expected, httpGet.getFirstHeader("Authorization").getValue());
    }
View Full Code Here

        return TARGET_SERVICE_S3;
    }

    @Override
    protected ProviderCredentials getCredentials() {
        return new AWSCredentials(
            testProperties.getProperty("aws.accesskey"),
            testProperties.getProperty("aws.secretkey"));
    }
View Full Code Here

            "cloudfront-origin-bucket", this.originBucket);
    }

    protected CloudFrontService getService() throws CloudFrontServiceException
    {
        AWSCredentials credentials = new AWSCredentials(
            testProperties.getProperty("aws.accesskey"),
            testProperties.getProperty("aws.secretkey"));
        return new CloudFrontService(credentials);
    }
View Full Code Here

    /**
     * @param args
     */
    public static void main(String[] args) throws Exception {
        AWSCredentials fakeAwsCredentials = new AWSCredentials("fake-aws-access-key", "fake-aws-secret-key");

        int port = 443;
        ServerSocketFactory ssocketFactory = SSLServerSocketFactory.getDefault();
        ServerSocket ssocket = ssocketFactory.createServerSocket(port);
        System.out.println("Accepting connections on port 443");

        while (port == 443) {
            // Listen for connections
            Socket socket = ssocket.accept();
            System.out.println("Opened connection");

            // Create streams to securely send and receive data to the client
            InputStream in = socket.getInputStream();
            OutputStream out = socket.getOutputStream();

            byte[] buffer = new byte[1024];
            int read;

            while ((read = in.read(buffer)) != -1) {
                String receivedDataStr = new String(buffer, 0, read);
                String requestActionAndHeaders =
                    receivedDataStr.substring(0, receivedDataStr.indexOf("\r\n\r\n") + 4);

                System.out.println(requestActionAndHeaders);

                if (requestActionAndHeaders.startsWith("GET")) {
                    String path = requestActionAndHeaders.substring(4,
                        requestActionAndHeaders.indexOf(' ', 4));

                    if (path.startsWith("/jets3t-")) {
                        // Return fake AWS credentials.
                        String headers =
                            "HTTP/1.1 200 OK\r\n" +
                            "x-amz-id-2: FakeAWSCredentials\r\n" +
                            "x-amz-request-id: FakeAWSCredentials\r\n" +
                            "Date: Thu, 24 May 2007 13:39:21 GMT\r\n" +
                            "Cache-Control: max-age=259200\r\n" +
                            "Last-Modified: Wed, 27 Dec 2006 02:37:58 GMT\r\n" +
                            "ETag: \"fa5d6b0ea9716cf692b286b6aa187f3d\"\r\n" +
                            "Content-Type: application/octet-stream\r\n" +
                            "Content-Length: 139\r\n" +
                            "Server: AmazonS3\r\n\r\n";

                        out.write(headers.getBytes("UTF-8"));
                        fakeAwsCredentials.save("please", out);
                    }

                    else if (path.equals("/")) {
                        // Return fake bucket listing.
                        String headers =
View Full Code Here

            throw new RuntimeException(
                "Properties file '" + SAMPLES_PROPERTIES_NAME
                + "' does not contain required property: " + AWS_SECRET_KEY_PROPERTY_NAME);
        }

        AWSCredentials awsCredentials = new AWSCredentials(
            testProperties.getProperty(AWS_ACCESS_KEY_PROPERTY_NAME),
            testProperties.getProperty(AWS_SECRET_KEY_PROPERTY_NAME));

        return awsCredentials;
    }
View Full Code Here

         * threaded listing will be performed for each such partition.
         */
        final String bucketName = "jets3t";
        final String delimiter = "/";

        AWSCredentials awsCredentials = SamplesUtils.loadAWSCredentials();
        S3Service restService = new RestS3Service(awsCredentials);

        final List allObjects = Collections.synchronizedList(new ArrayList());
        final Exception s3ServiceExceptions[] = new Exception[1];

View Full Code Here

        }
        if (missingInitParam) {
            throw new ServletException(errorMessage);
        }

        this.credentials = new AWSCredentials(awsAccessKey, awsSecretKey);

        s3BucketName = servletConfig.getInitParameter("S3BucketName");
        if (s3BucketName == null || s3BucketName.length() == 0) {
            throw new ServletException("Missing required servlet init parameters for DefaultBucketLister: "
                + "S3BucketName");
View Full Code Here

        }
        if (missingInitParam) {
            throw new ServletException(errorMessage);
        }

        this.credentials = new AWSCredentials(awsAccessKey, awsSecretKey);
        this.s3Service = new RestS3Service(credentials);

        String secondsToSign = servletConfig.getInitParameter("SecondsToSign");
        if (secondsToSign == null || secondsToSign.length() == 0) {
            throw new ServletException("Missing required servlet init parameters for DefaultUrlSigner: "
View Full Code Here

        int hoursAgo = Integer.parseInt(args[1]);
        String accessKey = args[2];
        String secretKey = args[3];

        // Create DevPay credentials and a service that uses them.
        AWSCredentials credentials = null;
        if (args.length == 4) {
            credentials = new AWSCredentials(accessKey, secretKey);
        } else {
            String userToken = args[4];
            String productToken = args[5];
            credentials = new AWSDevPayCredentials(accessKey, secretKey, userToken, productToken);
        }
View Full Code Here

TOP

Related Classes of org.jets3t.service.security.AWSCredentials

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.