Class S3Service

src/main/java/se/devrandom/heimdall/storage/S3Service.java:50–658

import java.util.Map;

@Service
public class S3Service {
    private static final Logger log = LoggerFactory.getLogger(S3Service.class);

    private final S3Client s3Client;
    private final S3Presigner s3Presigner;
    private final String bucketName;
    private final String orgId;

    public S3Service(
            @Value("${aws.s3.bucket-name}") String bucketName,
            @Value("${aws.s3.region:eu-north-1}") String region,
            @Value("${salesforce.org-id}") String orgId) {
        this.bucketName = bucketName;
        this.orgId = orgId;

        // Configure S3Client with timeouts to prevent hanging forever on slow/unreliable networks
        this.s3Client = S3Client.builder()
                .region(Region.of(region))
                .credentialsProvider(DefaultCredentialsProvider.create())
                .overrideConfiguration(ClientOverrideConfiguration.builder()
                        .apiCallTimeout(Duration.ofMinutes(5))          // Total timeout for API call (includes retries)
                        .apiCallAttemptTimeout(Duration.ofMinutes(3))   // Timeout per retry attempt
                        .retryPolicy(RetryPolicy.builder()
                                .numRetries(2)                          // Retry twice on failure
                                .build())
                        .build())
                .build();

        this.s3Presigner = S3Presigner.builder()
                .region(Region.of(region))
                .credentialsProvider(DefaultCredentialsProvider.create())
                .build();

        log.info("S3Service initialized with bucket: {} in region: {} (5min timeout, 2 retries)", bucketName, region);
    }

    /**
     * Upload a CSV file to S3 with partitioned path pattern:
     * OrgId={x}/Period={yyyymm}/Year={y}/Month={m}/Date={d}/{ObjectName}/{file}.csv
     *
     * @param csvPath Path to the CSV file to upload
     * @param objectName Salesforce object name (e.g., "Account")
     * @param queryAll Whether this is a queryAll (deleted records) backup
     * @return The S3 key where the file was uploaded
     */
    public String uploadCsvToS3(Path csvPath, String objectName, boolean queryAll) throws IOException {
        String period = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMM"));
        return uploadCsvToS3(csvPath, objectName, queryAll, period);
    }

    /**
     * Upload a CSV file to S3 with partitioned path pattern and explicit period:
     * OrgId={x}/Period={period}/Year={y}/Month={m}/Date={d}/{ObjectName}/{file}.csv
     *
     * @param csvPath Path to the CSV file to upload
     * @param objectName Salesforce object name (e.g., "Account")
     * @param queryAll Whether this is a queryAll (deleted records) backup