2020-03-03 06:25:03 -05:00
|
|
|
// Copyright 2020 The Hugo Authors. All rights reserved.
|
2018-08-05 05:13:49 -04:00
|
|
|
//
|
|
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
|
|
// you may not use this file except in compliance with the License.
|
|
|
|
// You may obtain a copy of the License at
|
|
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
//
|
|
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
|
|
// See the License for the specific language governing permissions and
|
|
|
|
// limitations under the License.
|
|
|
|
|
|
|
|
package publisher
|
|
|
|
|
|
|
|
import (
|
|
|
|
"errors"
|
2022-05-02 10:07:52 -04:00
|
|
|
"fmt"
|
2018-08-05 05:13:49 -04:00
|
|
|
"io"
|
2020-12-02 06:52:26 -05:00
|
|
|
"net/url"
|
2018-08-05 05:13:49 -04:00
|
|
|
"sync/atomic"
|
|
|
|
|
2020-03-03 06:25:03 -05:00
|
|
|
"github.com/gohugoio/hugo/resources"
|
|
|
|
|
2018-08-05 05:13:49 -04:00
|
|
|
"github.com/gohugoio/hugo/media"
|
|
|
|
|
|
|
|
"github.com/gohugoio/hugo/minifiers"
|
|
|
|
|
|
|
|
bp "github.com/gohugoio/hugo/bufferpool"
|
|
|
|
"github.com/gohugoio/hugo/helpers"
|
|
|
|
|
|
|
|
"github.com/spf13/afero"
|
|
|
|
|
|
|
|
"github.com/gohugoio/hugo/output"
|
|
|
|
"github.com/gohugoio/hugo/transform"
|
|
|
|
"github.com/gohugoio/hugo/transform/livereloadinject"
|
|
|
|
"github.com/gohugoio/hugo/transform/metainject"
|
|
|
|
"github.com/gohugoio/hugo/transform/urlreplacers"
|
|
|
|
)
|
|
|
|
|
|
|
|
// Descriptor describes the needed publishing chain for an item.
|
|
|
|
type Descriptor struct {
|
|
|
|
// The content to publish.
|
|
|
|
Src io.Reader
|
|
|
|
|
|
|
|
// The OutputFormat of the this content.
|
|
|
|
OutputFormat output.Format
|
|
|
|
|
|
|
|
// Where to publish this content. This is a filesystem-relative path.
|
|
|
|
TargetPath string
|
|
|
|
|
|
|
|
// Counter for the end build summary.
|
|
|
|
StatCounter *uint64
|
|
|
|
|
|
|
|
// Configuration that trigger pre-processing.
|
2020-12-02 06:52:26 -05:00
|
|
|
// LiveReload script will be injected if this is != nil
|
|
|
|
LiveReloadBaseURL *url.URL
|
2018-08-05 05:13:49 -04:00
|
|
|
|
|
|
|
// Enable to inject the Hugo generated tag in the header. Is currently only
|
|
|
|
// injected on the home page for HTML type of output formats.
|
|
|
|
AddHugoGeneratorTag bool
|
|
|
|
|
|
|
|
// If set, will replace all relative URLs with this one.
|
|
|
|
AbsURLPath string
|
|
|
|
|
|
|
|
// Enable to minify the output using the OutputFormat defined above to
|
|
|
|
// pick the correct minifier configuration.
|
|
|
|
Minify bool
|
|
|
|
}
|
|
|
|
|
|
|
|
// DestinationPublisher is the default and currently only publisher in Hugo. This
|
|
|
|
// publisher prepares and publishes an item to the defined destination, e.g. /public.
|
|
|
|
type DestinationPublisher struct {
|
2020-03-03 06:25:03 -05:00
|
|
|
fs afero.Fs
|
|
|
|
min minifiers.Client
|
|
|
|
htmlElementsCollector *htmlElementsCollector
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
|
|
|
|
2018-09-06 17:05:17 -04:00
|
|
|
// NewDestinationPublisher creates a new DestinationPublisher.
|
2020-03-03 06:25:03 -05:00
|
|
|
func NewDestinationPublisher(rs *resources.Spec, outputFormats output.Formats, mediaTypes media.Types) (pub DestinationPublisher, err error) {
|
|
|
|
fs := rs.BaseFs.PublishFs
|
|
|
|
cfg := rs.Cfg
|
|
|
|
var classCollector *htmlElementsCollector
|
2023-01-04 12:24:36 -05:00
|
|
|
if rs.BuildConfig().WriteStats {
|
2020-03-03 06:25:03 -05:00
|
|
|
classCollector = newHTMLElementsCollector()
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
2020-03-03 06:25:03 -05:00
|
|
|
pub = DestinationPublisher{fs: fs, htmlElementsCollector: classCollector}
|
|
|
|
pub.min, err = minifiers.New(mediaTypes, outputFormats, cfg)
|
2020-02-29 04:44:05 -05:00
|
|
|
return
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
// Publish applies any relevant transformations and writes the file
|
|
|
|
// to its destination, e.g. /public.
|
|
|
|
func (p DestinationPublisher) Publish(d Descriptor) error {
|
|
|
|
if d.TargetPath == "" {
|
2019-01-02 06:33:26 -05:00
|
|
|
return errors.New("Publish: must provide a TargetPath")
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
src := d.Src
|
|
|
|
|
|
|
|
transformers := p.createTransformerChain(d)
|
|
|
|
|
|
|
|
if len(transformers) != 0 {
|
|
|
|
b := bp.GetBuffer()
|
|
|
|
defer bp.PutBuffer(b)
|
|
|
|
|
|
|
|
if err := transformers.Apply(b, d.Src); err != nil {
|
2022-05-02 10:07:52 -04:00
|
|
|
return fmt.Errorf("failed to process %q: %w", d.TargetPath, err)
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
// This is now what we write to disk.
|
|
|
|
src = b
|
|
|
|
}
|
|
|
|
|
|
|
|
f, err := helpers.OpenFileForWriting(p.fs, d.TargetPath)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2018-08-11 14:19:07 -04:00
|
|
|
defer f.Close()
|
2018-08-05 05:13:49 -04:00
|
|
|
|
2020-03-03 06:25:03 -05:00
|
|
|
var w io.Writer = f
|
|
|
|
|
|
|
|
if p.htmlElementsCollector != nil && d.OutputFormat.IsHTML {
|
|
|
|
w = io.MultiWriter(w, newHTMLElementsCollectorWriter(p.htmlElementsCollector))
|
|
|
|
}
|
|
|
|
|
|
|
|
_, err = io.Copy(w, src)
|
2018-08-05 05:13:49 -04:00
|
|
|
if err == nil && d.StatCounter != nil {
|
|
|
|
atomic.AddUint64(d.StatCounter, uint64(1))
|
|
|
|
}
|
2020-03-03 06:25:03 -05:00
|
|
|
|
2018-08-05 05:13:49 -04:00
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
2020-03-03 06:25:03 -05:00
|
|
|
func (p DestinationPublisher) PublishStats() PublishStats {
|
|
|
|
if p.htmlElementsCollector == nil {
|
|
|
|
return PublishStats{}
|
|
|
|
}
|
|
|
|
|
|
|
|
return PublishStats{
|
|
|
|
HTMLElements: p.htmlElementsCollector.getHTMLElements(),
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
type PublishStats struct {
|
|
|
|
HTMLElements HTMLElements `json:"htmlElements"`
|
|
|
|
}
|
|
|
|
|
2018-08-05 05:13:49 -04:00
|
|
|
// Publisher publishes a result file.
|
|
|
|
type Publisher interface {
|
|
|
|
Publish(d Descriptor) error
|
2020-03-03 06:25:03 -05:00
|
|
|
PublishStats() PublishStats
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
// XML transformer := transform.New(urlreplacers.NewAbsURLInXMLTransformer(path))
|
|
|
|
func (p DestinationPublisher) createTransformerChain(f Descriptor) transform.Chain {
|
|
|
|
transformers := transform.NewEmpty()
|
|
|
|
|
|
|
|
isHTML := f.OutputFormat.IsHTML
|
|
|
|
|
|
|
|
if f.AbsURLPath != "" {
|
|
|
|
if isHTML {
|
|
|
|
transformers = append(transformers, urlreplacers.NewAbsURLTransformer(f.AbsURLPath))
|
|
|
|
} else {
|
|
|
|
// Assume XML.
|
|
|
|
transformers = append(transformers, urlreplacers.NewAbsURLInXMLTransformer(f.AbsURLPath))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if isHTML {
|
2020-12-02 06:52:26 -05:00
|
|
|
if f.LiveReloadBaseURL != nil {
|
|
|
|
transformers = append(transformers, livereloadinject.New(*f.LiveReloadBaseURL))
|
2018-08-05 05:13:49 -04:00
|
|
|
}
|
|
|
|
|
|
|
|
// This is only injected on the home page.
|
|
|
|
if f.AddHugoGeneratorTag {
|
|
|
|
transformers = append(transformers, metainject.HugoGenerator)
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
|
2020-03-20 11:34:53 -04:00
|
|
|
if p.min.MinifyOutput {
|
2018-08-05 05:13:49 -04:00
|
|
|
minifyTransformer := p.min.Transformer(f.OutputFormat.MediaType)
|
|
|
|
if minifyTransformer != nil {
|
|
|
|
transformers = append(transformers, minifyTransformer)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return transformers
|
|
|
|
}
|