|
@@ -32,13 +32,16 @@ func NewStore(serv types.IServCtx) (types.IStore, error) {
|
|
if serv == nil {
|
|
if serv == nil {
|
|
return nil, fmt.Errorf("NewStore(): IServCtx==nil")
|
|
return nil, fmt.Errorf("NewStore(): IServCtx==nil")
|
|
}
|
|
}
|
|
- _ = os.MkdirAll("./store/db", 0750)
|
|
|
|
|
|
+ err := os.MkdirAll("./store", 0750)
|
|
|
|
+ if err != nil {
|
|
|
|
+ return nil, fmt.Errorf("NewStore(): in create dir, err=\n\t%w", err)
|
|
|
|
+ }
|
|
db, err := leveldb.OpenFile("./store/db", nil)
|
|
db, err := leveldb.OpenFile("./store/db", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
if !strings.Contains(err.Error(), "leveldb: manifest corrupted") {
|
|
if !strings.Contains(err.Error(), "leveldb: manifest corrupted") {
|
|
return nil, fmt.Errorf("NewStore(): in create IStoreDisk, err=\n\t%w", err)
|
|
return nil, fmt.Errorf("NewStore(): in create IStoreDisk, err=\n\t%w", err)
|
|
}
|
|
}
|
|
- db, err = leveldb.RecoverFile("./stor/db", nil)
|
|
|
|
|
|
+ db, err = leveldb.RecoverFile("./store/db", nil)
|
|
if err != nil {
|
|
if err != nil {
|
|
return nil, fmt.Errorf("NewStore(): in recovery DB, err=\n\t%w", err)
|
|
return nil, fmt.Errorf("NewStore(): in recovery DB, err=\n\t%w", err)
|
|
}
|
|
}
|