DeforaNetworks/corteza
DeforaNetworks/corteza
3
0
Fork 0
Code

Fix broken messages & logic for del/undel/arch/unarch

Browse Source
This commit is contained in:
Denis Arh 2018-08-07 21:50:59 +02:00
parent 79ca22b9a8
commit a140eea1ba
1 changed files with 28 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
sam/service/channel.go
View File

@ -246,16 +246,21 @@ func (svc channel) Update(ctx context.Context, in *types.Channel) (out *types.Ch
func (svc channel) Delete(ctx context.Context, id uint64) error {
return svc.rpo.BeginWith(ctx, func(r repository.Interfaces) (err error) {
var userID = auth.GetIdentityFromContext(ctx).Identity()
var ch *types.Channel
// @todo [SECURITY] can user access this channel?
if ch, err = r.FindChannelByID(id); err != nil {
return
}
// @todo [SECURITY] can user delete this channel?
if ch.DeletedAt != nil {
return errors.New("Channel already deleted")
}
_, err = r.CreateMessage(svc.makeSystemMessage(ch,
"%s deleted this channel"))
_, err = r.CreateMessage(svc.makeSystemMessage(ch, "@%d deleted this channel", userID))
return r.DeleteChannelByID(id)
})
@ -263,16 +268,21 @@ func (svc channel) Delete(ctx context.Context, id uint64) error {
func (svc channel) Recover(ctx context.Context, id uint64) error {
return svc.rpo.BeginWith(ctx, func(r repository.Interfaces) (err error) {
var userID = auth.GetIdentityFromContext(ctx).Identity()
var ch *types.Channel
// @todo [SECURITY] can user access this channel?
if ch, err = r.FindChannelByID(id); err != nil {
return
}
// @todo [SECURITY] can user recover this channel?
if ch.DeletedAt == nil {
return errors.New("Channel not deleted")
}
_, err = r.CreateMessage(svc.makeSystemMessage(ch,
"%s recovered this channel"))
_, err = r.CreateMessage(svc.makeSystemMessage(ch, "@%d recovered this channel", userID))
return r.DeleteChannelByID(id)
})
@ -280,16 +290,21 @@ func (svc channel) Recover(ctx context.Context, id uint64) error {
func (svc channel) Archive(ctx context.Context, id uint64) error {
return svc.rpo.BeginWith(ctx, func(r repository.Interfaces) (err error) {
var userID = auth.GetIdentityFromContext(ctx).Identity()
var ch *types.Channel
// @todo [SECURITY] can user access this channel?
if ch, err = r.FindChannelByID(id); err != nil {
return
}
// @todo [SECURITY] can user archive this channel?
if ch.ArchivedAt != nil {
return errors.New("Channel already archived")
}
_, err = r.CreateMessage(svc.makeSystemMessage(ch,
"%s archived this channel"))
_, err = r.CreateMessage(svc.makeSystemMessage(ch, "@%d archived this channel", userID))
return r.ArchiveChannelByID(id)
})
@ -297,16 +312,21 @@ func (svc channel) Archive(ctx context.Context, id uint64) error {
func (svc channel) Unarchive(ctx context.Context, id uint64) error {
return svc.rpo.BeginWith(ctx, func(r repository.Interfaces) (err error) {
var userID = auth.GetIdentityFromContext(ctx).Identity()
var ch *types.Channel
// @todo [SECURITY] can user access this channel?
if ch, err = r.FindChannelByID(id); err != nil {
return
}
// @todo [SECURITY] can user unarchive this channel?
if ch.ArchivedAt == nil {
return errors.New("Channel not archived")
}
_, err = r.CreateMessage(svc.makeSystemMessage(ch,
"%s unarchived this channel"))
_, err = r.CreateMessage(svc.makeSystemMessage(ch, "@%d unarchived this channel", userID))
return r.ArchiveChannelByID(id)
})