add event

proto/greenfield/storage/events.proto

@@ -655,3 +655,16 @@ message EventBucketFlowRateLimitStatus {
   // is_limited define the status of the bucket flow rate limit
   bool is_limited = 2;
 }
+
+message EventToggleSPAsDelegatedAgent {
+  // bucket_name define the name of the bucket
+  string bucket_name = 1;
+  // bucket_id is the unique u256 for bucket. Not global, only unique in buckets.
+  string bucket_id = 2 [
+    (cosmos_proto.scalar) = "cosmos.Uint",
+    (gogoproto.customtype) = "Uint",
+    (gogoproto.nullable) = false
+  ];
+  // sp_as_delegated_agent_disabled indicates that whether bucket owner disable SP as the upload agent.
+  bool sp_as_delegated_agent_disabled = 3;
+}

x/storage/keeper/msg_server.go

@@ -113,8 +113,14 @@ func (k msgServer) ToggleSPAsDelegatedAgent(goCtx context.Context, msg *storaget
 	}
 	bucketInfo.SpAsDelegatedAgentDisabled = !bucketInfo.SpAsDelegatedAgentDisabled
 	k.SetBucketInfo(ctx, bucketInfo)
+	if err := ctx.EventManager().EmitTypedEvents(&types.EventToggleSPAsDelegatedAgent{
+		BucketName:                 bucketInfo.BucketName,
+		BucketId:                   bucketInfo.Id,
+		SpAsDelegatedAgentDisabled: bucketInfo.SpAsDelegatedAgentDisabled,
+	}); err != nil {
+		return nil, err
+	}
 	return &types.MsgToggleSPAsDelegatedAgentResponse{}, nil
-
 }
 
 func (k msgServer) CreateObject(goCtx context.Context, msg *types.MsgCreateObject) (*types.MsgCreateObjectResponse, error) {