407 lines
16 KiB
Swift
407 lines
16 KiB
Swift
import Flutter
|
|
import UIKit
|
|
import GoogleCast
|
|
|
|
public class SwiftFlutterCastFrameworkPlugin: NSObject, FlutterPlugin, GCKSessionManagerListener, CastHostApi, GCKRemoteMediaClientListener {
|
|
public static func register(with registrar: FlutterPluginRegistrar) {
|
|
let messenger : FlutterBinaryMessenger = registrar.messenger()
|
|
let flutterApi = CastFlutterApi.init(binaryMessenger: messenger)
|
|
|
|
let instance = SwiftFlutterCastFrameworkPlugin(flutterApi: flutterApi)
|
|
|
|
let channel = FlutterMethodChannel(name: "flutter_cast_framework_dummy_channel", binaryMessenger: messenger)
|
|
registrar.addMethodCallDelegate(instance, channel: channel)
|
|
|
|
let api : CastHostApi & NSObjectProtocol = instance
|
|
CastHostApiSetup(messenger, api)
|
|
}
|
|
|
|
private let castContext: GCKCastContext
|
|
private var castStateObserver: NSKeyValueObservation?
|
|
private let flutterApi : CastFlutterApi
|
|
private var progressTimer: Timer?
|
|
|
|
private let sessionManager: GCKSessionManager
|
|
|
|
private var castingChannels: Dictionary<String, MessageCastingChannel> = [:]
|
|
|
|
var _castSession: GCKCastSession?
|
|
var castSession: GCKCastSession? {
|
|
get { return _castSession }
|
|
set {
|
|
debugPrint("Updating castSession - castSession changed: \(_castSession != newValue)")
|
|
|
|
let oldSession = _castSession
|
|
let newSession = newValue
|
|
|
|
_castSession = newValue
|
|
|
|
remoteMediaClient = newValue?.remoteMediaClient
|
|
|
|
flutterApi.getSessionMessageNamespaces { (namespaces, err) in
|
|
debugPrint("Updating castSession - getSessionMessageNamespaces success - param: \(namespaces.joined(separator: ", "))")
|
|
if (oldSession == nil && newSession == nil) {
|
|
return // nothing to do here
|
|
}
|
|
|
|
if (namespaces.count == 0) {
|
|
return // nothing to do here
|
|
}
|
|
|
|
// removing castingChannels from old session
|
|
if (oldSession != nil && self.castingChannels.count != 0) {
|
|
self.castingChannels.values.forEach { (castingChannel) in
|
|
oldSession?.remove(castingChannel)
|
|
}
|
|
}
|
|
|
|
namespaces.forEach({ (namespace) in
|
|
let castingChannel = MessageCastingChannel.init(namespace: namespace, flutterApi: self.flutterApi)
|
|
self.castingChannels[namespace] = castingChannel
|
|
newSession?.add(castingChannel)
|
|
})
|
|
}
|
|
}
|
|
}
|
|
|
|
var _remoteMediaClient: GCKRemoteMediaClient?
|
|
var remoteMediaClient: GCKRemoteMediaClient? {
|
|
get { return _remoteMediaClient }
|
|
set {
|
|
debugPrint("Updating remoteMediaClient - remoteMediaClient changed: \(_remoteMediaClient != newValue)")
|
|
|
|
_remoteMediaClient?.remove(self)
|
|
newValue?.add(self)
|
|
|
|
_remoteMediaClient = newValue
|
|
}
|
|
}
|
|
|
|
init(flutterApi : CastFlutterApi) {
|
|
self.castContext = GCKCastContext.sharedInstance()
|
|
self.sessionManager = GCKCastContext.sharedInstance().sessionManager
|
|
|
|
self.flutterApi = flutterApi
|
|
|
|
super.init()
|
|
|
|
self.castSession = GCKCastContext.sharedInstance().sessionManager.currentCastSession
|
|
self.castStateObserver = GCKCastContext.sharedInstance().observe(\.castState, changeHandler: onCastStateChanged)
|
|
|
|
let notificationCenter = NotificationCenter.default
|
|
let app = UIApplication.shared
|
|
notificationCenter.addObserver(self, selector: #selector(appDidBecomeActive), name: UIApplication.didBecomeActiveNotification, object: app)
|
|
notificationCenter.addObserver(self, selector: #selector(appWillResignActive), name: UIApplication.willResignActiveNotification, object: app)
|
|
//notificationCenter.addObserver(self, selector: #selector(appDidEnterBackground), name: NSNotification.Name.UIApplicationDidEnterBackground, object: app)
|
|
//notificationCenter.addObserver(self, selector: #selector(appWillEnterForeground), name: NSNotification.Name.UIApplicationWillEnterForeground, object: app)
|
|
//notificationCenter.addObserver(self, selector: #selector(appWillTerminate), name: NSNotification.Name.UIApplicationWillTerminate, object: app)
|
|
}
|
|
|
|
@objc func appDidBecomeActive() {
|
|
debugPrint("AppLife: appDidBecomeActive - App moved to foreground!")
|
|
self.sessionManager.add(self)
|
|
self.castSession = self.sessionManager.currentCastSession
|
|
|
|
notifyCastState(castState: GCKCastContext.sharedInstance().castState)
|
|
}
|
|
|
|
@objc func appWillResignActive() {
|
|
debugPrint("AppLife: appWillResignActive - App moved to background!")
|
|
self.sessionManager.remove(self)
|
|
self.castSession = nil
|
|
}
|
|
|
|
private func onCastStateChanged(state: GCKCastContext, change: NSKeyValueObservedChange<GCKCastState>) {
|
|
let castState = GCKCastContext.sharedInstance().castState
|
|
debugPrint("cast state change to: \(castState.rawValue)")
|
|
notifyCastState(castState: castState)
|
|
}
|
|
|
|
private func notifyCastState(castState: GCKCastState) {
|
|
let castStateRaw = castState.rawValue
|
|
// Android CastStates are 1-to-4, while iOS CastStates are 0-to-3. I align iOS to Android by adding 1
|
|
let castStateRawAdjusted = castStateRaw + 1
|
|
self.flutterApi.onCastStateChangedCastState(NSNumber(value: castStateRawAdjusted)) { (_: Error?) in
|
|
|
|
}
|
|
}
|
|
|
|
public func handle(_ call: FlutterMethodCall, result: @escaping FlutterResult) {
|
|
print("Method [\(call.method)] is not implemented.")
|
|
}
|
|
|
|
deinit {
|
|
castStateObserver?.invalidate()
|
|
castStateObserver = nil
|
|
stopProgressTImer()
|
|
}
|
|
|
|
func startProgressTimer() {
|
|
if progressTimer != nil {
|
|
return
|
|
}
|
|
|
|
if #available(iOS 10.0, *) {
|
|
debugPrint("ProgressTimer: creating progress timer")
|
|
let timer = Timer.scheduledTimer(withTimeInterval: 1, repeats: true, block: onProgressTimerFired)
|
|
RunLoop.current.add(timer, forMode: .common)
|
|
progressTimer = timer
|
|
} else {
|
|
debugPrint("ProgressTimer: can't create progress timer")
|
|
}
|
|
}
|
|
|
|
private func onProgressTimerFired(t: Timer) {
|
|
let durationSecs = remoteMediaClient?.mediaStatus?.mediaInformation?.streamDuration ?? 0
|
|
let progressInterval = remoteMediaClient?.approximateStreamPosition() ?? 0
|
|
|
|
let durationMs = Int(durationSecs * 1000)
|
|
let progressMs = Int(progressInterval * 1000)
|
|
|
|
let nsDuration = NSNumber(value: durationMs)
|
|
let nsProgress = NSNumber(value: progressMs)
|
|
|
|
DispatchQueue.main.async {
|
|
self.flutterApi.onProgressUpdatedProgressMs(nsProgress, durationMs: nsDuration) { (_:Error?) in
|
|
}
|
|
}
|
|
}
|
|
|
|
func stopProgressTImer() {
|
|
debugPrint("ProgressTimer: stopping progress timer")
|
|
progressTimer?.invalidate()
|
|
progressTimer = nil
|
|
}
|
|
|
|
public func sendMessageMessage(_ message: CastMessage, error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
|
|
MessageCastingChannel.sendMessage(allCastingChannels: self.castingChannels, castMessage: message)
|
|
}
|
|
|
|
public func showCastDialogWithError(_ error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
castContext.presentCastDialog()
|
|
}
|
|
|
|
public func loadMediaLoadRequestDataRequest(_ request: MediaLoadRequestData, error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
|
|
let remoteMediaClient = castSession?.remoteMediaClient
|
|
if remoteMediaClient == nil {
|
|
return
|
|
}
|
|
|
|
let mediaLoadRequest = getMediaLoadRequest(request: request)
|
|
remoteMediaClient?.loadMedia(with: mediaLoadRequest)
|
|
}
|
|
|
|
public func getMediaInfoWithError(_ error: AutoreleasingUnsafeMutablePointer<FlutterError?>) -> MediaInfo? {
|
|
let hostMediaInfo = remoteMediaClient?.mediaStatus?.mediaInformation
|
|
|
|
if (hostMediaInfo == nil) {
|
|
return MediaInfo()
|
|
}
|
|
|
|
return getFlutterMediaInfo(mediaInfo: hostMediaInfo)
|
|
}
|
|
|
|
public func playWithError(_ error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
remoteMediaClient?.play()
|
|
}
|
|
|
|
public func pauseWithError(_ error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
remoteMediaClient?.pause()
|
|
}
|
|
|
|
public func stopWithError(_ error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
remoteMediaClient?.stop()
|
|
}
|
|
|
|
public func setMuteMuted(_ muted: NSNumber, error: AutoreleasingUnsafeMutablePointer<FlutterError?>) {
|
|
if (castSession == nil) {
|
|
return
|
|
}
|
|
let isMuted = muted == 1
|
|
castSession?.setDeviceMuted(isMuted)
|
|
}
|
|
|
|
public func getCastDeviceWithError(_ error: AutoreleasingUnsafeMutablePointer<FlutterError?>) -> CastDevice? {
|
|
let castDevice = castSession?.device
|
|
|
|
if (castDevice == nil) {
|
|
return CastDevice()
|
|
}
|
|
|
|
let result = CastDevice()
|
|
|
|
result.deviceId = castDevice?.deviceID
|
|
result.friendlyName = castDevice?.friendlyName
|
|
result.modelName = castDevice?.modelName
|
|
|
|
return result
|
|
}
|
|
|
|
// MARK: - GCKSessionManagerListener
|
|
|
|
// onSessionSuspended
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, didSuspend session: GCKCastSession, with reason: GCKConnectionSuspendReason) {
|
|
debugPrint("SessionListener: didSuspend")
|
|
flutterApi.onSessionSuspended { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onSessionStarting
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, willStart session: GCKCastSession) {
|
|
debugPrint("SessionListener: willStart")
|
|
flutterApi.onSessionStarting { (_:Error?) in
|
|
}
|
|
|
|
castSession = session
|
|
}
|
|
|
|
// onSessionResuming
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, willResumeCastSession session: GCKCastSession) {
|
|
debugPrint("SessionListener: willResumeCastSession")
|
|
flutterApi.onSessionResuming { (_:Error?) in
|
|
}
|
|
|
|
castSession = session
|
|
}
|
|
|
|
// onSessionEnding
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, willEnd session: GCKCastSession) {
|
|
debugPrint("SessionListener: willEnd")
|
|
stopProgressTImer()
|
|
flutterApi.onSessionEnding { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onSessionStartFailed
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, didFailToStart session: GCKCastSession, withError error: Error) {
|
|
debugPrint("SessionListener: didFailToStart")
|
|
flutterApi.onSessionStartFailed { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onSessionResumeFailed - Can't find this on iOS
|
|
|
|
// onSessionStarted
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, didStart session: GCKCastSession) {
|
|
debugPrint("SessionListener: didStart")
|
|
flutterApi.onSessionStarted { (_:Error?) in
|
|
}
|
|
|
|
castSession = session
|
|
}
|
|
|
|
// onSessionResumed
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, didResumeCastSession session: GCKCastSession) {
|
|
debugPrint("SessionListener: didResumeCastSession")
|
|
flutterApi.onSessionResumed { (_:Error?) in
|
|
}
|
|
|
|
castSession = session
|
|
}
|
|
|
|
// onSessionEnded
|
|
public func sessionManager(_ sessionManager: GCKSessionManager, didEnd session: GCKCastSession, withError error: Error?) {
|
|
debugPrint("SessionListener: didEnd")
|
|
flutterApi.onSessionEnded { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onQueueStatusUpdated
|
|
public func remoteMediaClientDidUpdateQueue(_ client: GCKRemoteMediaClient) {
|
|
debugPrint("RemoteMediaClientListener: didUpdateQueue")
|
|
flutterApi.onQueueStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onPreloadStatusUpdated
|
|
public func remoteMediaClientDidUpdatePreloadStatus(_ client: GCKRemoteMediaClient) {
|
|
debugPrint("RemoteMediaClientListener: didUpdatePreloadStatus")
|
|
flutterApi.onPreloadStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onStatusUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didUpdate mediaStatus: GCKMediaStatus?) {
|
|
var playerStateLabel = ""
|
|
|
|
switch mediaStatus?.playerState {
|
|
case .unknown:
|
|
playerStateLabel = "PlayerStateUnknown"
|
|
case .idle:
|
|
playerStateLabel = "PlayerStateIdle"
|
|
case .playing:
|
|
playerStateLabel = "PlayerStatePlaying"
|
|
startProgressTimer()
|
|
case .paused:
|
|
playerStateLabel = "PlayerStatePaused"
|
|
startProgressTimer()
|
|
case .buffering:
|
|
playerStateLabel = "PlayerStateBuffering"
|
|
startProgressTimer()
|
|
case .loading:
|
|
playerStateLabel = "PlayerStateLoading"
|
|
startProgressTimer()
|
|
default: break
|
|
}
|
|
|
|
debugPrint("RemoteMediaClientListener: didUpdate mediaStatus - playerState: \(playerStateLabel)")
|
|
let playerState = mediaStatus?.playerState ?? GCKMediaPlayerState.unknown
|
|
let nsPlayerState = NSNumber(value: playerState.rawValue)
|
|
flutterApi.onStatusUpdatedPlayerStateRaw(nsPlayerState) { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onAdBreakStatusUpdated - Can't find this on iOS
|
|
// onMediaError - Can't find this on iOS
|
|
|
|
// onMetadataUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didUpdate mediaMetadata: GCKMediaMetadata?) {
|
|
debugPrint("RemoteMediaClientListener: didUpdate mediaMetadata")
|
|
flutterApi.onMetadataUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onQueueStatusUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didReceive queueItems: [GCKMediaQueueItem]) {
|
|
debugPrint("RemoteMediaClientListener: didReceive queueItems")
|
|
flutterApi.onQueueStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onSendingRemoteMediaRequest
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didStartMediaSessionWithID sessionID: Int) {
|
|
debugPrint("RemoteMediaClientListener: didStartMediaSessionWithID")
|
|
flutterApi.onSendingRemoteMediaRequest { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onQueueStatusUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didReceiveQueueItemIDs queueItemIDs: [NSNumber]) {
|
|
debugPrint("RemoteMediaClientListener: didReceiveQueueItemIDs")
|
|
flutterApi.onQueueStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onQueueStatusUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didUpdateQueueItemsWithIDs queueItemIDs: [NSNumber]) {
|
|
debugPrint("RemoteMediaClientListener: didUpdateQueueItemsWithIDs")
|
|
flutterApi.onQueueStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onQueueStatusUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didRemoveQueueItemsWithIDs queueItemIDs: [NSNumber]) {
|
|
debugPrint("RemoteMediaClientListener: didRemoveQueueItemsWithIDs")
|
|
flutterApi.onQueueStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
|
|
// onQueueStatusUpdated
|
|
public func remoteMediaClient(_ client: GCKRemoteMediaClient, didInsertQueueItemsWithIDs queueItemIDs: [NSNumber], beforeItemWithID beforeItemID: UInt) {
|
|
debugPrint("RemoteMediaClientListener: didInsertQueueItemsWithIDs")
|
|
flutterApi.onQueueStatusUpdated { (_:Error?) in
|
|
}
|
|
}
|
|
}
|