Monorepo for Tangled
Something went wrong. Try again.
Go
at commit-links
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889package state
import ( "encoding/json" "fmt" "net/http" "strings"
comatproto "github.com/bluesky-social/indigo/api/atproto" "tangled.org/core/xrpc")
const maxBlobSize = 1_000_000
func (s *State) MarkdownPreview(w http.ResponseWriter, r *http.Request) { body := r.FormValue("body") s.pages.MarkdownPreviewFragment(w, body)}
// MarkupUpload proxies an image upload to the user's PDS via uploadBlob and// returns the blob ref plus a blob+at://<did>/<cid> URI. The browser can't call// uploadBlob directly (the DPoP key lives server-side), so this is the bridge.func (s *State) MarkupUpload(w http.ResponseWriter, r *http.Request) { l := s.logger.With("handler", "MarkupUpload")
user := s.oauth.GetMultiAccountUser(r) if user == nil { writeUploadError(w, http.StatusUnauthorized, "not logged in") return } l = l.With("did", user.Did)
contentType := r.Header.Get("Content-Type") if !strings.HasPrefix(contentType, "image/") { writeUploadError(w, http.StatusUnsupportedMediaType, "only image uploads are allowed") return }
// cap the body at the lexicon's maxSize (MaxBytesReader errors past it) r.Body = http.MaxBytesReader(w, r.Body, maxBlobSize) defer r.Body.Close()
client, err := s.oauth.AuthorizedClient(r) if err != nil { l.Error("failed to get authorized client", "err", err) writeUploadError(w, http.StatusBadGateway, "failed to connect to your PDS") return }
// pre-warm DPoP nonce if _, err := comatproto.ServerGetSession(r.Context(), client); err != nil { l.Error("failed to pre-warm session", "err", err) writeUploadError(w, http.StatusInternalServerError, "failed to pre-warm session") return }
resp, err := xrpc.RepoUploadBlob(r.Context(), client, r.Body, contentType) if err != nil { // MaxBytesReader's over-limit error surfaces through LexDo if strings.Contains(err.Error(), "request body too large") { l.Warn("upload exceeds size limit") writeUploadError(w, http.StatusRequestEntityTooLarge, "image too large (max 1MB)") return } l.Error("failed to upload blob", "err", err) writeUploadError(w, http.StatusBadGateway, "failed to upload image to your PDS") return }
blob := resp.Blob cid := blob.Ref.String() l.Info("uploaded blob", "cid", cid, "size", blob.Size)
w.Header().Set("Content-Type", "application/json") if err := json.NewEncoder(w).Encode(map[string]any{ "blob": blob, "did": user.Did, "uri": fmt.Sprintf("blob+at://%s/%s", user.Did, cid), }); err != nil { l.Error("failed to encode upload response", "err", err) }}
func writeUploadError(w http.ResponseWriter, status int, msg string) { w.Header().Set("Content-Type", "application/json") w.WriteHeader(status) _ = json.NewEncoder(w).Encode(map[string]string{"error": msg})}