Skip to content

Commit c216d84

Browse files
committed
log deletes
1 parent c89de14 commit c216d84

File tree

5 files changed

+30
-4
lines changed

5 files changed

+30
-4
lines changed

.idea/dataSources.xml

+7
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

internal/gen/vanderbot/public/model/message.go

+1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

internal/gen/vanderbot/public/table/message.go

+5-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

migrations/committed/000005.sql

+9
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
--! Previous: sha1:875a2400a3f198033fc726257819709a9c79617a
2+
--! Hash: sha1:d7c59ac531a7bd905a8b640aba7876f003e795ad
3+
4+
-- Enter migration here
5+
ALTER TABLE message
6+
DROP COLUMN IF EXISTS is_delete;
7+
8+
ALTER TABLE message
9+
ADD is_delete bool NOT NULL DEFAULT FALSE;

pkg/messagestorefx/module.go

+8-2
Original file line numberDiff line numberDiff line change
@@ -68,12 +68,16 @@ func New(p Params) (Result, error) {
6868
func (p *store) handleMessageCreate(s *discordgo.Session, m *discordgo.MessageCreate) {
6969
p.Log.Info("chat create", zap.Reflect("payload", m))
7070

71-
serializedMessage, err := json.Marshal(m.Message)
71+
p.logMessage(m.Message, false)
72+
}
73+
74+
func (p *store) logMessage(m *discordgo.Message, isDelete bool) {
75+
serializedMessage, err := json.Marshal(m)
7276
if err != nil {
7377
p.Log.Error("error serializing created message", zap.Error(err))
7478
return
7579
}
76-
insertStmt := table.Message.INSERT(table.Message.Blob).VALUES(serializedMessage)
80+
insertStmt := table.Message.INSERT(table.Message.Blob, table.Message.IsDelete).VALUES(serializedMessage, isDelete)
7781
_, err = insertStmt.Exec(p.db)
7882
if err != nil {
7983
p.Log.Error("error inserting message", zap.Error(err))
@@ -87,6 +91,8 @@ func (p *store) handleMessageEdit(s *discordgo.Session, m *discordgo.MessageEdit
8791

8892
func (p *store) handleMessageDelete(s *discordgo.Session, m *discordgo.MessageDelete) {
8993
p.Log.Info("chat delete", zap.Reflect("payload", m))
94+
95+
p.logMessage(m.Message, true)
9096
}
9197

9298
func (p *store) GetMessage(messageID string) (*discordgo.Message, error) {

0 commit comments

Comments
 (0)