aides-infra/aides-repo-api
0
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: aides-infra:e4f9743dea35a369db2614609adec3d5b2c4e75e
Branches Tags
aides-infra:main
..
compare: aides-infra:37007956ab0f5846af26b17843658f87d091b79c
Branches Tags
aides-infra:main

No commits in common. "e4f9743dea35a369db2614609adec3d5b2c4e75e" and "37007956ab0f5846af26b17843658f87d091b79c" have entirely different histories.
e4f9743dea ... 37007956ab

27 changed files with 55 additions and 148 deletions
Show stats Expand all files Collapse all files

2
.golangci.yml
View file

@ -10,7 +10,7 @@ linters-settings:
exclude-functions:
- github.com/go-chi/render.Render
goimports:
local-prefixes: "code.aides.space/aides-infra/aides-repo-api"
local-prefixes: "code.alt-gnome.ru/aides-infra/aides-repo-api"
gofmt:
simplify: true
gofumpt:

4
Makefile
View file

@ -22,13 +22,13 @@ swag:
build:
go build \
-ldflags="-X 'code.aides.space/aides-infra/aides-repo-api/internal/config.Version=$(APP_VERSION)'" \
-ldflags="-X 'code.alt-gnome.ru/aides-infra/aides-repo-api/internal/config.Version=$(APP_VERSION)'" \
-o aides-repo-api \
./cmd/aides-repo-api/main.go
release:
go build \
-ldflags="-s -w -X 'code.aides.space/aides-infra/aides-repo-api/internal/config.Version=$(APP_VERSION)'" \
-ldflags="-s -w -X 'code.alt-gnome.ru/aides-infra/aides-repo-api/internal/config.Version=$(APP_VERSION)'" \
-o aides-repo-api \
./cmd/aides-repo-api/main.go

2
README.md
View file

