Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Feat: Remove unused code #926

Merged
merged 4 commits into from
Apr 25, 2024
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
109 changes: 0 additions & 109 deletions pkg/storage/database/database.go
Original file line number Diff line number Diff line change
@@ -1,17 +1,11 @@
package database

import (
"encoding/json"
"time"

hivedb "github.com/iotaledger/hive.go/db"
"github.com/iotaledger/hive.go/ierrors"
"github.com/iotaledger/hive.go/kvstore"
"github.com/iotaledger/hive.go/kvstore/mapdb"
"github.com/iotaledger/hive.go/kvstore/rocksdb"
"github.com/iotaledger/hive.go/runtime/event"
"github.com/iotaledger/hive.go/runtime/ioutils"
"github.com/iotaledger/iota-core/pkg/metrics"
)

var (
Expand All @@ -28,109 +22,6 @@ var (
AllowedEnginesStorageAuto = append(AllowedEnginesStorage, hivedb.EngineAuto)
)

var (
// ErrNothingToCleanUp is returned when nothing is there to clean up in the database.
ErrNothingToCleanUp = ierrors.New("Nothing to clean up in the databases")
)

type Cleanup struct {
Start time.Time
End time.Time
}

func (c *Cleanup) MarshalJSON() ([]byte, error) {
cleanup := struct {
Start int64 `json:"start"`
End int64 `json:"end"`
}{
Start: 0,
End: 0,
}

if !c.Start.IsZero() {
cleanup.Start = c.Start.Unix()
}

if !c.End.IsZero() {
cleanup.End = c.End.Unix()
}

return json.Marshal(cleanup)
}

type Events struct {
Cleanup *event.Event1[*Cleanup]
Compaction *event.Event1[bool]
}

// Database holds the underlying KVStore and database specific functions.
type Database struct {
databaseDir string
store kvstore.KVStore
engine hivedb.Engine
metrics *metrics.DatabaseMetrics
events *Events
compactionSupported bool
compactionRunningFunc func() bool
}

// New creates a new Database instance.
func New(databaseDirectory string, kvStore kvstore.KVStore, engine hivedb.Engine, metrics *metrics.DatabaseMetrics, events *Events, compactionSupported bool, compactionRunningFunc func() bool) *Database {
return &Database{
databaseDir: databaseDirectory,
store: kvStore,
engine: engine,
metrics: metrics,
events: events,
compactionSupported: compactionSupported,
compactionRunningFunc: compactionRunningFunc,
}
}

// KVStore returns the underlying KVStore.
func (db *Database) KVStore() kvstore.KVStore {
return db.store
}

// Engine returns the database engine.
func (db *Database) Engine() hivedb.Engine {
return db.engine
}

// Metrics returns the database metrics.
func (db *Database) Metrics() *metrics.DatabaseMetrics {
return db.metrics
}

// Events returns the events of the database.
func (db *Database) Events() *Events {
return db.events
}

// CompactionSupported returns whether the database engine supports compaction.
func (db *Database) CompactionSupported() bool {
return db.compactionSupported
}

// CompactionRunning returns whether a compaction is running.
func (db *Database) CompactionRunning() bool {
if db.compactionRunningFunc == nil {
return false
}

return db.compactionRunningFunc()
}

// Size returns the size of the database.
func (db *Database) Size() (int64, error) {
if db.engine == hivedb.EngineMapDB {
// in-memory database does not support this method.
return 0, nil
}

return ioutils.FolderSize(db.databaseDir)
}

// CheckEngine is a wrapper around hivedb.CheckEngine to throw a custom error message in case of engine mismatch.
func CheckEngine(dbPath string, createDatabaseIfNotExists bool, dbEngine hivedb.Engine, allowedEngines ...hivedb.Engine) (hivedb.Engine, error) {
tmpAllowedEngines := AllowedEnginesDefault
Expand Down
19 changes: 0 additions & 19 deletions pkg/toolset/toolset.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ import (

flag "github.com/spf13/pflag"

"github.com/iotaledger/hive.go/app/configuration"
"github.com/iotaledger/hive.go/ierrors"
)

Expand Down Expand Up @@ -135,21 +134,3 @@ func printJSON(obj interface{}) error {

return nil
}

//nolint:unused // we will need it at a later point in time
func loadConfigFile(filePath string, parameters map[string]any) error {
config := configuration.New()
flagset := configuration.NewUnsortedFlagSet("", flag.ContinueOnError)

for namespace, pointerToStruct := range parameters {
config.BindParameters(flagset, namespace, pointerToStruct)
}

if err := config.LoadFile(filePath); err != nil {
return ierrors.Wrap(err, "loading config file failed")
}

config.UpdateBoundParameters()

return nil
}
Loading