Merge pull request #50 from Preloading/lists

feat: Lists

Author: Preloading

bluesky/auth.go

@@ -92,9 +92,26 @@ func RefreshToken(pds string, refreshToken string) (*AuthResponse, error) {
 func GetUserAuthData(handle string) (*string, *string, error) {
 	// thank you https://discord.com/channels/1097580399187738645/1097580399187738648/1318477650485973004 (ducky.ws) on https://discord.gg/zYvmrHAr8M for explaining this to me
 
+	// Get the user's DID
+	userDID, err := ResolveDIDFromHandle(handle)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	// Get the user's PDS
+	userPDS, err := ResolvePDSFromDID(*userDID)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	// and finally, return our data
+	return userDID, userPDS, nil
+}
+
+func ResolveDIDFromHandle(handle string) (*string, error) {
 	// Validate our handle
 	if !regexp.MustCompile(`^([a-zA-Z0-9-]+\.)+[a-zA-Z]{2,}$`).MatchString(handle) {
-		return nil, nil, errors.New("invalid handle")
+		return nil, errors.New("invalid handle")
 	}
 	userDID := ""
 
@@ -129,11 +146,13 @@ func GetUserAuthData(handle string) (*string, *string, error) {
 	}
 
 	if userDID == "" {
-		return nil, nil, errors.New("user does not exist")
+		return nil, errors.New("user does not exist")
 	}
 
-	// Get the user's PDS
+	return &userDID, nil
+}
 
+func ResolvePDSFromDID(userDID string) (*string, error) {
 	// we must do different things depending on the DID type.
 	didDocReqUrl := ""
 	switch strings.Split(userDID, ":")[1] {
@@ -147,17 +166,17 @@ func GetUserAuthData(handle string) (*string, *string, error) {
 	// get the DID doc
 	didDocReq, err := http.Get(didDocReqUrl)
 	if err != nil {
-		return nil, nil, errors.New("could not find PDS")
+		return nil, errors.New("could not find PDS")
 	}
 	bodyBytes, err := io.ReadAll(didDocReq.Body)
 	if err != nil {
-		return nil, nil, err
+		return nil, err
 	}
 	var userDIDDoc DIDDoc
 	err = json.Unmarshal(bodyBytes, &userDIDDoc)
 	didDocReq.Body.Close()
 	if err != nil {
-		return nil, nil, errors.New("could not find PDS")
+		return nil, errors.New("could not find PDS")
 	}
 
 	// get the user's PDS
@@ -169,9 +188,8 @@ func GetUserAuthData(handle string) (*string, *string, error) {
 		}
 	}
 	if userPDS == "" {
-		return nil, nil, errors.New("could not find PDS")
+		return nil, errors.New("could not find PDS")
 	}
 
-	// and finally, return our data
-	return &userDID, &userPDS, nil
+	return &userPDS, nil
 }

bluesky/blueskyapi.go

@@ -329,6 +329,37 @@ type Notifications struct {
 	SeenAt        time.Time      `json:"seenAt"`
 }
 
+type ListInfo struct {
+	URI     string `json:"uri"`
+	CID     string `json:"cid"`
+	Creator User   `json:"creator"`
+	Name    string `json:"name"`
+	// ignoring purpose
+
+	Description       string     `json:"description"`
+	DescriptionFacets []Facet    `json:"descriptionFacets"`
+	Avatar            string     `json:"avatar"`
+	ListItemCount     int        `json:"listItemCount"`
+	IndexedAt         time.Time  `json:"indexedAt"`
+	Viewer            PostViewer `json:"viewer"`
+}
+
+type ListItem struct {
+	URI     string `json:"uri"`
+	Subject User   `json:"subject"`
+}
+
+type Lists struct {
+	Lists  []ListInfo `json:"lists"`
+	Cursor string     `json:"cursor"`
+}
+
+type ListDetailed struct {
+	List   ListInfo   `json:"list"`
+	Cursor string     `json:"cursor"`
+	Items  []ListItem `json:"items"`
+}
+
 var (
 	configData *config.Config
 )
@@ -750,6 +781,40 @@ func GetMediaTimeline(pds string, token string, context string, actor string, li
 	return nil, &feeds
 }
 
+// https://docs.bsky.app/docs/api/app-bsky-graph-get-list
+func GetListTimeline(pds string, token string, context string, listURI string, limit int) (error, *Timeline) {
+	apiURL := pds + "/xrpc/app.bsky.feed.getListFeed?list=" + url.QueryEscape(listURI) + "&limit=" + fmt.Sprintf("%d", limit)
+	if context != "" {
+		apiURL = pds + "/xrpc/app.bsky.feed.getListFeed?list=" + url.QueryEscape(listURI) + "&cursor=" + context + "&limit=" + fmt.Sprintf("%d", limit)
+	}
+
+	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
 
@@ -1367,7 +1432,7 @@ func GetPostLikes(pds string, token string, uri string, limit int) (*Likes, erro
 func GetActorLikes(pds string, token string, context string, actor string, limit int) (error, *Timeline) {
 	url := fmt.Sprintf(pds+"/xrpc/app.bsky.feed.getActorLikes?limit=%d&actor=%s", limit, actor)
 	if context != "" {
-		url = fmt.Sprintf(pds+"/xrpc/app.bsky.feed.getActorLikes?limit=%d&actor=%s&context=%s", limit, actor, context)
+		url = fmt.Sprintf(pds+"/xrpc/app.bsky.feed.getActorLikes?limit=%d&actor=%s&cursor=%s", limit, actor, context)
 	}
 
 	resp, err := SendRequest(&token, http.MethodGet, url, nil)
@@ -1630,6 +1695,72 @@ func GetTrends(pds string, token string) (*TrendingTopics, error) {
 	return &trends, nil
 }
 
+func GetUsersLists(pds string, token string, actor string, limit int, cursor string) (*Lists, error) {
+	url := fmt.Sprintf(pds+"/xrpc/app.bsky.graph.getLists?limit=%d&actor=%s", limit, actor)
+	if cursor != "" {
+		url = fmt.Sprintf(pds+"/xrpc/app.bsky.graph.getLists?limit=%d&actor=%s&cursor=%s", limit, actor, cursor)
+	}
+
+	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 a user's lists")
+	}
+
+	lists := Lists{}
+	if err := json.NewDecoder(resp.Body).Decode(&lists); err != nil {
+		return nil, err
+	}
+
+	return &lists, nil
+}
+
+func GetList(pds string, token string, listURI string, limit int, cursor string) (*ListDetailed, error) {
+	url := fmt.Sprintf(pds+"/xrpc/app.bsky.graph.getList?limit=%d&list=%s", limit, listURI)
+	if cursor != "" {
+		url = fmt.Sprintf(pds+"/xrpc/app.bsky.graph.getList?limit=%d&list=%s&cursor=%s", limit, listURI, cursor)
+	}
+
+	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 a user's lists")
+	}
+
+	list := ListDetailed{}
+	if err := json.NewDecoder(resp.Body).Decode(&list); err != nil {
+		return nil, err
+	}
+
+	return &list, nil
+}
+
 func GetMySuggestedUsers(pds string, token string, limit int) ([]User, error) {
 	url := pds + "/xrpc/app.bsky.actor.getSuggestions?limit=" + fmt.Sprintf("%d", limit)
 

bridge/bridge.go

@@ -365,6 +365,41 @@ type AuthToken struct {
 	ServerURLs       []string `json:"server_urls"`       // URLs to access that server
 }
 
+type TwitterLists struct {
+	XMLName xml.Name      `xml:"lists" json:"-"`
+	Lists   []TwitterList `json:"lists" xml:"list"`
+	Cursors
+}
+
+type TwitterListMembers struct {
+	XMLName xml.Name       `xml:"users" json:"-"`
+	Users   []*TwitterUser `json:"users" xml:"users"`
+	Cursors
+}
+
+type Cursors struct {
+	PreviousCursor    int64  `json:"previous_cursor" xml:"previous_cursor"`
+	PreviousCursorStr string `json:"previous_cursor_str" xml:"previous_cursor_str"`
+	NextCursor        uint64 `json:"next_cursor" xml:"next_cursor"`
+	NextCursorStr     string `json:"next_cursor_str" xml:"next_cursor_str"`
+}
+
+type TwitterList struct {
+	XMLName         xml.Name    `xml:"list" json:"-"`
+	Slug            string      `json:"slug" xml:"slug"`
+	Name            string      `json:"name" xml:"name"`
+	URI             string      `json:"uri" xml:"uri"`
+	IDStr           string      `json:"id_str" xml:"id_str"`
+	SubscriberCount int         `json:"subscriber_count" xml:"subscriber_count"`
+	MemberCount     int         `json:"member_count" xml:"member_count"`
+	Mode            string      `json:"mode" xml:"mode"`
+	ID              int64       `json:"id" xml:"id"`
+	FullName        string      `json:"full_name" xml:"full_name"`
+	Description     string      `json:"description" xml:"description"`
+	User            TwitterUser `json:"user" xml:"user"`
+	Following       bool        `json:"following" xml:"following"`
+}
+
 func encodeToUint63(input string) *int64 {
 	hasher := fnv.New64a()                  // Create a new FNV-1a 64-bit hash
 	hasher.Write([]byte(input))             // Write the input string as bytes