Added changes for fail upload commit (#1318)

code/go/0chain.net/blobbercore/allocation/file_changer_upload.go

@@ -21,7 +21,7 @@ type UploadFileChanger struct {
 }
 
 // ApplyChange update references, and create a new FileRef
-func (nf *UploadFileChanger) ApplyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
+func (nf *UploadFileChanger) applyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
 	allocationRoot string, ts common.Timestamp, fileIDMeta map[string]string) (*reference.Ref, error) {
 
 	totalRefs, err := reference.CountRefs(ctx, nf.AllocationID)

code/go/0chain.net/blobbercore/allocation/file_changer_upload_integration.go

@@ -0,0 +1,28 @@
+//go:build integration_tests
+// +build integration_tests
+
+package allocation
+
+import (
+	"context"
+	"errors"
+
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/reference"
+	"github.com/0chain/blobber/code/go/0chain.net/conductor/conductrpc"
+	"github.com/0chain/blobber/code/go/0chain.net/core/common"
+	"github.com/0chain/blobber/code/go/0chain.net/core/node"
+)
+
+func (nf *UploadFileChanger) ApplyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
+	allocationRoot string, ts common.Timestamp, fileIDMeta map[string]string) (*reference.Ref, error) {
+
+	state := conductrpc.Client().State()
+	if state.FailUploadCommit != nil {
+		for _, nodeId := range state.FailUploadCommit {
+			if nodeId == node.Self.ID {
+				return nil, errors.New("error directed by conductor")
+			}
+		}
+	}
+	return nf.applyChange(ctx, rootRef, change, allocationRoot, ts, fileIDMeta)
+}

code/go/0chain.net/blobbercore/allocation/file_changer_upload_main.go

@@ -0,0 +1,15 @@
+//go:build !integration_tests
+// +build !integration_tests
+
+package allocation
+
+import (
+	"context"
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/reference"
+	"github.com/0chain/blobber/code/go/0chain.net/core/common"
+)
+
+func (nf *UploadFileChanger) ApplyChange(ctx context.Context, rootRef *reference.Ref, change *AllocationChange,
+	allocationRoot string, ts common.Timestamp, fileIDMeta map[string]string) (*reference.Ref, error) {
+	return nf.applyChange(ctx, rootRef, change, allocationRoot, ts, fileIDMeta)
+}

code/go/0chain.net/conductor/conductrpc/state.go

@@ -65,6 +65,7 @@ type State struct {
 	NotifyOnValidationTicketGeneration bool
 	StopWMCommit         *bool
 	FailRenameCommit     []string
+	FailUploadCommit     []string
 	GetFileMetaRoot      bool
 }