WIP: Add allocation immutable checks to upload, copy move

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

@@ -34,6 +34,7 @@ type Allocation struct {
 	LatestRedeemedWM string           `gorm:"column:latest_redeemed_write_marker"`
 	IsRedeemRequired bool             `gorm:"column:is_redeem_required"`
 	TimeUnit         time.Duration    `gorm:"column:time_unit"`
+	IsImmutable      bool             `gorm:"is_immutable"`
 	// Ending and cleaning
 	CleanedUp        bool `gorm:"column:cleaned_up"`
 	Finalized        bool `gorm:"column:finalized"`

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

@@ -127,6 +127,7 @@ func VerifyAllocationTransaction(ctx context.Context, allocationTx string,
 	a.UsedSize = sa.UsedSize
 	a.Finalized = sa.Finalized
 	a.TimeUnit = sa.TimeUnit
+	a.IsImmutable = sa.IsImmutable
 
 	// related terms
 	a.Terms = make([]*Terms, 0, len(sa.BlobberDetails))

code/go/0chain.net/blobbercore/handler/object_operation_handler.go

@@ -419,6 +419,10 @@ func (fsh *StorageHandler) CommitWrite(ctx context.Context, r *http.Request) (*C
 		return nil, common.NewError("invalid_parameters", "Invalid allocation id passed."+err.Error())
 	}
 
+	if allocationObj.IsImmutable {
+		return nil, common.NewError("immutable_allocation", "Cannot write to an immutable allocation")
+	}
+
 	allocationID := allocationObj.ID
 
 	connectionID := r.FormValue("connection_id")
@@ -585,6 +589,11 @@ func (fsh *StorageHandler) RenameObject(ctx context.Context, r *http.Request) (i
 	if err != nil {
 		return nil, common.NewError("invalid_parameters", "Invalid allocation id passed."+err.Error())
 	}
+
+	if allocationObj.IsImmutable {
+		return nil, common.NewError("immutable_allocation", "Cannot rename data in an immutable allocation")
+	}
+
 	allocationID := allocationObj.ID
 
 	clientID := ctx.Value(constants.CLIENT_CONTEXT_KEY).(string)
@@ -683,6 +692,10 @@ func (fsh *StorageHandler) UpdateObjectAttributes(ctx context.Context,
 		return nil, common.NewError("invalid_signature", "Invalid signature")
 	}
 
+	if alloc.IsImmutable {
+		return nil, common.NewError("immutable_allocation", "Cannot update data in an immutable allocation")
+	}
+
 	// runtime type check
 	_ = ctx.Value(constants.CLIENT_KEY_CONTEXT_KEY).(string)
 
@@ -779,6 +792,10 @@ func (fsh *StorageHandler) CopyObject(ctx context.Context, r *http.Request) (int
 		return nil, common.NewError("invalid_signature", "Invalid signature")
 	}
 
+	if allocationObj.IsImmutable {
+		return nil, common.NewError("immutable_allocation", "Cannot copy data in an immutable allocation")
+	}
+
 	clientID := ctx.Value(constants.CLIENT_CONTEXT_KEY).(string)
 	_ = ctx.Value(constants.CLIENT_KEY_CONTEXT_KEY).(string)
 
@@ -911,6 +928,10 @@ func (fsh *StorageHandler) WriteFile(ctx context.Context, r *http.Request) (*Upl
 		return nil, common.NewError("invalid_signature", "Invalid signature")
 	}
 
+	if allocationObj.IsImmutable {
+		return nil, common.NewError("immutable_allocation", "Cannot write to an immutable allocation")
+	}
+
 	allocationID := allocationObj.ID
 
 	if len(clientID) == 0 {

code/go/0chain.net/core/transaction/entity.go

@@ -69,7 +69,7 @@ type StakePoolSettings struct {
 }
 
 type StorageNodeGeolocation struct {
-	Latitude float64 `json:"latitude"`
+	Latitude  float64 `json:"latitude"`
 	Longitude float64 `json:"longitude"`
 }
 
@@ -101,6 +101,7 @@ type StorageAllocation struct {
 	Finalized      bool                 `json:"finalized"`
 	CCT            time.Duration        `json:"challenge_completion_time"`
 	TimeUnit       time.Duration        `json:"time_unit"`
+	IsImmutable    bool                 `json:"is_immutable"`
 }
 
 func (sa *StorageAllocation) Until() common.Timestamp {

sql/15-add-allocation-columns.sql

@@ -0,0 +1,6 @@
+\connect blobber_meta;
+
+BEGIN;
+    ALTER TABLE allocations ADD COLUMN repairer_id VARCHAR(64) NOT NULL;
+    ALTER TABLE allocations ADD COLUMN is_immutable BOOLEAN NOT NULL;
+COMMIT;