feat: media timeline

Author: Preloading

bluesky/blueskyapi.go

@@ -717,6 +717,39 @@ func GetUserTimeline(pds string, token string, context string, actor string, lim
 	return nil, &feeds
 }
 
+func GetMediaTimeline(pds string, token string, context string, actor string, limit int) (error, *Timeline) {
+	apiURL := pds + "/xrpc/app.bsky.feed.getAuthorFeed?actor=" + url.QueryEscape(actor) + "&limit=" + fmt.Sprintf("%d", limit) + "&filter=posts_with_media"
+	if context != "" {
+		apiURL = pds + "/xrpc/app.bsky.feed.getAuthorFeed?actor=" + url.QueryEscape(actor) + "&cursor=" + context + "&limit=" + fmt.Sprintf("%d", limit) + "&filter=posts_with_media"
+	}
+
+	resp, err := SendRequest(&token, http.MethodGet, apiURL, nil)
+	if err != nil {
+		return err, nil
+	}
+	defer resp.Body.Close()
+
+	// // Print the response body for debugging
+	// bodyBytes, _ := io.ReadAll(resp.Body)
+	// bodyString := string(bodyBytes)
+	// fmt.Println("Response Body:", bodyString)
+
+	if resp.StatusCode != http.StatusOK {
+		bodyBytes, _ := io.ReadAll(resp.Body)
+		bodyString := string(bodyBytes)
+		fmt.Println("Response Status:", resp.StatusCode)
+		fmt.Println("Response Body:", bodyString)
+		return errors.New("failed to fetch timeline"), nil
+	}
+
+	feeds := Timeline{}
+	if err := json.NewDecoder(resp.Body).Decode(&feeds); err != nil {
+		return err, nil
+	}
+
+	return nil, &feeds
+}
+
 func GetPost(pds string, token string, uri string, depth int, parentHeight int) (error, *ThreadRoot) {
 	// Example URL at://did:plc:dqibjxtqfn6hydazpetzr2w4/app.bsky.feed.post/3lchbospvbc2j
 

twitterv1/post_viewing.go

@@ -45,6 +45,26 @@ func user_timeline(c *fiber.Ctx) error {
 	return convert_timeline(c, actor, blueskyapi.GetUserTimeline)
 }
 
+func media_timeline(c *fiber.Ctx) error {
+	actor := c.Query("screen_name")
+	if actor == "" {
+		actor = c.Query("user_id")
+		if actor == "" {
+			return c.Status(fiber.StatusBadRequest).SendString("No user provided")
+		}
+		actorInt, err := strconv.ParseInt(actor, 10, 64)
+		if err != nil {
+			return c.Status(fiber.StatusBadRequest).SendString("Invalid user_id provided")
+		}
+		actorPtr, err := bridge.TwitterIDToBlueSky(&actorInt)
+		if err != nil {
+			return c.Status(fiber.StatusBadRequest).SendString("Invalid user_id provided")
+		}
+		actor = *actorPtr
+	}
+	return convert_timeline(c, actor, blueskyapi.GetMediaTimeline)
+}
+
 func likes_timeline(c *fiber.Ctx) error {
 	// We shall pretend that the only thing it can be is a user id. TODO: maybe rectify this later
 	actor := c.Params("id")

twitterv1/twitterv1.go

@@ -84,6 +84,7 @@ func InitServer(config *config.Config) {
 	// Posts
 	app.Get("/1/statuses/home_timeline.:filetype", home_timeline)
 	app.Get("/1/statuses/user_timeline.:filetype", user_timeline)
+	app.Get("/1/statuses/media_timeline.:filetype", media_timeline)
 	app.Get("/1/statuses/show/:id.:filetype", GetStatusFromId)
 	app.Get("/i/statuses/:id/activity/summary.:filetype", TweetInfo)
 	app.Get("/1/related_results/show/:id.:filetype", RelatedResults)