migration tests for storagenodedb infodb (#1628)
This commit is contained in:
Egon Elbre
Michal Niewrzal
parent
42a141965d
commit
fba9a5f945
@ -15,13 +15,13 @@ import (
|
||||
"storj.io/storj/storagenode/bandwidth"
|
||||
)
|
||||
|
||||
type bandwidthdb struct{ *infodb }
|
||||
type bandwidthdb struct{ *InfoDB }
|
||||
|
||||
// Bandwidth returns table for storing bandwidth usage.
|
||||
func (db *DB) Bandwidth() bandwidth.DB { return db.info.Bandwidth() }
|
||||
|
||||
// Bandwidth returns table for storing bandwidth usage.
|
||||
func (db *infodb) Bandwidth() bandwidth.DB { return &bandwidthdb{db} }
|
||||
func (db *InfoDB) Bandwidth() bandwidth.DB { return &bandwidthdb{db} }
|
||||
|
||||
// Add adds bandwidth usage to the table
|
||||
func (db *bandwidthdb) Add(ctx context.Context, satelliteID storj.NodeID, action pb.PieceAction, amount int64, created time.Time) error {
|
||||
|
||||
@ -15,14 +15,14 @@ import (
|
||||
)
|
||||
|
||||
type certdb struct {
|
||||
*infodb
|
||||
*InfoDB
|
||||
}
|
||||
|
||||
// CertDB returns certificate database.
|
||||
func (db *DB) CertDB() trust.CertDB { return db.info.CertDB() }
|
||||
|
||||
// CertDB returns certificate database.
|
||||
func (db *infodb) CertDB() trust.CertDB { return &certdb{db} }
|
||||
func (db *InfoDB) CertDB() trust.CertDB { return &certdb{db} }
|
||||
|
||||
// Include includes the certificate in the table and returns an unique id.
|
||||
func (db *certdb) Include(ctx context.Context, pi *identity.PeerIdentity) (certid int64, err error) {
|
||||
|
||||
@ -39,7 +39,7 @@ type DB struct {
|
||||
Close() error
|
||||
}
|
||||
|
||||
info *infodb
|
||||
info *InfoDB
|
||||
|
||||
kdb, ndb storage.KeyValueStore
|
||||
}
|
||||
@ -89,7 +89,7 @@ func NewInMemory(log *zap.Logger, storageDir string) (*DB, error) {
|
||||
}
|
||||
pieces := filestore.New(piecesDir)
|
||||
|
||||
infodb, err := newInfoInMemory()
|
||||
infodb, err := NewInfoInMemory()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
@ -15,17 +15,17 @@ import (
|
||||
"storj.io/storj/internal/migrate"
|
||||
)
|
||||
|
||||
// ErrInfo is the default error class for infodb
|
||||
// ErrInfo is the default error class for InfoDB
|
||||
var ErrInfo = errs.Class("infodb")
|
||||
|
||||
// infodb implements information database for piecestore.
|
||||
type infodb struct {
|
||||
// InfoDB implements information database for piecestore.
|
||||
type InfoDB struct {
|
||||
mu sync.Mutex
|
||||
db *sql.DB
|
||||
}
|
||||
|
||||
// newInfo creates or opens infodb at the specified path.
|
||||
func newInfo(path string) (*infodb, error) {
|
||||
// newInfo creates or opens InfoDB at the specified path.
|
||||
func newInfo(path string) (*InfoDB, error) {
|
||||
if err := os.MkdirAll(filepath.Dir(path), 0700); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
@ -35,50 +35,50 @@ func newInfo(path string) (*infodb, error) {
|
||||
return nil, ErrInfo.Wrap(err)
|
||||
}
|
||||
|
||||
return &infodb{db: db}, nil
|
||||
return &InfoDB{db: db}, nil
|
||||
}
|
||||
|
||||
// newInfoInMemory creates a new inmemory infodb.
|
||||
func newInfoInMemory() (*infodb, error) {
|
||||
// NewInfoInMemory creates a new inmemory InfoDB.
|
||||
func NewInfoInMemory() (*InfoDB, error) {
|
||||
db, err := sql.Open("sqlite3", ":memory:")
|
||||
if err != nil {
|
||||
return nil, ErrInfo.Wrap(err)
|
||||
}
|
||||
|
||||
return &infodb{db: db}, nil
|
||||
return &InfoDB{db: db}, nil
|
||||
}
|
||||
|
||||
// Close closes any resources.
|
||||
func (db *infodb) Close() error {
|
||||
func (db *InfoDB) Close() error {
|
||||
return db.db.Close()
|
||||
}
|
||||
|
||||
// locked allows easy locking the database.
|
||||
func (db *infodb) locked() func() {
|
||||
func (db *InfoDB) locked() func() {
|
||||
db.mu.Lock()
|
||||
return db.mu.Unlock
|
||||
}
|
||||
|
||||
// CreateTables creates any necessary tables.
|
||||
func (db *infodb) CreateTables(log *zap.Logger) error {
|
||||
func (db *InfoDB) CreateTables(log *zap.Logger) error {
|
||||
migration := db.Migration()
|
||||
return migration.Run(log.Named("migration"), db)
|
||||
}
|
||||
|
||||
// RawDB returns access to the raw database, only for migration tests.
|
||||
func (db *infodb) RawDB() *sql.DB { return db.db }
|
||||
func (db *InfoDB) RawDB() *sql.DB { return db.db }
|
||||
|
||||
// Begin begins transaction
|
||||
func (db *infodb) Begin() (*sql.Tx, error) { return db.db.Begin() }
|
||||
func (db *InfoDB) Begin() (*sql.Tx, error) { return db.db.Begin() }
|
||||
|
||||
// Rebind rebind parameters
|
||||
func (db *infodb) Rebind(s string) string { return s }
|
||||
func (db *InfoDB) Rebind(s string) string { return s }
|
||||
|
||||
// Schema returns schema
|
||||
func (db *infodb) Schema() string { return "" }
|
||||
func (db *InfoDB) Schema() string { return "" }
|
||||
|
||||
// Migration returns table migrations.
|
||||
func (db *infodb) Migration() *migrate.Migration {
|
||||
func (db *InfoDB) Migration() *migrate.Migration {
|
||||
return &migrate.Migration{
|
||||
Table: "versions",
|
||||
Steps: []*migrate.Step{
|
||||
|
||||
121
storagenode/storagenodedb/migrations_test.go
Normal file
121
storagenode/storagenodedb/migrations_test.go
Normal file
@ -0,0 +1,121 @@
|
||||
// Copyright (C) 2019 Storj Labs, Inc.
|
||||
// See LICENSE for copying information.
|
||||
|
||||
package storagenodedb_test
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"path/filepath"
|
||||
"strconv"
|
||||
"strings"
|
||||
"testing"
|
||||
|
||||
"github.com/stretchr/testify/require"
|
||||
"go.uber.org/zap/zaptest"
|
||||
|
||||
"storj.io/storj/internal/dbutil/dbschema"
|
||||
"storj.io/storj/internal/dbutil/sqliteutil"
|
||||
"storj.io/storj/storagenode/storagenodedb"
|
||||
)
|
||||
|
||||
// loadSnapshots loads all the dbschemas from testdata/db.* caching the result
|
||||
func loadSnapshots() (*dbschema.Snapshots, error) {
|
||||
snapshots := &dbschema.Snapshots{}
|
||||
|
||||
// snapshot represents clean DB state
|
||||
snapshots.Add(&dbschema.Snapshot{
|
||||
Version: -1,
|
||||
Schema: &dbschema.Schema{},
|
||||
Script: "",
|
||||
})
|
||||
|
||||
// find all sql files
|
||||
matches, err := filepath.Glob("testdata/sqlite.*")
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
for _, match := range matches {
|
||||
versionStr := match[17 : len(match)-4] // hack to avoid trim issues with path differences in windows/linux
|
||||
version, err := strconv.Atoi(versionStr)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
scriptData, err := ioutil.ReadFile(match)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
snapshot, err := sqliteutil.LoadSnapshotFromSQL(string(scriptData))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
snapshot.Version = version
|
||||
|
||||
snapshots.Add(snapshot)
|
||||
}
|
||||
|
||||
snapshots.Sort()
|
||||
|
||||
return snapshots, nil
|
||||
}
|
||||
|
||||
const newDataSeparator = `-- NEW DATA --`
|
||||
|
||||
func newData(snap *dbschema.Snapshot) string {
|
||||
tokens := strings.SplitN(snap.Script, newDataSeparator, 2)
|
||||
if len(tokens) != 2 {
|
||||
return ""
|
||||
}
|
||||
return tokens[1]
|
||||
}
|
||||
|
||||
func TestMigrate(t *testing.T) {
|
||||
snapshots, err := loadSnapshots()
|
||||
require.NoError(t, err)
|
||||
|
||||
log := zaptest.NewLogger(t)
|
||||
|
||||
// create a new satellitedb connection
|
||||
db, err := storagenodedb.NewInfoInMemory()
|
||||
require.NoError(t, err)
|
||||
defer func() { require.NoError(t, db.Close()) }()
|
||||
|
||||
// get migration for this database
|
||||
migrations := db.Migration()
|
||||
for i, step := range migrations.Steps {
|
||||
// the schema is different when migration step is before the step, cannot test the layout
|
||||
tag := fmt.Sprintf("#%d - v%d", i, step.Version)
|
||||
|
||||
// run migration up to a specific version
|
||||
err := migrations.TargetVersion(step.Version).Run(log.Named("migrate"), db)
|
||||
require.NoError(t, err, tag)
|
||||
|
||||
// find the matching expected version
|
||||
expected, ok := snapshots.FindVersion(step.Version)
|
||||
require.True(t, ok)
|
||||
|
||||
// insert data for new tables
|
||||
if newdata := newData(expected); newdata != "" {
|
||||
_, err = db.RawDB().Exec(newdata)
|
||||
require.NoError(t, err, tag)
|
||||
}
|
||||
|
||||
// load schema from database
|
||||
currentSchema, err := sqliteutil.QuerySchema(db.RawDB())
|
||||
require.NoError(t, err, tag)
|
||||
|
||||
// we don't care changes in versions table
|
||||
currentSchema.DropTable("versions")
|
||||
|
||||
// load data from database
|
||||
currentData, err := sqliteutil.QueryData(db.RawDB(), currentSchema)
|
||||
require.NoError(t, err, tag)
|
||||
|
||||
// verify schema and data
|
||||
require.Equal(t, expected.Schema, currentSchema, tag)
|
||||
require.Equal(t, expected.Data, currentData, tag)
|
||||
}
|
||||
}
|
||||
@ -17,13 +17,13 @@ import (
|
||||
"storj.io/storj/storagenode/orders"
|
||||
)
|
||||
|
||||
type ordersdb struct{ *infodb }
|
||||
type ordersdb struct{ *InfoDB }
|
||||
|
||||
// Orders returns database for storing orders
|
||||
func (db *DB) Orders() orders.DB { return db.info.Orders() }
|
||||
|
||||
// Orders returns database for storing orders
|
||||
func (db *infodb) Orders() orders.DB { return &ordersdb{db} }
|
||||
func (db *InfoDB) Orders() orders.DB { return &ordersdb{db} }
|
||||
|
||||
// Enqueue inserts order to the unsent list
|
||||
func (db *ordersdb) Enqueue(ctx context.Context, info *orders.Info) error {
|
||||
|
||||
@ -14,13 +14,13 @@ import (
|
||||
"storj.io/storj/storagenode/pieces"
|
||||
)
|
||||
|
||||
type pieceinfo struct{ *infodb }
|
||||
type pieceinfo struct{ *InfoDB }
|
||||
|
||||
// PieceInfo returns database for storing piece information
|
||||
func (db *DB) PieceInfo() pieces.DB { return db.info.PieceInfo() }
|
||||
|
||||
// PieceInfo returns database for storing piece information
|
||||
func (db *infodb) PieceInfo() pieces.DB { return &pieceinfo{db} }
|
||||
func (db *InfoDB) PieceInfo() pieces.DB { return &pieceinfo{db} }
|
||||
|
||||
// Add inserts piece information into the database.
|
||||
func (db *pieceinfo) Add(ctx context.Context, info *pieces.Info) error {
|
||||
|
||||
117
storagenode/storagenodedb/testdata/sqlite.v0.sql
vendored
Normal file
117
storagenode/storagenodedb/testdata/sqlite.v0.sql
vendored
Normal file
@ -0,0 +1,117 @@
|
||||
-- table for keeping serials that need to be verified against
|
||||
CREATE TABLE used_serial (
|
||||
satellite_id BLOB NOT NULL,
|
||||
serial_number BLOB NOT NULL,
|
||||
expiration TIMESTAMP NOT NULL
|
||||
);
|
||||
-- primary key on satellite id and serial number
|
||||
CREATE UNIQUE INDEX pk_used_serial ON used_serial(satellite_id, serial_number);
|
||||
-- expiration index to allow fast deletion
|
||||
CREATE INDEX idx_used_serial ON used_serial(expiration);
|
||||
|
||||
-- certificate table for storing uplink/satellite certificates
|
||||
CREATE TABLE certificate (
|
||||
cert_id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
|
||||
node_id BLOB NOT NULL,
|
||||
peer_identity BLOB UNIQUE NOT NULL
|
||||
);
|
||||
|
||||
-- table for storing piece meta info
|
||||
CREATE TABLE pieceinfo (
|
||||
satellite_id BLOB NOT NULL,
|
||||
piece_id BLOB NOT NULL,
|
||||
piece_size BIGINT NOT NULL,
|
||||
piece_expiration TIMESTAMP,
|
||||
|
||||
uplink_piece_hash BLOB NOT NULL,
|
||||
uplink_cert_id INTEGER NOT NULL,
|
||||
|
||||
FOREIGN KEY(uplink_cert_id) REFERENCES certificate(cert_id)
|
||||
);
|
||||
-- primary key by satellite id and piece id
|
||||
CREATE UNIQUE INDEX pk_pieceinfo ON pieceinfo(satellite_id, piece_id);
|
||||
|
||||
-- table for storing bandwidth usage
|
||||
CREATE TABLE bandwidth_usage (
|
||||
satellite_id BLOB NOT NULL,
|
||||
action INTEGER NOT NULL,
|
||||
amount BIGINT NOT NULL,
|
||||
created_at TIMESTAMP NOT NULL
|
||||
);
|
||||
CREATE INDEX idx_bandwidth_usage_satellite ON bandwidth_usage(satellite_id);
|
||||
CREATE INDEX idx_bandwidth_usage_created ON bandwidth_usage(created_at);
|
||||
|
||||
-- table for storing all unsent orders
|
||||
CREATE TABLE unsent_order (
|
||||
satellite_id BLOB NOT NULL,
|
||||
serial_number BLOB NOT NULL,
|
||||
|
||||
order_limit_serialized BLOB NOT NULL,
|
||||
order_serialized BLOB NOT NULL,
|
||||
order_limit_expiration TIMESTAMP NOT NULL,
|
||||
|
||||
uplink_cert_id INTEGER NOT NULL,
|
||||
|
||||
FOREIGN KEY(uplink_cert_id) REFERENCES certificate(cert_id)
|
||||
);
|
||||
CREATE UNIQUE INDEX idx_orders ON unsent_order(satellite_id, serial_number);
|
||||
|
||||
-- table for storing all sent orders
|
||||
CREATE TABLE order_archive (
|
||||
satellite_id BLOB NOT NULL,
|
||||
serial_number BLOB NOT NULL,
|
||||
|
||||
order_limit_serialized BLOB NOT NULL,
|
||||
order_serialized BLOB NOT NULL,
|
||||
|
||||
uplink_cert_id INTEGER NOT NULL,
|
||||
|
||||
status INTEGER NOT NULL,
|
||||
archived_at TIMESTAMP NOT NULL,
|
||||
|
||||
FOREIGN KEY(uplink_cert_id) REFERENCES certificate(cert_id)
|
||||
);
|
||||
CREATE INDEX idx_order_archive_satellite ON order_archive(satellite_id);
|
||||
CREATE INDEX idx_order_archive_status ON order_archive(status);
|
||||
|
||||
-- NEW DATA --
|
||||
|
||||
INSERT INTO used_serial VALUES(X'0693a8529105f5ff763e30b6f58ead3fe7a4f93f32b4b298073c01b2b39fa76e',X'18283dd3cec0a5abf6112e903549bdff','2019-04-01 18:58:53.3169599+03:00');
|
||||
INSERT INTO used_serial VALUES(X'976a6bbcfcec9d96d847f8642c377d5f23c118187fb0ca21e9e1c5a9fbafa5f7',X'18283dd3cec0a5abf6112e903549bdff','2019-04-01 18:58:53.3169599+03:00');
|
||||
|
||||
INSERT INTO certificate VALUES(1,X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',X'3082016230820108a003020102021100c33fe521df34530b97db93000404a190300a06082a8648ce3d0403023010310e300c060355040a130553746f726a3022180f30303031303130313030303030305a180f30303031303130313030303030305a3010310e300c060355040a130553746f726a3059301306072a8648ce3d020106082a8648ce3d03010703420004bff703807b8d8357dd2371124c31e19ef68b39dbc44d25b32d843324027e7c2b2387f3b46f973d2e0919e1864dc06c313e5d71df13279dfc73c510cc49c26946a33f303d300e0603551d0f0101ff0404030205a0301d0603551d250416301406082b0601050507030106082b06010505070302300c0603551d130101ff04023000300a06082a8648ce3d0403020348003045022100b97d54c84ce8d1673db96a3ac2073b39ec2abd0e7d04447fff864a4fedf0c72c022031c8e620dc8941f62034abfa43faa5305ee4be345c9518e86074d0c54f76a6383082015b30820101a003020102021100c7e57be609bdba51c2bf85aa24eb472b300a06082a8648ce3d0403023010310e300c060355040a130553746f726a3022180f30303031303130313030303030305a180f30303031303130313030303030305a3010310e300c060355040a130553746f726a3059301306072a8648ce3d020106082a8648ce3d030107034200044b3b89f6502a7ae97fcc639033859b1f6c160e070f350eff15df2d415d7b5b1cdb1458d63c453eebe45493b8b1ec697c2a4f01dd534e5b8e09cb653fd7770a9aa3383036300e0603551d0f0101ff04040302020430130603551d25040c300a06082b06010505070301300f0603551d130101ff040530030101ff300a06082a8648ce3d0403020348003045022100daf71e6ac3f4b23b7a41124d920755fc838d242174206826b02a288026e1f60802200de61e08af44121deec4805385143f1a4138e7dc7bb6d5b89971bec9cd7e49333082015a30820100a0030201020210773700aea87b629f5a1a28895cce3ef1300a06082a8648ce3d0403023010310e300c060355040a130553746f726a3022180f30303031303130313030303030305a180f30303031303130313030303030305a3010310e300c060355040a130553746f726a3059301306072a8648ce3d020106082a8648ce3d03010703420004cfd64f1621b3fc8629283cf876f667f341d8a25e7fe7d692aee61e5eef843f49805c15328c0c105b4a3820216712c1643e3bc6160384706fe2facb2d2fa6df01a3383036300e0603551d0f0101ff04040302020430130603551d25040c300a06082b06010505070301300f0603551d130101ff040530030101ff300a06082a8648ce3d040302034800304502202fa033fb085d71eae63266a25c39d0a2951e5a9aaa97718f127feb1f28a931d6022100d70f446ea3d7439bbfa0cf8e0dfd530649ac37d35f9c9b18d48d80dcd284beaf');
|
||||
INSERT INTO certificate VALUES(2,X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',X'3082016230820107a003020102021014b88821c7656cb81c018becec7890d9300a06082a8648ce3d0403023010310e300c060355040a130553746f726a3022180f30303031303130313030303030305a180f30303031303130313030303030305a3010310e300c060355040a130553746f726a3059301306072a8648ce3d020106082a8648ce3d030107034200048a0de5abc8fe7ef79268c6d3537a7ae6e5de8c9d9c6d2e7d905e53451cbc937dc30ec8bf122d2b1da76d37789fa7b4cabeacb8ca1198e9c2a3c2beb9d0989767a33f303d300e0603551d0f0101ff0404030205a0301d0603551d250416301406082b0601050507030106082b06010505070302300c0603551d130101ff04023000300a06082a8648ce3d04030203490030460221008acdfd5b518203817a68baca94214ba67599499e4f3f37a263c3fc21b8aa199b0221008a4f49fdd95d6eb005b4abb2af8cef504a5dbb9117e6282402c16304b11e1ee53082015b30820101a003020102021100fdfc8b0889977076db13fb8c8aafa0df300a06082a8648ce3d0403023010310e300c060355040a130553746f726a3022180f30303031303130313030303030305a180f30303031303130313030303030305a3010310e300c060355040a130553746f726a3059301306072a8648ce3d020106082a8648ce3d03010703420004d2b8b6fb4adbf0ab2aef7524bfed63969eb4d47cc4c97715cea6d02708101fd392a6c1415302876c3924635e3c6652b38ffd4157f21a3b0563bb1a23e497405fa3383036300e0603551d0f0101ff04040302020430130603551d25040c300a06082b06010505070301300f0603551d130101ff040530030101ff300a06082a8648ce3d0403020348003045022028657adc5655ef62371aa197e0f8b2abfa99204e7cc248ea48c8708ff37e7b37022100cfbd362c4dc028e875fb2c3d6fd4397c679d6360e08e79a6694f48c520a91bd53082015a30820100a0030201020210773700aea87b629f5a1a28895cce3ef1300a06082a8648ce3d0403023010310e300c060355040a130553746f726a3022180f30303031303130313030303030305a180f30303031303130313030303030305a3010310e300c060355040a130553746f726a3059301306072a8648ce3d020106082a8648ce3d03010703420004cfd64f1621b3fc8629283cf876f667f341d8a25e7fe7d692aee61e5eef843f49805c15328c0c105b4a3820216712c1643e3bc6160384706fe2facb2d2fa6df01a3383036300e0603551d0f0101ff04040302020430130603551d25040c300a06082b06010505070301300f0603551d130101ff040530030101ff300a06082a8648ce3d040302034800304502202fa033fb085d71eae63266a25c39d0a2951e5a9aaa97718f127feb1f28a931d6022100d70f446ea3d7439bbfa0cf8e0dfd530649ac37d35f9c9b18d48d80dcd284beaf');
|
||||
|
||||
INSERT INTO unsent_order VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',X'1eddef484b4c03f01332279032796972',X'0a101eddef484b4c03f0133227903279697212202b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf410001a201968996e7ef170a402fdfd88b6753df792c063c07c555905ffac9cd3cbd1c00022200ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac30002a20d00cf14f3c68b56321ace04902dec0484eb6f9098b22b31c6b3f82db249f191630643802420c08dfeb88e50510a8c1a5b9034a0c08dfeb88e50510a8c1a5b9035246304402204df59dc6f5d1bb7217105efbc9b3604d19189af37a81efbf16258e5d7db5549e02203bb4ead16e6e7f10f658558c22b59c3339911841e8dbaae6e2dea821f7326894',X'0a101eddef484b4c03f0133227903279697210321a47304502206d4c106ddec88140414bac5979c95bdea7de2e0ecc5be766e08f7d5ea36641a7022100e932ff858f15885ffa52d07e260c2c25d3861810ea6157956c1793ad0c906284','2019-04-01 16:01:35.9254586+00:00',1);
|
||||
|
||||
INSERT INTO pieceinfo VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',X'd5e757fd8d207d1c46583fb58330f803dc961b71147308ff75ff1e72a0df6b0b',123,'2019-04-01 19:00:14.2266298+03:00',X'0a20d5e757fd8d207d1c46583fb58330f803dc961b71147308ff75ff1e72a0df6b0b120501020304051a47304502201c16d76ecd9b208f7ad9f1edf66ce73dce50da6bde6bbd7d278415099a727421022100ca730450e7f6506c2647516f6e20d0641e47c8270f58dde2bb07d1f5a3a45673',1);
|
||||
INSERT INTO pieceinfo VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',X'd5e757fd8d207d1c46583fb58330f803dc961b71147308ff75ff1e72a0df6b0b',123,'2019-04-01 19:00:14.2266298+03:00',X'0a20d5e757fd8d207d1c46583fb58330f803dc961b71147308ff75ff1e72a0df6b0b120501020304051a483046022100e623cf4705046e2c04d5b42d5edbecb81f000459713ad460c691b3361817adbf022100993da2a5298bb88de6c35b2e54009d1bf306cda5d441c228aa9eaf981ceb0f3d',2);
|
||||
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',0,0,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',0,0,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',1,1,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',1,1,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',2,2,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',2,2,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',3,3,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',3,3,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',4,4,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',4,4,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',5,5,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',5,5,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',6,6,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',6,6,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',1,1,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',1,1,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',2,2,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',2,2,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',3,3,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',3,3,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',4,4,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',4,4,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',5,5,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',5,5,'2019-04-01 20:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'0ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac3000',6,6,'2019-04-01 18:51:24.1074772+03:00');
|
||||
INSERT INTO bandwidth_usage VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',6,6,'2019-04-01 20:51:24.1074772+03:00');
|
||||
|
||||
INSERT INTO order_archive VALUES(X'2b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf41000',X'62180593328b8ff3c9f97565fdfd305d',X'0a1062180593328b8ff3c9f97565fdfd305d12202b3a5863a41f25408a8f5348839d7a1361dbd886d75786bb139a8ca0bdf410001a201968996e7ef170a402fdfd88b6753df792c063c07c555905ffac9cd3cbd1c00022200ed28abb2813e184a1e98b0f6605c4911ea468c7e8433eb583e0fca7ceac30002a2077003db64dfd50c5bdc84daf28bcef97f140d302c3e5bfd002bcc7ac04e1273430643802420c08fce688e50510a0ffe7ff014a0c08fce688e50510a0ffe7ff0152473045022100943d90068a1b1e6879b16a6ed8cdf0237005de09f61cddab884933fefd9692bf0220417a74f2e59523d962e800a1b06618f0113039d584e28aae37737e4a71555966',X'0a1062180593328b8ff3c9f97565fdfd305d10321a47304502200f4d97f03ad2d87501f68bfcf0525ec518aebf817cf56aa5eeaea53d01b153a102210096e60cf4b594837b43b5c841d283e4b72c9a09207d64bdd4665c700dc2e0a4a2',1,1,'2019-04-01 18:51:24.5374893+03:00');
|
||||
@ -14,14 +14,14 @@ import (
|
||||
)
|
||||
|
||||
type usedSerials struct {
|
||||
*infodb
|
||||
*InfoDB
|
||||
}
|
||||
|
||||
// UsedSerials returns certificate database.
|
||||
func (db *DB) UsedSerials() piecestore.UsedSerials { return db.info.UsedSerials() }
|
||||
|
||||
// UsedSerials returns certificate database.
|
||||
func (db *infodb) UsedSerials() piecestore.UsedSerials { return &usedSerials{db} }
|
||||
func (db *InfoDB) UsedSerials() piecestore.UsedSerials { return &usedSerials{db} }
|
||||
|
||||
// Add adds a serial to the database.
|
||||
func (db *usedSerials) Add(ctx context.Context, satelliteID storj.NodeID, serialNumber storj.SerialNumber, expiration time.Time) error {
|
||||
|
||||
Loading…
Reference in New Issue
Block a user