Spaces:
Sleeping
Sleeping
File size: 3,656 Bytes
39978cf be05512 39978cf 5501149 39978cf be05512 39978cf be05512 39978cf be05512 39978cf 5501149 39978cf 5501149 39978cf 5501149 39978cf 5501149 39978cf be05512 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 | package controllers
import (
"strings"
"abdanhafidz.com/go-boilerplate/models/dto"
http_error "abdanhafidz.com/go-boilerplate/models/error"
"abdanhafidz.com/go-boilerplate/services"
"github.com/gin-gonic/gin"
)
type SuperAdminInjectController interface {
InjectProblemSet(ctx *gin.Context)
InjectZip(ctx *gin.Context)
}
type superAdminInjectController struct {
problemSetService services.ProblemSetService
zipInjectService services.ZipInjectService
}
func NewSuperAdminInjectController(problemSetService services.ProblemSetService, zipInjectService services.ZipInjectService) SuperAdminInjectController {
return &superAdminInjectController{problemSetService: problemSetService, zipInjectService: zipInjectService}
}
// InjectProblemSet godoc
// @Summary Super Admin: Inject Problem Sets from CSV Upload
// @Description Inject problem sets and questions from an uploaded CSV (normalized_questions.csv format)
// @Tags Super Admin Inject
// @Accept multipart/form-data
// @Produce json
// @Param file formData file true "CSV file (normalized_questions.csv format)"
// @Security BearerAuth
// @Success 200 {object} dto.SuccessResponse[dto.ProblemSetInjectResponse]
// @Failure 400 {object} dto.ErrorResponse
// @Failure 401 {object} dto.ErrorResponse
// @Failure 403 {object} dto.ErrorResponse
// @Failure 404 {object} dto.ErrorResponse
// @Failure 409 {object} dto.ErrorResponse
// @Failure 500 {object} dto.ErrorResponse
// @Router /api/v1/super-admin/inject/probset [post]
func (c *superAdminInjectController) InjectProblemSet(ctx *gin.Context) {
fileHeader, err := ctx.FormFile("file")
if err != nil {
ResponseJSON(ctx, gin.H{"file": ""}, dto.ProblemSetInjectResponse{}, http_error.BAD_REQUEST_ERROR)
return
}
file, err := fileHeader.Open()
if err != nil {
ResponseJSON(ctx, gin.H{"file": fileHeader.Filename}, dto.ProblemSetInjectResponse{}, http_error.INTERNAL_SERVER_ERROR)
return
}
defer file.Close()
result, err := c.problemSetService.InjectProblemSetsFromCSV(ctx.Request.Context(), fileHeader.Filename, file)
ResponseJSON(ctx, gin.H{"file": result.File}, result, err)
}
// InjectZip godoc
// @Summary Super Admin: Inject Zip to Storage
// @Description Upload a zip file and mirror its directory structure to storage
// @Tags Super Admin Inject
// @Accept multipart/form-data
// @Produce json
// @Param file formData file true "Zip file"
// @Param base_path formData string false "Base path prefix in storage"
// @Security BearerAuth
// @Success 200 {object} dto.SuccessResponse[dto.ZipInjectResponse]
// @Failure 400 {object} dto.ErrorResponse
// @Failure 401 {object} dto.ErrorResponse
// @Failure 403 {object} dto.ErrorResponse
// @Failure 500 {object} dto.ErrorResponse
// @Router /api/v1/super-admin/inject/zip [post]
func (c *superAdminInjectController) InjectZip(ctx *gin.Context) {
fileHeader, err := ctx.FormFile("file")
if err != nil {
ResponseJSON(ctx, gin.H{"file": ""}, dto.ZipInjectResponse{}, http_error.BAD_REQUEST_ERROR)
return
}
file, err := fileHeader.Open()
if err != nil {
ResponseJSON(ctx, gin.H{"file": fileHeader.Filename}, dto.ZipInjectResponse{}, http_error.INTERNAL_SERVER_ERROR)
return
}
defer file.Close()
basePath := strings.TrimSpace(ctx.PostForm("base_path"))
result, err := c.zipInjectService.InjectZipToStorage(ctx.Request.Context(), file, fileHeader.Size, basePath)
result.File = fileHeader.Filename
ResponseJSON(ctx, gin.H{"file": result.File}, result, err)
}
|