This commit is contained in:
13
main.go
13
main.go
@@ -1482,6 +1482,7 @@ type PrivilegedUsersPageData struct {
|
||||
}
|
||||
|
||||
type RawEventInsert struct {
|
||||
Time time.Time
|
||||
Message string
|
||||
SHA256 string
|
||||
}
|
||||
@@ -4323,11 +4324,11 @@ func insertRawEventsTx(ctx context.Context, tx *sql.Tx, firstEventID uint64, raw
|
||||
}
|
||||
|
||||
var sb strings.Builder
|
||||
args := make([]any, 0, len(rawEvents)*3)
|
||||
args := make([]any, 0, len(rawEvents)*4)
|
||||
|
||||
sb.WriteString(`
|
||||
INSERT INTO event_log_raw
|
||||
(event_log_id, msg, msg_sha256)
|
||||
(event_log_id, ts, msg, msg_sha256)
|
||||
VALUES
|
||||
`)
|
||||
|
||||
@@ -4336,10 +4337,16 @@ VALUES
|
||||
sb.WriteString(",")
|
||||
}
|
||||
|
||||
sb.WriteString("(?,?,?)")
|
||||
sb.WriteString("(?,?,?,?)")
|
||||
|
||||
eventTime := raw.Time.UTC()
|
||||
if eventTime.IsZero() {
|
||||
return fmt.Errorf("raw event at index %d has zero timestamp", i)
|
||||
}
|
||||
|
||||
args = append(args,
|
||||
firstEventID+uint64(i),
|
||||
eventTime,
|
||||
raw.Message,
|
||||
raw.SHA256,
|
||||
)
|
||||
|
||||
Reference in New Issue
Block a user