Merge pull request #477 from kube-tarian/agent-gin-fw-rest-server

Agent gin fw rest server

capten/Makefile

@@ -10,7 +10,7 @@ ${OPEN_API_CODEGEN}:
 
 tools: ${OPEN_API_CODEGEN}
 
-OPEN_API_DIR = ./api
+OPEN_API_DIR = ./gin-api-server/api/
 
 oapi-gen: tools oapi-gen-deployment-worker
 
@@ -20,6 +20,12 @@ oapi-gen-deployment-worker:
 	@mkdir -p ${APP_NAME}/${OPEN_API_DIR}
 	${GOBIN}/oapi-codegen -config ./${APP_NAME}/cfg.yaml ./${APP_NAME}/openapi.yaml
 
+oapi-gen-agent: tools
+	$(eval APP_NAME=agent)
+	@echo Generating server for ${APP_NAME}
+	@mkdir -p ${APP_NAME}/${OPEN_API_DIR}
+	${GOBIN}/oapi-codegen -config ./${APP_NAME}/cfg.yaml ./${APP_NAME}/openapi.yaml
+
 start-docker-compose-test:
 	docker compose -f ./docker-compose-cass-es.yml up -d --no-recreate
 	sleep 20

capten/agent/cfg.yaml

@@ -0,0 +1,6 @@
+package: api
+generate:
+  gin-server: true
+  models: true
+  embedded-spec: true
+output: agent/gin-api-server/api/agent.gen.go

capten/agent/gin-api-server/server.go

@@ -0,0 +1,19 @@
+package ginapiserver
+
+import (
+	"fmt"
+
+	"github.com/gin-gonic/gin"
+	"github.com/intelops/go-common/logging"
+	"github.com/kube-tarian/kad/capten/agent/gin-api-server/api"
+	"github.com/kube-tarian/kad/capten/agent/internal/config"
+)
+
+var log = logging.NewLogger()
+
+func StartRestServer(rpcapi api.ServerInterface, cfg *config.SericeConfig) {
+	r := gin.Default()
+	api.RegisterHandlers(r, rpcapi)
+
+	r.Run(fmt.Sprintf("%s:%d", cfg.Host, cfg.RestPort))
+}

capten/agent/internal/api/basic_handler.go

@@ -0,0 +1,17 @@
+package api
+
+import (
+	"net/http"
+
+	"github.com/gin-gonic/gin"
+	api "github.com/kube-tarian/kad/capten/agent/gin-api-server/api"
+)
+
+// open api swagger documentation
+func (a *Agent) GetApiDocs(c *gin.Context) {
+	apiDocs, err := api.GetSwagger()
+	if err != nil {
+		c.String(http.StatusInternalServerError, err.Error())
+	}
+	c.IndentedJSON(http.StatusOK, apiDocs)
+}