upstream/harbor
1
0
Fork 0
mirror of https://github.com/goharbor/harbor synced 2025-04-19 22:57:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
Wenkai Yin 2016-06-29 17:52:35 +08:00
parent 23b026655c
commit 2f9ace7eeb
1 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
api/repository.go
View File

@ -144,6 +144,18 @@ func (ra *RepositoryAPI) Delete() {
tags = append(tags, tag) tags = append(tags, tag)
} }
project := ""
if strings.Contains(repoName, "/") {
project = repoName[0:strings.LastIndex(repoName, "/")]
}
user, _, ok := ra.Ctx.Request.BasicAuth()
if !ok {
user, err = ra.getUsername()
if err != nil {
log.Errorf("failed to get user: %v", err)
}
}
for _, t := range tags { for _, t := range tags {
if err := rc.DeleteTag(t); err != nil { if err := rc.DeleteTag(t); err != nil {
if regErr, ok := err.(*registry_error.Error); ok { if regErr, ok := err.(*registry_error.Error); ok {
@ -155,6 +167,13 @@ func (ra *RepositoryAPI) Delete() {
} }
log.Infof("delete tag: %s %s", repoName, t) log.Infof("delete tag: %s %s", repoName, t)
go TriggerReplicationByRepository(repoName, []string{t}, models.RepOpDelete) go TriggerReplicationByRepository(repoName, []string{t}, models.RepOpDelete)
go func() {
if err := dao.AccessLog(user, project, repoName, t, "delete"); err != nil {
log.Errorf("failed to add access log: %v", err)
}
}()
} }
go func() { go func() {