From ac4ec2570aafb9ae1e14394b48e83c60c0a65693 Mon Sep 17 00:00:00 2001 From: Tit Petric Date: Wed, 3 Apr 2019 14:24:22 +0200 Subject: [PATCH] add(system): repository BindAvatar() --- system/internal/repository/user.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/system/internal/repository/user.go b/system/internal/repository/user.go index 79887e4c8..cc3608bd6 100644 --- a/system/internal/repository/user.go +++ b/system/internal/repository/user.go @@ -3,6 +3,7 @@ package repository import ( "context" "fmt" + "io" "time" "github.com/jmoiron/sqlx" @@ -25,6 +26,8 @@ type ( Create(mod *types.User) (*types.User, error) Update(mod *types.User) (*types.User, error) + BindAvatar(user *types.User, avatar io.Reader) (*types.User, error) + SuspendByID(id uint64) error UnsuspendByID(id uint64) error DeleteByID(id uint64) error @@ -166,6 +169,15 @@ func (r *user) Update(mod *types.User) (*types.User, error) { return mod, r.db().Replace(r.users, mod) } +func (r *user) BindAvatar(user *types.User, avatar io.Reader) (*types.User, error) { + if user.Meta == nil { + user.Meta = new(types.UserMeta) + } + // @todo: IMPORTANT: implement avatar uploading + user.Meta.Avatar = "" + return user, nil +} + func (r *user) SuspendByID(id uint64) error { return r.updateColumnByID(r.users, "suspend_at", time.Now(), id) }