randomizr/randomizr.go

package main

import (
	"bufio"
	"bytes"
	"flag"
	"fmt"
	"io"
	"math/rand"
	"os"
	"os/signal"
	"strconv"
	"strings"
	"syscall"
	"time"
)

var (
	dictionary string        // pathname for a file containing dictionary words
	words      wordBag       // index of words by length
	fname      string        // output filename
	freq       float64       // frequency at which lines are written
	ftruncate  bool          // whether or not to truncate file on open
	pidfile    string        // path of pidfile to write out
	reopen     bool          // whether or not to reopen the file handle on every line write
	stutter    time.Duration // amount of time to stutter when writing a line
	multiline  bool          // whether or not multiline messages are possible
	tsformat   string        // timestamp format
	lineLength lengthArg     // length of the lines to be generated
	ts         func() string // function to get a timestamp string
	line       func() string // function to generate a line
)

type wordBag map[int][]string

func (w wordBag) readAll(r io.Reader) error {
	br := bufio.NewReader(r)

ReadLines:
	for {
		line, err := br.ReadString('\n')
		switch err {
		case io.EOF:
			break ReadLines
		case nil:
			w.add(strings.TrimSpace(line))
		default:
			return fmt.Errorf("unable to add word to wordBag: %s", err.Error())
		}
	}
	return nil
}

func (w wordBag) add(word string) {
	if w[len(word)] == nil {
		w[len(word)] = make([]string, 0, 32)
	}
	w[len(word)] = append(w[len(word)], word)
}

func (w wordBag) lengths() []int {
	lengths := make([]int, 0, len(w))
	for length, _ := range w {
		lengths = append(lengths, length)
	}
	return lengths
}

func (w wordBag) randomWordN(n int) string {
	words, ok := w[n]
	if ok {
		if len(words) == 1 {
			return words[0]
		}
		return words[rand.Intn(len(words)-1)]
	}
	return ""
}

func (w wordBag) randomWordBelow(n int) string {
	for {
		s := w.randomWordN(rand.Intn(n))
		if s != "" {
			return s
		}
	}
}

func (w wordBag) wordString(n int) string {
	var (
		buf       bytes.Buffer
		remaining = n
	)

	for {
		switch {
		case remaining < 0:
			return buf.String()
		case remaining < 8:
			buf.WriteString(w.randomWordN(remaining))
		default:
			buf.WriteString(w.randomWordBelow(8))
		}
		remaining = n - buf.Len()
		if multiline && remaining > 1 && rand.Float64() > 0.98 {
			buf.WriteRune('\n')
		} else {
			buf.WriteRune(' ')
		}
	}
}

// command-line length argument parsing type.  Line lengths can be specified as
// either integers or strings, with strings naming known length-generating
// functions.
type lengthArg struct {
	n      int
	random bool
}

func (l *lengthArg) String() string {
	return "length."
}

// used by the flag paackge for parsing line length args
func (l *lengthArg) Set(v string) error {
	if i, err := strconv.Atoi(v); err == nil {
		*l = lengthArg{n: i}
		return nil
	}

	switch v {
	case "rand", "random":
		*l = lengthArg{random: true}
		return nil
	default:
		return fmt.Errorf("bad length arg: %s", v)
	}
}

func (l *lengthArg) mkLineFn() (func() string, error) {
	if ts == nil {
		ts = mkTsFn()
	}
	if l.n == 0 {
		l.n = 80
	}
	tsLen := len(ts())
	switch {
	case words != nil && l.random:
		return func() string {
			return words.wordString(rand.Intn(80 - tsLen))
		}, nil
	case words != nil:
		return func() string {
			return words.wordString(l.n - tsLen)
		}, nil
	case dictionary == "" && l.random:
		return func() string {
			return randomString(rand.Intn(80 - tsLen))
		}, nil
	case dictionary == "":
		if tsLen > l.n {
			return nil, fmt.Errorf("line length %d is too small for timestamps like %s", l.n, ts())
		}
		return func() string {
			return randomString(l.n - tsLen)
		}, nil
	default:
		return nil, fmt.Errorf("how did I even get here?")
	}
}

// generates a pseudorandom string of length n that is composed of alphanumeric
// characters.
func randomString(n int) string {
	var alpha = "  abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
	if multiline {
		alpha += "\n\n"
	}
	buf := make([]byte, n)
	for i := 0; i < len(buf); i++ {
		buf[i] = alpha[rand.Intn(len(alpha)-1)]
	}
	return string(buf)
}

