Skip to content
GetFileController.java 2.25 KiB
Newer Older
Sonia Zorba's avatar
Sonia Zorba committed
/*
 * This file is part of vospace-file-service
 * Copyright (C) 2021 Istituto Nazionale di Astrofisica
 * SPDX-License-Identifier: GPL-3.0-or-later
 */
Sonia Zorba's avatar
Sonia Zorba committed
package it.inaf.ia2.transfer.controller;

import it.inaf.ia2.transfer.persistence.model.FileInfo;
Sonia Zorba's avatar
Sonia Zorba committed
import it.inaf.ia2.transfer.auth.TokenPrincipal;
import it.inaf.ia2.transfer.persistence.FileDAO;
import it.inaf.ia2.transfer.service.AuthorizationService;
Sonia Zorba's avatar
Sonia Zorba committed
import java.io.File;
import java.util.Optional;
import javax.servlet.http.HttpServletResponse;
Sonia Zorba's avatar
Sonia Zorba committed
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
Sonia Zorba's avatar
Sonia Zorba committed
import org.springframework.beans.factory.annotation.Autowired;
import static org.springframework.http.HttpStatus.NOT_FOUND;
import static org.springframework.http.HttpStatus.UNAUTHORIZED;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class GetFileController extends FileController {
Sonia Zorba's avatar
Sonia Zorba committed

Sonia Zorba's avatar
Sonia Zorba committed
    private static final Logger LOG = LoggerFactory.getLogger(GetFileController.class);

Sonia Zorba's avatar
Sonia Zorba committed
    @Autowired
    private FileDAO fileDAO;

    @Autowired
    private AuthorizationService authorizationService;
Sonia Zorba's avatar
Sonia Zorba committed

    @Autowired
    private HttpServletResponse response;

    @GetMapping("/**")
    public ResponseEntity<?> getFile() {

        String path = getPath();
        LOG.debug("getFile called for path {}", path);
Sonia Zorba's avatar
Sonia Zorba committed
        Optional<FileInfo> optFileInfo = fileDAO.getFileInfo(path);

        if (optFileInfo.isPresent()) {

            FileInfo fileInfo = optFileInfo.get();

            if (!authorizationService.isDownloadable(fileInfo, (TokenPrincipal) request.getUserPrincipal())) {
Sonia Zorba's avatar
Sonia Zorba committed
                return new ResponseEntity<>("Unauthorized", UNAUTHORIZED);
            }

            return getFileResponse(fileInfo);
        } else {
            return new ResponseEntity<>("File " + path + " not found", NOT_FOUND);
        }
    }

    private ResponseEntity<?> getFileResponse(FileInfo fileInfo) {

        File file = new File(fileInfo.getOsPath());
        String vosName = fileInfo.getVirtualPath() == null ? null
                : fileInfo.getVirtualPath().substring(fileInfo.getVirtualPath().lastIndexOf("/") + 1);
Sonia Zorba's avatar
Sonia Zorba committed

        return FileResponseUtil.getFileResponse(response, file, vosName);
Sonia Zorba's avatar
Sonia Zorba committed
    }
}