Skip to content

Commit

Permalink
[scd/store] Remove unused store logger (#1114)
Browse files Browse the repository at this point in the history
  • Loading branch information
mickmis authored Sep 17, 2024
1 parent 54fce70 commit 22f5fa9
Show file tree
Hide file tree
Showing 2 changed files with 13 additions and 18 deletions.
2 changes: 1 addition & 1 deletion cmds/core-service/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ func createSCDServer(ctx context.Context, logger *zap.Logger) (*scd.Server, erro
return nil, stacktrace.Propagate(err, "Failed to connect to strategic conflict detection database; verify your database configuration is current with https://github.com/interuss/dss/tree/master/build#upgrading-database-schemas")
}

scdStore, err := scdc.NewStore(ctx, scdCrdb, logger)
scdStore, err := scdc.NewStore(ctx, scdCrdb)
if err != nil {
// TODO: More robustly detect failure to create SCD server is due to a problem that may be temporary
if strings.Contains(err.Error(), "connect: connection refused") || strings.Contains(err.Error(), "database \"scd\" does not exist") {
Expand Down
29 changes: 12 additions & 17 deletions pkg/scd/store/cockroach/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package cockroach

import (
"context"

"github.com/cockroachdb/cockroach-go/v2/crdb"
"github.com/cockroachdb/cockroach-go/v2/crdb/crdbpgxv5"
"github.com/coreos/go-semver/semver"
Expand All @@ -12,7 +13,6 @@ import (
"github.com/interuss/stacktrace"
"github.com/jackc/pgx/v5"
"github.com/jonboulle/clockwork"
"go.uber.org/zap"
)

const (
Expand All @@ -31,25 +31,22 @@ var (
// repo is an implementation of repos.Repo using
// a CockroachDB transaction.
type repo struct {
q dsssql.Queryable
logger *zap.Logger
clock clockwork.Clock
q dsssql.Queryable
clock clockwork.Clock
}

// Store is an implementation of an scd.Store using
// a CockroachDB database.
type Store struct {
db *cockroach.DB
logger *zap.Logger
clock clockwork.Clock
db *cockroach.DB
clock clockwork.Clock
}

// NewStore returns a Store instance connected to a cockroach instance via db.
func NewStore(ctx context.Context, db *cockroach.DB, logger *zap.Logger) (*Store, error) {
func NewStore(ctx context.Context, db *cockroach.DB) (*Store, error) {
store := &Store{
db: db,
logger: logger,
clock: DefaultClock,
db: db,
clock: DefaultClock,
}

if err := store.CheckCurrentMajorSchemaVersion(ctx); err != nil {
Expand Down Expand Up @@ -79,9 +76,8 @@ func (s *Store) CheckCurrentMajorSchemaVersion(ctx context.Context) error {
// Interact implements store.Interactor interface.
func (s *Store) Interact(_ context.Context) (repos.Repository, error) {
return &repo{
q: s.db.Pool,
logger: s.logger,
clock: s.clock,
q: s.db.Pool,
clock: s.clock,
}, nil
}

Expand All @@ -90,9 +86,8 @@ func (s *Store) Transact(ctx context.Context, f func(context.Context, repos.Repo
ctx = crdb.WithMaxRetries(ctx, flags.ConnectParameters().MaxRetries)
return crdbpgx.ExecuteTx(ctx, s.db.Pool, pgx.TxOptions{}, func(tx pgx.Tx) error {
return f(ctx, &repo{
q: tx,
logger: s.logger,
clock: s.clock,
q: tx,
clock: s.clock,
})
})
}
Expand Down

0 comments on commit 22f5fa9

Please sign in to comment.