Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
58 commits
Select commit Hold shift + click to select a range
57e5162
Merge branch 'master' of github.com:go-vela/server
jbrockopp Feb 23, 2022
b6b840c
Merge branch 'master' of github.com:go-vela/server
jbrockopp Mar 10, 2022
858c818
Merge branch 'master' of github.com:go-vela/server
jbrockopp Mar 16, 2022
ceddb11
Merge branch 'master' of github.com:go-vela/server
jbrockopp Mar 28, 2022
331b2a2
Merge branch 'master' of github.com:go-vela/server
jbrockopp Apr 11, 2022
c4ec5fb
Merge branches 'master' and 'master' of github.com:go-vela/server
jbrockopp Apr 18, 2022
30c1151
Merge branch 'master' of github.com:go-vela/server
jbrockopp Apr 20, 2022
0ddc31c
Merge branch 'master' of github.com:go-vela/server
jbrockopp Apr 27, 2022
890f9fa
Merge branch 'master' of github.com:go-vela/server
jbrockopp May 9, 2022
cf4ca0e
Merge branch 'master' of github.com:go-vela/server
jbrockopp May 20, 2022
175e5c5
Merge branch 'master' of github.com:go-vela/server
jbrockopp May 31, 2022
1728dce
Merge branch 'master' of github.com:go-vela/server
jbrockopp Jun 12, 2022
88d3974
Merge branch 'master' of github.com:go-vela/server
jbrockopp Jun 22, 2022
de5ac75
feat(database): add user engine
jbrockopp Jun 22, 2022
8f2fce6
chore(database): remove old user logic
jbrockopp Jun 22, 2022
736a0e9
refactor(database): restructure DDL functions
jbrockopp Jun 22, 2022
c28ca23
chore: updates for database user engine
jbrockopp Jun 22, 2022
a4d8bbc
Merge branch 'master' of github.com:go-vela/server
jbrockopp Jun 26, 2022
c719ab0
Merge branch 'refactor/database/user' of github.com:go-vela/server in…
jbrockopp Jun 26, 2022
a147ce8
feat(database): add repo engine
jbrockopp Jun 27, 2022
b7e267f
Merge branch 'master' of github.com:go-vela/server into refactor/data…
jbrockopp Aug 20, 2022
ff5b8e1
chore: save work
jbrockopp Aug 27, 2022
ef70014
Merge branch 'master' of github.com:go-vela/server
jbrockopp Aug 27, 2022
ca230da
Merge branch 'master' of github.com:go-vela/server into refactor/data…
jbrockopp Aug 27, 2022
ab2f213
fix: Scan() -> Take()
jbrockopp Aug 27, 2022
68cf328
fix: sort by for listing repos
jbrockopp Sep 10, 2022
55862b2
Merge branch 'master' into refactor/database/repo
jbrockopp Sep 10, 2022
443c5d0
Merge branches 'master' and 'master' of github.com:go-vela/server
jbrockopp Sep 11, 2022
a47cf36
Merge branch 'refactor/database/repo' of github.com:go-vela/server in…
jbrockopp Sep 11, 2022
8e628be
feat(database): add worker engine
jbrockopp Sep 11, 2022
a827790
chore(database): remove old worker logic
jbrockopp Sep 11, 2022
a960f5d
chore: updates for database worker engine
jbrockopp Sep 11, 2022
3b7918f
Merge branch 'main' into refactor/database/worker
jbrockopp Sep 30, 2022
535b2bb
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Sep 30, 2022
acad4fd
fix: issues from merge conflict
jbrockopp Sep 30, 2022
72bc1f1
Merge branch 'main' into refactor/database/worker
jbrockopp Sep 30, 2022
3745fdf
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Sep 30, 2022
6fcc762
chore: address linter feedback
jbrockopp Sep 30, 2022
57206f9
chore: address linter feedback v2
jbrockopp Sep 30, 2022
af3cf83
Merge branch 'main' into refactor/database/worker
jbrockopp Oct 5, 2022
6cf8508
Merge branch 'main' into refactor/database/worker
jbrockopp Oct 7, 2022
b5254d7
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Oct 7, 2022
0648d24
Merge branch 'main' into refactor/database/worker
jbrockopp Oct 7, 2022
4ac392a
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Oct 7, 2022
a7994ec
Merge branch 'main' into refactor/database/worker
jbrockopp Oct 7, 2022
7c2b5b7
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Oct 7, 2022
c4d188d
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Oct 7, 2022
1171ce1
feat(database): add hook engine
jbrockopp Oct 7, 2022
286e06e
chore: remove Limit(1) with Take()
jbrockopp Oct 7, 2022
a28899c
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Oct 7, 2022
d9d2749
chore(database): remove old hook logic
jbrockopp Oct 7, 2022
6086c0a
chore: updates for database hook engine
jbrockopp Oct 7, 2022
7991f03
refactor(database/worker): name of index
jbrockopp Oct 8, 2022
5b90666
Merge branch 'refactor/database/worker' of github.com:go-vela/server …
jbrockopp Oct 8, 2022
5bec8fa
Merge branch 'main' of github.com:go-vela/server into refactor/databa…
jbrockopp Dec 21, 2022
c79fef5
chore: address linter feedback
jbrockopp Dec 21, 2022
7444050
fix: unintended changes
jbrockopp Dec 21, 2022
6b87304
chore: update tests for unintended changes
jbrockopp Dec 21, 2022
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
chore: updates for database user engine
  • Loading branch information
