@@ -111,10 +111,12 @@ def upload_message(args) -> None:
111
111
"status" : "success" ,
112
112
"message_id" : message_id ,
113
113
"header" : args .header ,
114
- "body" : args .body
114
+ "body" : args .body ,
115
+ "environment" : args .environment
115
116
}))
116
117
else :
117
118
print (f"✓ Message uploaded successfully!" )
119
+ print (f" Environment: { args .environment } " )
118
120
print (f" Message ID: { message_id } " )
119
121
if args .header :
120
122
print (f" Header: { args .header } " )
@@ -165,21 +167,22 @@ def list_messages(args) -> None:
165
167
for msg in response .messageIdentifiers :
166
168
messages .append ({
167
169
"message_id" : msg .messageIdentifier ,
168
- "state" : msg .state .value if msg .state else None
170
+ "state" : msg .messageState .value if msg .messageState else None
169
171
})
170
172
print (json .dumps ({
171
173
"status" : "success" ,
172
174
"messages" : messages ,
173
- "total_count" : len (messages )
175
+ "total_count" : len (messages ),
176
+ "environment" : args .environment
174
177
}))
175
178
else :
176
179
if not response .messageIdentifiers or len (response .messageIdentifiers ) == 0 :
177
- print ("No retention messages found." )
180
+ print (f "No retention messages found in { args . environment } ." )
178
181
else :
179
- print (f"Found { len (response .messageIdentifiers )} retention message(s):" )
182
+ print (f"Found { len (response .messageIdentifiers )} retention message(s) in { args . environment } :" )
180
183
print ()
181
184
for msg in response .messageIdentifiers :
182
- state = msg .state .value if msg .state else "UNKNOWN"
185
+ state = msg .messageState .value if msg .messageState else "UNKNOWN"
183
186
print (f" Message ID: { msg .messageIdentifier } " )
184
187
print (f" State: { state } " )
185
188
print ()
@@ -227,10 +230,12 @@ def delete_message(args) -> None:
227
230
print (json .dumps ({
228
231
"status" : "success" ,
229
232
"message_id" : args .message_id ,
230
- "action" : "deleted"
233
+ "action" : "deleted" ,
234
+ "environment" : args .environment
231
235
}))
232
236
else :
233
237
print (f"✓ Message deleted successfully!" )
238
+ print (f" Environment: { args .environment } " )
234
239
print (f" Message ID: { args .message_id } " )
235
240
236
241
except APIException as e :
0 commit comments