Skip to content

Commit

Permalink
Remove unused Get method for fetching log entries from the database
Browse files Browse the repository at this point in the history
  • Loading branch information
abaldeweg authored Feb 3, 2025
1 parent d54398e commit dd06b11
Showing 1 changed file with 0 additions and 37 deletions.
37 changes: 0 additions & 37 deletions logs_web/db/db.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,6 @@ package db

import (
"context"
"fmt"
"time"

"github.com/abaldeweg/warehouse-server/logs_web/entity"
"github.com/spf13/viper"
Expand Down Expand Up @@ -41,41 +39,6 @@ func (handler *DBHandler) Close() error {
return handler.client.Disconnect(context.TODO())
}

// Get fetches log entries from the database within a specified time range.
func (handler *DBHandler) Get(from int, to int) ([]entity.LogEntry, error) {
fromTime, err := time.Parse("20060102", fmt.Sprintf("%d", from))
if err != nil {
return nil, err
}
toTime, err := time.Parse("20060102", fmt.Sprintf("%d", to))
if err != nil {
return nil, err
}
toTime = toTime.Add(23*time.Hour + 59*time.Minute + 59*time.Second)

filter := bson.M{
"time": bson.M{
"$gte": fromTime.Format(time.RFC3339),
"$lte": toTime.Format(time.RFC3339),
},
}
cursor, err := handler.collection.Find(context.TODO(), filter)
if err != nil {
return nil, err
}
defer cursor.Close(context.TODO())

var logs []entity.LogEntry
for cursor.Next(context.TODO()) {
var logEntry entity.LogEntry
if err := cursor.Decode(&logEntry); err != nil {
return nil, err
}
logs = append(logs, logEntry)
}
return logs, nil
}

// FindDemanded retrieves logs based on the provided filter.
func (handler *DBHandler) FindDemanded(filter map[string]interface{}) ([]entity.LogEntry, error) {
bsonFilter := bson.M(filter)
Expand Down

0 comments on commit dd06b11

Please sign in to comment.