Merge pull request #402 from filecoin-project/new-lotus-apis

feat: add various new APIs for Lotus

build.sh

@@ -5,8 +5,8 @@ set -e
 make clean
 cd rust
 rm -f Cargo.lock
-rustup target add x86_64-apple-darwin --toolchain $(cat rust-toolchain)
-rustup target add aarch64-apple-darwin --toolchain $(cat rust-toolchain)
+rustup target add x86_64-apple-darwin
+rustup target add aarch64-apple-darwin
 cargo update -p "filecoin-proofs-api"
 cargo install cargo-lipo
 cd ..

cgo/proofs.go

@@ -381,3 +381,39 @@ func MergeWindowPoStPartitionProofs(registeredProof RegisteredPoStProof, partiti
 
 	return resp.value.copy(), nil
 }
+
+// PoRep primitives
+
+func GenerateSDR(registeredProof RegisteredPoStProof, outDir SliceRefUint8, replicaID *ByteArray32) error {
+	resp := C.generate_sdr(registeredProof, outDir, replicaID)
+	defer resp.destroy()
+
+	return CheckErr(resp)
+}
+
+func GenerateTreeRLast(registeredProof RegisteredPoStProof, replicaPath, outDir SliceRefUint8) ([]byte, error) {
+	resp := C.generate_tree_r_last(registeredProof, replicaPath, outDir)
+	defer resp.destroy()
+	if err := CheckErr(resp); err != nil {
+		return nil, err
+	}
+
+	return resp.value.copy(), nil
+}
+
+func GenerateTreeC(registeredProof RegisteredPoStProof, inputDir, outDir SliceRefUint8) ([]byte, error) {
+	resp := C.generate_tree_c(registeredProof, inputDir, outDir)
+	defer resp.destroy()
+	if err := CheckErr(resp); err != nil {
+		return nil, err
+	}
+
+	return resp.value.copy(), nil
+}
+
+func EmptySectorUpdateDecodeFromRange(registeredProof RegisteredUpdateProof, commD, commR *ByteArray32, inputFd, sectorKeyFd, outputFd int32, nodesOffset, numNodes uint64) error {
+	resp := C.empty_sector_update_decode_from_range(registeredProof, commD, commR, C.int(inputFd), C.int(sectorKeyFd), C.int(outputFd), C.uint64_t(nodesOffset), C.uint64_t(numNodes))
+	defer resp.destroy()
+
+	return CheckErr(resp)
+}

proofs.go

@@ -518,6 +518,25 @@ func UnsealRange(
 	)
 }
 
+func GenerateSDR(
+	proofType abi.RegisteredSealProof,
+	cacheDirPath string,
+	replicaId [32]byte,
+) (err error) {
+	sp, err := toFilRegisteredSealProof(proofType)
+	if err != nil {
+		return err
+	}
+
+	replicaIdtBytes := cgo.AsByteArray32(replicaId[:])
+
+	return cgo.GenerateSDR(
+		sp,
+		cgo.AsSliceRefUint8([]byte(cacheDirPath)),
+		&replicaIdtBytes,
+	)
+}
+
 // GenerateWinningPoStSectorChallenge
 func GenerateWinningPoStSectorChallenge(
 	proofType abi.RegisteredPoStProof,