mirror of
https://codeberg.org/shroff/phylum.git
synced 2026-02-14 23:48:30 -06:00
53 lines
1.1 KiB
Go
53 lines
1.1 KiB
Go
package user
|
|
|
|
import (
|
|
"net/http"
|
|
"time"
|
|
|
|
"github.com/jackc/pgx/v5"
|
|
"github.com/jackc/pgx/v5/pgtype"
|
|
"github.com/shroff/phylum/server/internal/core/errors"
|
|
)
|
|
|
|
var ErrNotFound = errors.NewError(http.StatusNotFound, "user_not_found", "no such user")
|
|
|
|
func (m manager) ListUsers(since *time.Time) ([]User, error) {
|
|
s := pgtype.Timestamp{
|
|
Valid: true,
|
|
}
|
|
if since != nil {
|
|
s.Time = *since
|
|
}
|
|
results, err := m.db.ListUsers(m.ctx, s)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
users := make([]User, len(results))
|
|
for i, r := range results {
|
|
users[i] = User{
|
|
Username: r.Username,
|
|
DisplayName: r.DisplayName,
|
|
Root: r.Root,
|
|
Home: r.Home,
|
|
}
|
|
}
|
|
return users, nil
|
|
}
|
|
|
|
func (m manager) UserByEmail(email string) (User, error) {
|
|
result, err := m.db.UserByUsername(m.ctx, email)
|
|
if err != nil {
|
|
if errors.Is(err, pgx.ErrNoRows) {
|
|
err = ErrNotFound
|
|
}
|
|
return User{}, err
|
|
}
|
|
return User{
|
|
Username: result.Username,
|
|
DisplayName: result.DisplayName,
|
|
Permissions: result.Permissions,
|
|
Root: result.Root,
|
|
Home: result.Home,
|
|
}, nil
|
|
}
|