Add project files for API and lib Threads

Author: midudev

bun.lockb

@@ -5,10 +5,11 @@
     "bun-types": "latest"
   },
   "dependencies": {
-    "hono": "^2.2.5"
+    "hono": "^3.3.0"
   },
   "scripts": {
-    "start": "bun run src/index.ts"
+    "start:api": "bun run src/api/index.ts",
+    "watch:api": "bun run --watch src/api/index.ts"
   },
-  "module": "src/index.js"
+  "module": "src/lib/index.js"
 }

package.json

@@ -1,21 +1,17 @@
-# Hono with Bun runtime
+# Threads API no oficial
 
-## Getting Started
+<div align="center">
+  <small>Para fines educativos</small>
+</div>
 
-### Cloning the repo
+## Primeras pruebas con Curl
 
 ```sh
-bun create hono ./NAME_HERE
-```
-
-### Development
-
-```
-bun run start
-```
-
-Open http://localhost:3000 with your browser to see the result.
-
-### For more information
-
-See <https://honojs.dev/>
+curl 'https://www.threads.net/api/graphql' \
+  -H 'content-type: application/x-www-form-urlencoded' \
+  -H 'sec-fetch-site: same-origin' \
+  -H 'user-agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/114.0.0.0 Safari/537.36' \
+  -H 'x-ig-app-id: 238260118697367' \
+  --data 'variables={ "userID": "8242141302" }' \
+  --data doc_id=23996318473300828
+```

readme.md

@@ -0,0 +1,17 @@
+import { Hono } from 'hono';
+import { fetchUserProfile } from '../lib/fetch'
+
+const port = +(Bun.env.PORT ?? 1234)
+
+const app = new Hono()
+
+app.get('/api/users/:userId', async (context) => {
+  const userId = context.req.param('userId')
+  const data = await fetchUserProfile({ userId })
+  return context.json(data)
+})
+
+export default {
+  port,
+  fetch: app.fetch,
+}

src/api/index.ts

@@ -0,0 +1,11 @@
+export const THREADS_APP_ID = "238260118697367"
+export const GRAPHQL_ENDPOINT = 'https://www.threads.net/api/graphql'
+
+export const ENDPOINTS_DOCUMENT_ID = {
+  USER_THREADS: 6451898791498605,
+  USER_PROFILE: 23996318473300828,
+  THREADS_REPLIES: 6529829603744567,
+  USER_REPLIES: 6684830921547925
+}
+
+export const getMidudev = () => `pheralb`

src/index.ts

@@ -0,0 +1 @@
+export const IS_DEBUG = Boolean(Bun.env.DEBUG)

src/lib/consts.ts

@@ -0,0 +1,70 @@
+import { ENDPOINTS_DOCUMENT_ID, THREADS_APP_ID, GRAPHQL_ENDPOINT } from './consts';
+import { IS_DEBUG } from './env';
+import { ThreadsUserProfileResponse } from '../types/threads-api'
+import { mapUserProfile } from './map'
+
+const fetchBase = ({ documentId, variables }) => {
+  return fetch(GRAPHQL_ENDPOINT, {
+    method: 'POST',
+    headers: {
+      'content-type': 'application/x-www-form-urlencoded',
+      'user-agent': 'Threads API midu client',
+      'x-ig-app-id': THREADS_APP_ID
+    },
+    body: `variables=${JSON.stringify(variables)}&doc_id=${documentId}`
+    })
+  .then(response => response.json())
+}
+
+export const fetchUserIdByName = ({ userName }) => {
+  if (IS_DEBUG) console.info(`https://www.threads.net/@${userName}`)
+
+  return fetch(`https://www.threads.net/@${userName}`)
+    .then(res => res.text())
+    .then(html => {
+      const regex = /{"user_id":"(\d+)"}/g
+      const [[, userId]] = html.matchAll(regex) ?? []
+      return userId
+    })
+}
+
+export const fetchUserProfile = async (
+  { userId, userName }: { userId?: string, userName?: string }) => {
+  if (userName && !userId) {
+    userId = await fetchUserIdByName({ userName })
+  }
+
+  const variables = { userID: userId }
+  const data = (
+    await fetchBase({ variables, documentId: ENDPOINTS_DOCUMENT_ID.USER_PROFILE })
+  ) as ThreadsUserProfileResponse
+
+  return mapUserProfile(data)
+}
+
+export const fetchUserThreads = async (
+  { userId, userName }: { userId?: string, userName?: string }
+) => {
+  if (userName && !userId) {
+    userId = await fetchUserIdByName({ userName })
+  }
+
+  const variables = { userID: userId }
+  return fetchBase({ variables, documentId: ENDPOINTS_DOCUMENT_ID.USER_THREADS })
+}
+
+export const fetchUserReplies = async (
+  { userId, userName }: { userId?: string, userName?: string }
+) => {
+  if (userName && !userId) {
+    userId = await fetchUserIdByName({ userName })
+  }
+
+  const variables = { userID: userId }
+  return fetchBase({ variables, documentId: ENDPOINTS_DOCUMENT_ID.USER_REPLIES })
+}
+
+export const fetchThreadReplies = ({ threadId }) => {
+  const variables = { postID: threadId }
+  return fetchBase({ variables, documentId: ENDPOINTS_DOCUMENT_ID.THREADS_REPLIES })
+}

