From 4fa22c837cb00b87cd43c0aceec26729b8c3fa48 Mon Sep 17 00:00:00 2001 From: SayaAndy Date: Wed, 16 Jul 2025 13:36:07 +0700 Subject: format: rename processor to converter --- internal/converter/processor_interface.go | 8 +++ internal/converter/webp.go | 95 +++++++++++++++++++++++++++++++ internal/processor/processor_interface.go | 8 --- internal/processor/webp.go | 95 ------------------------------- 4 files changed, 103 insertions(+), 103 deletions(-) create mode 100644 internal/converter/processor_interface.go create mode 100644 internal/converter/webp.go delete mode 100644 internal/processor/processor_interface.go delete mode 100644 internal/processor/webp.go (limited to 'internal') diff --git a/internal/converter/processor_interface.go b/internal/converter/processor_interface.go new file mode 100644 index 0000000..88b5ac3 --- /dev/null +++ b/internal/converter/processor_interface.go @@ -0,0 +1,8 @@ +package converter + +import "io" + +type Converter interface { + DeductOutputPath(inputPath string) string + Process(ext string, reader io.ReadCloser, writer io.WriteCloser) error +} diff --git a/internal/converter/webp.go b/internal/converter/webp.go new file mode 100644 index 0000000..b7f1216 --- /dev/null +++ b/internal/converter/webp.go @@ -0,0 +1,95 @@ +package converter + +import ( + "fmt" + "image" + "image/jpeg" + "image/png" + "io" + "log/slog" + "strings" + + "golang.org/x/image/draw" + + "github.com/SayaAndy/saya-today-thumbnail-generator/config" + "github.com/kolesa-team/go-webp/encoder" + "github.com/kolesa-team/go-webp/webp" +) + +var _ Converter = (*WebpConverter)(nil) + +type WebpConverter struct { + maxWidth int + maxHeight int + quality int +} + +func NewWebpConverter(cfg *config.ConverterConfig) (*WebpConverter, error) { + if cfg.Type != "webp" { + return nil, fmt.Errorf("invalid storage type for WebpConverter") + } + webpCfg := cfg.Config.(*config.WebpConfig) + + return &WebpConverter{webpCfg.Size.MaxWidth, webpCfg.Size.MaxHeight, webpCfg.Quality}, nil +} + +func (p *WebpConverter) DeductOutputPath(inputPath string) string { + pathParts := strings.Split(inputPath, ".") + if len(pathParts) < 2 { + return inputPath + ".webp" + } + pathParts[len(pathParts)-1] = "webp" + return strings.Join(pathParts, ".") +} + +func (p *WebpConverter) Process(contentType string, reader io.ReadCloser, writer io.WriteCloser) error { + var src image.Image + var err error + + defer reader.Close() + defer writer.Close() + + switch contentType { + case "image/jpeg": + src, err = jpeg.Decode(reader) + if err != nil { + return fmt.Errorf("decode jpeg: %w", err) + } + case "image/png": + src, err = png.Decode(reader) + if err != nil { + return fmt.Errorf("decode png: %w", err) + } + default: + return fmt.Errorf("unsupported content type: %s", contentType) + } + + opts, err := encoder.NewLossyEncoderOptions(encoder.PresetDefault, float32(p.quality)) + if err != nil { + return fmt.Errorf("create webp encoder options: %w", err) + } + + xCoef := float64(p.maxWidth) / float64(src.Bounds().Max.X) + if p.maxWidth == 0 { + xCoef = 1 + } + yCoef := float64(p.maxHeight) / float64(src.Bounds().Max.Y) + if p.maxHeight == 0 { + yCoef = 1 + } + slog.Debug("calculated coefficients", slog.Float64("x_coef", xCoef), slog.Float64("y_coef", yCoef)) + + if xCoef > 1 && yCoef > 1 { + return webp.Encode(writer, src, opts) + } + + minCoef := xCoef + if yCoef < minCoef { + minCoef = yCoef + } + + dst := image.NewRGBA(image.Rect(0, 0, int(float64(src.Bounds().Max.X)*minCoef+0.5), int(float64(src.Bounds().Max.Y)*minCoef+0.5))) + draw.CatmullRom.Scale(dst, dst.Rect, src, src.Bounds(), draw.Over, nil) + + return webp.Encode(writer, dst, opts) +} diff --git a/internal/processor/processor_interface.go b/internal/processor/processor_interface.go deleted file mode 100644 index 7cf20f2..0000000 --- a/internal/processor/processor_interface.go +++ /dev/null @@ -1,8 +0,0 @@ -package processor - -import "io" - -type Processor interface { - DeductOutputPath(inputPath string) string - Process(ext string, reader io.ReadCloser, writer io.WriteCloser) error -} diff --git a/internal/processor/webp.go b/internal/processor/webp.go deleted file mode 100644 index 86ff567..0000000 --- a/internal/processor/webp.go +++ /dev/null @@ -1,95 +0,0 @@ -package processor - -import ( - "fmt" - "image" - "image/jpeg" - "image/png" - "io" - "log/slog" - "strings" - - "golang.org/x/image/draw" - - "github.com/SayaAndy/saya-today-thumbnail-generator/config" - "github.com/kolesa-team/go-webp/encoder" - "github.com/kolesa-team/go-webp/webp" -) - -var _ Processor = (*WebpProcessor)(nil) - -type WebpProcessor struct { - maxWidth int - maxHeight int - quality int -} - -func NewWebpProcessor(cfg *config.ProcessorConfig) (*WebpProcessor, error) { - if cfg.Type != "webp" { - return nil, fmt.Errorf("invalid storage type for WebpProcessor") - } - webpCfg := cfg.Config.(*config.WebpConfig) - - return &WebpProcessor{webpCfg.Size.MaxWidth, webpCfg.Size.MaxHeight, webpCfg.Quality}, nil -} - -func (p *WebpProcessor) DeductOutputPath(inputPath string) string { - pathParts := strings.Split(inputPath, ".") - if len(pathParts) < 2 { - return inputPath + ".webp" - } - pathParts[len(pathParts)-1] = "webp" - return strings.Join(pathParts, ".") -} - -func (p *WebpProcessor) Process(contentType string, reader io.ReadCloser, writer io.WriteCloser) error { - var src image.Image - var err error - - defer reader.Close() - defer writer.Close() - - switch contentType { - case "image/jpeg": - src, err = jpeg.Decode(reader) - if err != nil { - return fmt.Errorf("decode jpeg: %w", err) - } - case "image/png": - src, err = png.Decode(reader) - if err != nil { - return fmt.Errorf("decode png: %w", err) - } - default: - return fmt.Errorf("unsupported content type: %s", contentType) - } - - opts, err := encoder.NewLossyEncoderOptions(encoder.PresetDefault, float32(p.quality)) - if err != nil { - return fmt.Errorf("create webp encoder options: %w", err) - } - - xCoef := float64(p.maxWidth) / float64(src.Bounds().Max.X) - if p.maxWidth == 0 { - xCoef = 1 - } - yCoef := float64(p.maxHeight) / float64(src.Bounds().Max.Y) - if p.maxHeight == 0 { - yCoef = 1 - } - slog.Debug("calculated coefficients", slog.Float64("x_coef", xCoef), slog.Float64("y_coef", yCoef)) - - if xCoef > 1 && yCoef > 1 { - return webp.Encode(writer, src, opts) - } - - minCoef := xCoef - if yCoef < minCoef { - minCoef = yCoef - } - - dst := image.NewRGBA(image.Rect(0, 0, int(float64(src.Bounds().Max.X)*minCoef+0.5), int(float64(src.Bounds().Max.Y)*minCoef+0.5))) - draw.CatmullRom.Scale(dst, dst.Rect, src, src.Bounds(), draw.Over, nil) - - return webp.Encode(writer, dst, opts) -} -- cgit v1.3.1+13