Merge pull request openshift#1 from ecordell/basic-registry

Data storage for registry API

(upstream operator-registry commit: 3ebf38cfd6d676230293c4588e5b3e6e5e90559e)

Author: ecordell

staging/operator-registry/Dockerfile

@@ -4,9 +4,9 @@ RUN apk update && apk add sqlite build-base
 WORKDIR /go/src/github.com/operator-framework/operator-registry
 
 COPY vendor vendor
-COPY cmd cmd
-COPY pkg pkg
-RUN go build --tags json1 -o ./initializer ./cmd/init/...
+COPY init init
+COPY store store
+RUN go build --tags json1 -o ./initializer ./init/...
 
 COPY manifests manifests
 RUN ./initializer

staging/operator-registry/Gopkg.lock

@@ -29,6 +29,10 @@
   name = "github.com/mattn/go-sqlite3"
   version = "1.9.0"
 
+[[constraint]]
+  name = "github.com/operator-framework/operator-lifecycle-manager"
+  version = "0.7.1"
+
 [[constraint]]
   name = "github.com/sirupsen/logrus"
   version = "1.0.6"

staging/operator-registry/Gopkg.toml

@@ -0,0 +1,17 @@
+CREATE TABLE operatorbundle (
+	id   INTEGER, 
+	name TEXT,  
+	csv TEXT, 
+	bundle TEXT
+);
+CREATE TABLE package (
+	id   INTEGER, 
+	name TEXT, 
+);
+CREATE TABLE channel (
+	name TEXT, 
+	package_id INTEGER, 
+	operatorbundle_id INTEGER,
+	FOREIGN KEY(package_id) REFERENCES package(id),
+	FOREIGN KEY(operatorbundle_id) REFERENCES operatorbundle(id)
+)

staging/operator-registry/init.sql

@@ -0,0 +1,58 @@
+package main
+
+import (
+	"github.com/operator-framework/operator-registry/store"
+	"github.com/sirupsen/logrus"
+	"github.com/spf13/cobra"
+)
+
+func main() {
+	var rootCmd = &cobra.Command{
+		Short: "initializer",
+		Long:  `initializer takes a directory of OLM manifests and outputs a sqlite database containing them`,
+
+		PreRunE: func(cmd *cobra.Command, args []string) error {
+			if debug, _ := cmd.Flags().GetBool("debug"); debug {
+				logrus.SetLevel(logrus.DebugLevel)
+			}
+			return nil
+		},
+
+		RunE: runCmdFunc,
+	}
+
+	rootCmd.Flags().Bool("debug", false, "enable debug logging")
+	rootCmd.Flags().StringP("manifests", "m", "manifests", "relative path to directory of manifests")
+	rootCmd.Flags().StringP("output", "o", "bundles.db", "relative path to a sqlite file to create or overwrite")
+	if err := rootCmd.Flags().MarkHidden("debug"); err != nil {
+		panic(err)
+	}
+
+	if err := rootCmd.Execute(); err != nil {
+		panic(err)
+	}
+}
+
+func runCmdFunc(cmd *cobra.Command, args []string) error {
+	outFilename, err := cmd.Flags().GetString("output")
+	if err != nil {
+		return err
+	}
+	manifestDir, err := cmd.Flags().GetString("manifests")
+	if err != nil {
+		return err
+	}
+
+	dbLoader, err := store.NewSQLLiteLoader(outFilename)
+	if err != nil {
+		logrus.Fatal(err)
+	}
+	defer dbLoader.Close()
+
+	loader := store.NewSQLLoaderForDirectory(dbLoader, manifestDir)
+	if err := loader.Populate(); err != nil {
+		logrus.Fatal(err)
+	}
+
+	return nil
+}