Trusted Arbiter

// cloudXAd 是 CloudX 加载回调中的 CLXAd 对象。
// levelPlayAdInfo 是 Unity LevelPlay 的广告信息对象。
// pubMaticPrice 和 pubMaticPartnerName 来自 PubMatic/OpenWrap 出价对象。
CLXArbiterBid *cloudXBid = [CLXArbiterBid cloudXBidWithAd:cloudXAd];

CLXArbiterBid *levelPlayBid =
    [CLXArbiterBid levelPlayBidWithNetworkName:levelPlayAdInfo.adNetwork
                                       revenue:levelPlayAdInfo.revenue.doubleValue
                                     precision:levelPlayAdInfo.precision];

CLXArbiterBid *pubMaticBid =
    [CLXArbiterBid pubMaticBidWithPrice:pubMaticPrice
                            partnerName:pubMaticPartnerName
                                 extras:nil];

CLXArbiterConfiguration *configuration =
    [CLXArbiterConfiguration configurationWithBids:@[cloudXBid, levelPlayBid, pubMaticBid]];

[[CloudXCore shared] arbiterWithConfiguration:configuration completion:^(CLXArbiterResult *result) {
    NSLog(@"Selected platform: %@", result.platform.name);
}];

// cloudXAd 是 CloudX 加载回调中的 CLXAd 对象。
// levelPlayAdInfo 是 Unity LevelPlay 的广告信息对象。
// pubMaticPrice 和 pubMaticPartnerName 来自 PubMatic/OpenWrap 出价对象。
let cloudXBid = CLXArbiterBid.cloudX(ad: cloudXAd)

let levelPlayBid = CLXArbiterBid.levelPlay(
    networkName: levelPlayAdInfo.adNetwork,
    revenue: levelPlayAdInfo.revenue?.doubleValue ?? 0,
    precision: levelPlayAdInfo.precision
)

let pubMaticBid = CLXArbiterBid.pubMatic(
    price: pubMaticPrice,
    partnerName: pubMaticPartnerName,
    extras: nil
)

let configuration = CLXArbiterConfiguration.configuration(
    bids: [cloudXBid, levelPlayBid, pubMaticBid],
    builderBlock: nil
)

CloudXCore.shared.arbiter(with: configuration) { result in
    print("Selected platform: \(result.platform.name)")
}

func revenuePrecision(from precision: GADAdValuePrecision) -> CLXRevenuePrecision {
    switch precision {
    case .precise: return .exact
    case .estimated: return .estimated
    case .publisherProvided: return .publisherDefined
    default: return .undefined
    }
}

// Attach once to each Google ad you loaded as an arbiter candidate.
adMobInterstitial.paidEventHandler = { [weak adMobInterstitial] adValue in
    let servedBy = adMobInterstitial?.responseInfo.loadedAdNetworkResponseInfo
    let data = CLXRevenueData.revenueData(
        platform: .adMob,   // .gam for an Ad Manager ad
        revenue: adValue.value.doubleValue,
        adFormat: "interstitial"
    ) { builder in
        builder.currencyCode = adValue.currencyCode
        builder.precision = revenuePrecision(from: adValue.precision)
        builder.networkName = servedBy?.adSourceName
        builder.adUnitId = adMobAdUnitId
        builder.thirdPartyAdPlacementId = servedBy?.adSourceInstanceName
    }

    CloudXCore.shared.reportRevenueData(data)
}

static CLXRevenuePrecision *CLXRevenuePrecisionFromGAD(GADAdValuePrecision precision) {
    switch (precision) {
        case GADAdValuePrecisionPrecise: return CLXRevenuePrecision.exact;
        case GADAdValuePrecisionEstimated: return CLXRevenuePrecision.estimated;
        case GADAdValuePrecisionPublisherProvided: return CLXRevenuePrecision.publisherDefined;
        case GADAdValuePrecisionUnknown: return CLXRevenuePrecision.undefined;
    }
    return CLXRevenuePrecision.undefined;
}

