feat(message): add MessageImmediate option for setting pending=false (#320)

* added message pending options

* added WithPendion option

---------

Co-authored-by: Slava Bobik <[email protected]>

Author: slavabobik

message.go

@@ -123,7 +123,7 @@ type messageRequest struct {
 	Message                messageRequestMessage `json:"message"`
 	SkipPush               bool                  `json:"skip_push,omitempty"`
 	SkipEnrichURL          bool                  `json:"skip_enrich_url,omitempty"`
-	Pending                bool                  `json:"pending,omitempty"`
+	Pending                *bool                 `json:"pending,omitempty"`
 	IsPendingMessage       bool                  `json:"is_pending_message,omitempty"`
 	PendingMessageMetadata map[string]string     `json:"pending_message_metadata,omitempty"`
 	KeepChannelHidden      bool                  `json:"keep_channel_hidden,omitempty"`
@@ -225,10 +225,18 @@ func MessageSkipEnrichURL(r *messageRequest) {
 	}
 }
 
-// MessagePending is a flag that makes this a pending message.
+// MessagePending sets a flag that marks this message as pending.
+// Deprecated: Use WithPending(true) instead.
 func MessagePending(r *messageRequest) {
-	if r != nil {
-		r.Pending = true
+	WithPending(true)(r)
+}
+
+// WithPending returns an option that sets the Pending flag to the specified value.
+func WithPending(pending bool) SendMessageOption {
+	return func(r *messageRequest) {
+		if r != nil {
+			r.Pending = &pending
+		}
 	}
 }
 

message_test.go

@@ -69,6 +69,30 @@ func TestClient_SendMessage_Pending(t *testing.T) {
 	require.NoError(t, err)
 }
 
+func TestClient_SendMessage_WithPendingFalse(t *testing.T) {
+	c := initClient(t)
+	user := randomUser(t, c)
+
+	ctx := context.Background()
+
+	ch := initChannel(t, c, user.ID)
+	resp1, err := c.CreateChannel(ctx, ch.Type, ch.ID, user.ID, nil)
+	require.NoError(t, err)
+
+	msg := &Message{Text: "message with WithPending(false) - non-pending message"}
+	messageResp, err := resp1.Channel.SendMessage(ctx, msg, user.ID, WithPending(false))
+	require.NoError(t, err)
+
+	// Get the message to verify it's not in pending state
+	gotMsg, err := c.GetMessage(ctx, messageResp.Message.ID)
+	require.NoError(t, err)
+
+	// No need to commit the message as it's already in non-pending state
+	// The message should be immediately available without requiring a commit
+	require.NotNil(t, gotMsg.Message)
+	require.Equal(t, msg.Text, gotMsg.Message.Text)
+}
+
 func TestClient_SendMessage_SkipEnrichURL(t *testing.T) {
 	c := initClient(t)
 	user := randomUser(t, c)