package co.electrovan.knowco.servicios;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;

import com.amazonaws.AmazonClientException;
import com.amazonaws.AmazonServiceException;
import com.amazonaws.auth.profile.ProfileCredentialsProvider;
import com.amazonaws.services.s3.AmazonS3;
import com.amazonaws.services.s3.AmazonS3Client;
import com.amazonaws.services.s3.S3ResponseMetadata;
import com.amazonaws.services.s3.model.ListObjectsV2Request;
import com.amazonaws.services.s3.model.ListObjectsV2Result;
import com.amazonaws.services.s3.model.S3ObjectSummary;

import co.electrovan.knowco.bo.AccesoDatos;
import co.electrovan.knowco.dto.Rol;

@RestController
public class Prueba {

    @Autowired
    private AccesoDatos<Rol> accesoDatosRol;

    private static String bucketName = "knowco-eventos";

    @RequestMapping(value ="/get",  method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
    public List<Rol> getUsuarios(){

         AmazonS3 s3client = new AmazonS3Client(new ProfileCredentialsProvider());
            try {
                System.out.println("Listing objects of your bucket");
                final ListObjectsV2Request req = new ListObjectsV2Request().withBucketName(bucketName).withMaxKeys(100);
                ListObjectsV2Result result;
                do {
                   result = s3client.listObjectsV2(req);

                   for (S3ObjectSummary objectSummary :
                       result.getObjectSummaries()) {
                       System.out.println(" - " + objectSummary.getKey() + "  " +
                               "(size = " + objectSummary.getSize() +
                               ")");
                   }
                   System.out.println("Next Continuation Token : " + result.getNextContinuationToken());
                   req.setContinuationToken(result.getNextContinuationToken());
                   S3ResponseMetadata md = s3client.getCachedResponseMetadata(req);
                   System.out.println("Host ID: " + md.getHostId() + " RequestID: " + md.getRequestId());

                } while(result.isTruncated() == true );

             } catch (AmazonServiceException ase) {
                System.out.println("Caught an AmazonServiceException, " +
                        "which means your request made it " +
                        "to Amazon S3, but was rejected with an error response " +
                        "for some reason.");
                System.out.println("Error Message:    " + ase.getMessage());
                System.out.println("HTTP Status Code: " + ase.getStatusCode());
                System.out.println("AWS Error Code:   " + ase.getErrorCode());
                System.out.println("Error Type:       " + ase.getErrorType());
                System.out.println("Request ID:       " + ase.getRequestId());
            } catch (AmazonClientException ace) {
                System.out.println("Caught an AmazonClientException, " +
                        "which means the client encountered " +
                        "an internal error while trying to communicate" +
                        " with S3, " +
                        "such as not being able to access the network.");
                System.out.println("Error Message: " + ace.getMessage());
            }


        return accesoDatosRol.findAll(Rol.class);
    }

}