Function UpdateProfilePicture

twitterv1/account.go:147–209

(c *fiber.Ctx)

}

func UpdateProfilePicture(c *fiber.Ctx) error {
	// auth
	my_did, pds, _, oauthToken, err := GetAuthFromReq(c)
	if err != nil {
		return MissingAuth(c, err)
	}

	// Lock the mutex for this user
	userMutex := getUserMutex(*my_did)
	userMutex.Lock()
	defer userMutex.Unlock()

	// get the old profile
	oldProfile, err := blueskyapi.GetRecord(*pds, "app.bsky.actor.profile", *my_did, "self")
	if err != nil {
		fmt.Println("Error:", err)
		return HandleBlueskyError(c, err.Error(), "com.atproto.repo.getRecord", UpdateProfilePicture)
	}

	// get our new image
	image, err := c.FormFile("image")
	if err != nil {
		fmt.Println("Error:", err)
		return ReturnError(c, "Please upload an image", 195, 403) // idk about this error code, since it's for url params instead of post data.
	}

	// read the image file content
	file, err := image.Open()
	if err != nil {
		fmt.Println("Error:", err)
		return ReturnError(c, "Uploaded image is invalid.", 195, 403)
	}
	defer file.Close()

	imageData, err := io.ReadAll(file)
	if err != nil {
		fmt.Println("Error:", err)
		return ReturnError(c, "Uploaded image is invalid.", 195, 403)
	}

	// upload our new profile picture
	profilePictureBlob, err := blueskyapi.UploadBlob(*pds, *oauthToken, imageData, c.Get("Content-Type"))
	if err != nil {
		fmt.Println("Error:", err)
		return HandleBlueskyError(c, err.Error(), "com.atproto.repo.uploadBlob", UpdateProfilePicture)
	}

	// change our thing
	oldProfile.Value.Avatar = *profilePictureBlob

	if err := blueskyapi.UpdateRecord(*pds, *oauthToken, "app.bsky.actor.profile", *my_did, "self", oldProfile.CID, oldProfile.Value); err != nil {
		fmt.Println("Error:", err)
		return HandleBlueskyError(c, err.Error(), "com.atproto.repo.putRecord", UpdateProfilePicture)
	}

	user, err := blueskyapi.GetUserInfo(*pds, *oauthToken, *my_did, true)
	if err != nil {
		fmt.Println("Error:", err)