988bb52855
Change-Id: I51ebe69f9dc7920e59e91d7ba26617ee61889f78
164 lines
4.1 KiB
Go
164 lines
4.1 KiB
Go
// Copyright (C) 2020 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package heldamount
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"github.com/spacemonkeygo/monkit/v3"
|
|
"github.com/zeebo/errs"
|
|
"go.uber.org/zap"
|
|
|
|
"storj.io/common/pb"
|
|
"storj.io/common/rpc"
|
|
"storj.io/storj/pkg/storj"
|
|
"storj.io/storj/storagenode/trust"
|
|
)
|
|
|
|
var (
|
|
// HeldAmountServiceErr defines held amount service error
|
|
HeldAmountServiceErr = errs.Class("node stats service error")
|
|
|
|
mon = monkit.Package()
|
|
)
|
|
|
|
// Client encapsulates HeldAmountClient with underlying connection
|
|
//
|
|
// architecture: Client
|
|
type Client struct {
|
|
conn *rpc.Conn
|
|
pb.DRPCHeldAmountClient
|
|
}
|
|
|
|
// Close closes underlying client connection
|
|
func (c *Client) Close() error {
|
|
return c.conn.Close()
|
|
}
|
|
|
|
// Service retrieves info from satellites using an rpc client
|
|
//
|
|
// architecture: Service
|
|
type Service struct {
|
|
log *zap.Logger
|
|
|
|
dialer rpc.Dialer
|
|
trust *trust.Pool
|
|
}
|
|
|
|
// NewService creates new instance of service
|
|
func NewService(log *zap.Logger, dialer rpc.Dialer, trust *trust.Pool) *Service {
|
|
return &Service{
|
|
log: log,
|
|
dialer: dialer,
|
|
trust: trust,
|
|
}
|
|
}
|
|
|
|
// GetPaystubStats retrieves held amount for particular satellite
|
|
func (service *Service) GetPaystubStats(ctx context.Context, satelliteID storj.NodeID, period string) (_ *PayStub, err error) {
|
|
defer mon.Task()(&ctx)(&err)
|
|
|
|
client, err := service.dial(ctx, satelliteID)
|
|
if err != nil {
|
|
return nil, HeldAmountServiceErr.Wrap(err)
|
|
}
|
|
defer func() { err = errs.Combine(err, client.Close()) }()
|
|
|
|
requestedPeriod, err := stringToTime(period)
|
|
if err != nil {
|
|
return nil, HeldAmountServiceErr.Wrap(err)
|
|
}
|
|
|
|
resp, err := client.GetPayStub(ctx, &pb.GetHeldAmountRequest{Period: requestedPeriod})
|
|
if err != nil {
|
|
return nil, HeldAmountServiceErr.Wrap(err)
|
|
}
|
|
|
|
return &PayStub{
|
|
Period: period,
|
|
SatelliteID: satelliteID,
|
|
Created: resp.CreatedAt,
|
|
Codes: resp.Codes,
|
|
UsageAtRest: float64(resp.UsageAtRest),
|
|
UsageGet: resp.UsageGet,
|
|
UsagePut: resp.UsagePut,
|
|
UsageGetRepair: resp.CompGetRepair,
|
|
UsagePutRepair: resp.CompPutRepair,
|
|
UsageGetAudit: resp.UsageGetAudit,
|
|
CompAtRest: resp.CompAtRest,
|
|
CompGet: resp.CompGet,
|
|
CompPut: resp.CompPut,
|
|
CompGetRepair: resp.CompGetRepair,
|
|
CompPutRepair: resp.CompPutRepair,
|
|
CompGetAudit: resp.CompGetAudit,
|
|
SurgePercent: resp.SurgePercent,
|
|
Held: resp.Held,
|
|
Owed: resp.Owed,
|
|
Disposed: resp.Disposed,
|
|
Paid: resp.Paid,
|
|
}, nil
|
|
}
|
|
|
|
// GetPayment retrieves payment data from particular satellite
|
|
func (service *Service) GetPayment(ctx context.Context, satelliteID storj.NodeID, period string) (_ *Payment, err error) {
|
|
defer mon.Task()(&ctx)(&err)
|
|
|
|
client, err := service.dial(ctx, satelliteID)
|
|
if err != nil {
|
|
return nil, HeldAmountServiceErr.Wrap(err)
|
|
}
|
|
defer func() { err = errs.Combine(err, client.Close()) }()
|
|
|
|
requestedPeriod, err := stringToTime(period)
|
|
if err != nil {
|
|
return nil, HeldAmountServiceErr.Wrap(err)
|
|
}
|
|
|
|
resp, err := client.GetPayment(ctx, &pb.GetPaymentRequest{Period: requestedPeriod})
|
|
if err != nil {
|
|
return nil, HeldAmountServiceErr.Wrap(err)
|
|
}
|
|
|
|
return &Payment{
|
|
ID: resp.Id,
|
|
Created: resp.CreatedAt,
|
|
SatelliteID: satelliteID,
|
|
Period: period,
|
|
Amount: resp.Amount,
|
|
Receipt: resp.Receipt,
|
|
Notes: resp.Notes,
|
|
}, nil
|
|
}
|
|
|
|
// dial dials the HeldAmount client for the satellite by id
|
|
func (service *Service) dial(ctx context.Context, satelliteID storj.NodeID) (_ *Client, err error) {
|
|
defer mon.Task()(&ctx)(&err)
|
|
|
|
address, err := service.trust.GetAddress(ctx, satelliteID)
|
|
if err != nil {
|
|
return nil, errs.New("unable to find satellite %s: %w", satelliteID, err)
|
|
}
|
|
|
|
conn, err := service.dialer.DialAddressID(ctx, address, satelliteID)
|
|
if err != nil {
|
|
return nil, errs.New("unable to connect to the satellite %s: %w", satelliteID, err)
|
|
}
|
|
|
|
return &Client{
|
|
conn: conn,
|
|
DRPCHeldAmountClient: pb.NewDRPCHeldAmountClient(conn.Raw()),
|
|
}, nil
|
|
}
|
|
|
|
func stringToTime(period string) (_ time.Time, err error) {
|
|
layout := "2006-01"
|
|
result, err := time.Parse(layout, period)
|
|
if err != nil {
|
|
return time.Time{}, err
|
|
}
|
|
|
|
return result, nil
|
|
}
|