@ -1,3 +1,3 @@
# Aides repo API
[![Go Report Card](https://goreportcard.com/badge/code.aides.space/aides-infra/aides-repo-api)](https://goreportcard.com/report/code.aides.space/aides-infra/aides-repo-api) ![Coverage](./coverage-badge.svg)
[![Go Report Card](https://goreportcard.com/badge/code.alt-gnome.ru/aides-infra/aides-repo-api)](https://goreportcard.com/report/code.alt-gnome.ru/aides-infra/aides-repo-api) ![Coverage](./coverage-badge.svg)

2
cmd/aides-repo-api/main.go
View file

@ -1,7 +1,7 @@
package main
import (
"code.aides.space/aides-infra/aides-repo-api/internal/app"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/app"
)
// _

2
coverage-badge.svg
View file

@ -2,5 +2,5 @@
<rect width="1100" height="20" fill="#555"/>
<rect x="60" width="50" height="20" fill="#4c1"/>
<text x="5" y="14" fill="#fff" font-family="Verdana" font-size="11">coverage</text>
<text x="70" y="14" fill="#fff" font-family="Verdana" font-size="11">58.4%</text>
<text x="70" y="14" fill="#fff" font-family="Verdana" font-size="11">58.5%</text>
</svg>

Side by side Swipe Overlay

Before

Width:  |  Height:  |  Size: 341 B

After

Width:  |  Height:  |  Size: 341 B

2
go.mod
View file

@ -1,4 +1,4 @@
module code.aides.space/aides-infra/aides-repo-api
module code.alt-gnome.ru/aides-infra/aides-repo-api
go 1.23.3

18
internal/app/app.go
View file

@ -9,14 +9,14 @@ import (
gormlogger "gorm.io/gorm/logger"
"moul.io/zapgorm2"
"code.aides.space/aides-infra/aides-repo-api/internal/config"
"code.aides.space/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.aides.space/aides-infra/aides-repo-api/internal/router"
"code.aides.space/aides-infra/aides-repo-api/internal/services/cronservice"
"code.aides.space/aides-infra/aides-repo-api/internal/services/reposervice"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/config"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/router"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/cronservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/reposervice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
type App struct {
@ -121,7 +121,7 @@ func (app *App) Run() {
},
)
err := app.repo.Update(true)
err := app.repo.Update(false)
if err != nil {
panic(err)
}

4
internal/controllers/taskcontroller/controller.go
View file

@ -1,8 +1,8 @@
package taskcontroller
import (
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
type TaskService interface {

4
internal/controllers/taskcontroller/controller_test.go
View file

@ -3,8 +3,8 @@ package taskcontroller_test
import (
"errors"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
type TaskServiceMock struct {

4
internal/controllers/taskcontroller/create.go
View file

@ -6,8 +6,8 @@ import (
"github.com/go-chi/render"
"code.aides.space/aides-infra/aides-repo-api/internal/common/errors"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/common/errors"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
type CreateTaskDTO struct {

4
internal/controllers/taskcontroller/create_test.go
View file

@ -10,8 +10,8 @@ import (
"gorm.io/gorm"
"code.aides.space/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
func TestCreate(t *testing.T) {

6
internal/controllers/taskcontroller/upload.go
View file

@ -7,10 +7,10 @@ import (
"github.com/go-chi/chi/v5"
"github.com/go-chi/render"
commonErrors "code.aides.space/aides-infra/aides-repo-api/internal/common/errors"
commonErrors "code.alt-gnome.ru/aides-infra/aides-repo-api/internal/common/errors"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
type TaskUploadResponse struct {

4
internal/controllers/taskcontroller/upload_test.go
View file

@ -10,8 +10,8 @@ import (
"github.com/go-chi/chi/v5"
"code.aides.space/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
func TestUpload(t *testing.T) {

4
internal/middlewares/auth.go
View file

@ -5,8 +5,8 @@ import (
"github.com/go-chi/render"
"code.aides.space/aides-infra/aides-repo-api/internal/common/errors"
"code.aides.space/aides-infra/aides-repo-api/internal/config"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/common/errors"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/config"
)
func CreateAuthGuard(cfg *config.Config) func(next http.Handler) http.Handler {

2
internal/middlewares/logger.go
View file

@ -3,7 +3,7 @@ package middlewares
import (
"net/http"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
)
// CustomResponseWriter wraps http.ResponseWriter to capture status code and response size

10
internal/router/router.go
View file

@ -4,11 +4,11 @@ import (
"github.com/go-chi/chi/v5"
httpSwagger "github.com/swaggo/http-swagger"
docs "code.aides.space/aides-infra/aides-repo-api/docs"
"code.aides.space/aides-infra/aides-repo-api/internal/config"
"code.aides.space/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.aides.space/aides-infra/aides-repo-api/internal/middlewares"
docs "code.alt-gnome.ru/aides-infra/aides-repo-api/docs"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/config"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/controllers/taskcontroller"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/middlewares"
)
type Router struct {

2
internal/services/cronservice/service.go
View file

@ -3,7 +3,7 @@ package cronservice
import (
"github.com/go-co-op/gocron/v2"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
)
type RepoService interface {

6
internal/services/reposervice/service.go
View file

@ -7,8 +7,8 @@ import (
"gorm.io/gorm"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
type Config interface {
@ -106,7 +106,7 @@ func (s *Service) Update(force bool) error {
Model(&models.GitRepoAltRepoTask{}).
Select("1").
Where("alt_repo_id = ?", altRepo.ID).
Where("last_task_id != current_task_id OR current_task_id IS NULL").
Where("last_task_id != current_task_id").
Limit(1).
Scan(&exists).Error; err != nil {
return err

2
internal/services/reposervice/utils.go
View file

@ -6,7 +6,7 @@ import (
"os/exec"
"path"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
)
func createRepoDirs(repoDir, repoName, arch string) error {

2
internal/services/taskservice/create.go
View file

@ -1,7 +1,7 @@
package taskservice
import (
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
func (s *Service) Create(repo string) (*models.Task, error) {

2
internal/services/taskservice/service.go
View file

@ -7,7 +7,7 @@ import (
"gorm.io/gorm"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
type Config interface {

4
internal/services/taskservice/upload.go
View file

@ -13,8 +13,8 @@ import (
"github.com/cavaliergopher/rpm"
"gorm.io/gorm"
"code.aides.space/aides-infra/aides-repo-api/internal/logger"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/logger"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
type TaskUploadInput struct {

2
internal/services/taskservice/utils.go
View file

@ -1,6 +1,6 @@
package taskservice
import "code.aides.space/aides-infra/aides-repo-api/internal/models"
import "code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
type WrapperRpmVersion struct {
file *models.RPMFile

97
tests/integration/reposervice_forceupdate_test.go
View file

@ -8,8 +8,8 @@ import (
"github.com/stretchr/testify/assert"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.aides.space/aides-infra/aides-repo-api/internal/services/reposervice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/reposervice"
)
func TestRepoService_ForceUpdate(t *testing.T) {
@ -118,99 +118,6 @@ func TestRepoService_ForceUpdate(t *testing.T) {
assert.Equal(t, path.Join("../../../../tasks/1", fileName), linkDest)
})
t.Run("Correct update (update)", func(t *testing.T) {
// PREPARE
db := prepareDb(t)
config := prepareConfig()
os.MkdirAll(config.GetUploadDir(), os.ModePerm)
taskPath := path.Join(config.GetUploadDir(), "tasks/1")
os.MkdirAll(taskPath, os.ModePerm)
defer os.RemoveAll(config.GetUploadDir())
fileName := "example-foo-1.0.0-alt1.x86_64.rpm"
source, err := os.Open(path.Join("./test_rpms", fileName))
assert.NoError(t, err)
destination, err := os.Create(path.Join(taskPath, fileName))
assert.NoError(t, err)
defer destination.Close()
_, err = io.Copy(destination, source)
assert.NoError(t, err)
source.Close()
destination.Close()
gitRepo := &models.GitRepo{
Name: "example-foo",
}
altRepo := &models.ALTRepo{
Name: "Sisyphus",
}
db.Create(&models.GitRepoAltRepoTask{
Repo: gitRepo,
ALTRepo: altRepo,
CurrentTask: nil,
LastTask: &models.Task{
Status: models.StatusCompleted,
Files: []models.RPMFile{
{
Filename: fileName,
Name: "example-foo",
Version: "1.0.0",
Release: "1",
Arch: "x86_64",
Epoch: 0,
},
},
},
})
service := reposervice.New(
db,
config,
)
// EXECUTE
err = service.Update(false)
// CHECK
assert.NoError(t, err)
// TODO: check db
repoBasePath := path.Join(config.GetUploadDir(), "repo", "Sisyphus")
x86_64BasePath := path.Join(repoBasePath, "x86_64", "base")
x86_64RPMSPath := path.Join(repoBasePath, "x86_64", "RPMS.aides")
noarchBasePath := path.Join(repoBasePath, "noarch", "base")
expectedFiles := []string{
path.Join(x86_64BasePath, "pkglist.aides"),
path.Join(x86_64BasePath, "pkglist.aides.bz2"),
path.Join(x86_64BasePath, "pkglist.aides.xz"),
path.Join(x86_64BasePath, "release"),
path.Join(x86_64BasePath, "release.aides"),
path.Join(x86_64RPMSPath, fileName),
path.Join(noarchBasePath, "pkglist.aides"),
path.Join(noarchBasePath, "pkglist.aides.bz2"),
path.Join(noarchBasePath, "pkglist.aides.xz"),
path.Join(noarchBasePath, "release"),
path.Join(noarchBasePath, "release.aides"),
}
for _, filePath := range expectedFiles {
_, err := os.Stat(filePath)
assert.NoErrorf(t, err, "Файл %s не найден", filePath)
}
rpmPath := path.Join(x86_64RPMSPath, fileName)
linkDest, err := os.Readlink(rpmPath)
assert.NoError(t, err)
assert.Equal(t, path.Join("../../../../tasks/1", fileName), linkDest)
})
t.Run("Do not do anything if no updates", func(t *testing.T) {
// PREPARE
db := prepareDb(t)

4
tests/integration/taskservice_create_test.go
View file

@ -5,8 +5,8 @@ import (
"github.com/stretchr/testify/assert"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
func TestTaskService_Create(t *testing.T) {

4
tests/integration/taskservice_upload_test.go
View file

@ -13,8 +13,8 @@ import (
"github.com/stretchr/testify/assert"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.aides.space/aides-infra/aides-repo-api/internal/services/taskservice"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/services/taskservice"
)
func createMultipartFileHeader(filePath string) *multipart.FileHeader {

4
tests/integration/utils.go
View file

@ -7,8 +7,8 @@ import (
"gorm.io/driver/sqlite"
"gorm.io/gorm"
"code.aides.space/aides-infra/aides-repo-api/internal/config"
"code.aides.space/aides-infra/aides-repo-api/internal/models"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/config"
"code.alt-gnome.ru/aides-infra/aides-repo-api/internal/models"
)
func prepareDb(t *testing.T) *gorm.DB {