go-paste/image/image.go

package image

import (
	"context"
	"crypto/sha256"
	"encoding/base64"
	"encoding/json"
	"errors"
	"fmt"
	"io"
	"net/http"
	"os"
	"path/filepath"
	"strconv"
	"strings"
	"time"

	"github.com/h2non/filetype"
	"go.opentelemetry.io/otel/attribute"
	"go.opentelemetry.io/otel/metric"
	"go.opentelemetry.io/otel/trace"
	"golang.org/x/sys/unix"

	"go.sour.is/paste/src/pkg/readutil"
	"go.sour.is/pkg/lg"
)

type image struct {
	store   string
	maxSize int64

	m_image_get  metric.Int64Counter
	m_image_post metric.Int64Counter
	m_image_error metric.Int64Counter
}

const DefaultMaxSize = 500 * 1024 * 1024

func New(ctx context.Context, store string, maxSize int64) (a *image, err error) {
	a = &image{
		store:   store,
		maxSize: DefaultMaxSize,
	}

	if maxSize > 0 {
		a.maxSize = maxSize
	}

	if !chkStore(a.store) {
		return nil, fmt.Errorf("image Store location [%s] does not exist or is not writable", a.store)
	}

	m := lg.Meter(ctx)

	var merr error
	a.m_image_get, merr = m.Int64Counter("m_image_get",
		metric.WithDescription("retrieve image from store"),
	)
	err = errors.Join(err, merr)

	a.m_image_post, merr = m.Int64Counter("m_image_post",
		metric.WithDescription("save image to store"),
	)
	err = errors.Join(err, merr)

	a.m_image_error, merr = m.Int64Counter("m_image_error",
		metric.WithDescription("image api error"),
	)
	err = errors.Join(err, merr)


	return a, err
}
func (a *image) RegisterHTTP(mux *http.ServeMux) {
	mux.Handle("/i", http.StripPrefix("/i", a))
	mux.Handle("/i/", http.StripPrefix("/i/", a))
	mux.Handle("/3/upload", a)
}
func (a *image) ServeHTTP(w http.ResponseWriter, r *http.Request) {
	ctx := r.Context()
	ctx, span := lg.Span(ctx)
	defer span.End()

	switch r.Method {
	case http.MethodGet, http.MethodHead:
		a.m_image_get.Add(ctx, 1)

		name := strings.TrimPrefix(r.URL.Path, "/")
		if name != "" {
			rdr, head, err := a.loadFile(ctx, name)
			if err != nil {
				a.m_image_error.Add(ctx, 1)
				writeError(w, err)
				span.RecordError(err)
				return
			}

			defer rdr.Close()

			w.Header().Set("X-Content-Type-Options", "nosniff")
			w.Header().Set("Accept-Ranges", "bytes")
			w.Header().Set("Content-Type", head.Mime)
			w.Header().Set("ETag", head.ETag)
			w.Header().Set("Last-Modified", head.Modified.Format(time.RFC850))

			if r.Method == http.MethodHead {
				return
			}

			// io.Copy(w, rdr)
			http.ServeContent(w, r, "", head.Modified, rdr)

			return
		}

	case http.MethodPost:
		a.m_image_post.Add(ctx, 1)

		var err error
		defer r.Body.Close()

		var fd io.ReadCloser = r.Body
		if r.URL.Path == "/3/upload" {
			span.AddEvent("Imgur Emulation")
			if data := r.FormValue("image"); data != "" {
				var rdr io.Reader = strings.NewReader(data)
				if t := r.FormValue("type"); t == "base64" {
					rdr = base64.NewDecoder(base64.StdEncoding, rdr)
				}
				fd = io.NopCloser(rdr)
			} else if fd, _, err = r.FormFile("image"); err != nil {
				if err != nil {
					span.RecordError(err)
					w.WriteHeader(http.StatusBadRequest)
					return
				}
				defer fd.Close()
			}
			w.WriteHeader(http.StatusOK)
		} else {
			w.WriteHeader(http.StatusCreated)
		}

		length := 0
		if h := r.Header.Get("Content-Length"); h != "" {
			if i, err := strconv.Atoi(h); err != nil {
				length = i
			}
		}
		id, err := a.put(ctx, fd, length)
		if err != nil {
			a.m_image_error.Add(ctx, 1)
			writeError(w, err)
			span.RecordError(err)
			return
		}

		type data struct {
			Link       string `json:"link"`
			DeleteHash string `json:"deletehash"`
		}
		var resp = struct {
			Data    data `json:"data"`
			Success bool `json:"success"`
			Status  int  `json:"status"`
		}{
			Data: data{
				Link: fmt.Sprintf("https://%s/i/%s", r.Host, id),
			},
			Success: true,
			Status:  200,
		}

		err = json.NewEncoder(w).Encode(resp)
		span.RecordError(err)

	default:
		http.Error(w, http.StatusText(http.StatusNotFound), http.StatusNotFound)
	}
}

