feat: followers timeline

Author: Preloading

bridge/tidconversions.go

@@ -0,0 +1,56 @@
+package bridge
+
+import (
+	"fmt"
+	"strings"
+)
+
+var tidChars = "234567abcdefghijklmnopqrstuvwxyz"
+
+// numToTid converts a 64-bit number into a Bluesky TID.
+func NumToTid(number uint64) (string, error) {
+	// Ensure the first bit is 0
+	if (number & 0x8000000000000000) != 0 {
+		return "", fmt.Errorf("first bit must be 0")
+	}
+
+	// Convert to base32 manually
+	// the other one kept losing precision
+	var result strings.Builder
+	for i := 0; i < 13; i++ {
+		index := number & 0x1F // Take 5 bits
+		result.WriteByte(tidChars[index])
+		number >>= 5
+	}
+
+	// Reverse the string since we built it backwards
+	runes := []rune(result.String())
+	for i, j := 0, len(runes)-1; i < j; i, j = i+1, j-1 {
+		runes[i], runes[j] = runes[j], runes[i]
+	}
+
+	return string(runes), nil
+}
+
+// tidToNum converts a Bluesky TID into a 64-bit number.
+func TidToNum(tid string) (uint64, error) {
+	if len(tid) != 13 {
+		return 0, fmt.Errorf("TID must be 13 characters")
+	}
+
+	var num uint64
+	for _, c := range tid {
+		index := strings.IndexRune(tidChars, c)
+		if index == -1 {
+			return 0, fmt.Errorf("invalid character in TID: %c", c)
+		}
+		num = (num << 5) | uint64(index)
+	}
+
+	// Verify the first bit is 0
+	if (num & 0x8000000000000000) != 0 {
+		return 0, fmt.Errorf("first bit must be 0")
+	}
+
+	return num, nil
+}

twitterv1/twitterv1.go

@@ -83,8 +83,8 @@ func InitServer(config *config.Config) {
 	app.Post("/1/friendships/create.:filetype", FollowUser)
 	app.Post("/1/friendships/destroy.:filetype", UnfollowUserForm)
 	app.Post("/1/friendships/destroy/:id.:filetype", UnfollowUserParams)
-
-	app.Get("/1/statuses/followers.:filetype", GetFollowers)
+	app.Get("/1/followers.:filetype", GetFollowers)
+	app.Get("/1/statuses/followers.:filetype", GetStatusesFollowers)
 	app.Get("/1/statuses/friends.:filetype", GetFollows)
 
 	app.Get("/1/users/recommendations.:filetype", GetSuggestedUsers)

twitterv1/user.go

@@ -422,7 +422,7 @@ func UnfollowUserParams(c *fiber.Ctx) error {
 
 // https://web.archive.org/web/20101115102530/http://apiwiki.twitter.com/w/page/22554748/Twitter-REST-API-Method%3a-statuses%C2%A0followers
 // At the moment we are not doing pagination, so this will only return the first ~50 followers.
-func GetFollowers(c *fiber.Ctx) error {
+func GetStatusesFollowers(c *fiber.Ctx) error {
 	// auth
 	_, pds, _, oauthToken, err := GetAuthFromReq(c)
 	if err != nil {
@@ -483,6 +483,103 @@ func GetFollowers(c *fiber.Ctx) error {
 	})
 }
 
+func GetFollowers(c *fiber.Ctx) error {
+	// auth
+	_, pds, _, oauthToken, err := GetAuthFromReq(c)
+	if err != nil {
+		return c.Status(fiber.StatusUnauthorized).SendString("OAuth token not found in Authorization header")
+	}
+
+	// lets go get our user data
+	fmt.Println(c.Body())
+	fmt.Println(c.OriginalURL())
+	actor := c.FormValue("user_id")
+	if actor == "" {
+		actor = c.FormValue("screen_name")
+		if actor == "" {
+			c.Status(fiber.StatusBadRequest).SendString("No user provided")
+		}
+	} else {
+		id, err := strconv.ParseInt(actor, 10, 64)
+		if err != nil {
+			return c.Status(fiber.StatusBadRequest).SendString("Invalid user_id provided")
+		}
+		actorPtr, err := bridge.TwitterIDToBlueSky(&id)
+		if err != nil {
+			return c.Status(fiber.StatusBadRequest).SendString("Failed to convert user_id to screen_name")
+		}
+		if actorPtr == nil {
+			return c.Status(fiber.StatusBadRequest).SendString("Failed to convert user_id to screen_name")
+		}
+		actor = *actorPtr
+	}
+
+	cursor := ""
+	var cursorInt int64
+
+	cursorStr := c.FormValue("cursor")
+	if cursorStr != "" {
+		cursorInt, err = strconv.ParseInt(cursorStr, 10, 64)
+		if err != nil || cursorInt != -1 {
+			cursor, err = bridge.NumToTid(uint64(cursorInt))
+			if err != nil {
+				fmt.Println("Error when converting Followers Cursor:", err)
+				cursor = ""
+			}
+		} else {
+			cursor = ""
+		}
+	} else {
+		cursor = ""
+	}
+
+	// fetch followers
+	followers, err := blueskyapi.GetFollowers(*pds, *oauthToken, cursor, actor)
+	if err != nil {
+		fmt.Println("Error:", err)
+		return c.Status(fiber.StatusInternalServerError).SendString("Failed to fetch followers")
+	}
+
+	// convert users into twitter format
+	// This right now doesn't act on pagination, i'll figure that out later
+	var actorsToLookUp []string
+	for _, user := range followers.Followers {
+		actorsToLookUp = append(actorsToLookUp, user.DID)
+	}
+
+	twitterUsers, err := blueskyapi.GetUsersInfo(*pds, *oauthToken, actorsToLookUp, false)
+	if err != nil {
+		fmt.Println("Error:", err)
+		return c.Status(fiber.StatusInternalServerError).SendString("Failed to fetch user info")
+	}
+
+	// Convert []*bridge.TwitterUser to []bridge.TwitterUser
+	var twitterUsersConverted []bridge.TwitterUser
+	for _, user := range twitterUsers {
+		twitterUsersConverted = append(twitterUsersConverted, *user)
+	}
+
+	next_cursor, err := bridge.TidToNum(followers.Cursor)
+	if err != nil {
+		fmt.Println("Error when converting Followers Cursor:", err)
+		next_cursor = 0
+	}
+
+	return EncodeAndSend(c, struct {
+		Users             []bridge.TwitterUser `json:"users" xml:"users"`
+		NextCursor        uint64               `json:"next_cursor" xml:"next_cursor"`
+		PreviousCursor    uint64               `json:"previous_cursor" xml:"previous_cursor"`
+		NextCursorStr     string               `json:"next_cursor_str" xml:"-"`
+		PreviousCursorStr string               `json:"previous_cursor_str" xml:"-"`
+	}{
+		Users:             twitterUsersConverted,
+		NextCursor:        next_cursor,
+		PreviousCursor:    0, // Unimplemented. This could probably be figured out if i could figure out what the TID corrisponds to, if it corrisponds to anything at all.
+		NextCursorStr:     strconv.FormatUint(next_cursor, 10),
+		PreviousCursorStr: "0",
+	})
+}
+
 // https://web.archive.org/web/20120407214017/https://dev.twitter.com/docs/api/1/get/statuses/friends
 func GetFollows(c *fiber.Ctx) error {
 	// auth