Dynamic Rules for Request Signing

class RulesManager {
	constructor(apiKey) {
		this.apiKey = apiKey
		this.rules = null
		this.lastFetch = null
	}

	async getRules() {
		// Check if we need to fetch new rules
		if (!this.rules || this.shouldRefresh()) {
			await this.fetchRules()
		}
		return this.rules
	}

	async fetchRules() {
		const response = await fetch("https://api.ofauth.com/v2/dynamic-rules", {
			headers: { apikey: this.apiKey }
		})

		if (!response.ok) {
			throw new Error(`Failed to fetch rules: ${response.status}`)
		}

		const data = await response.json()
		this.rules = data
		this.lastFetch = Date.now()
	}

	shouldRefresh() {
		if (!this.rules || !this.lastFetch) return true
		// Refresh every 5 minutes or if rules are not current
		return Date.now() - this.lastFetch > 5 * 60 * 1000 || !this.rules.is_current
	}
}

class RequestSigner {
	constructor(rulesManager) {
		this.rulesManager = rulesManager
	}

	async signRequest(endpoint, userId = null) {
		const response = await fetch(
			"https://api.ofauth.com/v2/dynamic-rules/sign",
			{
				method: "POST",
				headers: {
					apikey: this.rulesManager.apiKey,
					"Content-Type": "application/json"
				},
				body: JSON.stringify({
					endpoint,
					...(userId && { "user-id": userId })
				})
			}
		)

		if (!response.ok) {
			throw new Error(`Signing failed: ${response.status}`)
		}

		return response.json()
	}

	async makeSignedRequest(endpoint, userId = null, options = {}) {
		const signedData = await this.signRequest(endpoint, userId)

		const headers = {
			...signedData.signed,
			"user-agent": "OnlyFans/1.0.0",
			accept: "application/json",
			...options.headers
		}

		return fetch(`https://onlyfans.com${endpoint}`, {
			...options,
			headers
		})
	}
}

class RequestSigner {
	constructor(rulesManager) {
		this.rulesManager = rulesManager
	}

	async makeSignedRequest(endpoint, userId = null, options = {}) {
		try {
			const signedData = await this.signRequest(endpoint, userId)
			
			const headers = {
				...signedData.signed,
				"user-agent": "Mozilla ...",
				accept: "application/json",
				...options.headers
			}

			const response = await fetch(`https://onlyfans.com${endpoint}`, {
				...options,
				headers
			})

			// ONLY refresh rules on 400 error from OnlyFans
			if (response.status === 400) {
				const body = await response.json()
				if (body?.error?.code === 401 && 
					body?.error?.message?.includes("Please refresh the page")) {
					console.log("Rules outdated, fetching new rules...")
					await this.rulesManager.fetchRules()
					// Retry the request with new rules
					return this.makeSignedRequest(endpoint, userId, options)
				}
			}

			return response
		} catch (error) {
			console.error("Request failed:", error)
			throw error
		}
	}
}