mirror of
https://github.com/gohugoio/hugo.git
synced 2026-09-03 04:02:38 +00:00
Compare commits
7 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| f5fefeda8f | |||
| e10915f80a | |||
| ec3890affe | |||
| 46cccb021b | |||
| cb6e27b32a | |||
| 5bbe95f9c5 | |||
| 31d19b505d |
Vendored
+19
-6
@@ -430,12 +430,25 @@ func (p *Partition[K, V]) doGetOrCreateWitTimeout(key K, duration time.Duration,
|
|||||||
errch := make(chan error, 1)
|
errch := make(chan error, 1)
|
||||||
|
|
||||||
go func() {
|
go func() {
|
||||||
v, _, err := p.c.GetOrCreate(key, create)
|
var (
|
||||||
if err != nil {
|
v V
|
||||||
errch <- err
|
err error
|
||||||
return
|
)
|
||||||
}
|
defer func() {
|
||||||
resultch <- v
|
if r := recover(); r != nil {
|
||||||
|
if rerr, ok := r.(error); ok {
|
||||||
|
err = rerr
|
||||||
|
} else {
|
||||||
|
err = fmt.Errorf("panic: %v", r)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
errch <- err
|
||||||
|
} else {
|
||||||
|
resultch <- v
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
v, _, err = p.c.GetOrCreate(key, create)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
select {
|
select {
|
||||||
|
|||||||
Vendored
+55
@@ -14,8 +14,11 @@
|
|||||||
package dynacache
|
package dynacache
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"errors"
|
||||||
|
"fmt"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"testing"
|
"testing"
|
||||||
|
"time"
|
||||||
|
|
||||||
qt "github.com/frankban/quicktest"
|
qt "github.com/frankban/quicktest"
|
||||||
"github.com/gohugoio/hugo/common/loggers"
|
"github.com/gohugoio/hugo/common/loggers"
|
||||||
@@ -165,6 +168,58 @@ func TestClear(t *testing.T) {
|
|||||||
cache.adjustCurrentMaxSize()
|
cache.adjustCurrentMaxSize()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestPanicInCreate(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
c := qt.New(t)
|
||||||
|
cache := newTestCache(t)
|
||||||
|
|
||||||
|
p1 := GetOrCreatePartition[string, testItem](cache, "/aaaa/bbbb", OptionsPartition{Weight: 30, ClearWhen: ClearOnRebuild})
|
||||||
|
|
||||||
|
willPanic := func(i int) func() {
|
||||||
|
return func() {
|
||||||
|
p1.GetOrCreate(fmt.Sprintf("panic-%d", i), func(key string) (testItem, error) {
|
||||||
|
panic(errors.New(key))
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetOrCreateWitTimeout needs to recover from panics in the create func.
|
||||||
|
willErr := func(i int) error {
|
||||||
|
_, err := p1.GetOrCreateWitTimeout(fmt.Sprintf("error-%d", i), 10*time.Second, func(key string) (testItem, error) {
|
||||||
|
return testItem{}, errors.New(key)
|
||||||
|
})
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
for i := 0; i < 3; i++ {
|
||||||
|
for j := 0; j < 3; j++ {
|
||||||
|
c.Assert(willPanic(i), qt.PanicMatches, fmt.Sprintf("panic-%d", i))
|
||||||
|
c.Assert(willErr(i), qt.ErrorMatches, fmt.Sprintf("error-%d", i))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Test the same keys again without the panic.
|
||||||
|
for i := 0; i < 3; i++ {
|
||||||
|
for j := 0; j < 3; j++ {
|
||||||
|
v, err := p1.GetOrCreate(fmt.Sprintf("panic-%d", i), func(key string) (testItem, error) {
|
||||||
|
return testItem{
|
||||||
|
name: key,
|
||||||
|
}, nil
|
||||||
|
})
|
||||||
|
c.Assert(err, qt.IsNil)
|
||||||
|
c.Assert(v.name, qt.Equals, fmt.Sprintf("panic-%d", i))
|
||||||
|
|
||||||
|
v, err = p1.GetOrCreateWitTimeout(fmt.Sprintf("error-%d", i), 10*time.Second, func(key string) (testItem, error) {
|
||||||
|
return testItem{
|
||||||
|
name: key,
|
||||||
|
}, nil
|
||||||
|
})
|
||||||
|
c.Assert(err, qt.IsNil)
|
||||||
|
c.Assert(v.name, qt.Equals, fmt.Sprintf("error-%d", i))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func TestAdjustCurrentMaxSize(t *testing.T) {
|
func TestAdjustCurrentMaxSize(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
c := qt.New(t)
|
c := qt.New(t)
|
||||||
|
|||||||
@@ -507,7 +507,7 @@ func (r *rootCommand) createLogger(running bool) (loggers.Logger, error) {
|
|||||||
return loggers.New(optsLogger), nil
|
return loggers.New(optsLogger), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (r *rootCommand) Reset() {
|
func (r *rootCommand) resetLogs() {
|
||||||
r.logger.Reset()
|
r.logger.Reset()
|
||||||
loggers.Log().Reset()
|
loggers.Log().Reset()
|
||||||
}
|
}
|
||||||
|
|||||||
+34
-24
@@ -27,7 +27,6 @@ import (
|
|||||||
"sync/atomic"
|
"sync/atomic"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/bep/logg"
|
|
||||||
"github.com/bep/simplecobra"
|
"github.com/bep/simplecobra"
|
||||||
"github.com/fsnotify/fsnotify"
|
"github.com/fsnotify/fsnotify"
|
||||||
"github.com/gohugoio/hugo/common/herrors"
|
"github.com/gohugoio/hugo/common/herrors"
|
||||||
@@ -136,10 +135,6 @@ func (e *hugoBuilderErrState) wasErr() bool {
|
|||||||
return e.waserr
|
return e.waserr
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *hugoBuilder) errCount() int {
|
|
||||||
return c.r.logger.LoggCount(logg.LevelError) + loggers.Log().LoggCount(logg.LevelError)
|
|
||||||
}
|
|
||||||
|
|
||||||
// getDirList provides NewWatcher() with a list of directories to watch for changes.
|
// getDirList provides NewWatcher() with a list of directories to watch for changes.
|
||||||
func (c *hugoBuilder) getDirList() ([]string, error) {
|
func (c *hugoBuilder) getDirList() ([]string, error) {
|
||||||
h, err := c.hugo()
|
h, err := c.hugo()
|
||||||
@@ -345,7 +340,6 @@ func (c *hugoBuilder) newWatcher(pollIntervalStr string, dirList ...string) (*wa
|
|||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case changes := <-c.r.changesFromBuild:
|
case changes := <-c.r.changesFromBuild:
|
||||||
c.errState.setBuildErr(nil)
|
|
||||||
unlock, err := h.LockBuild()
|
unlock, err := h.LockBuild()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
c.r.logger.Errorln("Failed to acquire a build lock: %s", err)
|
c.r.logger.Errorln("Failed to acquire a build lock: %s", err)
|
||||||
@@ -358,7 +352,7 @@ func (c *hugoBuilder) newWatcher(pollIntervalStr string, dirList ...string) (*wa
|
|||||||
}
|
}
|
||||||
if c.s != nil && c.s.doLiveReload {
|
if c.s != nil && c.s.doLiveReload {
|
||||||
doReload := c.changeDetector == nil || len(c.changeDetector.changed()) > 0
|
doReload := c.changeDetector == nil || len(c.changeDetector.changed()) > 0
|
||||||
doReload = doReload || c.showErrorInBrowser && c.errCount() > 0
|
doReload = doReload || c.showErrorInBrowser && c.errState.buildErr() != nil
|
||||||
if doReload {
|
if doReload {
|
||||||
livereload.ForceRefresh()
|
livereload.ForceRefresh()
|
||||||
}
|
}
|
||||||
@@ -372,7 +366,7 @@ func (c *hugoBuilder) newWatcher(pollIntervalStr string, dirList ...string) (*wa
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
c.handleEvents(watcher, staticSyncer, evs, configSet)
|
c.handleEvents(watcher, staticSyncer, evs, configSet)
|
||||||
if c.showErrorInBrowser && c.errCount() > 0 {
|
if c.showErrorInBrowser && c.errState.buildErr() != nil {
|
||||||
// Need to reload browser to show the error
|
// Need to reload browser to show the error
|
||||||
livereload.ForceRefresh()
|
livereload.ForceRefresh()
|
||||||
}
|
}
|
||||||
@@ -419,11 +413,17 @@ func (c *hugoBuilder) build() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *hugoBuilder) buildSites(noBuildLock bool) (err error) {
|
func (c *hugoBuilder) buildSites(noBuildLock bool) (err error) {
|
||||||
h, err := c.hugo()
|
defer func() {
|
||||||
|
c.errState.setBuildErr(err)
|
||||||
|
}()
|
||||||
|
|
||||||
|
var h *hugolib.HugoSites
|
||||||
|
h, err = c.hugo()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return
|
||||||
}
|
}
|
||||||
return h.Build(hugolib.BuildCfg{NoBuildLock: noBuildLock})
|
err = h.Build(hugolib.BuildCfg{NoBuildLock: noBuildLock})
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *hugoBuilder) copyStatic() (map[string]uint64, error) {
|
func (c *hugoBuilder) copyStatic() (map[string]uint64, error) {
|
||||||
@@ -619,6 +619,9 @@ func (c *hugoBuilder) fullRebuild(changeType string) {
|
|||||||
// Set the processing on pause until the state is recovered.
|
// Set the processing on pause until the state is recovered.
|
||||||
c.errState.setPaused(true)
|
c.errState.setPaused(true)
|
||||||
c.handleBuildErr(err, "Failed to reload config")
|
c.handleBuildErr(err, "Failed to reload config")
|
||||||
|
if c.s.doLiveReload {
|
||||||
|
livereload.ForceRefresh()
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
c.errState.setPaused(false)
|
c.errState.setPaused(false)
|
||||||
}
|
}
|
||||||
@@ -1081,37 +1084,44 @@ func (c *hugoBuilder) printChangeDetected(typ string) {
|
|||||||
c.r.logger.Println(htime.Now().Format(layout))
|
c.r.logger.Println(htime.Now().Format(layout))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *hugoBuilder) rebuildSites(events []fsnotify.Event) error {
|
func (c *hugoBuilder) rebuildSites(events []fsnotify.Event) (err error) {
|
||||||
|
defer func() {
|
||||||
|
c.errState.setBuildErr(err)
|
||||||
|
}()
|
||||||
if err := c.errState.buildErr(); err != nil {
|
if err := c.errState.buildErr(); err != nil {
|
||||||
ferrs := herrors.UnwrapFileErrorsWithErrorContext(err)
|
ferrs := herrors.UnwrapFileErrorsWithErrorContext(err)
|
||||||
for _, err := range ferrs {
|
for _, err := range ferrs {
|
||||||
events = append(events, fsnotify.Event{Name: err.Position().Filename, Op: fsnotify.Write})
|
events = append(events, fsnotify.Event{Name: err.Position().Filename, Op: fsnotify.Write})
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
c.errState.setBuildErr(nil)
|
var h *hugolib.HugoSites
|
||||||
h, err := c.hugo()
|
h, err = c.hugo()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return
|
||||||
}
|
}
|
||||||
|
err = h.Build(hugolib.BuildCfg{NoBuildLock: true, RecentlyVisited: c.visitedURLs, ErrRecovery: c.errState.wasErr()}, events...)
|
||||||
return h.Build(hugolib.BuildCfg{NoBuildLock: true, RecentlyVisited: c.visitedURLs, ErrRecovery: c.errState.wasErr()}, events...)
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *hugoBuilder) rebuildSitesForChanges(ids []identity.Identity) error {
|
func (c *hugoBuilder) rebuildSitesForChanges(ids []identity.Identity) (err error) {
|
||||||
c.errState.setBuildErr(nil)
|
defer func() {
|
||||||
h, err := c.hugo()
|
c.errState.setBuildErr(err)
|
||||||
|
}()
|
||||||
|
|
||||||
|
var h *hugolib.HugoSites
|
||||||
|
h, err = c.hugo()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return
|
||||||
}
|
}
|
||||||
whatChanged := &hugolib.WhatChanged{}
|
whatChanged := &hugolib.WhatChanged{}
|
||||||
whatChanged.Add(ids...)
|
whatChanged.Add(ids...)
|
||||||
err = h.Build(hugolib.BuildCfg{NoBuildLock: true, WhatChanged: whatChanged, RecentlyVisited: c.visitedURLs, ErrRecovery: c.errState.wasErr()})
|
err = h.Build(hugolib.BuildCfg{NoBuildLock: true, WhatChanged: whatChanged, RecentlyVisited: c.visitedURLs, ErrRecovery: c.errState.wasErr()})
|
||||||
c.errState.setBuildErr(err)
|
|
||||||
return err
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *hugoBuilder) reloadConfig() error {
|
func (c *hugoBuilder) reloadConfig() error {
|
||||||
c.r.Reset()
|
c.r.resetLogs()
|
||||||
c.r.configVersionID.Add(1)
|
c.r.configVersionID.Add(1)
|
||||||
|
|
||||||
if err := c.withConfE(func(conf *commonConfig) error {
|
if err := c.withConfE(func(conf *commonConfig) error {
|
||||||
|
|||||||
+11
-9
@@ -648,9 +648,8 @@ func (c *serverCommand) setServerInfoInConfig() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *serverCommand) getErrorWithContext() any {
|
func (c *serverCommand) getErrorWithContext() any {
|
||||||
errCount := c.errCount()
|
buildErr := c.errState.buildErr()
|
||||||
|
if buildErr == nil {
|
||||||
if errCount == 0 {
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -659,7 +658,7 @@ func (c *serverCommand) getErrorWithContext() any {
|
|||||||
m["Error"] = cleanErrorLog(c.r.logger.Errors())
|
m["Error"] = cleanErrorLog(c.r.logger.Errors())
|
||||||
|
|
||||||
m["Version"] = hugo.BuildVersionString()
|
m["Version"] = hugo.BuildVersionString()
|
||||||
ferrors := herrors.UnwrapFileErrorsWithErrorContext(c.errState.buildErr())
|
ferrors := herrors.UnwrapFileErrorsWithErrorContext(buildErr)
|
||||||
m["Files"] = ferrors
|
m["Files"] = ferrors
|
||||||
|
|
||||||
return m
|
return m
|
||||||
@@ -830,22 +829,25 @@ func (c *serverCommand) fixURL(baseURLFromConfig, baseURLFromFlag string, port i
|
|||||||
return u.String(), nil
|
return u.String(), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *serverCommand) partialReRender(urls ...string) error {
|
func (c *serverCommand) partialReRender(urls ...string) (err error) {
|
||||||
defer func() {
|
defer func() {
|
||||||
c.errState.setWasErr(false)
|
c.errState.setWasErr(false)
|
||||||
}()
|
}()
|
||||||
c.errState.setBuildErr(nil)
|
|
||||||
visited := types.NewEvictingStringQueue(len(urls))
|
visited := types.NewEvictingStringQueue(len(urls))
|
||||||
for _, url := range urls {
|
for _, url := range urls {
|
||||||
visited.Add(url)
|
visited.Add(url)
|
||||||
}
|
}
|
||||||
|
|
||||||
h, err := c.hugo()
|
var h *hugolib.HugoSites
|
||||||
|
h, err = c.hugo()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Note: We do not set NoBuildLock as the file lock is not acquired at this stage.
|
// Note: We do not set NoBuildLock as the file lock is not acquired at this stage.
|
||||||
return h.Build(hugolib.BuildCfg{NoBuildLock: false, RecentlyVisited: visited, PartialReRender: true, ErrRecovery: c.errState.wasErr()})
|
err = h.Build(hugolib.BuildCfg{NoBuildLock: false, RecentlyVisited: visited, PartialReRender: true, ErrRecovery: c.errState.wasErr()})
|
||||||
|
|
||||||
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *serverCommand) serve() error {
|
func (c *serverCommand) serve() error {
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ package hugo
|
|||||||
// This should be the only one.
|
// This should be the only one.
|
||||||
var CurrentVersion = Version{
|
var CurrentVersion = Version{
|
||||||
Major: 0,
|
Major: 0,
|
||||||
Minor: 136,
|
Minor: 137,
|
||||||
PatchLevel: 3,
|
PatchLevel: 0,
|
||||||
Suffix: "",
|
Suffix: "-DEV",
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ require (
|
|||||||
github.com/bep/gowebp v0.3.0
|
github.com/bep/gowebp v0.3.0
|
||||||
github.com/bep/helpers v0.5.0
|
github.com/bep/helpers v0.5.0
|
||||||
github.com/bep/imagemeta v0.8.1
|
github.com/bep/imagemeta v0.8.1
|
||||||
github.com/bep/lazycache v0.4.0
|
github.com/bep/lazycache v0.7.0
|
||||||
github.com/bep/logg v0.4.0
|
github.com/bep/logg v0.4.0
|
||||||
github.com/bep/mclib v1.20400.20402
|
github.com/bep/mclib v1.20400.20402
|
||||||
github.com/bep/overlayfs v0.9.2
|
github.com/bep/overlayfs v0.9.2
|
||||||
|
|||||||
@@ -143,6 +143,10 @@ github.com/bep/imagemeta v0.8.1 h1:tjZLPRftjxU7PTI87o5e5WKOFQ4S9S0engiP1OTpJTI=
|
|||||||
github.com/bep/imagemeta v0.8.1/go.mod h1:5piPAq5Qomh07m/dPPCLN3mDJyFusvUG7VwdRD/vX0s=
|
github.com/bep/imagemeta v0.8.1/go.mod h1:5piPAq5Qomh07m/dPPCLN3mDJyFusvUG7VwdRD/vX0s=
|
||||||
github.com/bep/lazycache v0.4.0 h1:X8yVyWNVupPd4e1jV7efi3zb7ZV/qcjKQgIQ5aPbkYI=
|
github.com/bep/lazycache v0.4.0 h1:X8yVyWNVupPd4e1jV7efi3zb7ZV/qcjKQgIQ5aPbkYI=
|
||||||
github.com/bep/lazycache v0.4.0/go.mod h1:NmRm7Dexh3pmR1EignYR8PjO2cWybFQ68+QgY3VMCSc=
|
github.com/bep/lazycache v0.4.0/go.mod h1:NmRm7Dexh3pmR1EignYR8PjO2cWybFQ68+QgY3VMCSc=
|
||||||
|
github.com/bep/lazycache v0.6.0 h1:0vCgFo7TBtMQpSx64jnH1sagmw0ZougIFRpsqPHTa5U=
|
||||||
|
github.com/bep/lazycache v0.6.0/go.mod h1:NmRm7Dexh3pmR1EignYR8PjO2cWybFQ68+QgY3VMCSc=
|
||||||
|
github.com/bep/lazycache v0.7.0 h1:VM257SkkjcR9z55eslXTkUIX8QMNKoqQRNKV/4xIkCY=
|
||||||
|
github.com/bep/lazycache v0.7.0/go.mod h1:NmRm7Dexh3pmR1EignYR8PjO2cWybFQ68+QgY3VMCSc=
|
||||||
github.com/bep/logg v0.4.0 h1:luAo5mO4ZkhA5M1iDVDqDqnBBnlHjmtZF6VAyTp+nCQ=
|
github.com/bep/logg v0.4.0 h1:luAo5mO4ZkhA5M1iDVDqDqnBBnlHjmtZF6VAyTp+nCQ=
|
||||||
github.com/bep/logg v0.4.0/go.mod h1:Ccp9yP3wbR1mm++Kpxet91hAZBEQgmWgFgnXX3GkIV0=
|
github.com/bep/logg v0.4.0/go.mod h1:Ccp9yP3wbR1mm++Kpxet91hAZBEQgmWgFgnXX3GkIV0=
|
||||||
github.com/bep/mclib v1.20400.20402 h1:olpCE2WSPpOAbFE1R4hnftSEmQ34+xzy2HRzd0m69rA=
|
github.com/bep/mclib v1.20400.20402 h1:olpCE2WSPpOAbFE1R4hnftSEmQ34+xzy2HRzd0m69rA=
|
||||||
|
|||||||
@@ -179,9 +179,6 @@ type hugoSitesInit struct {
|
|||||||
// Loads the data from all of the /data folders.
|
// Loads the data from all of the /data folders.
|
||||||
data *lazy.Init
|
data *lazy.Init
|
||||||
|
|
||||||
// Performs late initialization (before render) of the templates.
|
|
||||||
layouts *lazy.Init
|
|
||||||
|
|
||||||
// Loads the Git info and CODEOWNERS for all the pages if enabled.
|
// Loads the Git info and CODEOWNERS for all the pages if enabled.
|
||||||
gitInfo *lazy.Init
|
gitInfo *lazy.Init
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -250,10 +250,6 @@ func (h *HugoSites) process(ctx context.Context, l logg.LevelLogger, config *Bui
|
|||||||
l = l.WithField("step", "process")
|
l = l.WithField("step", "process")
|
||||||
defer loggers.TimeTrackf(l, time.Now(), nil, "")
|
defer loggers.TimeTrackf(l, time.Now(), nil, "")
|
||||||
|
|
||||||
if _, err := h.init.layouts.Do(ctx); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(events) > 0 {
|
if len(events) > 0 {
|
||||||
// This is a rebuild triggered from file events.
|
// This is a rebuild triggered from file events.
|
||||||
return h.processPartialFileEvents(ctx, l, config, init, events)
|
return h.processPartialFileEvents(ctx, l, config, init, events)
|
||||||
@@ -1067,8 +1063,6 @@ func (h *HugoSites) processPartialFileEvents(ctx context.Context, l logg.LevelLo
|
|||||||
}
|
}
|
||||||
|
|
||||||
if tmplChanged || i18nChanged {
|
if tmplChanged || i18nChanged {
|
||||||
// TODO(bep) we should split this, but currently the loading of i18n and layout files are tied together. See #12048.
|
|
||||||
h.init.layouts.Reset()
|
|
||||||
if err := loggers.TimeTrackfn(func() (logg.LevelLogger, error) {
|
if err := loggers.TimeTrackfn(func() (logg.LevelLogger, error) {
|
||||||
// TODO(bep) this could probably be optimized to somehow
|
// TODO(bep) this could probably be optimized to somehow
|
||||||
// only load the changed templates and its dependencies, but that is non-trivial.
|
// only load the changed templates and its dependencies, but that is non-trivial.
|
||||||
@@ -1141,10 +1135,6 @@ func (s *Site) handleContentAdapterChanges(bi pagesfromdata.BuildInfo, buildConf
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (h *HugoSites) processContentAdaptersOnRebuild(ctx context.Context, buildConfig *BuildCfg) error {
|
func (h *HugoSites) processContentAdaptersOnRebuild(ctx context.Context, buildConfig *BuildCfg) error {
|
||||||
// Make sure the layouts are initialized.
|
|
||||||
if _, err := h.init.layouts.Do(context.Background()); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
g := rungroup.Run[*pagesfromdata.PagesFromTemplate](ctx, rungroup.Config[*pagesfromdata.PagesFromTemplate]{
|
g := rungroup.Run[*pagesfromdata.PagesFromTemplate](ctx, rungroup.Config[*pagesfromdata.PagesFromTemplate]{
|
||||||
NumWorkers: h.numWorkers,
|
NumWorkers: h.numWorkers,
|
||||||
Handle: func(ctx context.Context, p *pagesfromdata.PagesFromTemplate) error {
|
Handle: func(ctx context.Context, p *pagesfromdata.PagesFromTemplate) error {
|
||||||
|
|||||||
@@ -246,11 +246,6 @@ func (s *IntegrationTestBuilder) AssertBuildCountGitInfo(count int) {
|
|||||||
s.Assert(s.H.init.gitInfo.InitCount(), qt.Equals, count)
|
s.Assert(s.H.init.gitInfo.InitCount(), qt.Equals, count)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *IntegrationTestBuilder) AssertBuildCountLayouts(count int) {
|
|
||||||
s.Helper()
|
|
||||||
s.Assert(s.H.init.layouts.InitCount(), qt.Equals, count)
|
|
||||||
}
|
|
||||||
|
|
||||||
func (s *IntegrationTestBuilder) AssertFileCount(dirname string, expected int) {
|
func (s *IntegrationTestBuilder) AssertFileCount(dirname string, expected int) {
|
||||||
s.Helper()
|
s.Helper()
|
||||||
fs := s.fs.WorkingDirReadOnly
|
fs := s.fs.WorkingDirReadOnly
|
||||||
|
|||||||
@@ -34,6 +34,15 @@ import (
|
|||||||
var pageIDCounter atomic.Uint64
|
var pageIDCounter atomic.Uint64
|
||||||
|
|
||||||
func (h *HugoSites) newPage(m *pageMeta) (*pageState, *paths.Path, error) {
|
func (h *HugoSites) newPage(m *pageMeta) (*pageState, *paths.Path, error) {
|
||||||
|
p, pth, err := h.doNewPage(m)
|
||||||
|
if err != nil {
|
||||||
|
// Make sure that any partially created page part is marked as stale.
|
||||||
|
m.MarkStale()
|
||||||
|
}
|
||||||
|
return p, pth, err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (h *HugoSites) doNewPage(m *pageMeta) (*pageState, *paths.Path, error) {
|
||||||
m.Staler = &resources.AtomicStaler{}
|
m.Staler = &resources.AtomicStaler{}
|
||||||
if m.pageMetaParams == nil {
|
if m.pageMetaParams == nil {
|
||||||
m.pageMetaParams = &pageMetaParams{
|
m.pageMetaParams = &pageMetaParams{
|
||||||
@@ -231,10 +240,6 @@ func (h *HugoSites) newPage(m *pageMeta) (*pageState, *paths.Path, error) {
|
|||||||
}
|
}
|
||||||
return ps, nil
|
return ps, nil
|
||||||
}()
|
}()
|
||||||
// Make sure to evict any cached and now stale data.
|
|
||||||
if err != nil {
|
|
||||||
m.MarkStale()
|
|
||||||
}
|
|
||||||
|
|
||||||
if ps == nil {
|
if ps == nil {
|
||||||
return nil, nil, err
|
return nil, nil, err
|
||||||
|
|||||||
@@ -344,7 +344,6 @@ func newHugoSites(cfg deps.DepsCfg, d *deps.Deps, pageTrees *pageTrees, sites []
|
|||||||
skipRebuildForFilenames: make(map[string]bool),
|
skipRebuildForFilenames: make(map[string]bool),
|
||||||
init: &hugoSitesInit{
|
init: &hugoSitesInit{
|
||||||
data: lazy.New(),
|
data: lazy.New(),
|
||||||
layouts: lazy.New(),
|
|
||||||
gitInfo: lazy.New(),
|
gitInfo: lazy.New(),
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
@@ -400,15 +399,6 @@ func newHugoSites(cfg deps.DepsCfg, d *deps.Deps, pageTrees *pageTrees, sites []
|
|||||||
return nil, nil
|
return nil, nil
|
||||||
})
|
})
|
||||||
|
|
||||||
h.init.layouts.Add(func(context.Context) (any, error) {
|
|
||||||
for _, s := range h.Sites {
|
|
||||||
if err := s.Tmpl().(tpl.TemplateManager).MarkReady(); err != nil {
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return nil, nil
|
|
||||||
})
|
|
||||||
|
|
||||||
h.init.gitInfo.Add(func(context.Context) (any, error) {
|
h.init.gitInfo.Add(func(context.Context) (any, error) {
|
||||||
err := h.loadGitInfo()
|
err := h.loadGitInfo()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|||||||
+4
-2
@@ -1,7 +1,9 @@
|
|||||||
# Release env.
|
# Release env.
|
||||||
# These will be replaced by script before release.
|
# These will be replaced by script before release.
|
||||||
HUGORELEASER_TAG=v0.136.2
|
HUGORELEASER_TAG=v0.136.5
|
||||||
HUGORELEASER_COMMITISH=ad985550a4faff6bc40ce4c88b11215a9330a74e
|
HUGORELEASER_COMMITISH=46cccb021bc6425455f4eec093f5cc4a32f1d12c
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,42 @@
|
|||||||
|
# Test the hugo server command when adding an error to a config file
|
||||||
|
# and then fixing it.
|
||||||
|
|
||||||
|
hugo server &
|
||||||
|
|
||||||
|
waitServer
|
||||||
|
|
||||||
|
httpget ${HUGOTEST_BASEURL_0}p1/ 'Title: P1'
|
||||||
|
|
||||||
|
replace $WORK/hugo.toml 'title =' 'titlefoo'
|
||||||
|
httpget ${HUGOTEST_BASEURL_0}p1/ 'failed'
|
||||||
|
|
||||||
|
replace $WORK/hugo.toml 'titlefoo' 'title ='
|
||||||
|
httpget ${HUGOTEST_BASEURL_0}p1/ 'Title: P1'
|
||||||
|
|
||||||
|
stopServer
|
||||||
|
|
||||||
|
-- hugo.toml --
|
||||||
|
title = "Hugo Server Test"
|
||||||
|
baseURL = "https://example.org/"
|
||||||
|
disableKinds = ["taxonomy", "term", "sitemap"]
|
||||||
|
-- layouts/index.html --
|
||||||
|
Title: {{ .Title }}|BaseURL: {{ site.BaseURL }}|
|
||||||
|
-- layouts/_default/single.html --
|
||||||
|
Title: {{ .Title }}|BaseURL: {{ site.BaseURL }}|
|
||||||
|
-- content/_index.md --
|
||||||
|
---
|
||||||
|
title: Hugo Home
|
||||||
|
---
|
||||||
|
-- content/p1/index.md --
|
||||||
|
---
|
||||||
|
title: P1
|
||||||
|
---
|
||||||
|
-- content/p2/index.md --
|
||||||
|
---
|
||||||
|
title: P2
|
||||||
|
---
|
||||||
|
-- static/staticfiles/static.txt --
|
||||||
|
static
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -0,0 +1,42 @@
|
|||||||
|
# Test the hugo server command when adding a front matter error to a content file
|
||||||
|
# and then fixing it.
|
||||||
|
|
||||||
|
hugo server &
|
||||||
|
|
||||||
|
waitServer
|
||||||
|
|
||||||
|
httpget ${HUGOTEST_BASEURL_0}p1/ 'Title: P1'
|
||||||
|
|
||||||
|
replace $WORK/content/p1/index.md 'title:' 'titlecolon'
|
||||||
|
httpget ${HUGOTEST_BASEURL_0}p1/ 'failed'
|
||||||
|
|
||||||
|
replace $WORK/content/p1/index.md 'titlecolon' 'title:'
|
||||||
|
httpget ${HUGOTEST_BASEURL_0}p1/ 'Title: P1'
|
||||||
|
|
||||||
|
stopServer
|
||||||
|
|
||||||
|
-- hugo.toml --
|
||||||
|
title = "Hugo Server Test"
|
||||||
|
baseURL = "https://example.org/"
|
||||||
|
disableKinds = ["taxonomy", "term", "sitemap"]
|
||||||
|
-- layouts/index.html --
|
||||||
|
Title: {{ .Title }}|BaseURL: {{ site.BaseURL }}|
|
||||||
|
-- layouts/_default/single.html --
|
||||||
|
Title: {{ .Title }}|BaseURL: {{ site.BaseURL }}|
|
||||||
|
-- content/_index.md --
|
||||||
|
---
|
||||||
|
title: Hugo Home
|
||||||
|
---
|
||||||
|
-- content/p1/index.md --
|
||||||
|
---
|
||||||
|
title: P1
|
||||||
|
---
|
||||||
|
-- content/p2/index.md --
|
||||||
|
---
|
||||||
|
title: P2
|
||||||
|
---
|
||||||
|
-- static/staticfiles/static.txt --
|
||||||
|
static
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
@@ -40,7 +40,6 @@ type TemplateManager interface {
|
|||||||
TemplateHandler
|
TemplateHandler
|
||||||
TemplateFuncGetter
|
TemplateFuncGetter
|
||||||
AddTemplate(name, tpl string) error
|
AddTemplate(name, tpl string) error
|
||||||
MarkReady() error
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// TemplateVariants describes the possible variants of a template.
|
// TemplateVariants describes the possible variants of a template.
|
||||||
|
|||||||
+4
-17
@@ -168,6 +168,10 @@ func newTemplateHandlers(d *deps.Deps) (*tpl.TemplateHandlers, error) {
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if err := h.main.createPrototypes(); err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
e := &templateExec{
|
e := &templateExec{
|
||||||
d: d,
|
d: d,
|
||||||
executor: exec,
|
executor: exec,
|
||||||
@@ -312,28 +316,11 @@ func (t *templateExec) GetFunc(name string) (reflect.Value, bool) {
|
|||||||
return v, found
|
return v, found
|
||||||
}
|
}
|
||||||
|
|
||||||
func (t *templateExec) MarkReady() error {
|
|
||||||
var err error
|
|
||||||
t.readyInit.Do(func() {
|
|
||||||
// We only need the clones if base templates are in use.
|
|
||||||
if len(t.needsBaseof) > 0 {
|
|
||||||
err = t.main.createPrototypes()
|
|
||||||
if err != nil {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
type templateHandler struct {
|
type templateHandler struct {
|
||||||
main *templateNamespace
|
main *templateNamespace
|
||||||
needsBaseof map[string]templateInfo
|
needsBaseof map[string]templateInfo
|
||||||
baseof map[string]templateInfo
|
baseof map[string]templateInfo
|
||||||
|
|
||||||
readyInit sync.Once
|
|
||||||
|
|
||||||
// This is the filesystem to load the templates from. All the templates are
|
// This is the filesystem to load the templates from. All the templates are
|
||||||
// stored in the root of this filesystem.
|
// stored in the root of this filesystem.
|
||||||
layoutsFs afero.Fs
|
layoutsFs afero.Fs
|
||||||
|
|||||||
@@ -248,7 +248,7 @@ func TestToMathMacros(t *testing.T) {
|
|||||||
-- hugo.toml --
|
-- hugo.toml --
|
||||||
disableKinds = ['page','rss','section','sitemap','taxonomy','term']
|
disableKinds = ['page','rss','section','sitemap','taxonomy','term']
|
||||||
-- layouts/index.html --
|
-- layouts/index.html --
|
||||||
{{ $macros := dict
|
{{ $macros := dict
|
||||||
"\\addBar" "\\bar{#1}"
|
"\\addBar" "\\bar{#1}"
|
||||||
"\\bold" "\\mathbf{#1}"
|
"\\bold" "\\mathbf{#1}"
|
||||||
}}
|
}}
|
||||||
@@ -261,3 +261,21 @@ disableKinds = ['page','rss','section','sitemap','taxonomy','term']
|
|||||||
<mi>y</mi>
|
<mi>y</mi>
|
||||||
`)
|
`)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Issue #12977
|
||||||
|
func TestUnmarshalWithIndentedYAML(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
files := `
|
||||||
|
-- hugo.toml --
|
||||||
|
disableKinds = ['page','rss','section','sitemap','taxonomy','term']
|
||||||
|
-- layouts/index.html --
|
||||||
|
{{ $yaml := "\n a:\n b: 1\n c:\n d: 2\n" }}
|
||||||
|
{{ $yaml | transform.Unmarshal | encoding.Jsonify }}
|
||||||
|
`
|
||||||
|
|
||||||
|
b := hugolib.Test(t, files)
|
||||||
|
|
||||||
|
b.AssertFileExists("public/index.html", true)
|
||||||
|
b.AssertFileContent("public/index.html", `{"a":{"b":1},"c":{"d":2}}`)
|
||||||
|
}
|
||||||
|
|||||||
@@ -112,9 +112,8 @@ func (ns *Namespace) Unmarshal(args ...any) (any, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, fmt.Errorf("type %T not supported", data)
|
return nil, fmt.Errorf("type %T not supported", data)
|
||||||
}
|
}
|
||||||
dataStr = strings.TrimSpace(dataStr)
|
|
||||||
|
|
||||||
if dataStr == "" {
|
if strings.TrimSpace(dataStr) == "" {
|
||||||
return nil, nil
|
return nil, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user