Merge pull request #361 from microlinkhq/onlyfans

feat: add onlyfans

public/README.md

@@ -158,6 +158,12 @@ It resolves user avatar using **microlink.io**.
 
 e.g., https://unavatar.io/microlink/microlink.io
 
+### OnlyFans
+
+It resolves user avatar using **onlyfans.com**.
+
+e.g., https://unavatar.io/onlyfans/amandaribas
+
 ### Read.cv
 
 Type: `username`

src/providers/index.js

@@ -20,7 +20,8 @@ const providers = {
   // tiktok: require('./tiktok'),
   twitch: require('./twitch'),
   x: require('./x'),
-  youtube: require('./youtube')
+  youtube: require('./youtube'),
+  onlyfans: require('./onlyfans')
 }
 
 const providersBy = reduce(

src/providers/onlyfans.js

@@ -0,0 +1,26 @@
+'use strict'
+
+const PCancelable = require('p-cancelable')
+const cheerio = require('cheerio')
+
+const getHTML = require('../util/html-get')
+
+module.exports = PCancelable.fn(async function onlyfans ({ input }, onCancel) {
+  const promise = getHTML(`https://onlyfans.com/${input}`, {
+    prerender: true,
+    puppeteerOpts: { abortTypes: ['other', 'image', 'font'] }
+  })
+  onCancel(() => promise.onCancel())
+  const { html } = await promise
+  const $ = cheerio.load(html)
+  const json = JSON.parse(
+    $('script[type="application/ld+json"]').contents().text()
+  )
+  return json.mainEntity.image
+})
+
+module.exports.supported = {
+  email: false,
+  username: true,
+  domain: false
+}

test/endpoints.js

@@ -61,7 +61,7 @@ test('soundcloud', async t => {
   t.is(statusCode, 200)
   t.true(body.url.includes('images.weserv.nl'))
 })
-//
+
 test('deviantart', async t => {
   const serverUrl = await runServer(t)
   const { body, statusCode } = await got('deviantart/spyed?json', {
@@ -126,7 +126,6 @@ test('telegram', async t => {
   t.is(statusCode, 200)
   t.true(body.url.includes('images.weserv.nl'))
 })
-//
 ;(isCI ? test.skip : test)('reddit', async t => {
   const serverUrl = await runServer(t)
   const { body, statusCode } = await got('reddit/kikobeats?json', {
@@ -135,7 +134,6 @@ test('telegram', async t => {
   t.is(statusCode, 200)
   t.true(body.url.includes('images.weserv.nl'))
 })
-//
 ;(isCI ? test.skip : test)('instagram', async t => {
   const serverUrl = await runServer(t)
   const { body, statusCode } = await got('instagram/willsmith?json', {
@@ -171,12 +169,20 @@ test('readcv', async t => {
   t.is(statusCode, 200)
   t.true(body.url.includes('images.weserv.nl'))
 })
-//
-test.skip('tiktok', async t => {
+;(isCI ? test.skip : test)('tiktok', async t => {
   const serverUrl = await runServer(t)
   const { body, statusCode } = await got('tiktok/carlosazaustre?json', {
     prefixUrl: serverUrl
   })
   t.is(statusCode, 200)
   t.true(body.url.includes('images.weserv.nl'))
 })
+
+test('onlyfans', async t => {
+  const serverUrl = await runServer(t)
+  const { body, statusCode } = await got('onlyfans/amandaribas?json', {
+    prefixUrl: serverUrl
+  })
+  t.is(statusCode, 200)
+  t.true(body.url.includes('images.weserv.nl'))
+})