feat: tweeting posts now properly mentions

Author: Preloading

bluesky/blueskyapi.go

@@ -206,6 +206,7 @@ type CreatePostRecord struct {
 	Text      string        `json:"text"`
 	CreatedAt time.Time     `json:"createdAt"`
 	Reply     *ReplySubject `json:"reply,omitempty"`
+	Facets    []Facet       `json:"facets,omitempty"`
 }
 
 type Subject struct {
@@ -808,11 +809,48 @@ func GetFollows(pds string, token string, context string, actor string) (*Follow
 }
 
 // This handles both normal & replys
-func UpdateStatus(pds string, token string, my_did string, status string, in_reply_to *string) (*ThreadRoot, error) {
+func UpdateStatus(pds string, token string, my_did string, status string, in_reply_to *string, mentions []bridge.MentionParsing) (*ThreadRoot, error) {
 	url := pds + "/xrpc/com.atproto.repo.createRecord"
 
 	var replySubject *ReplySubject
 	var err error
+	facets := []Facet{}
+
+	// find mention's DID
+	handles := []string{}
+	for _, mention := range mentions {
+		handles = append(handles, mention.Handle)
+	}
+	mentionedUsers, err := GetUsersInfo(pds, token, handles, false)
+
+	if err == nil {
+		for _, mention := range mentions {
+			var mentionDID string
+			for _, user := range mentionedUsers {
+				if user.ScreenName == mention.Handle {
+					mentionDID = bridge.TwitterIDToBlueSky(*user.ID) // efficency is poor
+					break
+				}
+			}
+
+			if mentionDID == "" {
+				continue
+			}
+
+			facets = append(facets, Facet{
+				Index: Index{
+					ByteStart: mention.Start,
+					ByteEnd:   mention.End,
+				},
+				Features: []Feature{
+					{
+						Type: "app.bsky.richtext.facet#mention",
+						Did:  mentionDID,
+					},
+				},
+			})
+		}
+	}
 
 	// Replying
 	if in_reply_to != nil && *in_reply_to != "" {
@@ -830,6 +868,7 @@ func UpdateStatus(pds string, token string, my_did string, status string, in_rep
 			Text:      status,
 			CreatedAt: time.Now().UTC(),
 			Reply:     replySubject,
+			Facets:    facets,
 		},
 	}
 

bridge/bridge.go

@@ -294,6 +294,12 @@ type InternalSearchResult struct {
 	Statuses []Tweet `json:"statuses"`
 }
 
+type MentionParsing struct {
+	Start  int
+	End    int
+	Handle string
+}
+
 // 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/interaction.go

@@ -3,6 +3,7 @@ package twitterv1
 import (
 	"fmt"
 	"math/big"
+	"regexp"
 	"time"
 
 	blueskyapi "github.com/Preloading/MastodonTwitterAPI/bluesky"
@@ -19,6 +20,10 @@ func status_update(c *fiber.Ctx) error {
 	}
 
 	status := c.FormValue("status")
+
+	// Status parsing!
+	mentions := findHandleInstances(status)
+
 	//	trim_user := c.FormValue("trim_user") // Unused
 	encoded_in_reply_to_status_id_str := c.FormValue("in_reply_to_status_id")
 	encoded_in_reply_to_status_id_int := new(big.Int)
@@ -31,7 +36,7 @@ func status_update(c *fiber.Ctx) error {
 		}
 	}
 
-	thread, err := blueskyapi.UpdateStatus(*pds, *oauthToken, *my_did, status, in_reply_to_status_id)
+	thread, err := blueskyapi.UpdateStatus(*pds, *oauthToken, *my_did, status, in_reply_to_status_id, mentions)
 
 	if err != nil {
 		fmt.Println("Error:", err)
@@ -232,3 +237,17 @@ func DeleteTweet(c *fiber.Ctx) error {
 		}(),
 	)
 }
+
+func findHandleInstances(input string) []bridge.MentionParsing {
+	regex := regexp.MustCompile(`@([a-zA-Z0-9]([a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?\.)+[a-zA-Z]([a-zA-Z0-9-]{0,61}[a-zA-Z0-9])?`)
+	matches := regex.FindAllStringIndex(input, -1)
+	results := []bridge.MentionParsing{}
+	for _, match := range matches {
+		results = append(results, bridge.MentionParsing{
+			Start:  match[0],
+			End:    match[1],
+			Handle: input[match[0]+1 : match[1]], // +1 to skip the '@' character
+		})
+	}
+	return results
+}

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"
@@ -24,7 +22,7 @@ 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("Request URL:", c.OriginalURL())
 		// fmt.Println("Post Body:", string(c.Body()))
 		// fmt.Println("Headers:", string(c.Request().Header.Header()))
 		// fmt.Println()