fix

Author: ilayzen

Dockerfile

@@ -15,9 +15,7 @@ COPY --from=builder /app/cassandra/schema.sql /usr/local/bin
 COPY --from=builder /app/dist/janus /bin/janus
 RUN chmod a+x /bin/janus && \
     mkdir -p /etc/janus/apis && \
-    mkdir -p /etc/janus/auth && \
-    mkdir -p /etc/config
-
+    mkdir -p /etc/janus/auth
 
 RUN apt-get update && apt-get install -y --no-install-recommends \
         ca-certificates \

assets/apis/example_SingleDefinition.json

@@ -3,7 +3,6 @@ package kafka
 import (
 	"context"
 	"encoding/json"
-	"fmt"
 	"github.com/hellofresh/janus/pkg/models"
 	"github.com/segmentio/kafka-go"
 	log "github.com/sirupsen/logrus"
@@ -17,18 +16,13 @@ func StartFactConsumer(kafkaAddr, topic, dlqtopic, consumerGroup string) {
 			if err != nil {
 				return err
 			}
-			fmt.Println("starting ping facts...")
-
 			var role models.Role
 
 			err = json.Unmarshal(*fact.Object, &role)
 			if err != nil {
 				log.Println(err)
 			}
 
-			fmt.Println(role)
-
-			fmt.Println("end of pinging gateway...")
 			return nil
 		},
 		func(msg Message, inerr error) {
@@ -45,12 +39,6 @@ func StartFactConsumer(kafkaAddr, topic, dlqtopic, consumerGroup string) {
 	return
 }
 
-func factToCache(fact *models.Fact) *models.Fact {
-	return &models.Fact{
-		Object: fact.Object,
-	}
-}
-
 type KafkaProducer struct {
 	kafkaWriter *kafka.Writer
 }

assets/auth/auth.json

@@ -3,7 +3,6 @@ package server
 import (
 	"context"
 	"fmt"
-	"github.com/hellofresh/janus/pkg/cache"
 	"net"
 	"net/http"
 	"time"
@@ -38,13 +37,11 @@ type Server struct {
 	webServer             *web.Server
 	profilingEnabled      bool
 	profilingPublic       bool
-	cache                 *cache.Cache
 }
 
 // New creates a new instance of Server
 func New(opts ...Option) *Server {
 	s := Server{
-		cache:             cache.NewCache(),
 		configurationChan: make(chan api.ConfigurationChanged, 100),
 		stopChan:          make(chan struct{}, 1),
 	}