CodeMirror/Picocrypt
1
0
Fork 0
mirror of https://github.com/HACKERALERT/Picocrypt.git synced 2024-05-28 08:00:24 +12:00
Code Issues Projects Releases Wiki Activity

Add -fix flag, use fast RS by default

Browse source
This commit is contained in:
Evan Su 2024-04-25 22:07:05 -04:00 committed by GitHub
parent 77aea6a8e4
commit 97bde62236
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 26 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

40
cli/v2/picocrypt/main.go
View file

@ -47,7 +47,10 @@ func rsEncode(rs *infectious.FEC, data []byte) []byte {
return res return res
} }
func rsDecode(rs *infectious.FEC, data []byte) ([]byte, error) { func rsDecode(rs *infectious.FEC, data []byte, fast bool) ([]byte, error) {
if rs.Total() == 136 && fast {
return data[:128], nil
}
tmp := make([]infectious.Share, rs.Total()) tmp := make([]infectious.Share, rs.Total())
for i := 0; i < rs.Total(); i++ { for i := 0; i < rs.Total(); i++ {
tmp[i].Number = i tmp[i].Number = i
@ -81,6 +84,7 @@ func work() int {
} }
paranoid := flag.Bool("p", false, "") paranoid := flag.Bool("p", false, "")
reedsolo := flag.Bool("r", false, "") reedsolo := flag.Bool("r", false, "")
fix := flag.Bool("fix", false, "")
flag.Parse() flag.Parse()
mode := "" mode := ""
@ -327,16 +331,16 @@ func work() int {
errs := make([]error, 10) errs := make([]error, 10)
version := make([]byte, 15) version := make([]byte, 15)
fin.Read(version) fin.Read(version)
_, errs[0] = rsDecode(rs5, version) _, errs[0] = rsDecode(rs5, version, !(*fix))
tmp := make([]byte, 15) tmp := make([]byte, 15)
fin.Read(tmp) fin.Read(tmp)
tmp, errs[1] = rsDecode(rs5, tmp) tmp, errs[1] = rsDecode(rs5, tmp, !(*fix))
commentsLength, _ := strconv.Atoi(string(tmp)) commentsLength, _ := strconv.Atoi(string(tmp))
fin.Read(make([]byte, commentsLength*3)) fin.Read(make([]byte, commentsLength*3))
total -= int64(commentsLength) * 3 total -= int64(commentsLength) * 3
flags := make([]byte, 15) flags := make([]byte, 15)
fin.Read(flags) fin.Read(flags)
flags, errs[2] = rsDecode(rs5, flags) flags, errs[2] = rsDecode(rs5, flags, !(*fix))
*paranoid = flags[0] == 1 *paranoid = flags[0] == 1
*reedsolo = flags[3] == 1 *reedsolo = flags[3] == 1
padded = flags[4] == 1 padded = flags[4] == 1
@ -349,25 +353,25 @@ func work() int {
} }
salt = make([]byte, 48) salt = make([]byte, 48)
fin.Read(salt) fin.Read(salt)
salt, errs[3] = rsDecode(rs16, salt) salt, errs[3] = rsDecode(rs16, salt, !(*fix))
hkdfSalt = make([]byte, 96) hkdfSalt = make([]byte, 96)
fin.Read(hkdfSalt) fin.Read(hkdfSalt)
hkdfSalt, errs[4] = rsDecode(rs32, hkdfSalt) hkdfSalt, errs[4] = rsDecode(rs32, hkdfSalt, !(*fix))
serpentIV = make([]byte, 48) serpentIV = make([]byte, 48)
fin.Read(serpentIV) fin.Read(serpentIV)
serpentIV, errs[5] = rsDecode(rs16, serpentIV) serpentIV, errs[5] = rsDecode(rs16, serpentIV, !(*fix))
nonce = make([]byte, 72) nonce = make([]byte, 72)
fin.Read(nonce) fin.Read(nonce)
nonce, errs[6] = rsDecode(rs24, nonce) nonce, errs[6] = rsDecode(rs24, nonce, !(*fix))
keyHashRef = make([]byte, 192) keyHashRef = make([]byte, 192)
fin.Read(keyHashRef) fin.Read(keyHashRef)
keyHashRef, errs[7] = rsDecode(rs64, keyHashRef) keyHashRef, errs[7] = rsDecode(rs64, keyHashRef, !(*fix))
keyfileHashRef := make([]byte, 96) keyfileHashRef := make([]byte, 96)
fin.Read(keyfileHashRef) fin.Read(keyfileHashRef)
_, errs[8] = rsDecode(rs32, keyfileHashRef) _, errs[8] = rsDecode(rs32, keyfileHashRef, !(*fix))
authTag = make([]byte, 192) authTag = make([]byte, 192)
fin.Read(authTag) fin.Read(authTag)
authTag, errs[9] = rsDecode(rs64, authTag) authTag, errs[9] = rsDecode(rs64, authTag, !(*fix))
for _, err := range errs { for _, err := range errs {
if err != nil { if err != nil {
fin.Close() fin.Close()
@ -487,7 +491,7 @@ func work() int {
src = nil src = nil
if len(dst) == MiB/128*136 { if len(dst) == MiB/128*136 {
for i := 0; i < MiB/128*136; i += 136 { for i := 0; i < MiB/128*136; i += 136 {
tmp, err := rsDecode(rs128, dst[i:i+136]) tmp, err := rsDecode(rs128, dst[i:i+136], !(*fix))
if err != nil { if err != nil {
fin.Close() fin.Close()
fout.Close() fout.Close()
@ -503,7 +507,7 @@ func work() int {
} else { } else {
chunks := len(dst)/136 - 1 chunks := len(dst)/136 - 1
for i := 0; i < chunks; i++ { for i := 0; i < chunks; i++ {
tmp, err := rsDecode(rs128, dst[i*136:(i+1)*136]) tmp, err := rsDecode(rs128, dst[i*136:(i+1)*136], !(*fix))
if err != nil { if err != nil {
fin.Close() fin.Close()
fout.Close() fout.Close()
@ -513,7 +517,7 @@ func work() int {
} }
src = append(src, tmp...) src = append(src, tmp...)
} }
tmp, err := rsDecode(rs128, dst[int(chunks)*136:]) tmp, err := rsDecode(rs128, dst[int(chunks)*136:], !(*fix))
if err != nil { if err != nil {
fin.Close() fin.Close()
fout.Close() fout.Close()
@ -571,6 +575,14 @@ func work() int {
fout.Close() fout.Close()
os.Remove(fout_) os.Remove(fout_)
fmt.Println("The input volume is damaged or modified.") fmt.Println("The input volume is damaged or modified.")
if *reedsolo {
if !(*fix) {
fmt.Println("Fortunately, this volume is encoded with Reed-Solomon.")
fmt.Println("Try again using the -fix flag to repair the corruption.")
} else {
fmt.Println("The corruption could not be fixed with Reed-Solomon.")
}
}
return 1 return 1
} }
} }