Adds files for first pass

.gitignore

@@ -0,0 +1,5 @@
+*~
+pullrequester
+.test
+
+testing

.travis.yml

@@ -0,0 +1,21 @@
+language: go
+
+go:
+  - 1.9
+
+branches:
+  only:
+    - master
+
+before_install:
+- ./look_for_logs.sh
+- go get github.com/axw/gocov/gocov
+- go get github.com/mattn/goveralls
+- go get golang.org/x/lint/golint
+- go get github.com/GeertJohan/fgt
+- if ! go get github.com/golang/tools/cmd/cover; then go get golang.org/x/tools/cmd/cover;
+  fi
+
+script:
+- fgt golint $(find . | grep .go$ | grep -v pullrequester.pb.go)
+- $HOME/gopath/bin/goveralls -service=travis-ci -ignore=pullrequester.go -package github.com/brotherlogic/pullrequester

build.sh

@@ -0,0 +1 @@
+protoc --proto_path ../../../ -I=./proto --go_out=plugins=grpc:./proto proto/pullrequester.proto

look_for_logs.sh

@@ -0,0 +1,20 @@
+#!/bin/bash
+grep log.Print * -Rl | grep .go$ | grep -v _test.go
+RESULT=$?
+if [ $RESULT != 1 ]; then
+    exit 1
+fi
+
+grep context.Background * -Rl | grep .go$ | grep -v _test.go
+RESULT=$?
+if [ $RESULT != 1 ]; then
+    exit 1
+fi
+
+RESULT1=$(grep "conn, err" *.go -R | wc | awk '{print $1}')
+RESULT2=$(grep "conn.Close" *.go -R | wc| awk '{print $1}')
+
+if [ $RESULT1 != $RESULT2 ]; then
+    echo "Missing Closes!"
+    exit 1
+fi

proto/pullrequester.proto

@@ -0,0 +1,8 @@
+syntax = "proto3";
+
+package pullrequester;
+
+message Config {
+  int64 last_run = 1;
+}
+

pullrequester.go

@@ -0,0 +1,114 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"time"
+
+	"github.com/brotherlogic/goserver"
+	"github.com/brotherlogic/keystore/client"
+	"golang.org/x/net/context"
+	"google.golang.org/grpc"
+
+	pbg "github.com/brotherlogic/goserver/proto"
+	"github.com/brotherlogic/goserver/utils"
+	pb "github.com/brotherlogic/pullrequester/proto"
+)
+
+const (
+	// KEY - where we store sale info
+	KEY = "/github.com/brotherlogic/pullrequester/config"
+)
+
+//Server main server type
+type Server struct {
+	*goserver.GoServer
+	config *pb.Config
+}
+
+// Init builds the server
+func Init() *Server {
+	s := &Server{
+		GoServer: &goserver.GoServer{},
+		config:   &pb.Config{},
+	}
+	return s
+}
+
+func (s *Server) save(ctx context.Context) {
+	s.KSclient.Save(ctx, KEY, s.config)
+}
+
+func (s *Server) load(ctx context.Context) error {
+	config := &pb.Config{}
+	data, _, err := s.KSclient.Read(ctx, KEY, config)
+
+	if err != nil {
+		return err
+	}
+
+	s.config = data.(*pb.Config)
+	return nil
+}
+
+// DoRegister does RPC registration
+func (s *Server) DoRegister(server *grpc.Server) {
+	// Pass
+}
+
+// ReportHealth alerts if we're not healthy
+func (s *Server) ReportHealth() bool {
+	return true
+}
+
+// Shutdown the server
+func (s *Server) Shutdown(ctx context.Context) error {
+	s.save(ctx)
+	return nil
+}
+
+// Mote promotes/demotes this server
+func (s *Server) Mote(ctx context.Context, master bool) error {
+	if master {
+		err := s.load(ctx)
+		return err
+	}
+
+	return nil
+}
+
+// GetState gets the state of the server
+func (s *Server) GetState() []*pbg.State {
+	return []*pbg.State{
+		&pbg.State{Key: "last_run", Value: s.config.LastRun},
+	}
+}
+
+func main() {
+	var quiet = flag.Bool("quiet", false, "Show all output")
+	var init = flag.Bool("init", false, "Prep server")
+	flag.Parse()
+
+	//Turn off logging
+	if *quiet {
+		log.SetFlags(0)
+		log.SetOutput(ioutil.Discard)
+	}
+	server := Init()
+	server.GoServer.KSclient = *keystoreclient.GetClient(server.DialMaster)
+	server.PrepServer()
+	server.Register = server
+	server.RegisterServer("pullrequester", false)
+
+	if *init {
+		ctx, cancel := utils.BuildContext("pullrequester", "pullrequester")
+		defer cancel()
+		server.config.LastRun = time.Now().Unix()
+		server.save(ctx)
+		return
+	}
+
+	fmt.Printf("%v", server.Serve())
+}

pullrequesterutils.go

@@ -0,0 +1,4 @@
+package main
+
+func doNothing() {
+}

pullrequesterutils_test.go

@@ -0,0 +1,7 @@
+package main
+
+import "testing"
+
+func TestBasic(t *testing.T) {
+	doNothing()
+}