main.go

package main

import (
	"errors"
	"fmt"
	"os"
	"runtime"

	"github.com/disintegration/imaging"
)

type picture struct {
	currentPath         string
	targetPath          string
	currentRgbHistogram rgbHistogram
	targetRgbHistogram  rgbHistogram
}

func main() {
	//Initial console output
	printInfo()
	//Read parameters from console
	config = collectConfigInformation()
	//Initialize Window from config and start GUI
	initalizeWindow()
	window.Main()
	os.Exit(0)
}

func runDeflickering() error {

	//Prepare
	configError := validateConfigInformation()
	if configError != nil {
		return configError
	}
	clear()
	runtime.GOMAXPROCS(config.threads)
	pictures, picturesError := readDirectory(config.sourceDirectory, config.destinationDirectory)
	if picturesError != nil {
		return picturesError
	}
	progress := createProgressBars(len(pictures))
	progress.container.Start()

	//Analyze and create Histograms
	var analyzeError error
	pictures, analyzeError = forEveryPicture(pictures, progress.bars["analyze"], config.threads, func(pic picture) (picture, error) {
		img, err := imaging.Open(pic.currentPath)
		if err != nil {
			return pic, errors.New(pic.currentPath + " | " + err.Error())
		}
		pic.currentRgbHistogram = generateRgbHistogramFromImage(img)
		return pic, nil
	})
	if analyzeError != nil {
		progress.container.Stop()
		return analyzeError
	}

	//Calculate global or rolling average
	if config.rollingAverage < 1 {
		var averageRgbHistogram rgbHistogram
		for i := range pictures {
			for j := 0; j < 256; j++ {
				averageRgbHistogram.r[j] += pictures[i].currentRgbHistogram.r[j]
				averageRgbHistogram.g[j] += pictures[i].currentRgbHistogram.g[j]
				averageRgbHistogram.b[j] += pictures[i].currentRgbHistogram.b[j]
			}
		}
		for i := 0; i < 256; i++ {
			averageRgbHistogram.r[i] /= uint32(len(pictures))
			averageRgbHistogram.g[i] /= uint32(len(pictures))
			averageRgbHistogram.b[i] /= uint32(len(pictures))
		}
		for i := range pictures {
			pictures[i].targetRgbHistogram = averageRgbHistogram
		}
	} else {
		for i := range pictures {
			var averageRgbHistogram rgbHistogram
			var start = i - config.rollingAverage
			if start < 0 {
				start = 0
			}
			var end = i + config.rollingAverage
			if end > len(pictures)-1 {
				end = len(pictures) - 1
			}
			for i := start; i <= end; i++ {
				for j := 0; j < 256; j++ {
					averageRgbHistogram.r[j] += pictures[i].currentRgbHistogram.r[j]
					averageRgbHistogram.g[j] += pictures[i].currentRgbHistogram.g[j]
					averageRgbHistogram.b[j] += pictures[i].currentRgbHistogram.b[j]
				}
			}
			for i := 0; i < 256; i++ {
				averageRgbHistogram.r[i] /= uint32(end - start + 1)
				averageRgbHistogram.g[i] /= uint32(end - start + 1)
				averageRgbHistogram.b[i] /= uint32(end - start + 1)
			}
			pictures[i].targetRgbHistogram = averageRgbHistogram
		}
	}

	var adjustError error
	pictures, adjustError = forEveryPicture(pictures, progress.bars["adjust"], config.threads, func(pic picture) (picture, error) {
		var img, _ = imaging.Open(pic.currentPath)
		lut := generateRgbLutFromRgbHistograms(pic.currentRgbHistogram, pic.targetRgbHistogram)
		img = applyRgbLutToImage(img, lut)
		err := imaging.Save(img, pic.targetPath, imaging.JPEGQuality(config.jpegCompression), imaging.PNGCompressionLevel(0))
		if err != nil {
			return pic, errors.New(pic.currentPath + " | " + err.Error())
		}
		return pic, nil
	})
	if adjustError != nil {
		progress.container.Stop()
		return adjustError
	}
	progress.container.Stop()
	clear()
	fmt.Printf("Saved %v pictures into %v", len(pictures),config.destinationDirectory)
	return nil
}