126. (TWOK/UTIL) [Android/Java] C_FirebaseStorageService : 파이어베이스 Storage 스토리지 관리 클래스

---

[설 명]

​

프로그램 : Android / Java

​

설 명 : C_FirebaseStorageService : 파이어베이스 Storage 스토리지 관리 클래스

 

---

[소스 코드]

 

package com.example.javaproject.C_Firebase;

import android.app.Activity;
import android.content.Context;
import android.net.Uri;

import androidx.annotation.NonNull;

import com.example.javaproject.C_Permission;
import com.example.javaproject.C_Util;
import com.example.javaproject.S_Log;
import com.google.android.gms.tasks.OnCompleteListener;
import com.google.android.gms.tasks.OnFailureListener;
import com.google.android.gms.tasks.OnSuccessListener;
import com.google.android.gms.tasks.Task;
import com.google.firebase.remoteconfig.FirebaseRemoteConfig;
import com.google.firebase.remoteconfig.FirebaseRemoteConfigSettings;
import com.google.firebase.storage.FirebaseStorage;
import com.google.firebase.storage.ListResult;
import com.google.firebase.storage.StorageReference;
import com.google.firebase.storage.UploadTask;

import java.io.File;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;

import io.reactivex.rxjava3.core.Observable;

public class C_FirebaseStorageService {


    /**
     * // --------------------------------------------------------------------------------------
     * TODO [클래스 설명]
     * // --------------------------------------------------------------------------------------
     * 1. 파이어베이스 Storage 스토리지 관리 클래스
     * // --------------------------------------------------------------------------------------
     * 2. 참고 사이트 (기본 Storage 설명) : https://firebase.google.com/docs/storage?hl=ko&_gl=1*1ylydtb*_up*MQ..*_ga*MTk1MzY3OTg4OS4xNzA5NzkyODU1*_ga_CW55HF8NVT*MTcwOTc5Mjg1NS4xLjAuMTcwOTc5Mjg1NS4wLjAuMA..
     * // --------------------------------------------------------------------------------------
     * 3. 참고 사이트 (Storage 비용 설명) : https://firebase.google.com/pricing?hl=ko
     * // --------------------------------------------------------------------------------------
     * 4. 참고 사이트 (Storage 생성 방법) : https://blog.naver.com/kkh0977/223376155889
     * // --------------------------------------------------------------------------------------
     * 5. TODO 서비스 적용 방법 :
     *
     *   - 안드로이드에서 사전 파일 외부 저장소 접근 파일 읽기, 쓰기 권한 필요
     *   - 파이베이스 콘솔 프로젝트 생성
     *   - googole.json 파일 프로젝트에 추가
     *   - 구글 서비스 의존성 추가 (bom:32.3.1)
     *      : implementation 'com.google.firebase:firebase-storage:20.2.1' // [Storage]
     * // --------------------------------------------------------------------------------------
     * */





    /**
     * // --------------------------------------------------------------------------------------
     * TODO [빠른 로직 찾기 : 주석 로직 찾기]
     * // --------------------------------------------------------------------------------------
     * // [SEARCH FAST] : [Observable] : [Save File] : 특정 파일 Storage 에 저장
     * // --------------------------------------------------------------------------------------
     * // [SEARCH FAST] : [Observable] : [Get File List] : Storage 에 저장 된 파일 리스트 확인
     * // --------------------------------------------------------------------------------------
     * // [SEARCH FAST] : [Observable] : [File DownLoad Url] : 특정 파일 다운 로드 URL 확인
     * // --------------------------------------------------------------------------------------
     *
     * // --------------------------------------------------------------------------------------
     *
     * // --------------------------------------------------------------------------------------
     */





