Skip to content

Commit

Permalink
Merge pull request #58 from JackalLabs/marston/remove-delete
Browse files Browse the repository at this point in the history
removing delete function
  • Loading branch information
dahn510 authored Jul 29, 2024
2 parents 2276ad5 + e86c889 commit 5c6ceba
Show file tree
Hide file tree
Showing 2 changed files with 42 additions and 41 deletions.
2 changes: 1 addition & 1 deletion core/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -237,7 +237,7 @@ func (a *App) Start() error {
go a.monitor.Start()

done := make(chan os.Signal, 1)
defer signal.Stop(done) //undo signal.Notify effect
defer signal.Stop(done) // undo signal.Notify effect

signal.Notify(done, syscall.SIGINT, syscall.SIGTERM)
<-done // Will block here until user hits ctrl+c
Expand Down
81 changes: 41 additions & 40 deletions file_system/file_system.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,11 +9,11 @@ import (
"fmt"
"io"

"github.com/dgraph-io/badger/v4"
"github.com/ipfs/go-cid"
"github.com/wealdtech/go-merkletree/v2"

"github.com/dgraph-io/badger/v4"
"github.com/rs/zerolog/log"
"github.com/wealdtech/go-merkletree/v2"
"github.com/wealdtech/go-merkletree/v2/sha3"
)
import jsoniter "github.com/json-iterator/go"
Expand Down Expand Up @@ -114,45 +114,46 @@ func (f *FileSystem) WriteFile(reader io.Reader, merkle []byte, owner string, st
}

func (f *FileSystem) DeleteFile(merkle []byte, owner string, start int64) error {
log.Info().Msg(fmt.Sprintf("Removing %x from disk...", merkle))
fileCount.Dec()
err := f.db.Update(func(txn *badger.Txn) error {
err := txn.Delete(treeKey(merkle, owner, start))
if err != nil {
return err
}

return nil
})
if err != nil {
return err
}

fcid := ""
_ = f.db.View(func(txn *badger.Txn) error {
b, err := txn.Get([]byte(fmt.Sprintf("cid/%x", merkle)))
if err != nil {
return err
}

_ = b.Value(func(val []byte) error {
fcid = string(val)
return nil
})
return nil
})

c, err := cid.Decode(fcid)
if err != nil {
return err
}

err = f.ipfs.Remove(context.Background(), c)
if err != nil {
return err
}

return nil
//log.Info().Msg(fmt.Sprintf("Removing %x from disk...", merkle))
//fileCount.Dec()
//err := f.db.Update(func(txn *badger.Txn) error {
// err := txn.Delete(treeKey(merkle, owner, start))
// if err != nil {
// return err
// }
//
// return nil
//})
//if err != nil {
// return err
//}
//
//fcid := ""
//_ = f.db.View(func(txn *badger.Txn) error {
// b, err := txn.Get([]byte(fmt.Sprintf("cid/%x", merkle)))
// if err != nil {
// return err
// }
//
// _ = b.Value(func(val []byte) error {
// fcid = string(val)
// return nil
// })
// return nil
//})
//
//c, err := cid.Decode(fcid)
//if err != nil {
// return err
//}
//
//err = f.ipfs.Remove(context.Background(), c)
//if err != nil {
// return err
//}
//
//return nil
}

func (f *FileSystem) ListFiles() ([][]byte, []string, []int64, error) {
Expand Down

0 comments on commit 5c6ceba

Please sign in to comment.