downgrade-kops-etcd-manager-state.go

package main

import (
	"log"
	"io/ioutil"
	"os"
	"fmt"
	protoetcd "kope.io/etcd-manager/pkg/apis/etcd"
	"github.com/golang/protobuf/proto"
)

func main() {
	log.Print("Starting")

	b, err := ioutil.ReadFile("/home/e/_kube_fuckup/events-state.orig")
	if err != nil {
		if os.IsNotExist(err) {
			return
		}
		log.Print(fmt.Errorf("error reading state file: %v", err))
		return
	}
	state := &protoetcd.EtcdState{}
	if err := proto.Unmarshal(b, state); err != nil {
		log.Print(fmt.Errorf("error parsing state file: %v", err))
		return
	}
	state.EtcdVersion = "2.2.1"
	state.Cluster.ClusterToken = "etcd-cluster-token-etcd-events"

	data, err := proto.Marshal(state)
	if err != nil {
		log.Print(fmt.Errorf("error marshaling state: %v", err))
		return
	}
	err = ioutil.WriteFile("/home/e/_kube_fuckup/events-state.new", data, 0644)
	if err != nil {
		log.Print(fmt.Errorf("error saving state: %v", err))
		return
	}

	b, err = ioutil.ReadFile("/home/e/_kube_fuckup/main-state.orig")
	if err != nil {
		if os.IsNotExist(err) {
			return
		}
		log.Print(fmt.Errorf("error reading state file: %v", err))
		return
	}
	state = &protoetcd.EtcdState{}
	if err := proto.Unmarshal(b, state); err != nil {
		log.Print(fmt.Errorf("error parsing state file: %v", err))
		return
	}
	state.EtcdVersion = "2.2.1"
	state.Cluster.ClusterToken = "etcd-cluster-token-etcd"

	data, err = proto.Marshal(state)
	if err != nil {
		log.Print(fmt.Errorf("error marshaling state: %v", err))
		return
	}
	err = ioutil.WriteFile("/home/e/_kube_fuckup/main-state.new", data, 0644)
	if err != nil {
		log.Print(fmt.Errorf("error saving state: %v", err))
		return
	}


	log.Print("Finished")
}