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