// Attach once to each Google ad you loaded as an arbiter candidate.
__weak GADInterstitialAd *weakAd = adMobInterstitial;
adMobInterstitial.paidEventHandler = ^(GADAdValue *adValue) {
    GADAdNetworkResponseInfo *servedBy = weakAd.responseInfo.loadedAdNetworkResponseInfo;
    CLXRevenueData *data =
        [CLXRevenueData revenueDataWithPlatform:CLXRevenuePlatformAdMob  // CLXRevenuePlatformGAM for Ad Manager
                                        revenue:adValue.value.doubleValue
                                       adFormat:@"interstitial"
                                   builderBlock:^(CLXRevenueDataBuilder *builder) {
            builder.currencyCode = adValue.currencyCode;
            builder.precision = CLXRevenuePrecisionFromGAD(adValue.precision);
            builder.networkName = servedBy.adSourceName;
            builder.adUnitId = adMobAdUnitId;
            builder.thirdPartyAdPlacementId = servedBy.adSourceInstanceName;
        }];

    [[CloudXCore shared] reportRevenueData:data];
};

// AdMob 广告单元。networkName 为可选参数；如果你知道获胜的广告来源，请传入它，
// 例如 responseInfo.loadedAdapterResponseInfo?.adSourceName。
let adMobBid = CLXArbiterBid.adMob(
    adUnitId: adMobAdUnitId,
    networkName: adMobNetworkName ?? "admob",
    manualRevenuePerImpressionUSD: nil,
    extras: [:]
)

// Ad Manager 广告单元 ID 的格式为 /NNNNNNN/placement/name。
let adManagerBid = CLXArbiterBid.gam(adUnitId: "/21775744923/example/interstitial")

let configuration = CLXArbiterConfiguration.configuration(
    bids: [CLXArbiterBid.cloudX(ad: cloudXAd), adMobBid, adManagerBid],
    builderBlock: nil
)

CloudXCore.shared.arbiter(with: configuration) { result in
    switch result.platform.name {
    case CLXArbiterPlatform.cloudX.name:
        cloudXInterstitial.show(from: viewController)
    case CLXArbiterPlatform.adMob.name:
        adMobInterstitial.present(fromRootViewController: viewController)
    case CLXArbiterPlatform.gam.name:
        adManagerInterstitial.present(fromRootViewController: viewController)
    default:
        break
    }
}

CLXArbiterBid *adMobBid =
    [CLXArbiterBid adMobBidWithAdUnitId:adMobAdUnitId
                             networkName:adMobNetworkName ?: @"admob"
          manualRevenuePerImpressionUSD:nil
                                  extras:@{}];

CLXArbiterBid *adManagerBid =
    [CLXArbiterBid gamBidWithAdUnitId:@"/21775744923/example/interstitial"];

CLXArbiterConfiguration *configuration =
    [CLXArbiterConfiguration configurationWithBids:@[
        [CLXArbiterBid cloudXBidWithAd:cloudXAd],
        adMobBid,
        adManagerBid
    ]];

[[CloudXCore shared] arbiterWithConfiguration:configuration completion:^(CLXArbiterResult *result) {
    if ([result.platform.name isEqualToString:CLXArbiterPlatform.cloudX.name]) {
        [cloudXInterstitial showFromViewController:viewController];
    } else if ([result.platform.name isEqualToString:CLXArbiterPlatform.adMob.name]) {
        [adMobInterstitial presentFromRootViewController:viewController];
    } else if ([result.platform.name isEqualToString:CLXArbiterPlatform.gam.name]) {
        [adManagerInterstitial presentFromRootViewController:viewController];
    }
}];

// GADAdValue.value 是已按货币单位表示的 NSDecimalNumber，直接原样传入即可，不要做任何除法。
let adMobBid = CLXArbiterBid.adMob(
    adUnitId: adMobAdUnitId,
    networkName: adMobNetworkName ?? "admob",
    manualRevenuePerImpressionUSD: preBidAdValue.value,
    extras: [:]
)

// GADAdValue.value 是已按货币单位表示的 NSDecimalNumber，直接原样传入即可，不要做任何除法。
CLXArbiterBid *adMobBid =
    [CLXArbiterBid adMobBidWithAdUnitId:adMobAdUnitId
                             networkName:adMobNetworkName ?: @"admob"
          manualRevenuePerImpressionUSD:preBidAdValue.value
                                  extras:@{}];

