update libs

svix · Nov 29, 2023 · e1f1c27 · e1f1c27
1 parent 3d4e622
commit e1f1c27
Show file tree

Hide file tree

Showing 7 changed files with 47 additions and 3 deletions.
diff --git a/csharp/Svix/MessageAttempt.cs b/csharp/Svix/MessageAttempt.cs
@@ -144,6 +144,7 @@ public List<MessageAttemptOut> ListAttemptsByEndpoint(string appId, string endpo
                     options?.Before,
                     options?.After,
                     options?.WithContent,
+                    options?.WithMsg,
                     options?.EventTypes);
 
                 return lResults?.Data;
@@ -175,6 +176,7 @@ public async Task<List<MessageAttemptOut>> ListAttemptsByEndpointAsync(string ap
                     options?.Before,
                     options?.After,
                     options?.WithContent,
+                    options?.WithMsg,
                     options?.EventTypes,
                     cancellationToken);
 

diff --git a/csharp/Svix/Models/AttemptsByEndpointListOptions.cs b/csharp/Svix/Models/AttemptsByEndpointListOptions.cs
@@ -18,5 +18,7 @@ public sealed class AttemptsByEndpointListOptions : ListOptions
         public DateTime? After { get; set; }
 
         public bool? WithContent { get; set; }
+
+        public bool? WithMsg { get; set; }
     }
 }
diff --git a/java/lib/src/main/java/com/svix/MessageAttempt.java b/java/lib/src/main/java/com/svix/MessageAttempt.java
@@ -59,6 +59,7 @@ public ListResponseMessageAttemptOut listByEndpoint(final String appId, final St
 					options.getBefore(),
 					options.getAfter(),
 					options.getWithContent(),
+					options.getWithMsg(),
 					new HashSet<>(options.getEventTypes())
 			);
 		} catch (com.svix.internal.ApiException e) {

diff --git a/java/lib/src/main/java/com/svix/MessageAttemptListOptions.java b/java/lib/src/main/java/com/svix/MessageAttemptListOptions.java
@@ -16,6 +16,7 @@ public class MessageAttemptListOptions extends ListOptions {
 	private String channel;
 	private Boolean withContent;
 	private String endpointId;
+	private Boolean withMsg;
 
 	public MessageAttemptListOptions() {
         super();
@@ -124,4 +125,17 @@ public MessageAttemptListOptions endpointId(final String endpointId) {
 		this.endpointId = endpointId;
 		return this;
 	}
+
+	public Boolean getWithMsg() {
+		return withMsg;
+	}
+
+	public void setWithMsg(final Boolean withMsg) {
+		this.withMsg = withMsg;
+	}
+
+	public MessageAttemptListOptions withMsg(final Boolean withMsg) {
+		this.withMsg = withMsg;
+		return this;
+	}
 }
diff --git a/kotlin/lib/src/main/kotlin/MessageAttempt.kt b/kotlin/lib/src/main/kotlin/MessageAttempt.kt
@@ -60,6 +60,7 @@ class MessageAttempt internal constructor(token: String, options: SvixOptions) {
                 options.before,
                 options.after,
                 options.withContent,
+                options.withMsg,
                 HashSet(options.eventTypes)
             )
         } catch (e: Exception) {

diff --git a/kotlin/lib/src/main/kotlin/MessageAttemptListOptions.kt b/kotlin/lib/src/main/kotlin/MessageAttemptListOptions.kt
@@ -4,7 +4,7 @@ import com.svix.kotlin.models.MessageStatus
 import com.svix.kotlin.models.StatusCodeClass
 import java.time.OffsetDateTime
 
-class MessageAttemptListOptions(var messageStatus: MessageStatus? = null, var before: OffsetDateTime? = null, var after: OffsetDateTime? = null, var eventTypes: List<String>? = null, var statusCodeClass: StatusCodeClass? = null, var channel: String? = null, var endpointId: String? = null, var withContent: Boolean? = null) : ListOptions() {
+class MessageAttemptListOptions(var messageStatus: MessageStatus? = null, var before: OffsetDateTime? = null, var after: OffsetDateTime? = null, var eventTypes: List<String>? = null, var statusCodeClass: StatusCodeClass? = null, var channel: String? = null, var endpointId: String? = null, var withContent: Boolean? = null, var withMsg: Boolean? = null) : ListOptions() {
     fun messageStatus(messageStatus: MessageStatus) = apply { this.messageStatus = messageStatus }
 
     fun before(before: OffsetDateTime) = apply { this.before = before }
@@ -20,4 +20,8 @@ class MessageAttemptListOptions(var messageStatus: MessageStatus? = null, var be
     override fun limit(limit: Int) = apply { super.limit(limit) }
 
     fun endpointId(endpointId: String) = apply { this.endpointId = endpointId }
+
+    fun withContent(withContent: Boolean) = apply { this.withContent = withContent }
+
+    fun withMsg(withMsg: Boolean) = apply { this.withMsg = withMsg }
 }
diff --git a/rust/src/api.rs b/rust/src/api.rs
@@ -901,6 +901,24 @@ pub struct MessageAttemptListOptions {
     pub endpoint_id: Option<String>,
 }
 
+#[derive(Default)]
+pub struct MessageAttemptListByEndpointOptions {
+    pub iterator: Option<String>,
+    pub limit: Option<i32>,
+    pub event_types: Option<Vec<String>>,
+    // FIXME: make before and after actual dates
+    /// RFC3339 date string
+    pub before: Option<String>,
+    /// RFC3339 date string
+    pub after: Option<String>,
+    pub channel: Option<String>,
+    pub status: Option<MessageStatus>,
+    pub status_code_class: Option<StatusCodeClass>,
+    pub with_content: Option<bool>,
+    pub with_msg: Option<bool>,
+    pub endpoint_id: Option<String>,
+}
+
 pub struct MessageAttempt<'a> {
     cfg: &'a Configuration,
 }
@@ -952,9 +970,9 @@ impl<'a> MessageAttempt<'a> {
         &self,
         app_id: String,
         endpoint_id: String,
-        options: Option<MessageAttemptListOptions>,
+        options: Option<MessageAttemptListByEndpointOptions>,
     ) -> Result<ListResponseMessageAttemptOut> {
-        let MessageAttemptListOptions {
+        let MessageAttemptListByEndpointOptions {
             iterator,
             limit,
             event_types,
@@ -965,6 +983,7 @@ impl<'a> MessageAttempt<'a> {
             status_code_class,
             endpoint_id: _,
             with_content,
+            with_msg,
         } = options.unwrap_or_default();
         Ok(message_attempt_api::v1_message_attempt_list_by_endpoint(
             self.cfg,
@@ -980,6 +999,7 @@ impl<'a> MessageAttempt<'a> {
                 status,
                 status_code_class,
                 with_content,
+                with_msg,
             },
         )
         .await?)