1// Ornek1: Dosya yükleme (MultipartFile) ve indirme (ResponseEntity<byte[]>).
2// Çalıştırma: portal gömülü Tomcat ile başlatır, self-test çıktısını alır.
3package com.egitim.springboot.dosya;
4
5import org.springframework.boot.CommandLineRunner;
6import org.springframework.boot.SpringApplication;
7import org.springframework.boot.autoconfigure.SpringBootApplication;
8import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
9import org.springframework.context.annotation.Bean;
10import org.springframework.core.io.ByteArrayResource;
11import org.springframework.http.*;
12import org.springframework.util.LinkedMultiValueMap;
13import org.springframework.util.MultiValueMap;
14import org.springframework.web.bind.annotation.*;
15import org.springframework.web.client.RestClient;
16import org.springframework.web.multipart.MultipartFile;
17
18import java.nio.charset.StandardCharsets;
19import java.util.Map;
20import java.util.concurrent.ConcurrentHashMap;
21
22@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)
23public class Ornek1 {
24
25    public static void main(String[] args) { SpringApplication.run(Ornek1.class, args); }
26
27    @RestController
28    @RequestMapping("/dosya")
29    static class DosyaController {
30        private final Map<String, byte[]> depo = new ConcurrentHashMap<>(); // bellek-içi (gerçekte disk/S3)
31
32        // YÜKLEME: multipart/form-data -> MultipartFile
33        @PostMapping("/yukle")
34        public Map<String, Object> yukle(@RequestParam("dosya") MultipartFile dosya) {
35            depo.put(dosya.getOriginalFilename(), getBytes(dosya));
36            return Map.of("ad", dosya.getOriginalFilename(),
37                    "boyut", dosya.getSize(),
38                    "tip", String.valueOf(dosya.getContentType()));
39        }
40
41        // İNDİRME: byte[] + Content-Disposition (tarayıcı "indir" diye algılar)
42        @GetMapping("/indir/{ad}")
43        public ResponseEntity<byte[]> indir(@PathVariable String ad) {
44            byte[] icerik = depo.get(ad);
45            if (icerik == null) return ResponseEntity.notFound().build();
46            return ResponseEntity.ok()
47                    .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + ad + "\"")
48                    .contentType(MediaType.APPLICATION_OCTET_STREAM)
49                    .body(icerik);
50        }
51
52        private static byte[] getBytes(MultipartFile f) {
53            try { return f.getBytes(); } catch (Exception e) { throw new RuntimeException(e); }
54        }
55    }
56
57    @Bean
58    CommandLineRunner selfTest() {
59        return args -> {
60            RestClient c = RestClient.create("http://localhost:8080");
61            System.out.println("\n========= DOSYA YÜKLE/İNDİR SELF-TEST =========");
62
63            // YÜKLE: multipart gövde oluştur (dosya adı + içerik).
64            byte[] icerik = "Merhaba, bu bir test dosyasıdır.".getBytes(StandardCharsets.UTF_8);
65            MultiValueMap<String, Object> govde = new LinkedMultiValueMap<>();
66            govde.add("dosya", new ByteArrayResource(icerik) {
67                @Override public String getFilename() { return "rapor.txt"; } // dosya adı şart
68            });
69            String yuklemeSonuc = c.post().uri("/dosya/yukle")
70                    .contentType(MediaType.MULTIPART_FORM_DATA)
71                    .body(govde).retrieve().body(String.class);
72            System.out.println("YÜKLE  -> " + yuklemeSonuc);
73
74            // İNDİR: yüklenen dosyayı geri al.
75            byte[] inen = c.get().uri("/dosya/indir/rapor.txt").retrieve().body(byte[].class);
76            System.out.println("İNDİR  -> içerik: '" + new String(inen, StandardCharsets.UTF_8) + "'");
77            System.out.println("İçerik aynı mı? " + java.util.Arrays.equals(icerik, inen));
78            System.out.println("===============================================");
79        };
80    }
81}