DeforaNetworks/corteza
3
0
Fork 0
Code Activity

Remove old migration code

Browse Source
This commit is contained in:
Denis Arh
2019-10-29 10:06:14 +01:00
parent 780f4094a0
commit f5baa1ce7a
3 changed files with 0 additions and 75 deletions
Download Patch File Download Diff File Expand all files Collapse all files
messaging/repository/message.go
-31
View File
@@ -2,7 +2,6 @@ package repository
import (
"context"
"fmt"
"io"
"strings"
"time"
@@ -33,11 +32,6 @@ type (
IncReplyCount(ID uint64) error
DecReplyCount(ID uint64) error
CountOwned(userID uint64) (c int, err error)
ChangeOwner(userID, target uint64) error
CountUserTags(userID uint64) (c int, err error)
ChangeUserTag(userID, target uint64) error
}
message struct {
@@ -339,28 +333,3 @@ func (r *message) DecReplyCount(ID uint64) error {
_, err := r.db().Exec(sqlMessageRepliesDecCount, ID)
return err
}
func (r *message) CountOwned(userID uint64) (c int, err error) {
return c, r.db().Get(&c,
"SELECT COUNT(*) FROM messaging_message WHERE rel_user = ?",
userID)
}
func (r *message) CountUserTags(userID uint64) (c int, err error) {
return c, r.db().Get(&c,
"SELECT COUNT(*) FROM messaging_message WHERE message LIKE ?",
fmt.Sprintf("%%@%d%%", userID))
}
func (r *message) ChangeOwner(userID, target uint64) error {
_, err := r.db().Exec("UPDATE messaging_message SET rel_user = ? WHERE rel_user = ?", target, userID)
return err
}
func (r *message) ChangeUserTag(userID, target uint64) error {
_, err := r.db().Exec("UPDATE messaging_message SET message = replace(message, ?, ?) WHERE message LIKE ?",
fmt.Sprintf("@%d", userID),
fmt.Sprintf("@%d", target),
fmt.Sprintf("%%@%d%%", userID))
return err
}
messaging/repository/message_flag.go
-14
View File
@@ -19,9 +19,6 @@ type (
FindByFlag(messageID, userID uint64, flag string) (*types.MessageFlag, error)
Create(mod *types.MessageFlag) (*types.MessageFlag, error)
DeleteByID(ID uint64) error
CountOwned(userID uint64) (c int, err error)
ChangeOwner(userID, target uint64) error
}
messageFlag struct {
@@ -88,14 +85,3 @@ func (r *messageFlag) Create(mod *types.MessageFlag) (*types.MessageFlag, error)
func (r *messageFlag) DeleteByID(ID uint64) error {
return exec(r.db().Exec("DELETE FROM messaging_message_flag WHERE id = ?", ID))
}
func (r *messageFlag) CountOwned(userID uint64) (c int, err error) {
return c, r.db().Get(&c,
"SELECT COUNT(*) FROM message_flag WHERE rel_user = ?",
userID)
}
func (r *messageFlag) ChangeOwner(userID, target uint64) error {
_, err := r.db().Exec("UPDATE message_flag SET rel_user = ? WHERE rel_user = ?", target, userID)
return err
}
messaging/repository/unread.go
-30
View File
@@ -22,9 +22,6 @@ type (
Inc(channelID, replyTo, userID uint64) error
Dec(channelID, replyTo, userID uint64) error
ClearThreads(channelID, userID uint64) (err error)
CountOwned(userID uint64) (c int, err error)
ChangeOwner(userID, target uint64) error
}
unread struct {
@@ -229,30 +226,3 @@ func (r *unread) Dec(channelID, threadID, userID uint64) (err error) {
return nil
}
func (r *unread) CountOwned(userID uint64) (c int, err error) {
return c, r.db().Get(&c,
"SELECT COUNT(*) FROM messaging_unread WHERE rel_user = ?",
userID)
}
func (r *unread) ChangeOwner(userID, target uint64) (err error) {
// Remove dups
// with an ugly mysql workaround
_, err = r.db().Exec(
"DELETE FROM messaging_unread WHERE rel_user = ? "+
"AND rel_channel IN (SELECT rel_channel FROM (SELECT * FROM messaging_unread) AS workaround WHERE rel_user = ?)",
userID,
target)
if err != nil {
return err
}
_, err = r.db().Exec(
"UPDATE messaging_unread SET rel_user = ? WHERE rel_user = ?",
target,
userID)
return err
}