import ReplayKit.broadcast
class ViewController: UIViewController {
	var broadcastPicker: RPSystemBroadcastPickerView?
	override func viewDidLoad() {
	super.viewDidLoad()
	broadcastPicker = RPSystemBroadcastPickerView(frame: kPickerFrame)
	broadcastPicker.preferredExtension = “com.your-app.broadcast.extension”
}

// SampleHandler created by Xcode templates for Upload Extension
class SampleHandler: RPBroadcastSampleHandler {
// User has requested to start the broadcast
override func broadcastStarted(withSetupInfo setupInfo: [String : NSObject]?)
// User has requested to finish the broadcast
override func broadcastFinished()
// Handle the sample buffer here
override func processSampleBuffer(_ sampleBuffer: CMSampleBuffer,
with sampleBufferType: RPSampleBufferType)
// Use details of application to annotate the broadcast
override func broadcastAnnotated(withApplicationInfo info: [String : NSObject])
}

// Override init to read login credentials from shared keychain
class SampleHandler : RPBroadcastSampleHandler {
	override func init() {
		super.init()
		session = BroadcastSession.instance
		var credentials = KeychainAccess.getLoginCredentials()
		session.authentificate(credentials)
	}
}

// Override broadcastStarted to prepare to receive media samples
override func broadcastStarted(withSetupInfo setupInfo: [String : NSObject]?) {
	// Verify user is logged in and there’s network connectivity
	if (session.userLoggedIn()) {
		session.createMediaEngine()
	} else {
		let userInfo = [NSLocalizedFailureReasonErrorKey : "Not Logged In"]
		let error = NSError(domain: "RPBroadcastErrorDomain", code: 401, userInfo: userInfo)
		finishBroadcastWithError(error)
	}
}

// Both audio and video samples are handled by processSampleBuffer routine
override func processSampleBuffer(_ sampleBuffer: CMSampleBuffer,
with sampleBufferType: RPSampleBufferType) {
	switch sampleBufferType {
		case RPSampleBufferType.video:
			var imageBuffer:CVImageBuffer = CMSampleBufferGetImageBuffer(sampleBuffer)!
			var pts = CMSampleBufferGetPresentationTimeStamp(sampleBuffer) as CMTime
			VTCompressionSessionEncodeFrame(session, imageBuffer, pts,
			break
		case RPSampleBufferType.audioApp:
			kCMTimeInvalid, nil, nil, nil)
			// Handle audio sample buffer for app audio
			break
		case RPSampleBufferType.audioMic:
			// Handle audio sample buffer for mic audio
			break
	}
}

// Use application details to help users find your broadcast
override func broadcastAnnotated(withApplicationInfo applicationInfo: [AnyHashable : Any]) {
	var bundleIdentifier = applicationInfo[RPApplicationInfoBundleIdentifierKey]
	if (bundleIdentifier != nil) {
		session.addMetadataWithApplicationInfo(bundleIdentifier)
	}
}

override func broadcastFinished() {
	// User has requested to finish the broadcast.
}

// Protecting content of your application from being captured
import UIKit
class func handleScreenCapturedChange() {
	let isScreenMirroring = UIScreen.screens.count > 1
	if (UIScreen.isCaptured && !isScreenMirroring) {
	}
	// stop audio playback and remove sensitive content from the screen
}

//发送通知
sendNotificationForMessageWithIdentifier(identifier: "broadcastStarted")
func sendNotificationForMessageWithIdentifier(identifier : String) {
    let center : CFNotificationCenter = CFNotificationCenterGetDarwinNotifyCenter()
    let identifierRef : CFNotificationName = CFNotificationName(identifier as CFString)
    CFNotificationCenterPostNotification(center, identifierRef, nil, nil, true)
}

///通知回调
func callback(_ name : String) {
    print("received notification: \(name)")
}

///通知注册
func registerObserver() {
    let observer = UnsafeRawPointer(Unmanaged.passUnretained(self).toOpaque())
    CFNotificationCenterAddObserver(CFNotificationCenterGetDarwinNotifyCenter(), observer, { (_, observer, name, _, _) -> Void in
        if let observer = observer, let name = name {
            // Extract pointer to `self` from void pointer:
            let mySelf = Unmanaged<OTCAppealVC>.fromOpaque(observer).takeUnretainedValue()
            // Call instance method:
            mySelf.callback(name.rawValue as String)
        }
    }, "broadcastFinished" as CFString, nil,.deliverImmediately)
}

//通知移除
deinit {
    let observer = UnsafeRawPointer(Unmanaged.passUnretained(self).toOpaque())
    let cfName: CFNotificationName = CFNotificationName("broadcastFinished" as CFString)
    CFNotificationCenterRemoveObserver(CFNotificationCenterGetDarwinNotifyCenter(), observer, cfName, nil)
}

struct Log {
    static var logFilePathInContainer: String? {
        guard let group = FileManager.default.containerURL(forSecurityApplicationGroupIdentifier: "$(group_id)") else {
            return nil
        }
        guard var path = (group as NSURL).path else {
            return nil
        }
        path = (path as NSString).appendingPathComponent("xx.log")
        return path
    }
}