func (a *image) loadFile(ctx context.Context, name string) (io.ReadSeekCloser, *Header, error) {
	_, span := lg.Span(ctx)
	defer span.End()

	ext := filepath.Ext(name)
	id := strings.TrimSuffix(name, ext)

	fname := filepath.Join(a.store, id)

	if !chkFile(fname) {
		return nil, nil, fmt.Errorf("%w: %s", ErrNotFound, fname)
	}

	if chkGone(fname) {
		return nil, nil, fmt.Errorf("%w: %s", ErrGone, fname)
	}

	f, err := os.Open(fname)
	if err != nil {
		return nil, nil, err
	}
	stat, err := f.Stat()
	if err != nil {
		return nil, nil, err
	}

	pr := readutil.NewPreviewReader(f)

	mime, err := readutil.ReadMIME(pr, name)
	if err != nil {
		return nil, nil, err
	}

	f.Seek(0, 0)

	return f,
		&Header{Mime: mime, Modified: stat.ModTime(), ETag: name},
		nil
}

func (a *image) put(ctx context.Context, r io.ReadCloser, length int) (string, error) {
	_, span := lg.Span(ctx)
	defer span.End()

	defer r.Close()

	span.AddEvent("content length", trace.WithAttributes(attribute.Int64("max-size", a.maxSize), attribute.Int("length", length)))

	if length > 0 {
		if int64(length) > a.maxSize {
			return "", ErrSizeTooLarge
		}
	}

	rdr := io.LimitReader(r, a.maxSize)
	pr := readutil.NewPreviewReader(rdr)
	if !isImageOrVideo(pr) {
		span.AddEvent("not image")
		return "", ErrUnsupportedType
	}
	rdr = pr.Drain()

	s256 := sha256.New()
	tmp, err := os.CreateTemp(a.store, "image-")
	if err != nil {
		span.RecordError(err)
		return "", fmt.Errorf("%w: %w", ErrBadInput, err)
	}

	defer os.Remove(tmp.Name())

	m := io.MultiWriter(s256, tmp)
	if _, err := io.Copy(m, rdr); err != nil {
		span.RecordError(err)
		return "", fmt.Errorf("%w: %w", ErrBadInput, err)
	}
	tmp.Close()

	id := base64.RawURLEncoding.EncodeToString(s256.Sum(nil)[12:])
	fname := filepath.Join(a.store, id)

	span.AddEvent("image: moving file", trace.WithAttributes(attribute.String("image-src", tmp.Name()), attribute.String("image-dst", fname)))
	_ = os.Rename(tmp.Name(), fname)

	return id, nil
}

func isImageOrVideo(in io.Reader) bool {
	buf := make([]byte, 320)
	_, err := in.Read(buf)
	if err != nil {
		return false
	}
	return filetype.IsImage(buf) || filetype.IsVideo(buf)
}

func chkStore(path string) bool {
	file, err := os.Stat(path)

	if err != nil && os.IsNotExist(err) {
		err = os.MkdirAll(path, 0744)
		if err != nil {
			return false
		}

		file, err = os.Stat(path)
	}

	if err != nil {
		return false
	}

	if !file.IsDir() {
		return false
	}

	if unix.Access(path, unix.W_OK&unix.R_OK) != nil {
		return false
	}

	return true
}
func chkFile(path string) bool {
	file, err := os.Stat(path)
	if err != nil {
		return false
	}

	if file.IsDir() {
		return false
	}

	if unix.Access(path, unix.W_OK&unix.R_OK) != nil {
		return false
	}

	return true
}
func chkGone(path string) bool {
	file, err := os.Stat(path)
	if err != nil {
		return true
	}

	if file.Size() == 0 {
		return true
	}

	return false
}
func writeError(w http.ResponseWriter, err error) {
	switch {
	case errors.Is(err, ErrGone):
		w.WriteHeader(http.StatusGone)
	case errors.Is(err, ErrNotFound):
		w.WriteHeader(http.StatusNotFound)
	case errors.Is(err, ErrReadingContent):
		w.WriteHeader(http.StatusInternalServerError)
	case errors.Is(err, ErrUnsupportedType):
		w.WriteHeader(http.StatusUnsupportedMediaType)
	}
}

type Header struct {
	Mime     string
	Modified time.Time
	ETag     string
}

var (
	ErrNotFound        = errors.New("not found")
	ErrGone            = errors.New("gone")
	ErrReadingContent  = errors.New("reading content")
	ErrSizeTooLarge    = errors.New("size too large")
	ErrBadInput        = errors.New("bad input")
	ErrUnsupportedType = errors.New("unsupported type")
)