···
···
"tangled.org/core/api/tangled"
"tangled.org/core/appview/pages"
"tangled.org/core/appview/pages/markup"
xrpcclient "tangled.org/core/appview/xrpcclient"
indigoxrpc "github.com/bluesky-social/indigo/xrpc"
"github.com/go-chi/chi/v5"
func (rp *Repo) Blob(w http.ResponseWriter, r *http.Request) {
l := rp.logger.With("handler", "RepoBlob")
f, err := rp.repoResolver.Resolve(r)
l.Error("failed to get repo and knot", "err", err)
ref := chi.URLParam(r, "ref")
ref, _ = url.PathUnescape(ref)
filePath := chi.URLParam(r, "*")
filePath, _ = url.PathUnescape(filePath)
···
// Use XRPC response directly instead of converting to internal types
var breadcrumbs [][]string
breadcrumbs = append(breadcrumbs, []string{f.Name, fmt.Sprintf("/%s/tree/%s", f.OwnerSlashRepo(), url.PathEscape(ref))})
···
breadcrumbs = append(breadcrumbs, []string{elem, fmt.Sprintf("%s/%s", breadcrumbs[idx][1], url.PathEscape(elem))})
-
if markup.GetFormat(resp.Path) == markup.FormatMarkdown {
-
showRendered = r.URL.Query().Get("code") != "true"
-
if resp.IsBinary != nil && *resp.IsBinary {
-
ext := strings.ToLower(filepath.Ext(resp.Path))
-
case ".jpg", ".jpeg", ".png", ".gif", ".svg", ".webp":
-
case ".mp4", ".webm", ".ogg", ".mov", ".avi":
-
// fetch the raw binary content using sh.tangled.repo.blob xrpc
-
repoName := fmt.Sprintf("%s/%s", f.OwnerDid(), f.Name)
-
Path: "/xrpc/sh.tangled.repo.blob",
-
query := baseURL.Query()
-
query.Set("repo", repoName)
-
query.Set("path", filePath)
-
query.Set("raw", "true")
-
baseURL.RawQuery = query.Encode()
-
blobURL := baseURL.String()
-
if !rp.config.Core.Dev {
-
contentSrc = markup.GenerateCamoURL(rp.config.Camo.Host, rp.config.Camo.SharedSecret, blobURL)
-
if resp.IsBinary == nil || !*resp.IsBinary {
-
lines = strings.Count(resp.Content, "\n") + 1
-
sizeHint = uint64(*resp.Size)
-
sizeHint = uint64(len(resp.Content))
user := rp.oauth.GetUser(r)
-
// Determine if content is binary (dereference pointer)
-
if resp.IsBinary != nil {
-
isBinary = *resp.IsBinary
rp.pages.RepoBlob(w, pages.RepoBlobParams{
RepoInfo: f.RepoInfo(user),
BreadCrumbs: breadcrumbs,
-
ShowRendered: showRendered,
-
RenderToggle: renderToggle,
-
Unsupported: unsupported,
-
ContentSrc: contentSrc,
-
Contents: resp.Content,
func (rp *Repo) RepoBlobRaw(w http.ResponseWriter, r *http.Request) {
l := rp.logger.With("handler", "RepoBlobRaw")
f, err := rp.repoResolver.Resolve(r)
l.Error("failed to get repo and knot", "err", err)
w.WriteHeader(http.StatusBadRequest)
ref := chi.URLParam(r, "ref")
ref, _ = url.PathUnescape(ref)
filePath := chi.URLParam(r, "*")
filePath, _ = url.PathUnescape(filePath)
···
l.Error("failed to create request", "err", err)
// forward the If-None-Match header
if clientETag := r.Header.Get("If-None-Match"); clientETag != "" {
req.Header.Set("If-None-Match", clientETag)
resp, err := client.Do(req)
l.Error("failed to reach knotserver", "err", err)
// forward 304 not modified
if resp.StatusCode == http.StatusNotModified {
w.WriteHeader(http.StatusNotModified)
if resp.StatusCode != http.StatusOK {
l.Error("knotserver returned non-OK status for raw blob", "url", blobURL, "statuscode", resp.StatusCode)
w.WriteHeader(resp.StatusCode)
_, _ = io.Copy(w, resp.Body)
contentType := resp.Header.Get("Content-Type")
body, err := io.ReadAll(resp.Body)
···
w.WriteHeader(http.StatusInternalServerError)
if strings.HasPrefix(contentType, "text/") || isTextualMimeType(contentType) {
// serve all textual content as text/plain
w.Header().Set("Content-Type", "text/plain; charset=utf-8")
···
func isTextualMimeType(mimeType string) bool {
textualTypes := []string{
···
···
"tangled.org/core/api/tangled"
+
"tangled.org/core/appview/config"
+
"tangled.org/core/appview/models"
"tangled.org/core/appview/pages"
"tangled.org/core/appview/pages/markup"
+
"tangled.org/core/appview/reporesolver"
xrpcclient "tangled.org/core/appview/xrpcclient"
indigoxrpc "github.com/bluesky-social/indigo/xrpc"
"github.com/go-chi/chi/v5"
+
// the content can be one of the following:
+
// - code : text | | raw
+
// - markup : text | rendered | raw
+
// - svg : text | rendered | raw
+
// - png : | rendered | raw
+
// - video : | rendered | raw
+
// - submodule : | rendered |
func (rp *Repo) Blob(w http.ResponseWriter, r *http.Request) {
l := rp.logger.With("handler", "RepoBlob")
f, err := rp.repoResolver.Resolve(r)
l.Error("failed to get repo and knot", "err", err)
ref := chi.URLParam(r, "ref")
ref, _ = url.PathUnescape(ref)
filePath := chi.URLParam(r, "*")
filePath, _ = url.PathUnescape(filePath)
···
// Use XRPC response directly instead of converting to internal types
var breadcrumbs [][]string
breadcrumbs = append(breadcrumbs, []string{f.Name, fmt.Sprintf("/%s/tree/%s", f.OwnerSlashRepo(), url.PathEscape(ref))})
···
breadcrumbs = append(breadcrumbs, []string{elem, fmt.Sprintf("%s/%s", breadcrumbs[idx][1], url.PathEscape(elem))})
+
// Create the blob view
+
blobView := NewBlobView(resp, rp.config, f, ref, filePath, r.URL.Query())
user := rp.oauth.GetUser(r)
rp.pages.RepoBlob(w, pages.RepoBlobParams{
RepoInfo: f.RepoInfo(user),
BreadCrumbs: breadcrumbs,
func (rp *Repo) RepoBlobRaw(w http.ResponseWriter, r *http.Request) {
l := rp.logger.With("handler", "RepoBlobRaw")
f, err := rp.repoResolver.Resolve(r)
l.Error("failed to get repo and knot", "err", err)
w.WriteHeader(http.StatusBadRequest)
ref := chi.URLParam(r, "ref")
ref, _ = url.PathUnescape(ref)
filePath := chi.URLParam(r, "*")
filePath, _ = url.PathUnescape(filePath)
···
l.Error("failed to create request", "err", err)
// forward the If-None-Match header
if clientETag := r.Header.Get("If-None-Match"); clientETag != "" {
req.Header.Set("If-None-Match", clientETag)
resp, err := client.Do(req)
l.Error("failed to reach knotserver", "err", err)
// forward 304 not modified
if resp.StatusCode == http.StatusNotModified {
w.WriteHeader(http.StatusNotModified)
if resp.StatusCode != http.StatusOK {
l.Error("knotserver returned non-OK status for raw blob", "url", blobURL, "statuscode", resp.StatusCode)
w.WriteHeader(resp.StatusCode)
_, _ = io.Copy(w, resp.Body)
contentType := resp.Header.Get("Content-Type")
body, err := io.ReadAll(resp.Body)
···
w.WriteHeader(http.StatusInternalServerError)
if strings.HasPrefix(contentType, "text/") || isTextualMimeType(contentType) {
// serve all textual content as text/plain
w.Header().Set("Content-Type", "text/plain; charset=utf-8")
···
+
// NewBlobView creates a BlobView from the XRPC response
+
func NewBlobView(resp *tangled.RepoBlob_Output, config *config.Config, f *reporesolver.ResolvedRepo, ref, filePath string, queryParams url.Values) models.BlobView {
+
view := models.BlobView{
+
view.SizeHint = uint64(*resp.Size)
+
} else if resp.Content != nil {
+
view.SizeHint = uint64(len(*resp.Content))
+
if resp.Submodule != nil {
+
view.ContentType = models.BlobContentTypeSubmodule
+
view.HasRenderedView = true
+
view.ContentSrc = resp.Submodule.Url
+
if resp.IsBinary != nil && *resp.IsBinary {
+
view.ContentSrc = generateBlobURL(config, f, ref, filePath)
+
ext := strings.ToLower(filepath.Ext(resp.Path))
+
case ".jpg", ".jpeg", ".png", ".gif", ".webp":
+
view.ContentType = models.BlobContentTypeImage
+
view.HasRenderedView = true
+
view.ShowingRendered = true
+
view.ContentType = models.BlobContentTypeSvg
+
view.HasTextView = true
+
view.HasRenderedView = true
+
view.ShowingRendered = queryParams.Get("code") != "true"
+
if resp.Content != nil {
+
bytes, _ := base64.StdEncoding.DecodeString(*resp.Content)
+
view.Contents = string(bytes)
+
view.Lines = strings.Count(view.Contents, "\n") + 1
+
case ".mp4", ".webm", ".ogg", ".mov", ".avi":
+
view.ContentType = models.BlobContentTypeVideo
+
view.HasRenderedView = true
+
view.ShowingRendered = true
+
// otherwise, we are dealing with text content
+
view.HasTextView = true
+
if resp.Content != nil {
+
view.Contents = *resp.Content
+
view.Lines = strings.Count(view.Contents, "\n") + 1
+
// with text, we may be dealing with markdown
+
format := markup.GetFormat(resp.Path)
+
if format == markup.FormatMarkdown {
+
view.ContentType = models.BlobContentTypeMarkup
+
view.HasRenderedView = true
+
view.ShowingRendered = queryParams.Get("code") != "true"
+
func generateBlobURL(config *config.Config, f *reporesolver.ResolvedRepo, ref, filePath string) string {
+
repoName := fmt.Sprintf("%s/%s", f.OwnerDid(), f.Name)
+
Path: "/xrpc/sh.tangled.repo.blob",
+
query := baseURL.Query()
+
query.Set("repo", repoName)
+
query.Set("path", filePath)
+
query.Set("raw", "true")
+
baseURL.RawQuery = query.Encode()
+
blobURL := baseURL.String()
+
return markup.GenerateCamoURL(config.Camo.Host, config.Camo.SharedSecret, blobURL)
func isTextualMimeType(mimeType string) bool {
textualTypes := []string{
oppi.li