添加token验证

Author: zhaoyongqiang

iOS/APIExample.xcodeproj/project.pbxproj

@@ -127,6 +127,9 @@
 		A7CA48C424553CF700507435 /* Popover.storyboard in Resources */ = {isa = PBXBuildFile; fileRef = A7CA48C224553CF600507435 /* Popover.storyboard */; };
 		CBCDE23FB64E60D6A79F3723 /* Pods_Agora_ScreenShare_Extension.framework in Frameworks */ = {isa = PBXBuildFile; fileRef = 09E72C5D1AABD812866E41A6 /* Pods_Agora_ScreenShare_Extension.framework */; };
 		D4046B5D3DE984062E3F6D92 /* Pods_APIExample.framework in Frameworks */ = {isa = PBXBuildFile; fileRef = 07A781F5D5D3783CEC7C8EFA /* Pods_APIExample.framework */; };
+		E74877DD28A3602400CA2F58 /* ToastView.swift in Sources */ = {isa = PBXBuildFile; fileRef = E74877DA28A3602400CA2F58 /* ToastView.swift */; };
+		E74877DE28A3602400CA2F58 /* NetworkManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = E74877DB28A3602400CA2F58 /* NetworkManager.swift */; };
+		E74877DF28A3602400CA2F58 /* JSONObject.swift in Sources */ = {isa = PBXBuildFile; fileRef = E74877DC28A3602400CA2F58 /* JSONObject.swift */; };
 		E763A87D288E977C00FE99FA /* Util.swift in Sources */ = {isa = PBXBuildFile; fileRef = E763A87C288E977C00FE99FA /* Util.swift */; };
 		E789AAF928694D8C00851463 /* LocalAccess.strings in Resources */ = {isa = PBXBuildFile; fileRef = E789AAF428694D8C00851463 /* LocalAccess.strings */; };
 		E789AAFA28694D8C00851463 /* LocalAccess.storyboard in Resources */ = {isa = PBXBuildFile; fileRef = E789AAF628694D8C00851463 /* LocalAccess.storyboard */; };
@@ -349,6 +352,9 @@
 		A7847F932458089E00469187 /* AgoraExtension.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = AgoraExtension.swift; sourceTree = "<group>"; };
 		A7BD765F247CC6920062A6B3 /* UITypeAlias.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = UITypeAlias.swift; sourceTree = "<group>"; };
 		A7CA48C324553CF600507435 /* Base */ = {isa = PBXFileReference; lastKnownFileType = file.storyboard; name = Base; path = Base.lproj/Popover.storyboard; sourceTree = "<group>"; };
+		E74877DA28A3602400CA2F58 /* ToastView.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = ToastView.swift; sourceTree = "<group>"; };
+		E74877DB28A3602400CA2F58 /* NetworkManager.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = NetworkManager.swift; sourceTree = "<group>"; };
+		E74877DC28A3602400CA2F58 /* JSONObject.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = JSONObject.swift; sourceTree = "<group>"; };
 		E763A87C288E977C00FE99FA /* Util.swift */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.swift; path = Util.swift; sourceTree = "<group>"; };
 		E789AAF528694D8C00851463 /* zh-Hans */ = {isa = PBXFileReference; lastKnownFileType = text.plist.strings; name = "zh-Hans"; path = "zh-Hans.lproj/LocalAccess.strings"; sourceTree = "<group>"; };
 		E789AAF728694D8C00851463 /* Base */ = {isa = PBXFileReference; lastKnownFileType = file.storyboard; name = Base; path = Base.lproj/LocalAccess.storyboard; sourceTree = "<group>"; };
