OZG-6697 File Upload Api hinzugefügt

api/gateway-config.yml

@@ -13,6 +13,9 @@ http:
     - selector: de.ozgcloud.antragraumproxy.CommandService.GetCommand
       get: "/api/v1/command/{id}"
     - selector: de.ozgcloud.antragraumproxy.BinaryFileService.GetBinaryFileContent
-      get: "/api/v1/filecontent/{fileId}"
+      get: "/api/v1/file/content/{fileId}"
     - selector: de.ozgcloud.antragraumproxy.BinaryFileService.FindBinaryFilesMetaData
-      get: "/api/v1/filemetadata/{fileId}"
+      get: "/api/v1/file/metadata/{fileId}"
\ No newline at end of file
+    - selector: de.ozgcloud.antragraumproxy.BinaryFileService.UploadBinaryFileAsStream
+      post: "/api/v1/file"
+      body: "*"
\ No newline at end of file

internal/server/middleware.go

@@ -32,7 +32,7 @@ import (
 	"net/http"
 )
 
-const RegisterFachstelleUrlPath = "/api/antragsraum"
+const GetRueckfrageUrlPath = "/api/v1/rueckfrage"
 
 type logResponseWriter struct {
 	http.ResponseWriter
@@ -46,7 +46,7 @@ func (rsp *logResponseWriter) WriteHeader(statusCode int) {
 
 func RequestLoggingMiddleware(h http.Handler) http.Handler {
 	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		if r.URL.Path != RegisterFachstelleUrlPath {
+		if r.URL.Path != GetRueckfrageUrlPath {
 			h.ServeHTTP(w, r)
 			return
 		}

internal/server/middleware_test.go

@@ -48,10 +48,36 @@ func TestRequestLoggingMiddleware(t *testing.T) {
 		log.SetFlags(originalFlags)
 	}()
 
-	jsonData := []byte(`{"fachstelle": {"mukId": "testMukId"}}`)
-	http.Post(fmt.Sprintf("http://localhost:8080%v", RegisterFachstelleUrlPath), "application/json", bytes.NewBuffer(jsonData))
+	jsonReplyData := []byte(`{
+                          "rueckfrage": {
+                            "id": "string",
+                            "vorgangId": "string",
+                            "vorgangName": "string",
+                            "vorgangNummer": "string",
+                            "sentAt": "string",
+                            "answeredAt": "string",
+                            "status": "string",
+                            "trustLevel": "string",
+                            "accessible": true,
+                            "text": "string",
+                            "attachmentFileId": [
+                              "string"
+                            ],
+                            "answers": [
+                              {
+                                "rueckfrageId": "string",
+                                "answerText": "string",
+                                "attachmentFileId": [
+                                  "string"
+                                ],
+                                "sentAt": "string"
+                              }
+                            ]
+                          }
+                        }`)
+	http.Post(fmt.Sprintf("http://localhost:8080%v", GetRueckfrageUrlPath), "application/json", bytes.NewBuffer(jsonReplyData))
 
 	logOutput := buf.String()
-	assert.Contains(t, logOutput, "received request with body: {\"fachstelle\": {\"mukId\": \"testMukId\"}}")
-	assert.Contains(t, logOutput, "successfully handled request with body: {\"fachstelle\": {\"mukId\": \"testMukId\"}}")
+	assert.Contains(t, logOutput, "received request with body: {\"rueckfrage\"")
+	assert.Contains(t, logOutput, "successfully handled request with body: {\"rueckfrage\"...")
 }