Use new simplified uuid.NewString() syntax

This commit is contained in:
Deluan 2021-02-01 01:22:31 -05:00
parent b47ec02f02
commit 861b406575
10 changed files with 17 additions and 32 deletions

View File

@ -40,9 +40,8 @@ func (p *players) Register(ctx context.Context, id, client, typ, ip string) (*mo
if err == nil { if err == nil {
log.Debug("Found player by name", "id", plr.ID, "client", client, "username", userName) log.Debug("Found player by name", "id", plr.ID, "client", client, "username", userName)
} else { } else {
r, _ := uuid.NewRandom()
plr = &model.Player{ plr = &model.Player{
ID: r.String(), ID: uuid.NewString(),
Name: fmt.Sprintf("%s (%s)", client, userName), Name: fmt.Sprintf("%s (%s)", client, userName),
UserName: userName, UserName: userName,
Client: client, Client: client,

View File

@ -29,8 +29,7 @@ func upAddDefaultTranscodings(tx *sql.Tx) error {
} }
for _, t := range consts.DefaultTranscodings { for _, t := range consts.DefaultTranscodings {
r, _ := uuid.NewRandom() _, err := stmt.Exec(uuid.NewString(), t["name"], t["targetFormat"], t["defaultBitRate"], t["command"])
_, err := stmt.Exec(r.String(), t["name"], t["targetFormat"], t["defaultBitRate"], t["command"])
if err != nil { if err != nil {
return err return err
} }

View File

@ -92,8 +92,7 @@ var _ = Describe("MediaRepository", func() {
}) })
It("delete tracks by id", func() { It("delete tracks by id", func() {
random, _ := uuid.NewRandom() id := uuid.NewString()
id := random.String()
Expect(mr.Put(&model.MediaFile{ID: id})).To(BeNil()) Expect(mr.Put(&model.MediaFile{ID: id})).To(BeNil())
Expect(mr.Delete(id)).To(BeNil()) Expect(mr.Delete(id)).To(BeNil())

View File

@ -78,9 +78,8 @@ func AssertPlayQueue(expected, actual *model.PlayQueue) {
func aPlayQueue(userId, current string, position int64, items ...model.MediaFile) *model.PlayQueue { func aPlayQueue(userId, current string, position int64, items ...model.MediaFile) *model.PlayQueue {
createdAt := time.Now() createdAt := time.Now()
updatedAt := createdAt.Add(time.Minute) updatedAt := createdAt.Add(time.Minute)
id, _ := uuid.NewRandom()
return &model.PlayQueue{ return &model.PlayQueue{
ID: id.String(), ID: uuid.NewString(),
UserID: userId, UserID: userId,
Current: current, Current: current,
Position: position, Position: position,

View File

@ -37,8 +37,7 @@ func (r sqlRepository) annUpsert(values map[string]interface{}, itemIDs ...strin
c, err := r.executeSQL(upd) c, err := r.executeSQL(upd)
if c == 0 || err == orm.ErrNoRows { if c == 0 || err == orm.ErrNoRows {
for _, itemID := range itemIDs { for _, itemID := range itemIDs {
id, _ := uuid.NewRandom() values["ann_id"] = uuid.NewString()
values["ann_id"] = id.String()
values["user_id"] = userId(r.ctx) values["user_id"] = userId(r.ctx)
values["item_type"] = r.tableName values["item_type"] = r.tableName
values["item_id"] = itemID values["item_id"] = itemID
@ -68,9 +67,8 @@ func (r sqlRepository) IncPlayCount(itemID string, ts time.Time) error {
c, err := r.executeSQL(upd) c, err := r.executeSQL(upd)
if c == 0 || err == orm.ErrNoRows { if c == 0 || err == orm.ErrNoRows {
id, _ := uuid.NewRandom()
values := map[string]interface{}{} values := map[string]interface{}{}
values["ann_id"] = id.String() values["ann_id"] = uuid.NewString()
values["user_id"] = userId(r.ctx) values["user_id"] = userId(r.ctx)
values["item_type"] = r.tableName values["item_type"] = r.tableName
values["item_id"] = itemID values["item_id"] = itemID

View File

@ -186,8 +186,7 @@ func (r sqlRepository) put(id string, m interface{}) (newId string, err error) {
} }
// If does not have an id OR could not update (new record with predefined id) // If does not have an id OR could not update (new record with predefined id)
if id == "" { if id == "" {
rand, _ := uuid.NewRandom() id = uuid.NewString()
id = rand.String()
values["id"] = id values["id"] = id
} }
// It is a insert. if there was a created_at, add it back to args // It is a insert. if there was a created_at, add it back to args

View File

@ -44,8 +44,7 @@ func (r *userRepository) GetAll(options ...model.QueryOptions) (model.Users, err
func (r *userRepository) Put(u *model.User) error { func (r *userRepository) Put(u *model.User) error {
if u.ID == "" { if u.ID == "" {
id, _ := uuid.NewRandom() u.ID = uuid.NewString()
u.ID = id.String()
} }
u.UpdatedAt = time.Now() u.UpdatedAt = time.Now()
values, _ := toSqlArgs(*u) values, _ := toSqlArgs(*u)

View File

@ -112,11 +112,10 @@ func CreateAdmin(ds model.DataStore) func(w http.ResponseWriter, r *http.Request
} }
func createDefaultUser(ctx context.Context, ds model.DataStore, username, password string) error { func createDefaultUser(ctx context.Context, ds model.DataStore, username, password string) error {
id, _ := uuid.NewRandom()
log.Warn("Creating initial user", "user", username) log.Warn("Creating initial user", "user", username)
now := time.Now() now := time.Now()
initialUser := model.User{ initialUser := model.User{
ID: id.String(), ID: uuid.NewString(),
UserName: username, UserName: username,
Name: strings.Title(username), Name: strings.Title(username),
Email: "", Email: "",

View File

@ -154,9 +154,8 @@ func (b *broker) ServeHTTP(w http.ResponseWriter, r *http.Request) {
func (b *broker) subscribe(r *http.Request) client { func (b *broker) subscribe(r *http.Request) client {
user, _ := request.UserFrom(r.Context()) user, _ := request.UserFrom(r.Context())
id, _ := uuid.NewRandom()
c := client{ c := client{
id: id.String(), id: uuid.NewString(),
username: user.UserName, username: user.UserName,
address: r.RemoteAddr, address: r.RemoteAddr,
userAgent: r.UserAgent(), userAgent: r.UserAgent(),

View File

@ -26,7 +26,7 @@ func initialSetup(ds model.DataStore) {
} }
if conf.Server.DevAutoCreateAdminPassword != "" { if conf.Server.DevAutoCreateAdminPassword != "" {
if err = createInitialAdminUser(ds); err != nil { if err = createInitialAdminUser(ds, conf.Server.DevAutoCreateAdminPassword); err != nil {
return err return err
} }
} }
@ -36,22 +36,18 @@ func initialSetup(ds model.DataStore) {
}) })
} }
func createInitialAdminUser(ds model.DataStore) error { func createInitialAdminUser(ds model.DataStore, initialPassword string) error {
users := ds.User(context.TODO()) users := ds.User(context.TODO())
c, err := users.CountAll() c, err := users.CountAll()
if err != nil { if err != nil {
panic(fmt.Sprintf("Could not access User table: %s", err)) panic(fmt.Sprintf("Could not access User table: %s", err))
} }
if c == 0 { if c == 0 {
id, _ := uuid.NewRandom() id := uuid.NewString()
random, _ := uuid.NewRandom() log.Warn("Creating initial admin user. This should only be used for development purposes!!",
initialPassword := random.String() "user", consts.DevInitialUserName, "password", initialPassword, "id", id)
if conf.Server.DevAutoCreateAdminPassword != "" {
initialPassword = conf.Server.DevAutoCreateAdminPassword
}
log.Warn("Creating initial admin user. This should only be used for development purposes!!", "user", consts.DevInitialUserName, "password", initialPassword)
initialUser := model.User{ initialUser := model.User{
ID: id.String(), ID: id,
UserName: consts.DevInitialUserName, UserName: consts.DevInitialUserName,
Name: consts.DevInitialName, Name: consts.DevInitialName,
Email: "", Email: "",
@ -72,9 +68,8 @@ func createJWTSecret(ds model.DataStore) error {
if err == nil { if err == nil {
return nil return nil
} }
jwtSecret, _ := uuid.NewRandom()
log.Warn("Creating JWT secret, used for encrypting UI sessions") log.Warn("Creating JWT secret, used for encrypting UI sessions")
err = properties.Put(consts.JWTSecretKey, jwtSecret.String()) err = properties.Put(consts.JWTSecretKey, uuid.NewString())
if err != nil { if err != nil {
log.Error("Could not save JWT secret in DB", err) log.Error("Could not save JWT secret in DB", err)
} }