@@ -761,6 +767,7 @@
 		03D13BFF24488F1E00B599B3 /* Common */ = {
 			isa = PBXGroup;
 			children = (
+				E74877D928A3602400CA2F58 /* NetworkManager */,
 				67B8C7A128050EE200195106 /* Utils */,
 				0364C1FF2551B19800C6C0AE /* ARKit */,
 				0339BE73251EF728007D4FDD /* RtcChannelPublishPlugin */,
@@ -944,6 +951,16 @@
 			name = "Supporting Files";
 			sourceTree = "<group>";
 		};
+		E74877D928A3602400CA2F58 /* NetworkManager */ = {
+			isa = PBXGroup;
+			children = (
+				E74877DA28A3602400CA2F58 /* ToastView.swift */,
+				E74877DB28A3602400CA2F58 /* NetworkManager.swift */,
+				E74877DC28A3602400CA2F58 /* JSONObject.swift */,
+			);
+			path = NetworkManager;
+			sourceTree = "<group>";
+		};
 		E789AAF328694D8C00851463 /* LocalAccess */ = {
 			isa = PBXGroup;
 			children = (
@@ -1207,6 +1224,7 @@
 				036CBA47251990B400D74FAD /* AgoraCustomEncryption.h in Sources */,
 				670709A5282659B100A72FD6 /* SampleHandlerUtil.m in Sources */,
 				033A9EFF252D61E200BC26E1 /* CustomVideoSourceMediaIO.swift in Sources */,
+				E74877DF28A3602400CA2F58 /* JSONObject.swift in Sources */,
 				036CBA3F2519186300D74FAD /* StreamEncryption.swift in Sources */,
 				0339BE9625203293007D4FDD /* ScreenShare.swift in Sources */,
 				033A9F00252D61E200BC26E1 /* CustomAudioSource.swift in Sources */,
@@ -1239,6 +1257,7 @@
 				033A9EE5252D5C6900BC26E1 /* VideoMetadata.swift in Sources */,
 				8BAF3C9A2758693B0073B30E /* VideoProcess.swift in Sources */,
 				036C42BF24D5853200A59000 /* AgoraMediaRawData.m in Sources */,
+				E74877DE28A3602400CA2F58 /* NetworkManager.swift in Sources */,
 				036C42B024D2955D00A59000 /* AgoraCameraSourcePush.swift in Sources */,
 				0318857924CD667A00C699EB /* SettingsViewController.swift in Sources */,
 				F3184EFF27F85AD700FA402D /* AgoraPictureInPictureController.m in Sources */,
@@ -1247,6 +1266,7 @@
 				A7BD7660247CC6920062A6B3 /* UITypeAlias.swift in Sources */,
 				57B7FC83259C313200407BE1 /* RawAudioData.swift in Sources */,
 				03DF1D9124CFC29700DF7151 /* UIColor+CSRGB.m in Sources */,
+				E74877DD28A3602400CA2F58 /* ToastView.swift in Sources */,
 				0339BECC25210A93007D4FDD /* SuperResolution.swift in Sources */,
 				03D13C0124488F1F00B599B3 /* KeyCenter.swift in Sources */,
 				03BEED08251C35E7005E78F4 /* AudioMixing.swift in Sources */,

iOS/APIExample/Common/KeyCenter.swift

@@ -7,8 +7,10 @@
 //
 
 struct KeyCenter {
-    static let AppId: String = <#Your App Id#>
+    static let AppId: String = <#YOUR APPID#>
 
     // assign token to nil if you have not enabled app certificate
-    static var Token: String? = <#Temp Access Token#>
+    static let Certificate: String? = <#YOUR Certificate#>
+    
+    static var Token: String? = nil
 }

iOS/APIExample/Common/NetworkManager/JSONObject.swift

@@ -0,0 +1,117 @@
+//
+//  JSONObject.swift
+//  BreakoutRoom
+//
+//  Created by zhaoyongqiang on 2021/11/2.
+//
+
+import Foundation
+
+class JSONObject {
+    /// 字典转模型
+    static func toModel<T: Codable>(_ type: T.Type, value: Any?) -> T? {
+        guard let value = value else { return nil }
+        return toModel(type, value: value)
+    }
+    /// 字典转模型
+    static func toModel<T: Codable>(_ type: T.Type, value: Any) -> T? {
+        guard let data = try? JSONSerialization.data(withJSONObject: value) else { return nil }
+        let decoder = JSONDecoder()
+        decoder.nonConformingFloatDecodingStrategy = .convertFromString(positiveInfinity: "+Infinity", negativeInfinity: "-Infinity", nan: "NaN")
+        return try? decoder.decode(type, from: data)
+    }
+    /// JSON字符串转模型
+    static func toModel<T: Codable>(_ type: T.Type, value: String?) -> T? {
+        guard let value = value else { return nil }
+        return toModel(type, value: value)
+    }
+    /// JSON字符串转模型
+    static func toModel<T: Codable>(_ type: T.Type, value: String) -> T? {
+        let decoder = JSONDecoder()
+        decoder.nonConformingFloatDecodingStrategy = .convertFromString(positiveInfinity: "+Infinity", negativeInfinity: "-Infinity", nan: "NaN")
+        guard let t = try? decoder.decode(T.self, from: value.data(using: .utf8)!) else { return nil }
+        return t
+    }
+    /// 模型转JSON字符串
+    static func toJson<T: Codable>(_ model: T) -> [String: Any] {
+        let jsonString = toJsonString(model) ?? ""
+        return toDictionary(jsonString: jsonString)
+    }
+    /// 模型转JSON数组字符串
+    static func toJsonArray<T: Codable>(_ model: T) -> [[String: Any]]? {
+        let jsonString = toJsonString(model) ?? ""
+        return toArray(jsonString: jsonString)
+    }
+    /// 模型转JSON字符串
+    static func toJsonString<T: Codable>(_ model: T) -> String? {
+        let encoder = JSONEncoder()
+        encoder.outputFormatting = .prettyPrinted
+        guard let data = try? encoder.encode(model) else { return nil }
+        return String(data: data, encoding: .utf8)
+    }
+    /// JSON字符串转字典
+    static func toDictionary(jsonString: String) -> [String: Any] {
+        guard let jsonData = jsonString.data(using: .utf8) else { return [:] }
+        guard let dict = try? JSONSerialization.jsonObject(with: jsonData, options: .mutableContainers), let result = dict as? [String: Any] else { return [:] }
+        return result
+    }
+    /// JSON字符串转字典
+    static func toDictionary(jsonStr: String) -> [String: String] {
+        guard let jsonData = jsonStr.data(using: .utf8) else { return [:] }
+        guard let dict = try? JSONSerialization.jsonObject(with: jsonData, options: .mutableContainers), let result = dict as? [String: Any] else { return [:] }
+        var data = [String: String]()
+        for item in result {
+            data[item.key] = "\(item.value)"
+        }
+        return data
+    }
+    /// JSON字符串转数组
+    static func toArray(jsonString: String) -> [[String: Any]]? {
+        guard let jsonData = jsonString.data(using: .utf8) else { return nil }
+        guard let array = try? JSONSerialization.jsonObject(with: jsonData, options: .mutableContainers), let result = array as? [[String: Any]] else { return nil }
+        return result
+    }
+    /// 字典转JSON字符串
+    static func toJsonString(dict: [String: Any]?) -> String? {
+        guard let dict = dict else { return nil }
+        if (!JSONSerialization.isValidJSONObject(dict)) {
+            print("字符串格式错误！")
+            return nil
+        }
+        guard let data = try? JSONSerialization.data(withJSONObject: dict, options: []) else { return nil }
+        guard let jsonString = String(data: data, encoding: .utf8) else { return nil }
+        return jsonString
+    }
+    /// 字典数组转JSON字符串
+    static func toJsonString(array: [[String: Any]?]?) -> String? {
+        guard let array = array else { return nil }
+        var jsonString = "["
+        var i = 0
+        let count = array.count
+        for dict in array {
+            guard let dict = dict else { return nil }
+            if (!JSONSerialization.isValidJSONObject(dict)) {
+                print("字符串格式错误！")
+                return nil
+            }
+            guard let data = try? JSONSerialization.data(withJSONObject: dict, options: []) else { return nil }
+            guard let tmp = String(data: data, encoding: .utf8) else { return nil }
+            jsonString.append(tmp)
+            if i < count - 1 {
+                jsonString.append(",")
+            }
+            i = i + 1
+        }
+        jsonString.append("]")
+        return jsonString
+    }
+}
+
+extension String {
+    func toArray() -> [[String: Any]]? {
+        JSONObject.toArray(jsonString: self)
+    }
+    func toDictionary() -> [String : String] {
+       JSONObject.toDictionary(jsonStr: self)
+    }
+}

iOS/APIExample/Common/NetworkManager/NetworkManager.swift

@@ -0,0 +1,177 @@
+//
+//  NetworkManager.swift
+//  Scene-Examples
+//
+//  Created by zhaoyongqiang on 2021/11/19.
+//
+
+import UIKit
+
+class NetworkManager {
+    enum HTTPMethods: String {
+        case GET = "GET"
+        case POST = "POST"
+    }
+        
+    typealias SuccessClosure = ([String: Any]) -> Void
+    typealias FailClosure = (String) -> Void
+    
+    private lazy var sessionConfig: URLSessionConfiguration = {
+        let config = URLSessionConfiguration.default
+        config.httpAdditionalHeaders = ["Content-Type": "application/json",
+                                        "X-LC-Id": "fkUjxadPMmvYF3F3BI4uvmjo-gzGzoHsz",
+                                        "X-LC-Key": "QAvFS62IOR28GfSFQO5ze45s",
+                                        "X-LC-Session": "qmdj8pdidnmyzp0c7yqil91oc"]
+        config.timeoutIntervalForRequest = 30
+        config.timeoutIntervalForResource = 30
+        config.requestCachePolicy = .reloadIgnoringLocalCacheData
+        return config
+    }()
+    
+    static let shared = NetworkManager()
+    private init() { }
+    private let baseUrl = "https://test-toolbox.bj2.agoralab.co/v1/token/generate"
+    
+    
+    func generateToken(channelName: String, uid: UInt = 0, success: @escaping () -> Void) {
+        generateToken(channelName: channelName, uid: uid) { _ in
+            success()
+        }
+    }
+    
+    func generateToken(channelName: String, uid: UInt = 0, success: @escaping (String?) -> Void) {
+        ToastView.showWait(text: "loading...", view: nil)
+        if KeyCenter.Certificate == nil || KeyCenter.Certificate?.isEmpty == true {
+            success(nil)
+            ToastView.hidden()
+            return
+        }
+        let params = ["appCertificate": KeyCenter.Certificate ?? "",
+                      "appId": KeyCenter.AppId,
+                      "channelName": channelName,
+                      "expire": 900,
+                      "src": "iOS",
+                      "ts": "".timeStamp,
+                      "type": 1,
+                      "uid": "\(uid)"] as [String : Any]
+        NetworkManager.shared.postRequest(urlString: "https://test-toolbox.bj2.agoralab.co/v1/token/generate", params: params, success: { response in
+            let data = response["data"] as? [String: String]
+            let token = data?["token"]
+            KeyCenter.Token = token
+            print(response)
+            success(token)
+            ToastView.hidden(delay: 0.25)
+        }, failure: { error in
+            print(error)
+            success(nil)
+            ToastView.hidden(delay: 0.25)
+        })
+    }
+    
+    func getRequest(urlString: String, success: SuccessClosure?, failure: FailClosure?) {
+        DispatchQueue.global().async {
+            self.request(urlString: urlString, params: nil, method: .GET, success: success, failure: failure)
+        }
+    }
+    func postRequest(urlString: String, params: [String: Any]?, success: SuccessClosure?, failure: FailClosure?) {
+        DispatchQueue.global().async {
+            self.request(urlString: urlString, params: params, method: .POST, success: success, failure: failure)
+        }
+    }
+    
+    private func request(urlString: String,
+                         params: [String: Any]?,
+                         method: HTTPMethods,
+                         success: SuccessClosure?,
+                         failure: FailClosure?) {
+        let session = URLSession(configuration: sessionConfig)
+        guard let request = getRequest(urlString: urlString,
+                                       params: params,
+                                       method: method,
+                                       success: success,
+                                       failure: failure) else { return }
+        session.dataTask(with: request) { data, response, error in
+            DispatchQueue.main.async {
+                self.checkResponse(response: response, data: data, success: success, failure: failure)
+            }
+        }.resume()
+    }
+    
+    private func getRequest(urlString: String,
+                            params: [String: Any]?,
+                            method: HTTPMethods,
+                            success: SuccessClosure?,
+                            failure: FailClosure?) -> URLRequest? {
+        
+        let string = urlString.hasPrefix("http") ? urlString : baseUrl.appending(urlString)
+        guard let url = URL(string: string) else {
+            return nil
+        }
+        var request = URLRequest(url: url)
+        request.httpMethod = method.rawValue
+        if method == .POST {
+            request.httpBody = try? JSONSerialization.data(withJSONObject: params ?? [], options: .sortedKeys)//convertParams(params: params).data(using: .utf8)
+        }
+        let curl = request.cURL(pretty: true)
+        debugPrint("curl == \(curl)")
+        return request
+    }
+    
+    private func convertParams(params: [String: Any]?) -> String {
+        guard let params = params else { return "" }
+        let value = params.map({ String(format: "%@=%@", $0.key, "\($0.value)") }).joined(separator: "&")
+        return value
+    }
+    
+    private func checkResponse(response: URLResponse?, data: Data?, success: SuccessClosure?, failure: FailClosure?) {
+        if let httpResponse = response as? HTTPURLResponse {
+            switch httpResponse.statusCode {
+            case 200...201:
+                if let resultData = data {
+                    let result = String(data: resultData, encoding: .utf8)
+                    print(result ?? "")
+                    success?(JSONObject.toDictionary(jsonString: result ?? ""))
+                } else {
+                    failure?("Error in the request status code \(httpResponse.statusCode), response: \(String(describing: response))")
+                }
+            default:
+                failure?("Error in the request status code \(httpResponse.statusCode), response: \(String(describing: response))")
+            }
+        }
+    }
+}
+
+extension URLRequest {
+    public func cURL(pretty: Bool = false) -> String {
+        let newLine = pretty ? "\\\n" : ""
+        let method = (pretty ? "--request " : "-X ") + "\(httpMethod ?? "GET") \(newLine)"
+        let url: String = (pretty ? "--url " : "") + "\'\(url?.absoluteString ?? "")\' \(newLine)"
+        
+        var cURL = "curl "
+        var header = ""
+        var data: String = ""
+        
+        if let httpHeaders = allHTTPHeaderFields, httpHeaders.keys.count > 0 {
+            for (key,value) in httpHeaders {
+                header += (pretty ? "--header " : "-H ") + "\'\(key): \(value)\' \(newLine)"
+            }
+        }
+        
+        if let bodyData = httpBody, let bodyString = String(data: bodyData, encoding: .utf8), !bodyString.isEmpty {
+            data = "--data '\(bodyString)'"
+        }
+        
+        cURL += method + url + header + data
+        
+        return cURL
+    }
+}
+
+extension String {
+    var timeStamp: String {
+        let date = Date()
+        let timeInterval = date.timeIntervalSince1970
+        let millisecond = CLongLong(timeInterval * 1000)
+        return "\(millisecond)"
+    }
+}