Function watchOffer

src/lib/adRewards.js:338–410

(offerId, { onStep } = {})

		return Boolean(activeWatchPromise);
	},
	async watchOffer(offerId, { onStep } = {}) {
		if (activeWatchPromise) {
			return activeWatchPromise;
		}

		const offer = OFFERS.find((item) => item.id === offerId);
		if (!offer) {
			throw new Error("Reward offer not found.");
		}
		if (!this.isRewardedSupported()) {
			throw new Error(this.getRewardedUnavailableReason());
		}

		await refreshState({ notifyExpiry: false });
		const redemptionStatus = this.canRedeemNow();
		if (!redemptionStatus.ok) {
			throw new Error(redemptionStatus.reason);
		}

		const sessionId =
			typeof crypto?.randomUUID === "function"
				? crypto.randomUUID()
				: `${Date.now()}-${Math.random().toString(36).slice(2, 10)}`;

		activeWatchPromise = (async () => {
			for (let step = 1; step <= offer.adsRequired; step += 1) {
				onStep?.({
					step,
					totalSteps: offer.adsRequired,
					offer,
				});
				await showRewardedStep(offer, step, sessionId);

				if (step < offer.adsRequired) {
					toast(
						`Reward ${step}/${offer.adsRequired} complete. Loading the next ad...`,
						2500,
					);
				}
			}

			const redeemedState = normalizeStatus(
				await secureAdRewardState.redeem(offer.id),
			);
			const grantedDurationMs =
				Number(redeemedState.appliedDurationMs) ||
				Number(redeemedState.grantedDurationMs) ||
				0;

			state = redeemedState;
			emitChange();
			hideActiveBanner();
			scheduleExpiryCheck();

			notify(
				"Ad-free pass started",
				`${formatDuration(grantedDurationMs)} unlocked. Ads will stay hidden until ${new Date(redeemedState.adFreeUntil).toLocaleString()}.`,
				"success",