155 lines
3.5 KiB
Go
155 lines
3.5 KiB
Go
package operations
|
|
|
|
import (
|
|
"archive/tar"
|
|
"context"
|
|
"database/sql"
|
|
"path/filepath"
|
|
|
|
"github.com/pojntfx/stfs/internal/converters"
|
|
"github.com/pojntfx/stfs/internal/records"
|
|
"github.com/pojntfx/stfs/internal/tarext"
|
|
"github.com/pojntfx/stfs/pkg/config"
|
|
"github.com/pojntfx/stfs/pkg/encryption"
|
|
"github.com/pojntfx/stfs/pkg/recovery"
|
|
"github.com/pojntfx/stfs/pkg/signature"
|
|
)
|
|
|
|
func (o *Operations) Delete(name string) error {
|
|
name = filepath.ToSlash(name)
|
|
|
|
o.diskOperationLock.Lock()
|
|
defer o.diskOperationLock.Unlock()
|
|
|
|
writer, err := o.backend.GetWriter()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
dirty := false
|
|
tw, cleanup, err := tarext.NewTapeWriter(writer.Drive, writer.DriveIsRegular, o.pipes.RecordSize)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
lastIndexedRecord, lastIndexedBlock, err := o.metadata.Metadata.GetLastIndexedRecordAndBlock(context.Background(), o.pipes.RecordSize)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
headersToDelete := []*config.Header{}
|
|
dbhdr, err := o.metadata.Metadata.GetHeader(context.Background(), name)
|
|
if err != nil {
|
|
if err == sql.ErrNoRows {
|
|
dbhdr, err = o.metadata.Metadata.GetHeaderByLinkname(context.Background(), name)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
} else {
|
|
return err
|
|
}
|
|
}
|
|
headersToDelete = append(headersToDelete, dbhdr)
|
|
|
|
// If the header refers to a directory, get it's children
|
|
if dbhdr.Typeflag == tar.TypeDir && dbhdr.Linkname == "" {
|
|
dbhdrs, err := o.metadata.Metadata.GetHeaderChildren(context.Background(), name)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
headersToDelete = append(headersToDelete, dbhdrs...)
|
|
}
|
|
|
|
// Append deletion hdrs to the tape or tar file
|
|
hdrs := []tar.Header{}
|
|
for _, dbhdr := range headersToDelete {
|
|
hdr, err := converters.DBHeaderToTarHeader(converters.ConfigHeaderToDBHeader(dbhdr))
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
hdr.Size = 0 // Don't try to seek after the record
|
|
hdr.PAXRecords[records.STFSRecordVersion] = records.STFSRecordVersion1
|
|
hdr.PAXRecords[records.STFSRecordAction] = records.STFSRecordActionDelete
|
|
|
|
hdrs = append(hdrs, *hdr)
|
|
|
|
if o.onHeader != nil {
|
|
dbhdr, err := converters.TarHeaderToDBHeader(-1, -1, -1, -1, hdr)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
o.onHeader(&config.HeaderEvent{
|
|
Type: config.HeaderEventTypeDelete,
|
|
Indexed: false,
|
|
Header: converters.DBHeaderToConfigHeader(dbhdr),
|
|
})
|
|
}
|
|
|
|
if err := signature.SignHeader(hdr, writer.DriveIsRegular, o.pipes.Signature, o.crypto.Identity); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := encryption.EncryptHeader(hdr, o.pipes.Encryption, o.crypto.Recipient); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := tw.WriteHeader(hdr); err != nil {
|
|
return err
|
|
}
|
|
|
|
dirty = true
|
|
}
|
|
|
|
if err := cleanup(&dirty); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := o.backend.CloseWriter(); err != nil {
|
|
return err
|
|
}
|
|
|
|
reader, err := o.backend.GetReader()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer o.backend.CloseReader()
|
|
|
|
return recovery.Index(
|
|
reader,
|
|
o.backend.MagneticTapeIO,
|
|
o.metadata,
|
|
o.pipes,
|
|
o.crypto,
|
|
|
|
int(lastIndexedRecord),
|
|
int(lastIndexedBlock),
|
|
false,
|
|
false,
|
|
1, // Ignore the first header, which is the last header which we already indexed
|
|
|
|
func(hdr *tar.Header, i int) error {
|
|
if len(hdrs) <= i {
|
|
return config.ErrTarHeaderMissing
|
|
}
|
|
|
|
*hdr = hdrs[i]
|
|
|
|
return nil
|
|
},
|
|
func(hdr *tar.Header, isRegular bool) error {
|
|
return nil // We sign above, no need to verify
|
|
},
|
|
|
|
func(hdr *config.Header) {
|
|
o.onHeader(&config.HeaderEvent{
|
|
Type: config.HeaderEventTypeDelete,
|
|
Indexed: true,
|
|
Header: hdr,
|
|
})
|
|
},
|
|
)
|
|
}
|