/// 以 20-30 秒为周期，在 CloudX 和 LevelPlay 的横幅广告之间进行仲裁。
///
/// 只挂载获胜出价对应的视图。未获胜的视图保持已加载但不挂载的状态，
/// 因此永远不会渲染或触发展示事件。当前展示的获胜广告触发展示事件后，
/// 会为该网络发起新的加载，并保留另一个网络已经加载好的广告，用于下一轮仲裁。
@interface ArbiterBannerController () <CLXBannerDelegate, CLXAdRevenueDelegate, LPMBannerAdViewDelegate>
@property (nonatomic, weak) UIView *containerView;
@property (nonatomic, weak) UIViewController *presentingViewController;
@property (nonatomic, strong) CLXBannerAdView *cloudXBanner;
@property (nonatomic, strong) LPMBannerAdView *levelPlayBanner;
@property (nonatomic, strong) CLXAd *cloudXAd;
@property (nonatomic, assign) BOOL cloudXLoadDone;
@property (nonatomic, strong) LPMAdInfo *levelPlayAdInfo;
@property (nonatomic, assign) BOOL levelPlayLoadDone;
@property (nonatomic, copy) NSString *attachedPlatformName;
@property (nonatomic, strong) NSTimer *refreshTimer;
@end

@implementation ArbiterBannerController

- (instancetype)initWithContainerView:(UIView *)containerView
                presentingViewController:(UIViewController *)presentingViewController
                       cloudXAdUnitId:(NSString *)cloudXAdUnitId
                    levelPlayAdUnitId:(NSString *)levelPlayAdUnitId {
    self = [super init];
    if (self) {
        _containerView = containerView;
        _presentingViewController = presentingViewController;

        _cloudXBanner = [[CloudXCore shared] createBannerWithAdUnitId:cloudXAdUnitId];
        _cloudXBanner.delegate = self;
        _cloudXBanner.revenueDelegate = self;
        [_cloudXBanner stopAutoRefresh];

        LPMBannerAdViewConfigBuilder *levelPlayConfigBuilder = [[LPMBannerAdViewConfigBuilder alloc] init];
        LPMBannerAdViewConfig *levelPlayConfig = [levelPlayConfigBuilder build];
        _levelPlayBanner = [[LPMBannerAdView alloc] initWithAdUnitId:levelPlayAdUnitId
                                                                config:levelPlayConfig];
        _levelPlayBanner.delegate = self;
        // LevelPlay 的自动刷新需要通过 LevelPlay 自身的配置（控制台/API）关闭。
    }
    return self;
}

/// 为每个当前没有已填充广告的网络启动加载。
- (void)loadMissingAds {
    if (!self.cloudXAd) { [self.cloudXBanner load]; }
    if (!self.levelPlayAdInfo) {
        [self.levelPlayBanner loadAdWithViewController:self.presentingViewController];
    }
}

/// 启动周期性的 20-30 秒刷新定时器。仅在首次加载周期开始后调用一次。
- (void)startRefreshTimer {
    [self.refreshTimer invalidate];
    self.refreshTimer = [NSTimer scheduledTimerWithTimeInterval:25.0
                                                          target:self
                                                        selector:@selector(runArbiterIfReady)
                                                        userInfo:nil
                                                         repeats:YES];
}

- (void)runArbiterIfReady {
    if (!self.cloudXLoadDone || !self.levelPlayLoadDone) { return; }

    NSMutableArray<CLXArbiterBid *> *bids = [NSMutableArray array];
    if (self.cloudXAd) {
        [bids addObject:[CLXArbiterBid cloudXBidWithAd:self.cloudXAd]];
    }
    if (self.levelPlayAdInfo) {
        [bids addObject:[CLXArbiterBid levelPlayBidWithNetworkName:self.levelPlayAdInfo.adNetwork
                                                            revenue:self.levelPlayAdInfo.revenue.doubleValue
                                                          precision:self.levelPlayAdInfo.precision]];
    }
    if (bids.count == 0) { return; }

    CLXArbiterConfiguration *configuration = [CLXArbiterConfiguration configurationWithBids:bids];
    [[CloudXCore shared] arbiterWithConfiguration:configuration completion:^(CLXArbiterResult *result) {
        [self attachWinner:result.platform.name];
    }];
}

