import AVFoundation
import Connect

ConnectCustomEvent.sharedInstance().logSignal([
    "signalType": "richMediaInteraction",
    "mediaId": "product-demo-wireless-headphones",
    "mediaName": "Wireless Headphones Demo",
    "interactionType": "LAUNCH",
    "effect": "positive"
])

#import <AVFoundation/AVFoundation.h>
#import <Connect/Connect.h>

[[ConnectCustomEvent sharedInstance] logSignal:@{
    @"signalType": @"richMediaInteraction",
    @"mediaId": @"product-demo-wireless-headphones",
    @"mediaName": @"Wireless Headphones Demo",
    @"interactionType": @"LAUNCH",
    @"effect": @"positive"
}];

import AVFoundation
import Connect

final class ProductVideoViewController: UIViewController {

    private var player: AVPlayer?
    private var playerObservation: NSKeyValueObservation?
    private var launched = false

    private let mediaId: String
    private let mediaName: String

    init(mediaId: String, mediaName: String) {
        self.mediaId = mediaId
        self.mediaName = mediaName
        super.init(nibName: nil, bundle: nil)
    }
    required init?(coder: NSCoder) { fatalError("init(coder:)") }

    override func viewDidLoad() {
        super.viewDidLoad()
        guard let url = URL(string: mediaId) else { return }

        let item = AVPlayerItem(url: url)
        let player = AVPlayer(playerItem: item)
        self.player = player

        // Embed player layer ...

        attachSignalObservers(player: player, item: item)
    }

    private func attachSignalObservers(player: AVPlayer, item: AVPlayerItem) {
        // Observe play/pause/buffer state via timeControlStatus KVO
        playerObservation = player.observe(\.timeControlStatus, options: [.new]) { [weak self] player, _ in
            guard let self else { return }
            switch player.timeControlStatus {
            case .playing:
                let interactionType = self.launched ? "CONTINUE" : "LAUNCH"
                self.launched = true
                self.sendRichMediaSignal(interactionType: interactionType)
            case .paused:
                if self.launched {
                    self.sendRichMediaSignal(interactionType: "PAUSE")
                }
            default:
                break
            }
        }

        // Observe completion via notification
        NotificationCenter.default.addObserver(
            self,
            selector: #selector(playerDidFinish),
            name: .AVPlayerItemDidPlayToEndTime,
            object: item
        )
    }

    @objc private func playerDidFinish() {
        sendRichMediaSignal(interactionType: "COMPLETE")
    }

    private func sendRichMediaSignal(interactionType: String) {
        var signal: [String: Any] = [
            "signalType": "richMediaInteraction",
            "mediaId": mediaId,
            "mediaName": mediaName,
            "interactionType": interactionType,
            "mediaCategory": "product demo",
            "effect": "positive"
        ]

        if UserSession.shared.isAuthenticated, let email = UserSession.shared.email {
            signal["audience"] = ["Email Address": email]
        }

        let accepted = ConnectCustomEvent.sharedInstance().logSignal(signal)
        NSLog("[Connect] richMediaInteraction (\(interactionType)) signal accepted: \(accepted)")
    }

    deinit {
        playerObservation?.invalidate()
        NotificationCenter.default.removeObserver(self)
    }
}

#import <AVFoundation/AVFoundation.h>
#import <Connect/Connect.h>

// Add these instance variables or properties to your view controller:
// AVPlayer *player;
// BOOL launched;
// NSString *mediaId;
// NSString *mediaName;

- (void)viewDidLoad {
    [super viewDidLoad];
    NSURL *url = [NSURL URLWithString:self.mediaId];
    if (!url) return;

    AVPlayerItem *item = [AVPlayerItem playerItemWithURL:url];
    AVPlayer *player = [AVPlayer playerWithPlayerItem:item];
    self.player = player;

    // Embed player layer ...

    [player addObserver:self
             forKeyPath:@"timeControlStatus"
                options:NSKeyValueObservingOptionNew
                context:nil];

    [[NSNotificationCenter defaultCenter] addObserver:self
                                             selector:@selector(playerDidFinish)
                                                 name:AVPlayerItemDidPlayToEndTimeNotification
                                               object:item];
}

- (void)observeValueForKeyPath:(NSString *)keyPath
                      ofObject:(id)object
                        change:(NSDictionary *)change
                       context:(void *)context {
    if ([keyPath isEqualToString:@"timeControlStatus"] && object == self.player) {
        NSInteger status = [change[NSKeyValueChangeNewKey] integerValue];
        if (status == AVPlayerTimeControlStatusPlaying) {
            NSString *interactionType = self.launched ? @"CONTINUE" : @"LAUNCH";
            self.launched = YES;
            [self sendRichMediaSignalWithInteractionType:interactionType];
        } else if (status == AVPlayerTimeControlStatusPaused) {
            if (self.launched) {
                [self sendRichMediaSignalWithInteractionType:@"PAUSE"];
            }
        }
    }
}

- (void)playerDidFinish {
    [self sendRichMediaSignalWithInteractionType:@"COMPLETE"];
}

- (void)sendRichMediaSignalWithInteractionType:(NSString *)interactionType {
    NSMutableDictionary *signal = [@{
        @"signalType": @"richMediaInteraction",
        @"mediaId": self.mediaId,
        @"mediaName": self.mediaName,
        @"interactionType": interactionType,
        @"mediaCategory": @"product demo",
        @"effect": @"positive"
    } mutableCopy];

    if ([[UserSession shared] isAuthenticated] && [[UserSession shared] email]) {
        signal[@"audience"] = @{ @"Email Address": [[UserSession shared] email] };
    }

    BOOL accepted = [[ConnectCustomEvent sharedInstance] logSignal:signal];
    NSLog(@"[Connect] richMediaInteraction (%@) signal accepted: %@",
          interactionType, accepted ? @"true" : @"false");
}

- (void)dealloc {
    [self.player removeObserver:self forKeyPath:@"timeControlStatus"];
    [[NSNotificationCenter defaultCenter] removeObserver:self];
}