Edits history of script submission #6041 for ' Search Post (reddit)'

• bun

  Ap­pro­ved version

  Edit in Windmill

  Embed

  import axios from 'axios'
  
  type Reddit = {
  	clientId: string
  	clientSecret: string
  	username: string
  	password: string
  	userAgent?: string
  }
  
  export async function main(
  	resource: Reddit,
  	subreddit: string,
  	searchQuery: string,
  	limit: number
  ) {
  	const endpoint = `/r/${subreddit}/search`
  	const params = {
  		q: searchQuery,
  		limit: limit
  	}
  	return await makeRequest(resource, endpoint, { params })
  }
  
  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')
  	}
  }
  

  Submitted by hugo697 181 days ago

• bun

  Edit in Windmill

  Embed

  import axios from 'axios'
  
  type Reddit = {
  	clientId: string
  	clientSecret: string
  	username: string
  	password: string
  	userAgent?: string
  }
  
  export async function main(
  	resource: Reddit,
  	subreddit: string,
  	searchQuery: string,
  	limit: number
  ) {
  	const endpoint = `/r/${subreddit}/search`
  	const params = {
  		q: searchQuery,
  		limit: limit
  	}
  	return await makeRequest(resource, endpoint, { params })
  }
  
  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')
  	}
  }
  

  Submitted by hugo697 589 days ago