import axios from 'axios'

import qs from 'qs'

type Reddit = {

	clientId: string

	clientSecret: string

	username: string

	password: string

	userAgent?: string

}

export async function main(

	resource: Reddit,

	subreddit: string,

	title: string,

	text: string,

	kind: string

) {

	const endpoint = `/api/submit`

	const data = {

		sr: subreddit,

		title,

		text,

		kind,

		api_type: 'json'

	}

	return await makeRequest(resource, endpoint, {

		data: qs.stringify(data),

		method: 'POST'

	})

}

async function makeRequest(resource: Reddit, endpoint: string, options = {}) {

	try {

		const access_token = await getAccessToken(resource)

		const headers = {

			Authorization: `Bearer ${access_token}`,

			'User-Agent': resource.userAgent

		}

		const baseUrl = 'https://oauth.reddit.com'

		const url = `${baseUrl}${endpoint}`

		const response = await axios(url, {

			headers,

			...options

		})

		return response.data

	} catch (error: Error | any) {

		console.error(error.message)

	}

}

async function getAccessToken(resource: Reddit) {

	try {

		const auth = {

			username: resource.clientId,

			password: resource.clientSecret

		}

		const response = await axios.post('https://www.reddit.com/api/v1/access_token', null, {

			params: { grant_type: 'password', username: resource.username, password: resource.password },

			auth

		})

		return response?.data?.access_token

	} catch (error) {

		throw new Error('Error getting access token')

	}

}