add minimal slack support

Author: sechmann

.gitignore

@@ -1,2 +1,3 @@
 .idea/
 bin
+.env

apiserver/config/config.go

@@ -1,7 +1,9 @@
 package config
 
 type Config struct {
-	DbConnURI string
+	DbConnURI   string
+	SlackToken  string
+	BindAddress string
 }
 
 func DefaultConfig() Config {

apiserver/slack/slack.go

@@ -0,0 +1,84 @@
+package slack
+
+import (
+	"fmt"
+	"github.com/nais/device/apiserver/database"
+	log "github.com/sirupsen/logrus"
+	"github.com/slack-go/slack"
+	"strings"
+)
+
+type slackbot struct {
+	api      *slack.Client
+	database database.APIServerDB
+}
+
+func New(token string, database database.APIServerDB) *slackbot {
+	return &slackbot{
+		api:      slack.New(token),
+		database: database,
+	}
+}
+
+func (s *slackbot) registrationSlackHandler() {
+	log.SetLevel(log.DebugLevel)
+	rtm := s.api.NewRTM()
+
+	go rtm.ManageConnection()
+
+	for message := range rtm.IncomingEvents {
+		log.Debugf("received rtm msg: %v", message)
+		switch ev := message.Data.(type) {
+		case *slack.MessageEvent:
+			msg := ev.Msg
+
+			if msg.SubType != "" {
+				break
+			}
+
+			log.Debugf("%v", msg.User)
+			publicKey, serial, err := parseRegisterMessage(msg.Text)
+			if err != nil {
+				log.Errorf("parsing message: %v", err)
+			}
+
+			email, err := s.getUserEmail(msg.User)
+			if err != nil {
+				log.Errorf("getting user email: %v", err)
+			}
+
+			log.Infof("email: %v, publicKey: %v, serial: %v", email, publicKey, serial)
+
+			err = s.database.AddClient(msg.Username, publicKey, serial)
+			if err != nil {
+				log.Errorf("adding client to database: %v", err)
+				rtm.SendMessage(rtm.NewOutgoingMessage("Something went wrong during registration :sweat_smile:, I've notified the nais device team for you.", msg.Channel))
+			} else {
+				rtm.SendMessage(rtm.NewOutgoingMessage("Successfully registered :partyparrot:", msg.Channel))
+			}
+
+
+		case *slack.InvalidAuthEvent:
+			log.Fatalf("slack auth failed: %v", message)
+		}
+	}
+}
+
+func parseRegisterMessage(text string) (string, string, error) {
+	// "register publicKey serial"
+	parts := strings.Split(text, " ")
+	publicKey, serial := parts[1], parts[2]
+	return publicKey, serial, nil
+}
+
+func (s *slackbot) getUserEmail(userID string) (string, error) {
+	if info, err := s.api.GetUserInfo(userID); err != nil {
+		return "", fmt.Errorf("getting user info: %w", err)
+	} else {
+		return info.Profile.Email, nil
+	}
+}
+
+func (s *slackbot) Run() {
+	go s.registrationSlackHandler()
+}

cmd/apiserver/main.go

@@ -8,6 +8,7 @@ import (
 	"github.com/nais/device/apiserver/api"
 	"github.com/nais/device/apiserver/config"
 	"github.com/nais/device/apiserver/database"
+	"github.com/nais/device/apiserver/slack"
 	log "github.com/sirupsen/logrus"
 	flag "github.com/spf13/pflag"
 )
@@ -19,6 +20,8 @@ var (
 func init() {
 	log.SetFormatter(&log.JSONFormatter{})
 	flag.StringVar(&cfg.DbConnURI, "db-connection-uri", os.Getenv("DB_CONNECTION_URI"), "database connection URI (DSN)")
+	flag.StringVar(&cfg.SlackToken, "slack-token", os.Getenv("SLACK_TOKEN"), "Slack token")
+	flag.StringVar(&cfg.BindAddress, "bind-address", "10.255.240.1:80", "Bind address")
 
 	flag.Parse()
 }
@@ -30,9 +33,12 @@ func main() {
 		panic(fmt.Sprintf("instantiating database: %s", err))
 	}
 
+
+	slack:= slack.New(cfg.SlackToken, db)
+	slack.Run()
+
 	router := api.New(api.Config{DB: db})
 
-	bindAddr := fmt.Sprintf("%s:%d", "10.255.240.1", 80)
-	fmt.Println("running @", bindAddr)
-	fmt.Println(http.ListenAndServe(bindAddr, router))
+	fmt.Println("running @", cfg.BindAddress)
+	fmt.Println(http.ListenAndServe(cfg.BindAddress, router))
 }

go.mod

@@ -7,7 +7,9 @@ require (
 	github.com/jackc/pgx/v4 v4.5.0
 	github.com/lib/pq v1.3.0 // indirect
 	github.com/sirupsen/logrus v1.4.2
+	github.com/slack-go/slack v0.6.3
 	github.com/spf13/pflag v1.0.5
 	github.com/stretchr/testify v1.5.1
-	golang.zx2c4.com/wireguard v0.0.20200320
+	golang.org/x/crypto v0.0.0-20191002192127-34f69633bfdc // indirect
+	golang.org/x/sys v0.0.0-20200302150141-5c8b2ff67527 // indirect
 )

go.sum

@@ -9,8 +9,12 @@ github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSs
 github.com/go-chi/chi v4.0.4+incompatible h1:7fVnpr0gAXG15uDbtH+LwSeMztvIvlHrBNRkTzgphS0=
 github.com/go-chi/chi v4.0.4+incompatible/go.mod h1:eB3wogJHnLi3x/kFX2A+IbTBlXxmMeXJVKy9tTv1XzQ=
 github.com/go-stack/stack v1.8.0/go.mod h1:v0f6uXyyMGvRgIKkXu+yp6POWl0qKG85gN/melR3HDY=
+github.com/go-test/deep v1.0.4 h1:u2CU3YKy9I2pmu9pX0eq50wCgjfGIt539SqR7FbHiho=
+github.com/go-test/deep v1.0.4/go.mod h1:wGDj63lr65AM2AQyKZd/NYHGb0R+1RLqB8NKt3aSFNA=
 github.com/gofrs/uuid v3.2.0+incompatible h1:y12jRkkFxsd7GpqdSZ+/KCs/fJbqpEXSGd4+jfEaewE=
 github.com/gofrs/uuid v3.2.0+incompatible/go.mod h1:b2aQJv3Z4Fp6yNu3cdSllBxTCLRxnplIgP/c0N/04lM=
+github.com/gorilla/websocket v1.2.0 h1:VJtLvh6VQym50czpZzx07z/kw9EgAxI3x1ZB8taTMQQ=
+github.com/gorilla/websocket v1.2.0/go.mod h1:E7qHFY5m1UJ88s3WnNqhKjPHQ0heANvMoAMk2YaljkQ=
 github.com/jackc/chunkreader v1.0.0 h1:4s39bBR8ByfqH+DKm8rQA3E1LHZWB9XWcrz8fqaZbe0=
 github.com/jackc/chunkreader v1.0.0/go.mod h1:RT6O25fNZIuasFJRyZ4R/Y2BbhasbmZXF9QQ7T3kePo=
 github.com/jackc/chunkreader/v2 v2.0.0/go.mod h1:odVSm741yZoC3dpHEUXIqA9tQRhFrgOHwnPIn9lDKlk=
@@ -71,6 +75,8 @@ github.com/mattn/go-isatty v0.0.5/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hd
 github.com/mattn/go-isatty v0.0.7/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
 github.com/mattn/go-isatty v0.0.8/go.mod h1:Iq45c/XA43vh69/j3iqttzPXn0bhXyGjM0Hdxcsrc5s=
 github.com/mattn/go-isatty v0.0.9/go.mod h1:YNRxwqDuOph6SZLI9vUUz6OYw3QyUt7WiY2yME+cCiQ=
+github.com/nlopes/slack v0.6.0/go.mod h1:JzQ9m3PMAqcpeCam7UaHSuBuupz7CmpjehYMayT6YOk=
+github.com/pkg/errors v0.8.0/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pkg/errors v0.8.1 h1:iURUrRGxPUNPdy5/HRSm+Yj6okJ6UtLINN0Q9M4+h3I=
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
@@ -84,6 +90,8 @@ github.com/shopspring/decimal v0.0.0-20180709203117-cd690d0c9e24/go.mod h1:M+9Nz
 github.com/sirupsen/logrus v1.4.1/go.mod h1:ni0Sbl8bgC9z8RoU9G6nDWqqs/fq4eDPysMBDgk/93Q=
 github.com/sirupsen/logrus v1.4.2 h1:SPIRibHv4MatM3XXNO2BJeFLZwZ2LvZgfQ5+UNI2im4=
 github.com/sirupsen/logrus v1.4.2/go.mod h1:tLMulIdttU9McNUspp0xgXVQah82FyeX6MwdIuYE2rE=
+github.com/slack-go/slack v0.6.3 h1:qU037g8gQ71EuH6S9zYKnvYrEUj0fLFH4HFekFqBoRU=
+github.com/slack-go/slack v0.6.3/go.mod h1:HE4RwNe7YpOg/F0vqo5PwXH3Hki31TplTvKRW9dGGaw=
 github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
@@ -111,8 +119,6 @@ golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn
 golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
 golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/net v0.0.0-20190813141303-74dc4d7220e7/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
-golang.org/x/net v0.0.0-20191003171128-d98b1b443823 h1:Ypyv6BNJh07T1pUSrehkLemqPKXhus2MkfktJ91kRh4=
-golang.org/x/net v0.0.0-20191003171128-d98b1b443823/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
 golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sys v0.0.0-20180905080454-ebe1bf3edb33/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
@@ -135,8 +141,6 @@ golang.org/x/xerrors v0.0.0-20190410155217-1f06c39b4373/go.mod h1:I/5z698sn9Ka8T
 golang.org/x/xerrors v0.0.0-20190513163551-3ee3066db522/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7 h1:9zdDQZ7Thm29KFXgAX/+yaf3eVbP7djjWp/dXAppNCc=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.zx2c4.com/wireguard v0.0.20200320 h1:1vE6zVeO7fix9cJX1Z9ZQ+ikPIIx7vIyU0o0tLDD88g=
-golang.zx2c4.com/wireguard v0.0.20200320/go.mod h1:lDian4Sw4poJ04SgHh35nzMVwGSYlPumkdnHcucAQoY=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=