feat: add repository endpoint

api/api.yaml

@@ -4,6 +4,71 @@ info:
   title: "Artifact Store API specification"
   version: "0.1.0"
 paths:
+  /v1/repositories:
+    get:
+      summary: "Get all available repositories"
+      operationId: "getRepositories"
+      responses:
+        '200':
+          description: List of repositories
+          content:
+            application/json:
+              schema:
+                type: array
+                $ref: '#/components/schemas/Repository'
+    post:
+      summary: "Create repository"
+      operationId: "addRepository"
+      operation: addRepository
+      requestBody:
+        content:
+          multipart/form-data:
+            schema:
+              type: object
+              properties:
+                name:
+                  type: string
+                repository:
+                  type: string
+                artifact:
+                  type: string
+                  description: "The artifact kind the repository will host"
+                  enum:
+                    - helm
+              required:
+                - name
+                - repository
+                - artifact
+      responses:
+        '201':
+          description: "Repository created"
+          content:
+            application/json:
+              schema:
+                type: object
+                properties:
+                  name:
+                    type: string
+                required:
+                  - name
+        '400':
+          description: "Bad request"
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+        '409':
+          description: "Conflict — repository already exists"
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
+        '500':
+          description: "Internal server error"
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/Error'
   /v1/helm:
     get:
       summary: "Get all available Helm charts"
@@ -61,18 +126,25 @@ paths:
             application/json:
               schema:
                 $ref: '#/components/schemas/Error'
-  /v1/helm/{name}/{version}:
+  /v1/helm/{repository}/{name}/{version}:
     get:
       summary: "Download version of Helm chart"
       operationId: "getChart"
       parameters:
+        - name: repository
+          in: path
+          required: false
+          schema:
+            type: string
+            default: default
+          description: "Chart repository"
         - name: name
           in: path
           required: true
           schema:
             type: string
           description: "Helm chart name"
-        - name: version
+        - name: version # TODO: make optional, default to 'latest'
           in: path
           required: true
           schema:
@@ -103,14 +175,15 @@ paths:
       summary: "Add Helm chart"
       operationId: "addChart"
       requestBody:
-        required: true
         content:
           multipart/form-data:
             schema:
               type: object
               properties:
                 name:
                   type: string
+                repository:
+                  type: string
                 chart:
                   type: string
                   format: binary
@@ -158,6 +231,15 @@ components:
           type: integer
         message:
           type: string
+    Repository:
+      type: object
+      properties:
+        name:
+          type: string
+        artifact:
+          type: string
+          enum:
+            - chart
     Chart:
       type: object
       properties:

internal/api/impl.go → internal/api/pkg_helm.go

@@ -8,24 +8,14 @@ import (
 	"net/http"
 	openapi_types "github.com/oapi-codegen/runtime/types"
 
-	"artifacts/internal/storage"
+	//"artifacts/internal/storage"
 	"artifacts/internal/storage/storage_error"
 )
 
-var chartMIMEType = []string{"application/gzip"}
-
-type Server struct{
-	storageHandler storage.Storage
-}
-
-func NewServer(storageHandler storage.Storage) Server {
-	return Server{
-		storageHandler: storageHandler,
-	}
-}
+var chartMIMEType = []string{"application/octet-stream"}
 
 func (s Server) GetCharts(w http.ResponseWriter, r *http.Request) {
-	data, err := s.storageHandler.Read("", "")
+	data, err := s.storageHandler.Read("", "", "")
 	if err != nil {
 		w.WriteHeader(http.StatusInternalServerError)
 		return
@@ -34,10 +24,10 @@ func (s Server) GetCharts(w http.ResponseWriter, r *http.Request) {
 	_ = json.NewEncoder(w).Encode(data)
 }
 
-func (s Server) GetChart(w http.ResponseWriter, r *http.Request, resource string, version string) {
+func (s Server) GetChart(w http.ResponseWriter, r *http.Request, repository string, resource string, version string) {
 	w.Header().Set("Content-Type", "application/json")
 
-	data, err := s.storageHandler.Read(resource, version)
+	data, err := s.storageHandler.Read(repository, resource, version)
 
 	if err != nil {
 		if err == storage_error.NotFound {
@@ -89,6 +79,16 @@ func (s Server) AddChart(w http.ResponseWriter, r *http.Request) {
 		}
 	}()
 
+	repo := r.FormValue("repository")
+	if repo == "" {
+		w.WriteHeader(http.StatusBadRequest)
+		_ = json.NewEncoder(w).Encode(Error{
+			Code: new(int(http.StatusBadRequest)),
+			Message: new(string("Missing 'repository' parameter")),
+		})
+		return
+	}
+
 	// Extract chart name from form data
 	name := r.FormValue("name")
 	if name == "" {
@@ -144,7 +144,7 @@ func (s Server) AddChart(w http.ResponseWriter, r *http.Request) {
 		})
 	}
 
-	if err := s.storageHandler.Write(name, bytes); err != nil {  // TODO: return created version
+	if err := s.storageHandler.Write(repo, name, bytes); err != nil {  // TODO: return created version
 		w.WriteHeader(http.StatusInternalServerError)
 		_ = json.NewEncoder(w).Encode(Error{
 			Code: new(int(http.StatusInternalServerError)),

internal/api/repositories.go

@@ -0,0 +1,32 @@
+package api
+
+import (
+	"encoding/json"
+	// "fmt"
+	// "io"
+	// "slices"
+	"net/http"
+	//openapi_types "github.com/oapi-codegen/runtime/types"
+
+	// "artifacts/internal/storage"
+	// "artifacts/internal/storage/storage_error"
+)
+
+func (s Server) GetRepositories(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+	w.WriteHeader(http.StatusOK)
+	_ = json.NewEncoder(w).Encode(Error{
+		Code: new(int(http.StatusOK)),
+		Message: new(string("")),
+	})
+	return
+}
+
+func (s Server) AddRepository(w http.ResponseWriter, r *http.Request) {
+	w.Header().Set("Content-Type", "application/json")
+	_ = json.NewEncoder(w).Encode(Error{
+		Code: new(int(http.StatusCreated)),
+		Message: new(string("Repository created")),
+	})
+	return
+}