Move prototypical etsi14 emulator in its own dir

See merge request !59

Makefile

@@ -44,12 +44,18 @@ build-ekms: pre
 build-quantumlayer: pre
 	$(GOBUILD) -o $(BUILD_ARTIFACTS_PATH)/quantumlayer ./quantumlayer/example/main.go
 
+build-etsi14module: pre
+	$(GOBUILD) -o $(BUILD_ARTIFACTS_PATH)/etsi14module ./etsi14module/main.go
+
 build-akms-simulator: pre
 	$(GOBUILD) -o $(BUILD_ARTIFACTS_PATH)/akms-simulator ./akms-simulator/akms-simulator.go
 
 quantumlayer-container:
 	docker buildx build --rm -t quantumlayer --load -f ./quantumlayer/Dockerfile --build-arg GITLAB_LOGIN=${GITLAB_LOGIN} --build-arg GITLAB_TOKEN=${GITLAB_TOKEN} --build-arg GOLANG_VERSION=${GOLANG_VERSION} .
 
+etsi14module-container:
+	docker buildx build --rm -t etsi14module --load -f ./etsi14module/Dockerfile --build-arg GOLANG_VERSION=${GOLANG_VERSION} .
+
 ekms-build-debug: pre
 	$(GOBUILD) -gcflags="all=-N -l" -o $(BUILD_ARTIFACTS_PATH)/ekms ./ekms/main.go
 

ekms/cmd/start.go

@@ -40,7 +40,6 @@ import (
 	"code.fbi.h-da.de/danet/quant/ekms/handlers/danet"
 	"code.fbi.h-da.de/danet/quant/ekms/handlers/system"
 	gnmitargetygot "code.fbi.h-da.de/danet/quant/ekms/model"
-	"code.fbi.h-da.de/danet/quant/ekms/restserver"
 	"github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
 	"github.com/spf13/viper"
@@ -74,9 +73,6 @@ var startCmd = &cobra.Command{
 		fmt.Println("Startup of GNMI Target...")
 		lvl := viper.GetString("logLevel")
 
-		etsi14RESTService := restserver.NewETSI14RESTService(":1414")
-		restserver.SetupETSI14RestServer(etsi14RESTService)
-
 		// parse string, this is built-in feature of logrus
 		ll, err := logrus.ParseLevel(lvl)
 		if err != nil {

etsi14module/.dockerignore

+artifacts

etsi14module/Dockerfile

+ARG GOLANG_VERSION=1.22
+ARG BUILDARGS
+
+FROM ${GITLAB_PROXY}golang:$GOLANG_VERSION-bookworm as builder
+WORKDIR /app/
+COPY . .
+RUN --mount=type=cache,target=/root/go/pkg/mod \
+    --mount=type=cache,target=/root/.cache/go-build \
+    make build-etsi14module
+
+FROM ${GITLAB_PROXY}debian:bookworm-slim
+WORKDIR /app/
+COPY --from=builder /app/artifacts/etsi14module ./etsi14module
+ENTRYPOINT ["./etsi14module"]

ekms/restserver/restserver.go → etsi14module/main.go

-package restserver
+package main
 
 import (
 	"context"
+	"crypto/rand"
+	"encoding/base64"
 	"net/http"
+	"os"
+	"os/signal"
+	"sync"
+	"syscall"
 
 	restserver "code.fbi.h-da.de/danet/quant/ekms/api/go/rest/etsi/server/go"
+	"github.com/google/uuid"
 	"github.com/sirupsen/logrus"
 )
 
@@ -12,6 +19,9 @@ type ETSI14RESTService struct {
 	serviceAddress string
 }
 
+var keyStoreMutex sync.RWMutex
+var keyStore = make(map[string]string, 0)
+
 func NewETSI14RESTService(serviceAdress string) *ETSI14RESTService {
 	return &ETSI14RESTService{
 		serviceAddress: serviceAdress,
@@ -45,14 +55,26 @@ func (s *ETSI14RESTService) GetKey(ctx context.Context, slaveSAEID interface{},
 	// return Response(503, nil),nil
 
 	keyContainer := &restserver.KeyContainer{}
-	keyContainer.Keys = append(keyContainer.Keys, restserver.KeyContainerKeysInner{
-		KeyID: "1234",
-		Key:   "asdf",
-	})
-	keyContainer.Keys = append(keyContainer.Keys, restserver.KeyContainerKeysInner{
-		KeyID: "5787538778534",
-		Key:   "cddelffsfkllfsdmflmdl",
-	})
+
+	for range number {
+		keyId := uuid.New().String()
+
+		b := make([]byte, 32)
+		_, err := rand.Read(b)
+		if err != nil {
+			//TODO: todo
+		}
+
+		keyAsBase64String := base64.StdEncoding.EncodeToString(b)
+
+		keyContainer.Keys = append(keyContainer.Keys, restserver.KeyContainerKeysInner{
+			KeyID: keyId,
+			Key:   keyAsBase64String,
+		})
+		keyStoreMutex.Lock()
+		keyStore[keyId] = keyAsBase64String
+		keyStoreMutex.Unlock()
+	}
 
 	return restserver.Response(http.StatusOK, keyContainer), nil
 }
@@ -100,10 +122,17 @@ func (s *ETSI14RESTService) GetKeyWithIds(ctx context.Context, masterSAEID inter
 	// TODO: Uncomment the next line to return response Response(503, {}) or use other options such as http.Ok ...
 	// return Response(503, nil),nil
 
+	keyStoreMutex.RLock()
+	key, ok := keyStore[keyID]
+	if !ok {
+		//TODO: todo
+	}
+	keyStoreMutex.RUnlock()
+
 	keyContainer := &restserver.KeyContainer{}
 	keyContainer.Keys = append(keyContainer.Keys, restserver.KeyContainerKeysInner{
-		KeyID: "1234",
-		Key:   "asdf",
+		KeyID: keyID,
+		Key:   key,
 	})
 
 	return restserver.Response(http.StatusOK, keyContainer), nil
@@ -170,3 +199,13 @@ func (s *ETSI14RESTService) GetStatus(ctx context.Context, slaveSAEID interface{
 
 	return resp, nil
 }
+
+func main() {
+	etsi14RESTService := NewETSI14RESTService(":1414")
+	SetupETSI14RestServer(etsi14RESTService)
+
+	stopChan := make(chan os.Signal, 1)
+	signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM)
+
+	<-stopChan
+}