[WIP] make c8y bootstrap work

c8y/c8y_client.go

@@ -0,0 +1,51 @@
+package c8y
+
+import (
+	"errors"
+	"fmt"
+	"math/rand"
+	"strings"
+)
+import MQTT "github.com/eclipse/paho.mqtt.golang"
+
+func C8yBootstrap(tenant string, password string) (string, error) {
+	// configure MQTT client
+	opts := MQTT.NewClientOptions().AddBroker("tcps://" + tenant + ".cumulocity.com:8883") // scheme://host:port
+	opts.SetUsername("management/devicebootstrap")
+	opts.SetUsername(password)
+	opts.SetClientID(fmt.Sprintf("%s-c8y-mqtt-client-%d", tenant, rand.Uint32()))
+
+	c8yError := make(chan error)
+	c8yAuth := make(chan string)
+	var receive MQTT.MessageHandler = func(client MQTT.Client, msg MQTT.Message) {
+		authorization := string(msg.Payload())
+		if strings.HasPrefix(authorization, "70") {
+			c8yAuth <- authorization
+		}
+		c8yError <- errors.New(fmt.Sprintf("unknown message received: %v", msg))
+	}
+
+	// configure OnConnect callback: subscribe
+	opts.OnConnect = func(c MQTT.Client) {
+		if token := c.Subscribe("s/dcr", 0, receive); token.Wait() && token.Error() != nil {
+			c8yError <- token.Error()
+			return
+		}
+
+		pubTopic := "s/ucr"
+		c.Publish(pubTopic, 0, false, nil)
+	}
+
+	client := MQTT.NewClient(opts)
+	if token := client.Connect(); token.Wait() && token.Error() != nil {
+		return "", token.Error()
+	}
+
+	defer client.Disconnect(0)
+	select {
+	case auth := <-c8yAuth:
+		return auth, nil
+	case err := <-c8yError:
+		return "", err
+	}
+}

go.mod → c8y/go.mod

@@ -1,9 +1,8 @@
-module github.com/ubirch/ubirch-go-c8y-client
+module github.com/ubirch/ubirch-go-c8y-client/c8y
 
 go 1.13
 
 require (
 	github.com/eclipse/paho.mqtt.golang v1.2.0
-	github.com/google/uuid v1.1.1
 	golang.org/x/net v0.0.0-20191014212845-da9a3fd4c582 // indirect
 )

main/go.mod

@@ -0,0 +1,7 @@
+module main
+
+go 1.13
+
+require github.com/ubirch/ubirch-go-c8y-client/c8y v1.0.0
+
+replace github.com/ubirch/ubirch-go-c8y-client/c8y v1.0.0 => ../c8y

main/main.go

@@ -1,14 +1,17 @@
 package main
 
 import (
-	// "github.com/google/uuid"
-	"github.com/ubirch/ubirch-go-c8y-client"
+	"fmt"
+	"github.com/ubirch/ubirch-go-c8y-client/c8y"
 )
-import MQTT "github.com/eclipse/paho.mqtt.golang"
 
 func main() {
 	tenant := "ubirch"
-	c8yPassword := "xyz"
-	handler := MQTT.MessageHandler{}
-	c8yAuth, err := ubirch_go_c8y_client.C8yBootstrap(tenant, c8yPassword, handler)
+	c8yPassword := "---"
+	c8yAuth, err := c8y.C8yBootstrap(tenant, c8yPassword)
+	if err != nil {
+		panic(fmt.Sprintf("unable to bootstrap device: %v", err))
+	}
+
+	fmt.Printf(c8yAuth)
 }