func outFile() (*os.File, error) {
	if fname == "" {
		return os.Stdout, nil
	}
	options := os.O_WRONLY | os.O_CREATE
	if ftruncate {
		options |= os.O_TRUNC
	} else {
		options |= os.O_APPEND
	}

	return os.OpenFile(fname, options, 0644)
}

func reopenWrite(c chan string) {
	for line := range c {
		f, err := outFile()
		if err != nil {
			fmt.Printf("ERROR: unable to open outfile: %v", err)
			continue
		}
		if _, err := f.WriteString(line); err != nil {
			fmt.Printf("ERROR: unable to write line: %v", err)
		}
		f.Close()
	}
}

func regularWrite(c chan string) {
	hup := make(chan os.Signal, 1)
	signal.Notify(hup, syscall.SIGHUP, syscall.SIGUSR1)

START:
	f, err := outFile()
	if err != nil {
		fmt.Printf("ERROR: unable to open outfile: %v", err)
		return
	}

	for {
		select {
		case line := <-c:
			if _, err := f.WriteString(line); err != nil {
				fmt.Printf("ERROR: unable to write line: %v", err)
			}
		case <-hup:
			fmt.Fprintf(f, "%s HUP\n", ts())
			f.Close()
			goto START
		}
	}
}

func writeLines(c chan string) {
	if reopen {
		go reopenWrite(c)
	} else {
		go regularWrite(c)
	}
}

func writePid() {
	if pidfile == "" {
		return
	}
	f, err := os.OpenFile(pidfile, os.O_WRONLY|os.O_TRUNC|os.O_CREATE, 0644)
	if err != nil {
		fmt.Fprintf(os.Stderr, "ERROR unable to open pidfile: %v", err)
		return
	}
	fmt.Fprintln(f, os.Getpid())
}

func mkTsFn() func() string {
	switch tsformat {
	case "":
		return func() string {
			t := time.Now()
			return fmt.Sprintf("%s %4.4d", t.Format("15:04:05"), t.Nanosecond()/1e5)
		}
	case "ns":
		return func() string {
			t := time.Now()
			return fmt.Sprintf("%d", t.UnixNano())
		}
	case "ms":
		return func() string {
			t := time.Now()
			return fmt.Sprintf("%d", t.UnixNano()/1e6)
		}
	case "epoch", "unix":
		return func() string {
			t := time.Now()
			return fmt.Sprintf("%d", t.Unix())
		}
	default:
		return func() string {
			return time.Now().Format(tsformat)
		}
	}
}

func readDict(path string) error {
	f, err := os.Open(path)
	if err != nil {
		return fmt.Errorf("unable to read dictionary file: %s", err.Error())
	}
	defer f.Close()

	words = make(wordBag, 32)
	if err := words.readAll(f); err != nil {
		return fmt.Errorf("error reading dictionary file: %s", err.Error())
	}
	return nil
}

func flags() (err error) {
	flag.Parse()
	if dictionary != "" {
		readDict(dictionary)
	}
	ts = mkTsFn()
	line, err = lineLength.mkLineFn()
	return
}

func main() {
	if err := flags(); err != nil {
		fmt.Println(err.Error())
		os.Exit(1)
	}
	writePid()
	c := make(chan string)

	if stutter > 0 {
		cc := make(chan string, 1)
		go func() {
			for line := range c {
				n := rand.Intn(len(line))
				left, right := line[:n], line[n:]
				cc <- left
				time.Sleep(stutter)
				cc <- right
			}
		}()
		writeLines(cc)
	} else {
		writeLines(c)
	}

	for _ = range time.Tick(time.Duration(1e9 / freq)) {
		c <- fmt.Sprintf("%s %s\n", ts(), line())
	}
}

func init() {
	flag.StringVar(&fname, "file", "", "destination file to which random data will be written")
	flag.StringVar(&tsformat, "ts-format", "", "timestamp format")
	flag.BoolVar(&multiline, "multiline", false, "whether or not multiline messages are possible")
	flag.StringVar(&pidfile, "pidfile", "", "file to which a pid is written")
	flag.BoolVar(&ftruncate, "truncate", false, "truncate file on opening instead of appending")
	flag.DurationVar(&stutter, "stutter", 0, "stutter for this amount of time when writing each line")
	flag.StringVar(&dictionary, "dict", "", "dictionary of words to use for generating log data")
	flag.BoolVar(&reopen, "reopen", false, "reopen file handle on every write instead of using a persistent handle")
	flag.Float64Var(&freq, "freq", 10, "frequency in hz at which lines will be written")
	flag.Var(&lineLength, "line-length", "length of the lines to be generated (in bytes)")
	rand.Seed(time.Now().UnixNano())
}