Function FollowUser

bluesky/blueskyapi.go:1360–1410

(pds string, token string, targetActor string, my_did string)

}

func FollowUser(pds string, token string, targetActor string, my_did string) (*User, error) {
	url := pds + "/xrpc/com.atproto.repo.createRecord"

	targetUser, err := GetUserInfoRaw(pds, token, targetActor)
	if err != nil {
		return nil, errors.New("failed to fetch post")
	}

	if targetUser.Viewer.Following != nil {
		return nil, errors.New("already following user")
	}

	payload := CreateRecordPayload{
		Collection: "app.bsky.graph.follow",
		Repo:       my_did,
		Record: PostInteractionRecord{
			Type:      "app.bsky.graph.follow",
			CreatedAt: time.Now().UTC().Format(time.RFC3339),
			Subject:   targetUser.DID,
		},
	}

	reqBody, err := json.Marshal(payload)
	if err != nil {
		return nil, errors.New("failed to marshal payload")
	}

	resp, err := SendRequest(&token, http.MethodPost, url, bytes.NewReader(reqBody))
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	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(bodyString) // return response
	}

	followRes := CreateRecordResult{}
	if err := json.NewDecoder(resp.Body).Decode(&followRes); err != nil {
		return nil, err
	}

	targetUser.Viewer.Following = &strings.Split(followRes.URI, "/app.bsky.graph.follow/")[1]
	targetUser.FollowersCount++

	return targetUser, nil
}

func UnfollowUser(pds string, token string, targetActor string, my_did string) (*User, error) {
	url := pds + "/xrpc/com.atproto.repo.deleteRecord"