653. (ios/swift5) [Soto 7.2.0] AWS KVS listStreams 생성 된 비디오 스트림 리스트 확인

---

[개발 환경 설정]

​

개발 툴 : XCODE

개발 언어 : SWIFT5

​

 

---

[소스 코드]

​

// --------------------------------------------------------------------------------------
[개발 및 테스트 환경]
// --------------------------------------------------------------------------------------

- 언어 : Swift5

- 개발 툴 : Xcode

- 기술 구분 : Soto / AWS / KVS / KinesisVideo

// --------------------------------------------------------------------------------------






// --------------------------------------------------------------------------------------
[소스 코드]
// --------------------------------------------------------------------------------------

import Foundation
import UIKit

import SotoCore
import SotoS3
import SotoKinesisVideo

class C_Aws_Kvs_Module: NSObject {
    
 
    // -----------------------------------------------------------------------------------------
    // MARK: - [전역 변수 선언]
    // -----------------------------------------------------------------------------------------
    public static let ACTIVITY_NAME = "C_Aws_Kvs_Module"
    
    public static let AWS_IAM_CLI_ACCESS_KEY = "A..7Q"; 

    public static let AWS_IAM_CLI_SECRET_KEY = "Zz..xj"; 
    
    public static let AWS_IAM_CLI_REGION = "ap-northeast-1"; // TODO [리전]
    
    
    
    
    
    
    // -----------------------------------------------------------------------------------------
    // MARK: - [SEARCH FAST] : getKvsVideoStreamList : KVS 생성 된 비디오 스트림 리스트 확인
    // -----------------------------------------------------------------------------------------
    // TODO [Call Method]
    // ------------------------------------------------------------------------------------------
    /*
     C_Aws_Kvs_Module().getKvsVideoStreamList(accessKey: C_Aws_Kvs_Module.AWS_IAM_CLI_ACCESS_KEY, secretKey: C_Aws_Kvs_Module.AWS_IAM_CLI_SECRET_KEY, region: C_Aws_Kvs_Module.AWS_IAM_CLI_REGION){(result) in
             
             S_Log._F_(description: "KVS 생성 된 비디오 스트림 리스트 확인 결과", data: ["\(result)"])
             
     }
    */
    // ------------------------------------------------------------------------------------------
    static var streamList : Array<String> = []
    func getKvsVideoStreamList(accessKey: String, secretKey: String, region: String, completion: @escaping (Array<String>)->()) {
        
        /*
        // -----------------------------------------
        [getKvsVideoStreamList 메소드 설명]
        // -----------------------------------------
        1. KVS 생성 된 비디오 스트림 리스트 확인
        // -----------------------------------------
        2. 필요 import : package(url: "https://github.com/soto-project/soto.git", from: "7.2.0")
         
         import SotoCore
         import SotoS3
         import SotoKinesisVideo
        // -----------------------------------------
        3. 참고 사항 :
         
         AWS IAM 계정의 AccessKeyId 와 SecretAccessKey 를 가지고 있어야합니다

         해당 계정이 sts:AssumeRole 권한을 가지고 있어야합니다
        // -----------------------------------------
        */
        
        
        // [변수 초기화]
        C_Aws_Kvs_Module.streamList = []

        
        // [로직 처리 수행]
        DispatchQueue.main.async {
            
            Task { // MARK: await used
                
                S_Log._D_(description: "KVS 생성 된 비디오 스트림 리스트 확인 요청", data: [
                    "accessKey :: \(accessKey)",
                    "secretKey :: \(secretKey)",
                    "region :: \(region)"
                ])
                
                
                // [방어 로직 : input data check]
                if C_Util().stringNotNullMulti(data: [accessKey, secretKey, region]) == true {
                    
                    // ---------------------------------------------
                    // MARK: 자격 증명 직접 입력 (정적 방식)
                    // ---------------------------------------------
                    let client = AWSClient(
                        credentialProvider: .static(
                            accessKeyId: accessKey,
                            secretAccessKey: secretKey
                        )
                        //, httpClientProvider: .createNew // SDK 6.8.0 이하 버전 설정 필요
                    )
                    
                    do {
                        
                        
                        // ---------------------------------------------
                        // MARK: KinesisVideo 클라이언트 생성
                        // ---------------------------------------------
                        let kv = KinesisVideo(client: client, region: Region(rawValue: region))
                        
                        
                        // ---------------------------------------------
                        // MARK: ListStreamsInput 요청 생성
                        // ---------------------------------------------
                        let request = KinesisVideo.ListStreamsInput(maxResults: 30)
                        
                        
                        // ---------------------------------------------
                        // MARK: 스트림 리스트 요청

                        // ---------------------------------------------
                        let response = try await kv.listStreams(request)
                        
                        S_Log._W_(description: C_Aws_Kvs_Module.ACTIVITY_NAME + " :: getKvsVideoStreamList :: Http End", data: nil )
                        
                        
                        // ---------------------------------------------
                        // MARK: streamInfoList 확인
                        // ---------------------------------------------
                        if let streams = response.streamInfoList {
                            
                            for stream in streams {
                                print("Stream Name - \(stream.streamName ?? "")")
                                
                                C_Aws_Kvs_Module.streamList.append("\(stream.streamName ?? "")") // [Add List]
                            }
                            
                            S_Log._W_(description: C_Aws_Kvs_Module.ACTIVITY_NAME + " :: getKvsVideoStreamList :: Success", data: ["\(C_Aws_Kvs_Module.streamList)"])
                            
                            completion( C_Aws_Kvs_Module.streamList ) // [Return CallBack]
                        }
                        else {
                            S_Log._E_(description: C_Aws_Kvs_Module.ACTIVITY_NAME + " :: getKvsVideoStreamList :: response.streamInfoList Is Null", data: nil)
                            
                            completion( C_Aws_Kvs_Module.streamList ) // [Return CallBack]
                        }
                        
                    } catch {
                        S_Log._E_(description: C_Aws_Kvs_Module.ACTIVITY_NAME + " :: getKvsVideoStreamList :: Exception", data: [ "\(error)" ] )
                        
                        // ---------------------------------------------
                        // MARK: PermanentRedirect: The bucket you are attempting to access must be addressed using the specified endpoint. Please send all future requests to this endpoint.
                        // ---------------------------------------------
                        // MARK: AWSClient 초기화 액세스 키 정보가 올바르지 않거나, region 에 버킷이 없는 경우 에러 발생
                        // ---------------------------------------------
                        
                        completion(C_Aws_Kvs_Module.streamList) // [Return CallBack]
                        
                    }
                    
                    // ---------------------------------------------
                    // MARK: AWSClient 리소스 정리 반드시 필요 (SotoCore/AWSClient.swift:105: Assertion failed: AWSClient not shut down before the deinit. Please call client.syncShutdown() when no longer needed.)
                    // ---------------------------------------------
                    try await client.shutdown()
                }
                else {
                    S_Log._E_(description: C_Aws_Kvs_Module.ACTIVITY_NAME + " :: getKvsVideoStreamList :: Error", data: [ "Input Data Is Null" ] )
                    
                    completion(C_Aws_Kvs_Module.streamList) // [Return CallBack]
                    
                }
                
            }
        }
    }
    
    
} // [클래스 종료]

// --------------------------------------------------------------------------------------





// --------------------------------------------------------------------------------------
[참고 사이트]
// --------------------------------------------------------------------------------------

[Soto] SPM 사용해 Soto 라이브러리 ( AWS 기능 사용 ) 설치 방법 정리

https://blog.naver.com/kkh0977/223922887762


[간단 설명] SPM (Swift Package Manager) 사용해 특정 라이브러리 버전 변경 및 업데이트 방법

https://blog.naver.com/kkh0977/223600587894?trackingCode=blog_bloghome_searchlist


[Soto Git 다운로드 주소]

https://github.com/soto-project/soto.git


[Soto 라이브러리 release 버전 참고]

https://github.com/soto-project/soto/releases?page=1

// --------------------------------------------------------------------------------------

 

---

[참고 사이트]

​

https://blog.naver.com/kkh0977/223922887762

640. (ios/swift5) [Soto] SPM 사용해 Soto 라이브러리 ( AWS 기능 사용 ) 설치 방법 정리

---