chore: update config

Signed-off-by: Brad McCoy <[email protected]>

Author: bradmccoydev

.github/workflows/release.yaml

@@ -82,7 +82,6 @@ jobs:
         cosign sign ghcr.io/bradmccoydev/cdevents-controller:latest --yes
         cosign sign ghcr.io/bradmccoydev/cdevents-controller:${{ steps.prep.outputs.VERSION }} --yes
 
-
     # - name: Generate SBOM
     #   uses: anchore/sbom-action@4d571ad1038a9cc29d676154ef265ab8f9027042 # v0.14.2
     #   with:

Makefile

@@ -13,7 +13,7 @@ EXTRA_RUN_ARGS?=
 run:
 	go run -ldflags "-s -w -X github.com/bradmccoydev/cdevents-controller/pkg/version.REVISION=$(GIT_COMMIT)" cmd/cdevents-controller/* \
 	--level=debug --grpc-port=9999 --backend-url=https://httpbin.org/status/401 --backend-url=https://httpbin.org/status/500 \
-	--ui-logo=https://raw.githubusercontent.com/bradmccoydev/cdevents-controller/gh-pages/cuddle_clap.gif $(EXTRA_RUN_ARGS)
+	$(EXTRA_RUN_ARGS)
 
 .PHONY: test
 test:

cmd/cdevents-controller/main.go

@@ -76,6 +76,7 @@ func main() {
 	viper.RegisterAlias("backendUrl", "backend-url")
 	hostname, _ := os.Hostname()
 	viper.SetDefault("jwt-secret", "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9")
+	viper.SetDefault("mongodb-url", "mongodb://mongodb-headless:27017")
 	viper.SetDefault("ui-logo", "https://raw.githubusercontent.com/bradmccoydev/cdevents-controller/gh-pages/cuddle_clap.gif")
 	viper.Set("hostname", hostname)
 	viper.Set("version", version.VERSION)

pkg/api/cdevent.go

@@ -11,6 +11,7 @@ import (
 	"github.com/gorilla/mux"
 	"go.mongodb.org/mongo-driver/mongo"
 	"go.mongodb.org/mongo-driver/mongo/options"
+	"gopkg.in/yaml.v3"
 )
 
 // Info godoc
@@ -33,7 +34,12 @@ func (s *Server) cdEventHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	client, err := mongo.NewClient(options.Client().ApplyURI("mongodb://mongodb-headless:27017/cdevents?ssl=false"))
+	var cdevent CDEvent
+	if err := yaml.Unmarshal(body, &cdevent); err != nil {
+		log.Fatal(err)
+	}
+
+	client, err := mongo.NewClient(options.Client().ApplyURI(s.config.MongodbURL))
 	if err != nil {
 		log.Fatal(err)
 	}
@@ -55,36 +61,29 @@ func (s *Server) cdEventHandler(w http.ResponseWriter, r *http.Request) {
 	db := client.Database("cdevents")
 	collection := db.Collection("items")
 
-	cdevent := CDEvent{
-		SubjectID:        "1",
-		SubjectSource:    "2",
-		SubjectType:      "3",
-		SubjectContent:   "4",
-		ContextVersion:   "5",
-		ContextID:        "6",
-		ContextSource:    "7",
-		ContextType:      "8",
-		ContextTimestamp: "9",
-	}
-
-	_, err = collection.InsertOne(ctx, cdevent)
+	result, err := collection.InsertOne(ctx, cdevent)
 	if err != nil {
 		log.Fatal(err)
 	}
 
-	fmt.Printf("Item inserted successfully! %s", key)
+	fmt.Printf("Inserted document with _id: %v\n", result.InsertedID)
 
 	s.JSONResponse(w, r, body)
 }
 
 type CDEvent struct {
-	SubjectID        string `json:"subjectId"`
-	SubjectSource    string `json:"subjectSource"`
-	SubjectType      string `json:"subjectType"`
-	SubjectContent   string `json:"subjectContent"`
-	ContextVersion   string `json:"contextVersion"`
-	ContextID        string `json:"contextId"`
-	ContextSource    string `json:"contextSource"`
-	ContextType      string `json:"contextType"`
-	ContextTimestamp string `json:"contextTimestamp"`
+	Context struct {
+		Version   string    `json:"version"`
+		ID        string    `json:"id"`
+		Source    string    `json:"source"`
+		Type      string    `json:"type"`
+		Timestamp time.Time `json:"timestamp"`
+	} `json:"context"`
+	Subject struct {
+		ID      string `json:"id"`
+		Source  string `json:"source"`
+		Type    string `json:"type"`
+		Content struct {
+		} `json:"content"`
+	} `json:"subject"`
 }

pkg/api/server.go

@@ -72,6 +72,7 @@ type Config struct {
 	Unready               bool          `mapstructure:"unready"`
 	JWTSecret             string        `mapstructure:"jwt-secret"`
 	CacheServer           string        `mapstructure:"cache-server"`
+	MongodbURL            string        `mapstructure:"mongodb-url"`
 }
 
 type Server struct {