jbrockopp committed Jun 22, 2022
commit c28ca23b1aa84fdc046b33a908c02e4780165d50
2 changes: 1 addition & 1 deletion api/admin/user.go
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@ func AllUsers(c *gin.Context) {
logrus.Info("Admin: reading all users")

// send API call to capture all users
u, err := database.FromContext(c).GetUserList()
u, err := database.FromContext(c).ListUsers()
if err != nil {
retErr := fmt.Errorf("unable to capture all users: %w", err)

Expand Down
4 changes: 2 additions & 2 deletions api/authenticate.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ func Authenticate(c *gin.Context) {
}

// send API call to capture the user logging in
u, err := database.FromContext(c).GetUserName(newUser.GetName())
u, err := database.FromContext(c).GetUserForName(newUser.GetName())
// create a new user account
if len(u.GetName()) == 0 || err != nil {
// create unique id for the user
Expand Down Expand Up @@ -314,7 +314,7 @@ func AuthenticateToken(c *gin.Context) {
}

// check if the user exists
u, err = database.FromContext(c).GetUserName(u.GetName())
u, err = database.FromContext(c).GetUserForName(u.GetName())
if err != nil {
retErr := fmt.Errorf("user %s not found", u.GetName())

Expand Down
2 changes: 1 addition & 1 deletion api/metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ func CustomMetrics(c *gin.Context) {
// helper function to get the totals of resource types.
func recordGauges(c *gin.Context) {
// send API call to capture the total number of users
u, err := database.FromContext(c).GetUserCount()
u, err := database.FromContext(c).CountUsers()
if err != nil {
logrus.Errorf("unable to get count of all users: %v", err)
}
Expand Down
26 changes: 8 additions & 18 deletions api/user.go
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ func CreateUser(c *gin.Context) {
}

// send API call to capture the created user
user, _ := database.FromContext(c).GetUserName(input.GetName())
user, _ := database.FromContext(c).GetUserForName(input.GetName())

c.JSON(http.StatusCreated, user)
}
Expand Down Expand Up @@ -172,18 +172,8 @@ func GetUsers(c *gin.Context) {
// ensure per_page isn't above or below allowed values
perPage = util.MaxInt(1, util.MinInt(100, perPage))

// send API call to capture the total number of users
t, err := database.FromContext(c).GetUserCount()
if err != nil {
retErr := fmt.Errorf("unable to get users count: %w", err)

util.HandleError(c, http.StatusInternalServerError, retErr)

return
}

// send API call to capture the list of users
users, err := database.FromContext(c).GetUserLiteList(page, perPage)
users, t, err := database.FromContext(c).ListLiteUsers(page, perPage)
if err != nil {
retErr := fmt.Errorf("unable to get users: %w", err)

Expand Down Expand Up @@ -311,7 +301,7 @@ func UpdateCurrentUser(c *gin.Context) {
}

// send API call to capture the updated user
u, err = database.FromContext(c).GetUserName(u.GetName())
u, err = database.FromContext(c).GetUserForName(u.GetName())
if err != nil {
retErr := fmt.Errorf("unable to get updated user %s: %w", u.GetName(), err)

Expand Down Expand Up @@ -363,7 +353,7 @@ func GetUser(c *gin.Context) {
}).Infof("reading user %s", user)

// send API call to capture the user
u, err := database.FromContext(c).GetUserName(user)
u, err := database.FromContext(c).GetUserForName(user)
if err != nil {
retErr := fmt.Errorf("unable to get user %s: %w", user, err)

Expand Down Expand Up @@ -548,7 +538,7 @@ func UpdateUser(c *gin.Context) {
}

// send API call to capture the user
u, err = database.FromContext(c).GetUserName(user)
u, err = database.FromContext(c).GetUserForName(user)
if err != nil {
retErr := fmt.Errorf("unable to get user %s: %w", user, err)

Expand Down Expand Up @@ -584,7 +574,7 @@ func UpdateUser(c *gin.Context) {
}

// send API call to capture the updated user
u, _ = database.FromContext(c).GetUserName(user)
u, _ = database.FromContext(c).GetUserForName(user)

c.JSON(http.StatusOK, u)
}
Expand Down Expand Up @@ -633,7 +623,7 @@ func DeleteUser(c *gin.Context) {
}).Infof("deleting user %s", user)

// send API call to capture the user
u, err := database.FromContext(c).GetUserName(user)
u, err := database.FromContext(c).GetUserForName(user)
if err != nil {
retErr := fmt.Errorf("unable to get user %s: %w", user, err)

Expand All @@ -643,7 +633,7 @@ func DeleteUser(c *gin.Context) {
}

// send API call to remove the user
err = database.FromContext(c).DeleteUser(u.GetID())
err = database.FromContext(c).DeleteUser(u)
if err != nil {
retErr := fmt.Errorf("unable to delete user %s: %w", u.GetName(), err)

Expand Down
2 changes: 1 addition & 1 deletion router/middleware/token/token.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ func Parse(t string, db database.Service) (*library.User, error) {

// lookup the user in the database
logrus.WithField("user", name).Debugf("reading user %s", name)
u, err = db.GetUserName(name)
u, err = db.GetUserForName(name)
return []byte(u.GetHash()), err
})

Expand Down