/// 卸载上一个获胜方的视图，挂载新获胜方的视图，并在获胜网络的展示事件触发后为其发起新的加载。
- (void)attachWinner:(NSString *)platformName {
    [self.cloudXBanner removeFromSuperview];
    [self.levelPlayBanner removeFromSuperview];

    if ([platformName isEqualToString:CLXArbiterPlatform.cloudX.name]) {
        [self.containerView addSubview:self.cloudXBanner];
        self.attachedPlatformName = platformName;
    } else if ([platformName isEqualToString:CLXArbiterPlatform.levelPlay.name]) {
        [self.containerView addSubview:self.levelPlayBanner];
        self.attachedPlatformName = platformName;
    } else {
        self.attachedPlatformName = nil;
    }
}

#pragma mark - CLXBannerDelegate

- (void)didLoadAd:(CLXAd *)ad {
    self.cloudXAd = ad;
    self.cloudXLoadDone = YES;
    [self runArbiterIfReady];
}

- (void)didFailToLoadAd:(NSString *)adUnitId error:(CLXError *)error {
    self.cloudXAd = nil;
    self.cloudXLoadDone = YES;
    [self runArbiterIfReady];
}

#pragma mark - CLXAdRevenueDelegate

- (void)didPayRevenueForAd:(CLXAd *)ad {
    if ([self.attachedPlatformName isEqualToString:CLXArbiterPlatform.cloudX.name]) {
        self.cloudXAd = nil;
        self.cloudXLoadDone = NO;
        [self.cloudXBanner load];
    }
}

#pragma mark - LPMBannerAdViewDelegate

- (void)didLoadAdWithAdInfo:(LPMAdInfo *)adInfo {
    self.levelPlayAdInfo = adInfo;
    self.levelPlayLoadDone = YES;
    [self runArbiterIfReady];
}

- (void)didFailToLoadAdWithAdUnitId:(NSString *)adUnitId error:(NSError *)error {
    self.levelPlayAdInfo = nil;
    self.levelPlayLoadDone = YES;
    [self runArbiterIfReady];
}

- (void)didDisplayAdWithAdInfo:(LPMAdInfo *)adInfo {
    if ([self.attachedPlatformName isEqualToString:CLXArbiterPlatform.levelPlay.name]) {
        self.levelPlayAdInfo = nil;
        self.levelPlayLoadDone = NO;
        [self.levelPlayBanner loadAdWithViewController:self.presentingViewController];
    }
}

@end

/// 以 20-30 秒为周期，在 CloudX 和 LevelPlay 的横幅广告之间进行仲裁。
///
/// 只挂载获胜出价对应的视图。未获胜的视图保持已加载但不挂载的状态，
/// 因此永远不会渲染或触发展示事件。当前展示的获胜广告触发展示事件后，
/// 会为该网络发起新的加载，并保留另一个网络已经加载好的广告，用于下一轮仲裁。
final class ArbiterBannerController: NSObject {
    private weak var containerView: UIView?
    private weak var presentingViewController: UIViewController?
    private let cloudXBanner: CLXBannerAdView
    private let levelPlayBanner: LPMBannerAdView
    private var cloudXAd: CLXAd?
    private var cloudXLoadDone = false
    private var levelPlayAdInfo: LPMAdInfo?
    private var levelPlayLoadDone = false
    private var attachedPlatformName: String?
    private var refreshTimer: Timer?

    init(containerView: UIView, presentingViewController: UIViewController, cloudXAdUnitId: String, levelPlayAdUnitId: String) {
        self.containerView = containerView
        self.presentingViewController = presentingViewController
        cloudXBanner = CloudXCore.shared.createBanner(adUnitId: cloudXAdUnitId)
        let levelPlayConfig = LPMBannerAdViewConfigBuilder().build()
        levelPlayBanner = LPMBannerAdView(adUnitId: levelPlayAdUnitId, config: levelPlayConfig)
        super.init()

        cloudXBanner.delegate = self
        cloudXBanner.revenueDelegate = self
        cloudXBanner.stopAutoRefresh()

        levelPlayBanner.setDelegate(self)
        // LevelPlay 的自动刷新需要通过 LevelPlay 自身的配置（控制台/API）关闭。
    }

    /// 为每个当前没有已填充广告的网络启动加载。
    func loadMissingAds() {
        if cloudXAd == nil { cloudXBanner.load() }
        if levelPlayAdInfo == nil, let presentingViewController {
            levelPlayBanner.loadAd(with: presentingViewController)
        }
    }

