// Copyright 2019 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// The maintwatch commands tails the maintner mutation log.
package main

import (
	"context"
	"flag"
	"fmt"
	"log"
	"os"
	"time"

	"github.com/golang/protobuf/proto"
	"golang.org/x/build/maintner"
)

var server = flag.String("server", "https://maintner.golang.org/logs", "maintner server's /logs URL")

func main() {
	flag.Parse()
	for {
		err := maintner.TailNetworkMutationSource(context.Background(), *server, func(e maintner.MutationStreamEvent) error {
			if e.Err != nil {
				log.Printf("# ignoring err: %v\n", e.Err)
				time.Sleep(5 * time.Second)
				return nil
			}
			if e.Mutation != nil {
				fmt.Println()
				tm := proto.TextMarshaler{Compact: false}
				tm.Marshal(os.Stdout, e.Mutation)
			}
			return nil
		})
		log.Printf("tail error: %v; restarting", err)
		time.Sleep(time.Second)
	}
}