rnhmjoj/magnetico
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

fixed pkg/persistence/interface.go

Browse Source
This commit is contained in:
Bora Alper 2018-03-03 17:09:49 +00:00
parent 7a49acb50a
commit 3a886229fc
1 changed files with 21 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
pkg/persistence/interface.go
View File

@ -2,8 +2,10 @@ package persistence
import ( import (
"fmt" "fmt"
"go.uber.org/zap"
"net/url" "net/url"
"time"
"go.uber.org/zap"
) )
type Database interface { type Database interface {
@ -21,58 +23,38 @@ type Database interface {
// * that match the @query if it's not empty, // * that match the @query if it's not empty,
// ordered by the @orderBy in ascending order if @isDescending is false, else in descending // ordered by the @orderBy in ascending order if @isDescending is false, else in descending
// order. // order.
QueryTorrents(query string, orderBy orderingCriteria, ord order, n uint, when presence, timePoint int64) ([]TorrentMetadata, error) QueryTorrents(query string, discoveredOnBefore int64, orderBy orderingCriteria, ascending bool, page uint, pageSize uint) ([]TorrentMetadata, error)
// GetTorrents returns the TorrentExtMetadata for the torrent of the given InfoHash. Might return // GetTorrents returns the TorrentExtMetadata for the torrent of the given InfoHash. Might return
// nil, nil if the torrent does not exist in the database. // nil, nil if the torrent does not exist in the database.
GetTorrent(infoHash []byte) (*TorrentMetadata, error) GetTorrent(infoHash []byte) (*TorrentMetadata, error)
GetFiles(infoHash []byte) ([]File, error) GetFiles(infoHash []byte) ([]File, error)
GetStatistics(from ISO8601, period uint) (*Statistics, error) GetStatistics(n uint, granularity Granularity, to time.Time) (*Statistics, error)
} }
type orderingCriteria uint8 type orderingCriteria uint8
const ( const (
BY_RELEVANCE orderingCriteria = 1 ByRelevance orderingCriteria = iota
BY_SIZE = 2 BySize
BY_DISCOVERED_ON = 3 ByDiscoveredOn
BY_N_FILES = 4 ByNFiles
) )
type order uint8 type Granularity uint8
const ( const (
ASCENDING order = 1 Yearly Granularity = iota
DESCENDING = 2 Monthly
) Weekly
Daily
type presence uint8 Hourly
const (
BEFORE presence = 1
AFTER = 2
)
type statisticsGranularity uint8
type ISO8601 string
const (
HOURLY_STATISTICS statisticsGranularity = 1
DAILY_STATISTICS = 2
WEEKLY_STATISTICS = 3
MONTHLY_STATISTICS = 4
YEARLY_STATISTICS = 5
) )
type databaseEngine uint8 type databaseEngine uint8
const ( const (
SQLITE3_ENGINE databaseEngine = 1 Sqlite3 databaseEngine = 1
) )
type Statistics struct { type Statistics struct {
Granularity statisticsGranularity N uint
From ISO8601
Period uint
// All these slices below have the exact length equal to the Period. // All these slices below have the exact length equal to the Period.
NTorrentsDiscovered []uint NTorrentsDiscovered []uint
@ -87,7 +69,7 @@ type File struct {
type TorrentMetadata struct { type TorrentMetadata struct {
InfoHash []byte InfoHash []byte
Name string Name string
Size uint64 TotalSize uint64
DiscoveredOn int64 DiscoveredOn int64
NFiles uint NFiles uint
} }
@ -111,7 +93,8 @@ func MakeDatabase(rawURL string, enableFTS bool, logger *zap.Logger) (Database,
case "mysql": case "mysql":
return nil, fmt.Errorf("mysql is not yet supported!") return nil, fmt.Errorf("mysql is not yet supported!")
}
return nil, fmt.Errorf("unknown URI scheme (database engine)!") default:
return nil, fmt.Errorf("unknown URI scheme (database engine)!")
}
} }