feat(cmd/idpd): add influxdata platform server

feat(cmd/idpd): add influxdata platform server daemon

cmd/idpd/main.go

@@ -0,0 +1,146 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	nethttp "net/http"
+	_ "net/http/pprof"
+	"os"
+	"os/signal"
+	"syscall"
+	"time"
+
+	"go.uber.org/zap"
+
+	influxlogger "github.com/influxdata/influxdb/logger"
+	"github.com/influxdata/platform"
+	"github.com/influxdata/platform/bolt"
+	"github.com/influxdata/platform/http"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+func main() {
+	Execute()
+}
+
+var (
+	httpBindAddress   string
+	authorizationPath string
+	boltPath          string
+)
+
+func init() {
+	viper.SetEnvPrefix("INFLUX")
+
+	platformCmd.Flags().StringVar(&httpBindAddress, "http-bind-address", ":9999", "bind address for the rest http api")
+	viper.BindEnv("HTTP_BIND_ADDRESS")
+	if h := viper.GetString("HTTP_BIND_ADDRESS"); h != "" {
+		httpBindAddress = h
+	}
+
+	platformCmd.Flags().StringVar(&authorizationPath, "authorizationPath", "", "path to a bootstrap token")
+	viper.BindEnv("TOKEN_PATH")
+	if h := viper.GetString("TOKEN_PATH"); h != "" {
+		authorizationPath = h
+	}
+
+	platformCmd.Flags().StringVar(&boltPath, "bolt-path", "idpdb.bolt", "path to boltdb database")
+	viper.BindEnv("BOLT_PATH")
+	if h := viper.GetString("BOLT_PATH"); h != "" {
+		boltPath = h
+	}
+}
+
+var platformCmd = &cobra.Command{
+	Use:   "idpd",
+	Short: "influxdata platform",
+	Run:   platformF,
+}
+
+func platformF(cmd *cobra.Command, args []string) {
+	// Create top level logger
+	logger := influxlogger.New(os.Stdout)
+
+	c := bolt.NewClient()
+	c.Path = boltPath
+
+	if err := c.Open(context.TODO()); err != nil {
+		logger.Error("failed opening bolt", zap.Error(err))
+		os.Exit(1)
+	}
+	defer c.Close()
+
+	var authSvc platform.AuthorizationService
+	{
+	}
+
+	var bucketSvc platform.BucketService
+	{
+		bucketSvc = c
+	}
+
+	var orgSvc platform.OrganizationService
+	{
+	}
+
+	var userSvc platform.UserService
+	{
+	}
+
+	errc := make(chan error)
+
+	sigs := make(chan os.Signal, 1)
+	signal.Notify(sigs, syscall.SIGTERM)
+
+	httpServer := &nethttp.Server{
+		Addr: httpBindAddress,
+	}
+
+	// HTTP server
+	go func() {
+		bucketHandler := http.NewBucketHandler()
+		bucketHandler.BucketService = bucketSvc
+
+		orgHandler := http.NewOrgHandler()
+		orgHandler.OrganizationService = orgSvc
+
+		userHandler := http.NewUserHandler()
+		userHandler.UserService = userSvc
+
+		authHandler := http.NewAuthorizationHandler()
+		authHandler.AuthorizationService = authSvc
+		authHandler.Logger = logger.With(zap.String("handler", "auth"))
+
+		platformHandler := &http.PlatformHandler{
+			BucketHandler:        bucketHandler,
+			OrgHandler:           orgHandler,
+			UserHandler:          userHandler,
+			AuthorizationHandler: authHandler,
+		}
+		h := http.NewHandler("platform")
+		h.Handler = platformHandler
+
+		httpServer.Handler = h
+		logger.Info("listening", zap.String("transport", "http"), zap.String("addr", httpBindAddress))
+		errc <- httpServer.ListenAndServe()
+	}()
+
+	select {
+	case <-sigs:
+	case err := <-errc:
+		logger.Fatal("unable to start platform", zap.Error(err))
+	}
+
+	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
+	defer cancel()
+	httpServer.Shutdown(ctx)
+}
+
+// Execute executes the idped command
+func Execute() {
+	if err := platformCmd.Execute(); err != nil {
+		fmt.Println(err)
+		os.Exit(1)
+	}
+}