feat: (very basic) searching

Author: Preloading

bluesky/blueskyapi.go

@@ -246,6 +246,12 @@ type ItemByWithDate struct {
 	Actor     User      `json:"actor"`
 }
 
+type PostSearchResult struct {
+	Posts     []Post `json:"posts"`
+	HitsTotal int    `json:"hitsTotal"`
+	Cursor    string `json:"cursor"`
+}
+
 type UserSearchResult struct {
 	Actors []User `json:"actors"`
 }
@@ -1209,6 +1215,35 @@ func UserSearch(pds string, token string, query string) ([]User, error) {
 	return users.Actors, nil
 }
 
+func PostSearch(pds string, token string, query string) ([]Post, error) {
+	url := pds + "/xrpc/app.bsky.feed.searchPosts?q=" + url.QueryEscape(query)
+
+	resp, err := SendRequest(&token, http.MethodGet, url, nil)
+	if err != nil {
+		return nil, err
+	}
+	defer resp.Body.Close()
+
+	// // Print the response body
+	// 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 nil, errors.New("failed to fetch search results")
+	}
+
+	posts := PostSearchResult{}
+	if err := json.NewDecoder(resp.Body).Decode(&posts); err != nil {
+		return nil, err
+	}
+	return posts.Posts, nil
+}
+
 // thank you https://docs.bsky.app/blog/create-post#replies
 func GetReplyRefs(pds string, token string, parentURI string) (*ReplySubject, error) {
 	// Get the parent post

bridge/bridge.go

@@ -290,6 +290,10 @@ type TwitterRecommendation struct {
 	Token  string      `json:"token"`
 }
 
+type InternalSearchResult struct {
+	Statuses []Tweet `json:"statuses"`
+}
+
 // Bluesky's API returns a letter ID for each user,
 // While twitter uses a numeric ID, meaning we
 // need to convert between the two

twitterv1/connect.go

@@ -188,5 +188,6 @@ func GetMyActivity(c *fiber.Ctx) error {
 
 		position++ // Increment position
 	}
+
 	return c.JSON(twitterNotifications)
 }

twitterv1/discover.go

@@ -17,11 +17,38 @@ import (
 // 2. Too common of a function to find
 // 3. Has a "non internal" version that is documented, but isn't this request.
 
-// TODO: Implement this
-func Search(c *fiber.Ctx) error {
+func InternalSearch(c *fiber.Ctx) error {
 	q := c.Query("q")
 	fmt.Println("Search query:", q)
-	return c.SendStatus(fiber.StatusNotImplemented)
+
+	_, pds, _, oauthToken, err := GetAuthFromReq(c)
+	if err != nil {
+		return c.Status(fiber.StatusUnauthorized).SendString("OAuth token not found in Authorization header")
+	}
+
+	bskySearch, err := blueskyapi.PostSearch(*pds, *oauthToken, q)
+
+	if err != nil {
+		fmt.Println("Error:", err)
+		return c.Status(fiber.StatusInternalServerError).SendString("Failed to search")
+	}
+
+	// Optimization: Get all users at once so we don't have to do it in chunks
+	var dids []string
+	for _, search := range bskySearch {
+		dids = append(dids, search.Author.DID)
+	}
+	blueskyapi.GetUsersInfo(*pds, *oauthToken, dids, false)
+
+	// Translate to twitter
+	tweets := []bridge.Tweet{}
+	for _, search := range bskySearch {
+		tweets = append(tweets, TranslatePostToTweet(search, "", "", nil, nil, *oauthToken, *pds))
+	}
+
+	return c.JSON(bridge.InternalSearchResult{
+		Statuses: tweets,
+	})
 }
 
 // https://web.archive.org/web/20120313235613/https://dev.twitter.com/docs/api/1/get/trends/%3Awoeid

twitterv1/twitterv1.go

@@ -1,8 +1,6 @@
 package twitterv1
 
 import (
-	"fmt"
-
 	blueskyapi "github.com/Preloading/MastodonTwitterAPI/bluesky"
 	"github.com/Preloading/MastodonTwitterAPI/config"
 	"github.com/gofiber/fiber/v2"
@@ -23,11 +21,11 @@ func InitServer(config *config.Config) {
 
 	// Custom middleware to log request details
 	app.Use(func(c *fiber.Ctx) error {
-		fmt.Println("Request Method:", c.Method())
-		fmt.Println("Request URL:", c.OriginalURL())
-		fmt.Println("Post Body:", string(c.Body()))
-		fmt.Println("Headers:", string(c.Request().Header.Header()))
-		fmt.Println()
+		// fmt.Println("Request Method:", c.Method())
+		// fmt.Println("Request URL:", c.OriginalURL())
+		// fmt.Println("Post Body:", string(c.Body()))
+		// fmt.Println("Headers:", string(c.Request().Header.Header()))
+		// fmt.Println()
 		return c.Next()
 	})
 
@@ -81,7 +79,7 @@ func InitServer(config *config.Config) {
 
 	// Discover
 	app.Get("/1/trends/:woeid.json", trends_woeid)
-	app.Get("/i/search.json", Search)
+	app.Get("/i/search.json", InternalSearch)
 
 	// Setings
 	app.Get("/1/account/settings.xml", GetSettings)