123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104 |
- // Copyright (C) 2014 The Syncthing Authors.
- //
- // This Source Code Form is subject to the terms of the Mozilla Public
- // License, v. 2.0. If a copy of the MPL was not distributed with this file,
- // You can obtain one at https://mozilla.org/MPL/2.0/.
- package stats
- import (
- "time"
- "github.com/syncthing/syncthing/lib/db"
- )
- type FolderStatistics struct {
- LastFile LastFile `json:"lastFile"`
- LastScan time.Time `json:"lastScan"`
- }
- type FolderStatisticsReference struct {
- ns *db.NamespacedKV
- folder string
- }
- type LastFile struct {
- At time.Time `json:"at"`
- Filename string `json:"filename"`
- Deleted bool `json:"deleted"`
- }
- func NewFolderStatisticsReference(ldb *db.Lowlevel, folder string) *FolderStatisticsReference {
- return &FolderStatisticsReference{
- ns: db.NewFolderStatisticsNamespace(ldb, folder),
- folder: folder,
- }
- }
- func (s *FolderStatisticsReference) GetLastFile() (LastFile, error) {
- at, ok, err := s.ns.Time("lastFileAt")
- if err != nil {
- return LastFile{}, err
- } else if !ok {
- return LastFile{}, nil
- }
- file, ok, err := s.ns.String("lastFileName")
- if err != nil {
- return LastFile{}, err
- } else if !ok {
- return LastFile{}, nil
- }
- deleted, _, err := s.ns.Bool("lastFileDeleted")
- if err != nil {
- return LastFile{}, err
- }
- return LastFile{
- At: at,
- Filename: file,
- Deleted: deleted,
- }, nil
- }
- func (s *FolderStatisticsReference) ReceivedFile(file string, deleted bool) error {
- l.Debugln("stats.FolderStatisticsReference.ReceivedFile:", s.folder, file)
- if err := s.ns.PutTime("lastFileAt", time.Now().Truncate(time.Second)); err != nil {
- return err
- }
- if err := s.ns.PutString("lastFileName", file); err != nil {
- return err
- }
- if err := s.ns.PutBool("lastFileDeleted", deleted); err != nil {
- return err
- }
- return nil
- }
- func (s *FolderStatisticsReference) ScanCompleted() error {
- return s.ns.PutTime("lastScan", time.Now().Truncate(time.Second))
- }
- func (s *FolderStatisticsReference) GetLastScanTime() (time.Time, error) {
- lastScan, ok, err := s.ns.Time("lastScan")
- if err != nil {
- return time.Time{}, err
- } else if !ok {
- return time.Time{}, nil
- }
- return lastScan, nil
- }
- func (s *FolderStatisticsReference) GetStatistics() (FolderStatistics, error) {
- lastFile, err := s.GetLastFile()
- if err != nil {
- return FolderStatistics{}, err
- }
- lastScanTime, err := s.GetLastScanTime()
- if err != nil {
- return FolderStatistics{}, err
- }
- return FolderStatistics{
- LastFile: lastFile,
- LastScan: lastScanTime,
- }, nil
- }
|