mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2025-09-15 18:56:59 +00:00
F3: Forgejo driver and CLI
user, topic, project, label, milestone, repository, pull_request, release, asset, comment, reaction, review providers Signed-off-by: Earl Warren <contact@earl-warren.org> Preserve file size when creating attachments Introduced inc6f5029708
repoList.LoadAttributes has a ctx argument now Rename `repo.GetOwner` to `repo.LoadOwner`bd66fa586a
upgrade to the latest gof3 (cherry picked from commitc770713656
) [F3] ID remapping logic is in place, remove workaround (cherry picked from commitd0fee30167
) [F3] it is experimental, do not enable by default (cherry picked from commitde325b21d0
) (cherry picked from commit547e7b3c40
) (cherry picked from commit820df3a56b
) (cherry picked from commiteaba87689b
) (cherry picked from commit1b86896b3b
) (cherry picked from commit0046aac1c6
) (cherry picked from commitf14220df8f
) (cherry picked from commit559b731001
)
This commit is contained in:
parent
4c354196c2
commit
801f7d600d
28 changed files with 2748 additions and 6 deletions
134
services/f3/driver/user.go
Normal file
134
services/f3/driver/user.go
Normal file
|
@ -0,0 +1,134 @@
|
|||
// SPDX-License-Identifier: MIT
|
||||
|
||||
package driver
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
|
||||
"code.gitea.io/gitea/models/db"
|
||||
user_model "code.gitea.io/gitea/models/user"
|
||||
"code.gitea.io/gitea/modules/util"
|
||||
user_service "code.gitea.io/gitea/services/user"
|
||||
|
||||
"lab.forgefriends.org/friendlyforgeformat/gof3/format"
|
||||
f3_util "lab.forgefriends.org/friendlyforgeformat/gof3/util"
|
||||
)
|
||||
|
||||
type User struct {
|
||||
user_model.User
|
||||
}
|
||||
|
||||
func UserConverter(f *user_model.User) *User {
|
||||
return &User{
|
||||
User: *f,
|
||||
}
|
||||
}
|
||||
|
||||
func (o User) GetID() int64 {
|
||||
return o.ID
|
||||
}
|
||||
|
||||
func (o *User) SetID(id int64) {
|
||||
o.ID = id
|
||||
}
|
||||
|
||||
func (o *User) IsNil() bool {
|
||||
return o.ID == 0
|
||||
}
|
||||
|
||||
func (o *User) Equals(other *User) bool {
|
||||
return (o.Name == other.Name)
|
||||
}
|
||||
|
||||
func (o *User) ToFormat() *format.User {
|
||||
return &format.User{
|
||||
Common: format.NewCommon(o.ID),
|
||||
UserName: o.Name,
|
||||
Name: o.FullName,
|
||||
Email: o.Email,
|
||||
Password: o.Passwd,
|
||||
}
|
||||
}
|
||||
|
||||
func (o *User) FromFormat(user *format.User) {
|
||||
*o = User{
|
||||
User: user_model.User{
|
||||
ID: user.Index.GetID(),
|
||||
Name: user.UserName,
|
||||
FullName: user.Name,
|
||||
Email: user.Email,
|
||||
Passwd: user.Password,
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
type UserProvider struct {
|
||||
g *Forgejo
|
||||
}
|
||||
|
||||
func (o *UserProvider) ToFormat(ctx context.Context, user *User) *format.User {
|
||||
return user.ToFormat()
|
||||
}
|
||||
|
||||
func (o *UserProvider) FromFormat(ctx context.Context, p *format.User) *User {
|
||||
var user User
|
||||
user.FromFormat(p)
|
||||
return &user
|
||||
}
|
||||
|
||||
func (o *UserProvider) GetObjects(ctx context.Context, page int) []*User {
|
||||
users, _, err := user_model.SearchUsers(&user_model.SearchUserOptions{
|
||||
Actor: o.g.GetDoer(),
|
||||
Type: user_model.UserTypeIndividual,
|
||||
ListOptions: db.ListOptions{Page: page, PageSize: o.g.perPage},
|
||||
})
|
||||
if err != nil {
|
||||
panic(fmt.Errorf("error while listing users: %v", err))
|
||||
}
|
||||
return f3_util.ConvertMap[*user_model.User, *User](users, UserConverter)
|
||||
}
|
||||
|
||||
func (o *UserProvider) ProcessObject(ctx context.Context, user *User) {
|
||||
}
|
||||
|
||||
func (o *UserProvider) Get(ctx context.Context, exemplar *User) *User {
|
||||
var user *user_model.User
|
||||
var err error
|
||||
if exemplar.GetID() > 0 {
|
||||
user, err = user_model.GetUserByID(ctx, exemplar.GetID())
|
||||
} else if exemplar.Name != "" {
|
||||
user, err = user_model.GetUserByName(ctx, exemplar.Name)
|
||||
} else {
|
||||
panic("GetID() == 0 and UserName == \"\"")
|
||||
}
|
||||
if user_model.IsErrUserNotExist(err) {
|
||||
return &User{}
|
||||
}
|
||||
if err != nil {
|
||||
panic(fmt.Errorf("user %v %w", exemplar, err))
|
||||
}
|
||||
return UserConverter(user)
|
||||
}
|
||||
|
||||
func (o *UserProvider) Put(ctx context.Context, user *User) *User {
|
||||
overwriteDefault := &user_model.CreateUserOverwriteOptions{
|
||||
IsActive: util.OptionalBoolTrue,
|
||||
}
|
||||
u := user.User
|
||||
err := user_model.CreateUser(&u, overwriteDefault)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
return o.Get(ctx, UserConverter(&u))
|
||||
}
|
||||
|
||||
func (o *UserProvider) Delete(ctx context.Context, user *User) *User {
|
||||
u := o.Get(ctx, user)
|
||||
if !u.IsNil() {
|
||||
if err := user_service.DeleteUser(ctx, &user.User, true); err != nil {
|
||||
panic(err)
|
||||
}
|
||||
}
|
||||
return u
|
||||
}
|
Loading…
Add table
Add a link
Reference in a new issue