diff --git a/main.go b/main.go index 7d0bed3..fbe9367 100644 --- a/main.go +++ b/main.go @@ -37,20 +37,12 @@ type Config struct { } } -type MsgDirection string - -const ( - Incoming MsgDirection = `incoming` - Outgoing MsgDirection = `outgoing` -) - type ChatWarsMessage struct { - MsgID64 int64 `json:"msg_id"` - ChatID64 int64 `json:"chat_id"` - UserID64 int64 `json:"user_id"` - Direction MsgDirection `json:"direction"` - MsgText string `json:"msg"` - MsgDate int32 `json:"date"` + MsgID64 int64 `json:"msg_id"` + ChatID64 int64 `json:"chat_id"` + UserID64 int64 `json:"user_id"` + MsgText string `json:"msg"` + MsgDate int32 `json:"date"` } var ( diff --git a/sql.go b/sql.go index c8ab528..9620c06 100644 --- a/sql.go +++ b/sql.go @@ -68,7 +68,6 @@ func initDB() { id BIGINT UNSIGNED NOT NULL ,chat_id BIGINT UNSIGNED NOT NULL ,user_id BIGINT UNSIGNED NOT NULL - ,direction ENUM('incoming', 'outgoing') ,date TIMESTAMP NOT NULL ,text VARCHAR(4096) NOT NULL ,PRIMARY KEY (id, chat_id) @@ -81,13 +80,13 @@ func initDB() { } func putMsg(m ChatWarsMessage) { - stmt, err := db.Prepare(`INSERT INTO msg (id, chat_id, user_id, direction, date , text) - VALUES (?, ?, ?, ?, FROM_UNIXTIME(?), ?);`) + stmt, err := db.Prepare(`INSERT INTO msg (id, chat_id, user_id, date , text) + VALUES (?, ?, ?, FROM_UNIXTIME(?), ?);`) if err != nil { log.Fatal(err) } - _, err = stmt.Exec(m.MsgID64, m.ChatID64, m.UserID64, m.Direction, m.MsgDate, m.MsgText) + _, err = stmt.Exec(m.MsgID64, m.ChatID64, m.UserID64, m.MsgDate, m.MsgText) if err != nil { log.Fatal(err) }