    /// 启动周期性的 20-30 秒刷新定时器。仅在首次加载周期开始后调用一次。
    func startRefreshTimer() {
        refreshTimer?.invalidate()
        refreshTimer = Timer.scheduledTimer(withTimeInterval: 25.0, repeats: true) { [weak self] _ in
            self?.runArbiterIfReady()
        }
    }

    private func runArbiterIfReady() {
        guard cloudXLoadDone, levelPlayLoadDone else { return }

        var bids: [CLXArbiterBid] = []
        if let cloudXAd {
            bids.append(CLXArbiterBid.cloudX(ad: cloudXAd))
        }
        if let levelPlayAdInfo {
            bids.append(CLXArbiterBid.levelPlay(
                networkName: levelPlayAdInfo.adNetwork,
                revenue: levelPlayAdInfo.revenue?.doubleValue ?? 0,
                precision: levelPlayAdInfo.precision
            ))
        }
        guard !bids.isEmpty else { return }

        let configuration = CLXArbiterConfiguration.configuration(bids: bids, builderBlock: nil)
        CloudXCore.shared.arbiter(with: configuration) { [weak self] result in
            self?.attachWinner(result.platform.name)
        }
    }

    /// 卸载上一个获胜方的视图，挂载新获胜方的视图，并在获胜网络的展示事件触发后为其发起新的加载。
    private func attachWinner(_ platformName: String) {
        cloudXBanner.removeFromSuperview()
        levelPlayBanner.removeFromSuperview()

        switch platformName {
        case CLXArbiterPlatform.cloudX.name:
            containerView?.addSubview(cloudXBanner)
            attachedPlatformName = platformName
        case CLXArbiterPlatform.levelPlay.name:
            containerView?.addSubview(levelPlayBanner)
            attachedPlatformName = platformName
        default:
            attachedPlatformName = nil
        }
    }
}

extension ArbiterBannerController: CLXBannerDelegate {
    func didLoad(_ ad: CLXAd) {
        cloudXAd = ad
        cloudXLoadDone = true
        runArbiterIfReady()
    }

    func didFailToLoadAd(_ adUnitId: String, error: CLXError) {
        cloudXAd = nil
        cloudXLoadDone = true
        runArbiterIfReady()
    }
}

extension ArbiterBannerController: CLXAdRevenueDelegate {
    func didPayRevenue(for ad: CLXAd) {
        guard attachedPlatformName == CLXArbiterPlatform.cloudX.name else { return }
        cloudXAd = nil
        cloudXLoadDone = false
        cloudXBanner.load()
    }
}

extension ArbiterBannerController: LPMBannerAdViewDelegate {
    func didLoadAd(with adInfo: LPMAdInfo) {
        levelPlayAdInfo = adInfo
        levelPlayLoadDone = true
        runArbiterIfReady()
    }

    func didFailToLoadAd(withAdUnitId adUnitId: String, error: Error) {
        levelPlayAdInfo = nil
        levelPlayLoadDone = true
        runArbiterIfReady()
    }

    func didDisplayAd(with adInfo: LPMAdInfo) {
        guard attachedPlatformName == CLXArbiterPlatform.levelPlay.name,
              let presentingViewController else { return }
        levelPlayAdInfo = nil
        levelPlayLoadDone = false
        levelPlayBanner.loadAd(with: presentingViewController)
    }
}

CLXArbiterBid *customBid =
    [CLXArbiterBid customBidWithPlatformName:@"my_mediation_platform"
                                 networkName:@"winning_demand_source"
                     revenuePerImpressionUSD:0.00125
                                   precision:CLXArbiterPrecision.exact
                                      extras:@{@"ad_unit": @"third-party-ad-unit-id"}];

CLXArbiterConfiguration *configuration =
    [CLXArbiterConfiguration configurationWithBids:@[
        [CLXArbiterBid cloudXBidWithAd:cloudXAd],
        customBid
    ]];

let customBid = CLXArbiterBid.custom(
    platformName: "my_mediation_platform",
    networkName: "winning_demand_source",
    revenuePerImpressionUSD: 0.00125,
    precision: .exact,
    extras: ["ad_unit": "third-party-ad-unit-id"]
)

let configuration = CLXArbiterConfiguration.configuration(
    bids: [CLXArbiterBid.cloudX(ad: cloudXAd), customBid],
    builderBlock: nil
)