gitea/services/f3/driver/release.go

// Copyright 2022 The Gitea Authors. All rights reserved.
// Use of this source code is governed by a MIT-style
// license that can be found in the LICENSE file.

package driver

import (
	"fmt"
	"strings"
	"time"

	"code.gitea.io/gitea/models/db"
	repo_model "code.gitea.io/gitea/models/repo"
	user_model "code.gitea.io/gitea/models/user"
	"code.gitea.io/gitea/modules/git"
	"code.gitea.io/gitea/modules/timeutil"
	release_service "code.gitea.io/gitea/services/release"

	"lab.forgefriends.org/friendlyforgeformat/gof3/format"
	"lab.forgefriends.org/friendlyforgeformat/gof3/util"
)

type Release struct {
	repo_model.Release
}

func ReleaseConverter(f *repo_model.Release) *Release {
	return &Release{
		Release: *f,
	}
}

func (o Release) GetID() int64 {
	return o.ID
}

func (o *Release) SetID(id int64) {
	o.ID = id
}

func (o *Release) IsNil() bool {
	return o.ID == 0
}

func (o *Release) Equals(other *Release) bool {
	return o.ID == other.ID
}

func (o *Release) ToFormat() *format.Release {
	return &format.Release{
		Common:          format.Common{Index: o.ID},
		TagName:         o.TagName,
		TargetCommitish: o.Target,
		Name:            o.Title,
		Body:            o.Note,
		Draft:           o.IsDraft,
		Prerelease:      o.IsPrerelease,
		Created:         o.CreatedUnix.AsTime(),
		PublisherID:     o.Publisher.ID,
		PublisherName:   o.Publisher.Name,
		PublisherEmail:  o.Publisher.Email,
	}
}

func (o *Release) FromFormat(release *format.Release) {
	if release.Created.IsZero() {
		if !release.Published.IsZero() {
			release.Created = release.Published
		} else {
			release.Created = time.Now()
		}
	}

	*o = Release{
		repo_model.Release{
			PublisherID: release.PublisherID,
			Publisher: &user_model.User{
				ID:    release.PublisherID,
				Name:  release.PublisherName,
				Email: release.PublisherEmail,
			},
			TagName:      release.TagName,
			LowerTagName: strings.ToLower(release.TagName),
			Target:       release.TargetCommitish,
			Title:        release.Name,
			Note:         release.Body,
			IsDraft:      release.Draft,
			IsPrerelease: release.Prerelease,
			IsTag:        false,
			CreatedUnix:  timeutil.TimeStamp(release.Created.Unix()),
		},
	}
}

type ReleaseProvider struct {
	g *Gitea
}

func (o *ReleaseProvider) ToFormat(release *Release) *format.Release {
	return release.ToFormat()
}

func (o *ReleaseProvider) FromFormat(i *format.Release) *Release {
	var release Release
	release.FromFormat(i)
	return &release
}

func (o *ReleaseProvider) GetObjects(user *User, project *Project, page int) []*Release {
	releases, err := repo_model.GetReleasesByRepoID(project.GetID(), repo_model.FindReleasesOptions{
		ListOptions:   db.ListOptions{Page: page, PageSize: o.g.perPage},
		IncludeDrafts: true,
		IncludeTags:   false,
	})
	if err != nil {
		panic(fmt.Errorf("error while listing releases: %v", err))
	}

	return util.ConvertMap[*repo_model.Release, *Release](releases, ReleaseConverter)
}

func (o *ReleaseProvider) ProcessObject(user *User, project *Project, release *Release) {
	if err := (&release.Release).LoadAttributes(); err != nil {
		panic(err)
	}
}

func (o *ReleaseProvider) Get(user *User, project *Project, exemplar *Release) *Release {
	id := exemplar.GetID()
	release, err := repo_model.GetReleaseByID(o.g.ctx, id)
	if repo_model.IsErrReleaseNotExist(err) {
		return &Release{}
	}
	if err != nil {
		panic(err)
	}
	r := ReleaseConverter(release)
	o.ProcessObject(user, project, r)
	return r
}

func (o *ReleaseProvider) Put(user *User, project *Project, release *Release) *Release {
	r := release.Release
	r.RepoID = project.GetID()

	repoPath := repo_model.RepoPath(user.Name, project.Name)
	gitRepo, err := git.OpenRepository(o.g.ctx, repoPath)
	if err != nil {
		panic(err)
	}
	defer gitRepo.Close()

	if err := release_service.CreateRelease(gitRepo, &r, nil, ""); err != nil {
		panic(err)
	}
	return o.Get(user, project, ReleaseConverter(&r))
}

func (o *ReleaseProvider) Delete(user *User, project *Project, release *Release) *Release {
	m := o.Get(user, project, release)
	if !m.IsNil() {
		if err := release_service.DeleteReleaseByID(o.g.ctx, release.GetID(), o.g.GetDoer(), false); err != nil {
			panic(err)
		}
	}
	return m
}