src/lib/env.ts

@@ -0,0 +1 @@
+export * from './fetch';

src/lib/fetch.ts

@@ -0,0 +1,29 @@
+import { ThreadsUserProfileResponse} from '../types/threads-api'
+
+/*
+{"data":{"userData":{"user":{"is_private":false,"profile_pic_url":"https://scontent.cdninstagram.com/v/t51.2885-19/358174537_954616899107816_8099109910283809308_n.jpg?stp=dst-jpg_s150x150&_nc_ht=scontent.cdninstagram.com&_nc_cat=108&_nc_ohc=s5qTOIc_KREAX8qfpDD&edm=APs17CUBAAAA&ccb=7-5&oh=00_AfDaktW3vHUeFvaE14qoy7LmddGuAqWUh2uirC7ulm_TsQ&oe=64B34341&_nc_sid=10d13b","username":"midu.dev","hd_profile_pic_versions":[{"height":320,"url":"https://scontent.cdninstagram.com/v/t51.2885-19/358174537_954616899107816_8099109910283809308_n.jpg?stp=dst-jpg_s320x320&_nc_ht=scontent.cdninstagram.com&_nc_cat=108&_nc_ohc=s5qTOIc_KREAX8qfpDD&edm=APs17CUBAAAA&ccb=7-5&oh=00_AfBUgVik0k-VaqXmyuuJUp6bEmAyDHIkkB3ssbnHYwGg_A&oe=64B34341&_nc_sid=10d13b","width":320},{"height":640,"url":"https://scontent.cdninstagram.com/v/t51.2885-19/358174537_954616899107816_8099109910283809308_n.jpg?stp=dst-jpg_s640x640&_nc_ht=scontent.cdninstagram.com&_nc_cat=108&_nc_ohc=s5qTOIc_KREAX8qfpDD&edm=APs17CUBAAAA&ccb=7-5&oh=00_AfCG0VVjm58zezRMrUgG_HlTuOL0MlMMsUpGRDgn4CrMiA&oe=64B34341&_nc_sid=10d13b","width":640}],"is_verified":false,"biography":"👨‍💻 Ingeniero de Software + JavaScript\n⌨️ Aprende Programación conmigo\n🏆 Google Expert + GitHub Star\n🙌 Comparto recursos y tutoriales","biography_with_entities":null,"follower_count":34756,"profile_context_facepile_users":null,"bio_links":[{"url":"https://twitch.tv/midudev"}],"pk":"8242141302","full_name":"midudev • Programación y Desarrollo JavaScript","id":null}}},"extensions":{"is_final":true}}
+*/
+
+export const mapUserProfile = (rawResponse: ThreadsUserProfileResponse) => {
+  const userApiResponse = rawResponse?.data?.userData?.user
+  if (!userApiResponse) return null
+
+  const { username, is_verified, biography, follower_count, bio_links, pk: id, full_name, hd_profile_pic_versions, profile_pic_url } = userApiResponse
+
+  const profile_pics = [{
+    height: 150,
+    width: 150,
+    url: profile_pic_url
+  }, ...hd_profile_pic_versions]
+
+  return {
+    id,
+    username,
+    is_verified,
+    biography,
+    follower_count,
+    bio_links,
+    full_name,
+    profile_pics
+  }
+}

src/lib/index.ts

@@ -0,0 +1,42 @@
+export type ThreadsUserProfileResponse = {
+  data:       Data;
+  extensions: Extensions;
+}
+
+export type Data = {
+  userData: UserData;
+}
+
+export type UserData = {
+  user: User;
+}
+
+export type User = {
+  is_private:                     boolean;
+  profile_pic_url:                string;
+  username:                       string;
+  hd_profile_pic_versions:        HDProfilePicVersion[];
+  is_verified:                    boolean;
+  biography:                      string;
+  biography_with_entities:        null;
+  follower_count:                 number;
+  profile_context_facepile_users: null;
+  bio_links:                      BioLink[];
+  pk:                             string;
+  full_name:                      string;
+  id:                             null;
+}
+
+export type BioLink = {
+  url: string;
+}
+
+export type HDProfilePicVersion = {
+  height: number;
+  url:    string;
+  width:  number;
+}
+
+export type Extensions = {
+  is_final: boolean;
+}