fix: db connection bug and delete debug logs
This commit is contained in:
@@ -55,7 +55,6 @@ var DaemonCmd = &cobra.Command{
|
|||||||
ticker := time.NewTicker(5 * time.Second)
|
ticker := time.NewTicker(5 * time.Second)
|
||||||
defer ticker.Stop()
|
defer ticker.Stop()
|
||||||
for range ticker.C {
|
for range ticker.C {
|
||||||
log.Info("TICK: ProcessUnviewed about to run")
|
|
||||||
if err := j.ProcessUnviewed(); err != nil {
|
if err := j.ProcessUnviewed(); err != nil {
|
||||||
log.Error("Failed to process unviewed", "error", err)
|
log.Error("Failed to process unviewed", "error", err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -39,7 +39,6 @@ func (j *Judge) LoadRules(rules []config.Rule) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (j *Judge) ProcessUnviewed() error {
|
func (j *Judge) ProcessUnviewed() error {
|
||||||
j.logger.Info("Processing unviewed logs")
|
|
||||||
rows, err := j.db.SearchUnViewed()
|
rows, err := j.db.SearchUnViewed()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
j.logger.Error(fmt.Sprintf("Failed to query database: %v", err))
|
j.logger.Error(fmt.Sprintf("Failed to query database: %v", err))
|
||||||
@@ -64,7 +63,6 @@ func (j *Judge) ProcessUnviewed() error {
|
|||||||
&entry.IsViewed,
|
&entry.IsViewed,
|
||||||
&entry.CreatedAt,
|
&entry.CreatedAt,
|
||||||
)
|
)
|
||||||
j.logger.Info("Scanning database row," + entry.IP)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
j.logger.Error(fmt.Sprintf("Failed to scan database row: %v", err))
|
j.logger.Error(fmt.Sprintf("Failed to scan database row: %v", err))
|
||||||
continue
|
continue
|
||||||
|
|||||||
@@ -23,8 +23,8 @@ func NewDB() (*DB, error) {
|
|||||||
"sqlite",
|
"sqlite",
|
||||||
"/var/lib/banforge/storage.db?_pragma=journal_mode(WAL)&_pragma=busy_timeout(30000)&_pragma=synchronous(NORMAL)",
|
"/var/lib/banforge/storage.db?_pragma=journal_mode(WAL)&_pragma=busy_timeout(30000)&_pragma=synchronous(NORMAL)",
|
||||||
)
|
)
|
||||||
db.SetMaxOpenConns(1)
|
db.SetMaxOpenConns(4)
|
||||||
db.SetMaxIdleConns(1)
|
db.SetMaxIdleConns(2)
|
||||||
db.SetConnMaxLifetime(0)
|
db.SetConnMaxLifetime(0)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
Reference in New Issue
Block a user