    // -----------------------------------------------------------------------------------------
    // TODO [전역 변수 선언]
    // -----------------------------------------------------------------------------------------
    private static final String ACTIVITY_NAME = "C_FirebaseStorageService";





    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [Observable] : [Save File] : 특정 파일 Storage 에 저장
    // -----------------------------------------------------------------------------------------
    // TODO [호출 방법 소스 코드]
    // -----------------------------------------------------------------------------------------
    /*
    try {
        // [외부 저장소 특정 파일 경로 지정]
        String filePath = C_App.externalCommonDownloadPath() + "/" + "LOG_SAVE_FOLDER" + "/" + "APP_CRASH_LOG.txt";
        String fileName = "CRASH_LOG.txt";

        C_FirebaseStorageService.observableStorageSaveFile(A_Webview.this, filePath, fileName)
                .subscribeOn(AndroidSchedulers.mainThread()) // [Observable (생성자) 로직을 IO 스레드에서 실행 : 백그라운드]
                .observeOn(Schedulers.io()) // [Observer (관찰자) 로직을 메인 스레드에서 실행]
                .subscribe(new Observer<Boolean>() { // [Observable.create 타입 지정]
                    @Override
                    public void onSubscribe(@NonNull Disposable d) {
                    }
                    @Override
                    public void onNext(@NonNull Boolean value) {
                    }
                    @Override
                    public void onError(@NonNull Throwable e) {
                    }
                    @Override
                    public void onComplete() {
                    }
                });
    }
    catch (Exception e){
        e.printStackTrace();
    }
    */
    // -----------------------------------------------------------------------------------------
    public static Observable<Boolean> observableStorageSaveFile(Context mContext, String filePath, String fileName){

        // [로직 처리 실시]
        return Observable.create(subscriber -> {

            try {
                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 수행", new String[]{ "filePath :: " + String.valueOf(filePath), "fileName :: " + String.valueOf(fileName) });

                // [방어 로직] : 널 체크
                if (C_Util.stringNotNull(filePath) == true && C_Util.stringNotNull(fileName) == true){

                    // [사전) 모든 파일 접근 권한 상태 체크]
                    if (C_Permission.getFileAccessPermissionEnable(mContext) == true){

                        // [File 변경]
                        File file = new File(filePath);

                        if (file.exists() == true){ // [해당 파일 존재]

                            Uri uri_file = Uri.fromFile(file); // [파일 Uri 지정]

                            FirebaseStorage storage = FirebaseStorage.getInstance(); // [인스턴스 생성]

                            StorageReference storageReference = storage.getReference(); // [Storage 저장 장소 및 파일 명칭 지정]
                            StorageReference riversRef = storageReference.child("/"+String.valueOf(fileName));

                            UploadTask uploadTask = riversRef.putFile(uri_file); // [Storage 파일 업로드]

                            // [업로드 핸들러]
                            uploadTask.addOnFailureListener(new OnFailureListener() {
                                @Override
                                public void onFailure(@NonNull Exception e) {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 에러", new String[]{ "Firebase Upload Error :: " + String.valueOf(e.getMessage()) });

                                    subscriber.onNext(false);
                                    subscriber.onComplete();
                                }
                            }).addOnSuccessListener(new OnSuccessListener<UploadTask.TaskSnapshot>() {
                                @Override
                                public void onSuccess(UploadTask.TaskSnapshot taskSnapshot) {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 성공", null);

                                    subscriber.onNext(true);
                                    subscriber.onComplete();
                                }
                            });
                        }
                        else { // [해당 파일 없음]

                            S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 에러", new String[]{ "ERROR :: File Not Exists" });

                            subscriber.onNext(false);
                            subscriber.onComplete();

                        }

                    }
                    else {
                        S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 에러", new String[]{ "ERROR :: File Permission Check Error" });

                        subscriber.onNext(false);
                        subscriber.onComplete();

                    }
                }
                else {
                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 에러", new String[]{ "ERROR :: Input Data Is Null" });

                    subscriber.onNext(false);
                    subscriber.onComplete();

                }

            } catch (final Exception e){
                S_Log._printStackTrace_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] [Exception]", null, e);

                // ------------------------------------------------------
                // TODO [리턴 데이터 반환]
                // ------------------------------------------------------
                try {
                    subscriber.onNext(false);
                    subscriber.onComplete();
                }
                catch (Exception ex){
                    ex.printStackTrace();
                }
            }

        });
    }





    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [Observable] : [Get File List] : Storage 에 저장 된 파일 리스트 확인
    // -----------------------------------------------------------------------------------------
    // TODO [호출 방법 소스 코드]
    // -----------------------------------------------------------------------------------------
    /*
    try {
        // [파이어베이스 저장소 경로 지정]
        String filePath = "/";

        C_FirebaseStorageService.observableStorageGetFileList(A_Webview.this, filePath)
                .subscribeOn(AndroidSchedulers.mainThread()) // [Observable (생성자) 로직을 IO 스레드에서 실행 : 백그라운드]
                .observeOn(Schedulers.io()) // [Observer (관찰자) 로직을 메인 스레드에서 실행]
                .subscribe(new Observer<ArrayList<String>>() { // [Observable.create 타입 지정]
                    @Override
                    public void onSubscribe(@NonNull Disposable d) {
                    }
                    @Override
                    public void onNext(@NonNull ArrayList<String> value) {
                    }
                    @Override
                    public void onError(@NonNull Throwable e) {
                    }
                    @Override
                    public void onComplete() {
                    }
                });
    }
    catch (Exception e){
        e.printStackTrace();
    }
    */
    // -----------------------------------------------------------------------------------------
    public static Observable<ArrayList<String>> observableStorageGetFileList(Context mContext, String filePath){

        // [리턴 변수 선언]
        ArrayList<String> returnData = new ArrayList<>();

        // [로직 처리 실시]
        return Observable.create(subscriber -> {

            try {
                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 목록 확인", new String[]{ "filePath :: " + String.valueOf(filePath) });

                // [방어 로직] : 널 체크
                if (C_Util.stringNotNull(filePath) == true){

                    FirebaseStorage storage = FirebaseStorage.getInstance(); // [인스턴스 생성]

                    StorageReference storageReference = storage.getReference(); // [Storage 저장 장소 지정]
                    StorageReference riversRef = storageReference.child(filePath);

                    // [파이어베이스에 저장된 파일 확인]
                    riversRef.listAll().addOnFailureListener(new OnFailureListener() {
                        @Override
                        public void onFailure(@NonNull Exception e) {
                            S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 목록 확인 에러", new String[]{ "Firebase Get File List :: " + String.valueOf(e.getMessage()) });

                            subscriber.onNext(returnData);
                            subscriber.onComplete();
                        }
                    }).addOnSuccessListener(new OnSuccessListener<ListResult>() {
                        @Override
                        public void onSuccess(ListResult listResult) {
                            if (listResult != null && listResult.getItems().size() > 0){
                                for (StorageReference item : listResult.getItems()) {
                                    returnData.add(item.getName()); // [리턴 배열에 추가]
                                }
                                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 목록 확인 성공", new String[]{ String.valueOf(returnData) });

                                subscriber.onNext(returnData);
                                subscriber.onComplete();
                            }
                            else {
                                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 목록 없음", new String[]{ "Reason :: listResult Is Null" });

                                subscriber.onNext(returnData);
                                subscriber.onComplete();
                            }
                        }
                    });

                }
                else {
                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 저장 목록 확인 에러", new String[]{ "ERROR :: Input Data Is Null" });

                    subscriber.onNext(returnData);
                    subscriber.onComplete();

                }

            } catch (final Exception e){
                S_Log._printStackTrace_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] [Exception]", null, e);

                // ------------------------------------------------------
                // TODO [리턴 데이터 반환]
                // ------------------------------------------------------
                try {
                    subscriber.onNext(returnData);
                    subscriber.onComplete();
                }
                catch (Exception ex){
                    ex.printStackTrace();
                }
            }

        });
    }





    // -----------------------------------------------------------------------------------------
    // TODO [SEARCH FAST] : [Observable] : [File DownLoad Url] : 특정 파일 다운 로드 URL 확인
    // -----------------------------------------------------------------------------------------
    // TODO [호출 방법 소스 코드]
    // -----------------------------------------------------------------------------------------
    /*
    try {
        // [파이어베이스 저장소 경로 및 명칭 지정]
        String filePath = "/";
        String fileName = "DEBUG_LOG.txt";

        C_FirebaseStorageService.observableFileDownUrl(A_Webview.this, filePath, fileName)
                .subscribeOn(AndroidSchedulers.mainThread()) // [Observable (생성자) 로직을 IO 스레드에서 실행 : 백그라운드]
                .observeOn(Schedulers.io()) // [Observer (관찰자) 로직을 메인 스레드에서 실행]
                .subscribe(new Observer<String>() { // [Observable.create 타입 지정]
                    @Override
                    public void onSubscribe(@NonNull Disposable d) {
                    }
                    @Override
                    public void onNext(@NonNull String value) {
                    }
                    @Override
                    public void onError(@NonNull Throwable e) {
                    }
                    @Override
                    public void onComplete() {
                    }
                });
    }
    catch (Exception e){
        e.printStackTrace();
    }
    */
    // -----------------------------------------------------------------------------------------
    public static Observable<String> observableFileDownUrl(Context mContext, String filePath, String fileName){

        // [로직 처리 실시]
        return Observable.create(subscriber -> {

            try {
                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 확인", new String[]{ "filePath :: " + String.valueOf(filePath), "fileName :: " + String.valueOf(fileName) });

                // [방어 로직] : 널 체크
                if (C_Util.stringNotNull(filePath) == true){

                    FirebaseStorage storage = FirebaseStorage.getInstance(); // [인스턴스 생성]

                    StorageReference storageReference = storage.getReference(); // [Storage 저장 장소 지정]
                    StorageReference riversRef = storageReference.child(filePath);

                    // [파이어베이스에 저장된 파일 확인]
                    riversRef.listAll().addOnFailureListener(new OnFailureListener() {
                        @Override
                        public void onFailure(@NonNull Exception e) {
                            S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 확인 에러", new String[]{ "Firebase Get File List :: " + String.valueOf(e.getMessage()) });

                            subscriber.onNext("");
                            subscriber.onComplete();
                        }
                    }).addOnSuccessListener(new OnSuccessListener<ListResult>() {
                        @Override
                        public void onSuccess(ListResult listResult) {
                            if (listResult != null && listResult.getItems().size() > 0){

                                boolean fileSearchFlag = false;
                                StorageReference search_item = null;

                                for (StorageReference item : listResult.getItems()) {
                                    if (String.valueOf(item.getName()).equals(fileName) == true){
                                        fileSearchFlag = true; // [플래그 값 변경]
                                        search_item = item; // [아이템 값 삽입]
                                        break;
                                    }
                                }

                                if (fileSearchFlag == true){ // [해당 파일 존재할 경우]

                                    search_item.getDownloadUrl().addOnFailureListener(new OnFailureListener() {
                                        @Override
                                        public void onFailure(@NonNull Exception e) {
                                            S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 확인 에러", new String[]{ "Firebase Get File Url :: " + String.valueOf(e.getMessage()) });

                                            subscriber.onNext("");
                                            subscriber.onComplete();
                                        }
                                    }).addOnSuccessListener(new OnSuccessListener<Uri>() {
                                        @Override
                                        public void onSuccess(Uri uri) {

                                            if (uri != null && uri.toString().length()>0){

                                                String fileUrl = String.valueOf(uri.toString());

                                                if (fileUrl.startsWith("http") == true && fileUrl.contains("firebase") == true){
                                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 확인 성공 [1]", new String[]{ String.valueOf(fileUrl) });

                                                    subscriber.onNext(String.valueOf(fileUrl));
                                                    subscriber.onComplete();
                                                }
                                                else {
                                                    fileUrl = "https://firebasestorage.googleapis.com" + fileUrl;

                                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 확인 성공 [2]", new String[]{ String.valueOf(fileUrl) });

                                                    subscriber.onNext(String.valueOf(fileUrl));
                                                    subscriber.onComplete();
                                                }
                                            }
                                            else {
                                                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 찾을 수 없음", new String[]{ "Reason :: File Url Is Null" });

                                                subscriber.onNext("");
                                                subscriber.onComplete();
                                            }
                                        }
                                    });
                                }
                                else {
                                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 찾을 수 없음", new String[]{ "Reason :: File Search Not Found" });

                                    subscriber.onNext("");
                                    subscriber.onComplete();
                                }
                            }
                            else {
                                S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 목록 없음", new String[]{ "Reason :: listResult Is Null" });

                                subscriber.onNext("");
                                subscriber.onComplete();
                            }
                        }
                    });

                }
                else {
                    S_Log._F_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] 파일 다운 URL 확인 에러", new String[]{ "ERROR :: Input Data Is Null" });

                    subscriber.onNext("");
                    subscriber.onComplete();

                }

            } catch (final Exception e){
                S_Log._printStackTrace_(mContext, ACTIVITY_NAME + " : [Firebase] [Storage] [Exception]", null, e);

                // ------------------------------------------------------
                // TODO [리턴 데이터 반환]
                // ------------------------------------------------------
                try {
                    subscriber.onNext("");
                    subscriber.onComplete();
                }
                catch (Exception ex){
                    ex.printStackTrace();
                }
            }

        });
    }


} // TODO [클래스 종료]

---