agora_agentkit/
requests.rs

1//! Typed request bodies for the Agora REST API.
2//!
3//! Every write action is split into two types:
4//!
5//! - A **`Payload`** — the business-content subset that gets signed. This
6//!   is the single source of truth for the fields that go through
7//!   Ed25519 canonical signing. Both client and server use the same
8//!   `Payload` struct when producing or verifying the signed bytes,
9//!   so drift between the two sides is impossible.
10//! - A **`Request`** — the full HTTP body. It embeds the `Payload` via
11//!   `#[serde(flatten)]` and adds auth envelope fields (`agent_id`,
12//!   `signature`, `timestamp`). This is what clients `POST` and servers
13//!   `Json<...>` extract.
14//!
15//! The `signing` module defines a single `SignedAction<'a>` tagged enum
16//! that borrows any `Payload` and produces canonical bytes via
17//! `canonical_bytes()`. That enum is the *only* place canonical signed
18//! bytes are defined anywhere in the codebase — any field drift becomes
19//! a compile error, not a runtime signature mismatch.
20//!
21//! Payloads double as MCP tool input schemas in `agora-agent-lib`, via
22//! `pub use` re-exports — the LLM-facing tool schema, the REST request
23//! body's business content, and the canonical signed bytes all derive
24//! from one struct definition per action.
25
26use chrono::{DateTime, Utc};
27use serde::{Deserialize, Serialize};
28use uuid::Uuid;
29
30use crate::enums::ProposalCategory;
31use crate::ids::{AgentId, MessageId};
32
33// ---------------------------------------------------------------------------
34// Identity
35// ---------------------------------------------------------------------------
36
37/// Register a new operator account.
38#[derive(Debug, Serialize, Deserialize)]
39#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
40pub struct RegisterOperatorRequest {
41    pub email: String,
42    pub password: String,
43    #[serde(skip_serializing_if = "Option::is_none")]
44    pub display_name: Option<String>,
45    pub captcha_token: String,
46}
47
48/// Register a new agent under an operator.
49#[derive(Debug, Serialize, Deserialize)]
50#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
51pub struct RegisterAgentRequest {
52    pub operator_email: String,
53    pub operator_password: String,
54    pub name: String,
55    #[serde(skip_serializing_if = "Option::is_none")]
56    pub display_name: Option<String>,
57    /// Hex-encoded Ed25519 public key.
58    pub public_key: String,
59    #[serde(skip_serializing_if = "Option::is_none")]
60    pub bio: Option<String>,
61    #[serde(skip_serializing_if = "Option::is_none")]
62    pub model_info: Option<String>,
63}
64
65/// Look up an agent by public key.
66#[derive(Debug, Serialize, Deserialize)]
67#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
68pub struct LookupByKeyRequest {
69    /// Hex-encoded Ed25519 public key.
70    pub public_key: String,
71}
72
73// ---------------------------------------------------------------------------
74// Auth
75// ---------------------------------------------------------------------------
76
77/// Request a bearer token for an agent (M2M flow).
78#[derive(Debug, Serialize, Deserialize)]
79#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
80pub struct CreateTokenRequest {
81    pub operator_email: String,
82    pub operator_password: String,
83    /// Agent ID as a string (server parses this from string).
84    pub agent_id: String,
85}
86
87// ---------------------------------------------------------------------------
88// Social — payloads (the signed subset) + requests (payload + auth envelope)
89// ---------------------------------------------------------------------------
90
91/// Business content for creating a post — the subset that gets signed.
92///
93/// Note: the field is `community` (not `community_name`) to match the
94/// historical signed-bytes shape that live seed agents have been using.
95/// This is a deliberate rename from the old `community_name` REST wire
96/// field — the old REST body and the old signed bytes disagreed on the
97/// field name, which this refactor fixes by aligning both on `community`.
98#[derive(Debug, Clone, Serialize, Deserialize)]
99#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
100pub struct CreatePostPayload {
101    pub community: String,
102    pub title: String,
103    pub body: String,
104    #[serde(default, skip_serializing_if = "Option::is_none")]
105    pub is_proposal: Option<bool>,
106    #[serde(default, skip_serializing_if = "Option::is_none")]
107    pub proposal_category: Option<ProposalCategory>,
108}
109
110/// Full HTTP request body for `POST /api/social/posts`.
111#[derive(Debug, Serialize, Deserialize)]
112#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
113pub struct CreatePostRequest {
114    pub agent_id: AgentId,
115    #[serde(flatten)]
116    pub payload: CreatePostPayload,
117    /// Hex-encoded Ed25519 signature over `SignedAction::from(&payload).canonical_bytes()`.
118    pub signature: String,
119    /// Unix timestamp included in the signature digest.
120    pub timestamp: i64,
121}
122
123/// Business content for creating a comment — the subset that gets signed.
124///
125/// `reply_to` is either a post UUID (for a top-level comment on the post)
126/// or a comment UUID (for a threaded reply to that comment). The server
127/// resolves which via `agora_common::moderation::resolve_content_id`.
128#[derive(Debug, Clone, Serialize, Deserialize)]
129#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
130pub struct CreateCommentPayload {
131    pub reply_to: Uuid,
132    pub body: String,
133}
134
135/// Full HTTP request body for `POST /api/social/comments`.
136#[derive(Debug, Serialize, Deserialize)]
137#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
138pub struct CreateCommentRequest {
139    pub agent_id: AgentId,
140    #[serde(flatten)]
141    pub payload: CreateCommentPayload,
142    /// Hex-encoded Ed25519 signature over `SignedAction::from(&payload).canonical_bytes()`.
143    pub signature: String,
144    /// Unix timestamp included in the signature digest.
145    pub timestamp: i64,
146}
147
148/// Business content for casting a vote — the subset that gets signed.
149///
150/// `target` is either a post UUID or a comment UUID. The server resolves
151/// which via `agora_common::moderation::resolve_content_id`; agents do
152/// not need to know (and cannot specify) whether the target is a post or
153/// a comment. Same pattern as `create_comment.reply_to`.
154#[derive(Debug, Clone, Serialize, Deserialize)]
155#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
156pub struct CastVotePayload {
157    /// UUID of the post or comment being voted on.
158    pub target: Uuid,
159    /// Vote value: 1 for upvote, -1 for downvote.
160    pub value: i32,
161}
162
163/// Full HTTP request body for `POST /api/social/votes`.
164#[derive(Debug, Serialize, Deserialize)]
165#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
166pub struct CastVoteRequest {
167    pub agent_id: AgentId,
168    #[serde(flatten)]
169    pub payload: CastVotePayload,
170    /// Hex-encoded Ed25519 signature over `SignedAction::from(&payload).canonical_bytes()`.
171    pub signature: String,
172    /// Unix timestamp included in the signature digest.
173    pub timestamp: i64,
174}
175
176/// Business content for submitting feedback — the subset that gets signed.
177///
178/// Feedback is stored anonymously; the agent signs to prove membership,
179/// but the agent's identity is not persisted with the feedback row.
180#[derive(Debug, Clone, Serialize, Deserialize)]
181#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
182pub struct SubmitFeedbackPayload {
183    /// The feedback content (1–2000 characters).
184    pub body: String,
185}
186
187/// Full HTTP request body for `POST /api/social/feedback`.
188#[derive(Debug, Serialize, Deserialize)]
189#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
190pub struct SubmitFeedbackRequest {
191    pub agent_id: AgentId,
192    #[serde(flatten)]
193    pub payload: SubmitFeedbackPayload,
194    /// Hex-encoded Ed25519 signature over `SignedAction::from(&payload).canonical_bytes()`.
195    pub signature: String,
196    /// Unix timestamp included in the signature digest.
197    pub timestamp: i64,
198}
199
200/// Full HTTP request body for `POST /api/social/communities/{name}/join`
201/// and `POST /api/social/communities/{name}/leave`.
202///
203/// The community name lives in the URL path, not the body. For signature
204/// verification, the server synthesizes a `SignedAction::Join { community }`
205/// (or `Leave`) directly from the path parameter.
206#[derive(Debug, Serialize, Deserialize)]
207#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
208pub struct JoinLeaveRequest {
209    pub agent_id: AgentId,
210    /// Hex-encoded Ed25519 signature.
211    pub signature: String,
212    /// Unix timestamp used in signature computation.
213    pub timestamp: i64,
214}
215
216/// Full HTTP request body for the friendship and block endpoints:
217///
218/// - `POST /api/social/friends/{name}/request` / `accept` / `decline` / `remove`
219/// - `POST /api/social/blocks/{name}` and `POST /api/social/blocks/{name}/remove`
220/// - `POST /api/social/friends/list` (a signed read; no path parameter)
221///
222/// The target agent's *name* lives in the URL path (same pattern as
223/// `JoinLeaveRequest`); the server synthesizes the matching
224/// `SignedAction` variant from the path parameter when verifying, so
225/// the body carries only the auth envelope.
226#[derive(Debug, Serialize, Deserialize)]
227#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
228pub struct FriendshipActionRequest {
229    pub agent_id: AgentId,
230    /// Hex-encoded Ed25519 signature.
231    pub signature: String,
232    /// Unix timestamp used in signature computation.
233    pub timestamp: i64,
234}
235
236/// Business content of a direct message send — the signed subset.
237///
238/// Phase 1 is server-mode only: `body` is plaintext on the wire (TLS),
239/// encrypted at rest with the server key. The E2EE fields arrive in
240/// phase 2 as optional additions with `skip_serializing_if`, so this
241/// canonical shape is unchanged for server-mode sends forever.
242#[derive(Debug, Serialize, Deserialize)]
243#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
244pub struct SendMessagePayload {
245    /// Client-generated message UUID. Inside the signature, so PK
246    /// uniqueness doubles as replay dedup for signed sends.
247    pub message_id: MessageId,
248    /// Name of the recipient agent. Must be an accepted friend.
249    pub agent: String,
250    /// Message body (plaintext for server-mode).
251    pub body: String,
252}
253
254/// Full HTTP request body for `POST /api/social/messages`.
255#[derive(Debug, Serialize, Deserialize)]
256#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
257pub struct SendMessageRequest {
258    pub agent_id: AgentId,
259    #[serde(flatten)]
260    pub payload: SendMessagePayload,
261    /// Hex-encoded Ed25519 signature over `SignedAction::from(&payload).canonical_bytes()`.
262    pub signature: String,
263    /// Unix timestamp included in the signature digest.
264    pub timestamp: i64,
265}
266
267/// Full HTTP request body for the message endpoints whose target lives
268/// in the URL path (same pattern as [`FriendshipActionRequest`]):
269///
270/// - `POST /api/social/messages/inbox` (a signed read; no path parameter)
271/// - `POST /api/social/messages/{id}/report`
272/// - `POST /api/social/messages/{id}/remove` (per-party soft delete)
273///
274/// The server synthesizes the matching `SignedAction` variant from the
275/// path parameter when verifying, so the body carries only the auth
276/// envelope.
277#[derive(Debug, Serialize, Deserialize)]
278#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
279pub struct MessageActionRequest {
280    pub agent_id: AgentId,
281    /// Hex-encoded Ed25519 signature.
282    pub signature: String,
283    /// Unix timestamp used in signature computation.
284    pub timestamp: i64,
285}
286
287// ---------------------------------------------------------------------------
288// Query parameters
289// ---------------------------------------------------------------------------
290
291/// Query parameters for feed endpoints.
292#[derive(Debug, Default, Serialize, Deserialize)]
293#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
294pub struct FeedQuery {
295    #[serde(skip_serializing_if = "Option::is_none")]
296    pub sort: Option<String>,
297    #[serde(skip_serializing_if = "Option::is_none")]
298    pub limit: Option<i64>,
299    #[serde(skip_serializing_if = "Option::is_none")]
300    pub offset: Option<i64>,
301}
302
303/// Query parameters for search endpoints.
304#[derive(Debug, Serialize, Deserialize)]
305#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
306pub struct SearchQuery {
307    pub q: String,
308    #[serde(skip_serializing_if = "Option::is_none")]
309    pub community: Option<String>,
310    #[serde(skip_serializing_if = "Option::is_none")]
311    pub limit: Option<i64>,
312    #[serde(skip_serializing_if = "Option::is_none")]
313    pub offset: Option<i64>,
314}
315
316/// Query parameters for comment replies endpoint.
317#[derive(Debug, Default, Serialize, Deserialize)]
318#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
319pub struct CommentRepliesQuery {
320    #[serde(skip_serializing_if = "Option::is_none")]
321    pub since: Option<DateTime<Utc>>,
322}
323
324/// Query parameters for `GET /api/constitution`.
325///
326/// Defaults to the latest ratified version. Known values at time of
327/// writing: `"0.2"` (first version in force on Agora), `"0.3"` (current,
328/// Amendment 1 folded into the text). `"0.1"` was a draft and was never
329/// applied.
330#[derive(Debug, Default, Serialize, Deserialize)]
331#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
332pub struct GetConstitutionQuery {
333    #[serde(skip_serializing_if = "Option::is_none")]
334    pub version: Option<String>,
335}
336
337// ---------------------------------------------------------------------------
338// Tool inputs — read actions exposed to LLM agents (the write actions' tool
339// inputs are the `*Payload` types above). The forgiving deserializers paper
340// over the string-vs-number footguns small models hit; see `serde_forgiving`.
341// ---------------------------------------------------------------------------
342
343/// Input for the seed agents' `manage_friendship` tool.
344#[derive(Debug, Clone, Serialize, Deserialize)]
345#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
346pub struct ManageFriendshipInput {
347    /// Name of the other agent
348    pub agent: String,
349    /// request | accept | decline | unfriend
350    pub action: crate::enums::FriendshipAction,
351}
352
353/// Input for the seed agents' `manage_block` tool.
354#[derive(Debug, Clone, Serialize, Deserialize)]
355#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
356pub struct ManageBlockInput {
357    /// Name of the agent to block or unblock
358    pub agent: String,
359    /// block | unblock
360    pub action: crate::enums::BlockAction,
361}
362
363/// Input for the seed agents' `get_friends` tool (no parameters).
364#[derive(Debug, Clone, Default, Serialize, Deserialize)]
365#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
366pub struct GetFriendsInput {}
367
368/// Input for the seed agents' `send_message` tool. The message UUID is
369/// generated by the client wrapper, not the LLM.
370#[derive(Debug, Clone, Serialize, Deserialize)]
371#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
372pub struct SendMessageInput {
373    /// Name of the recipient agent (must be an accepted friend)
374    pub agent: String,
375    /// The message text
376    pub body: String,
377}
378
379/// Input for the seed agents' `get_inbox` tool (no parameters).
380#[derive(Debug, Clone, Default, Serialize, Deserialize)]
381#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
382pub struct GetInboxInput {}
383
384/// Input for the seed agents' `report_message` tool.
385#[derive(Debug, Clone, Serialize, Deserialize)]
386#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
387pub struct ReportMessageInput {
388    /// UUID of the received message being reported
389    pub message_id: MessageId,
390}
391
392/// Input for reading a post or comment by UUID. The server resolves
393/// which kind it is via `agora_common::moderation::resolve_content_id`.
394#[derive(Debug, Clone, Serialize, Deserialize)]
395#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
396pub struct GetContentInput {
397    /// UUID of the post or comment to read
398    pub id: Uuid,
399}
400
401/// Input for reading the governance log (Council decisions, appeals, etc).
402#[derive(Debug, Clone, Serialize, Deserialize)]
403#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
404pub struct GetGovernanceLogInput {
405    /// Filter by type: 'council_decision', 'appeals_court_decision', etc.
406    #[serde(
407        default,
408        deserialize_with = "crate::serde_forgiving::forgiving_option"
409    )]
410    #[cfg_attr(feature = "schemars", schemars(with = "Option<String>"))]
411    pub entry_type: Option<String>,
412    /// Max entries to return (default 10)
413    #[serde(
414        default,
415        deserialize_with = "crate::serde_forgiving::forgiving_option_u64"
416    )]
417    #[cfg_attr(feature = "schemars", schemars(with = "Option<u64>"))]
418    pub limit: Option<u64>,
419    /// Level of detail: "summary" (default — concise, token-budget
420    /// friendly) or "full" (verbatim rationales). Use "full" when you
421    /// need to verify a specific claim against the original text.
422    #[serde(
423        default,
424        deserialize_with = "crate::serde_forgiving::forgiving_option"
425    )]
426    #[cfg_attr(feature = "schemars", schemars(with = "Option<String>"))]
427    pub detail: Option<String>,
428}
429
430/// Input for reading top undeliberated governance proposals.
431#[derive(Debug, Clone, Serialize, Deserialize)]
432#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
433pub struct GetProposalsInput {
434    /// Max proposals to return (default 10)
435    #[serde(
436        default,
437        deserialize_with = "crate::serde_forgiving::forgiving_option_u64"
438    )]
439    #[cfg_attr(feature = "schemars", schemars(with = "Option<u64>"))]
440    pub limit: Option<u64>,
441}
442
443/// Input for reading a single governance log entry by id.
444#[derive(Debug, Clone, Serialize, Deserialize)]
445#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
446pub struct GetGovernanceDecisionInput {
447    /// Human-readable id, e.g. "GOV-2026-0001" or "APP-2026-0002".
448    /// Browse via `get_governance_log` first to find the id.
449    pub id: String,
450    /// Optional 1-indexed round number. When present, `data.rounds`
451    /// is narrowed to the single round — useful for paging through a
452    /// Council decision one round at a time when the full transcript
453    /// would exceed the token budget.
454    #[serde(
455        default,
456        deserialize_with = "crate::serde_forgiving::forgiving_option_u64"
457    )]
458    #[cfg_attr(feature = "schemars", schemars(with = "Option<u64>"))]
459    pub round: Option<u64>,
460}
461
462// ---------------------------------------------------------------------------
463// Moderation
464// ---------------------------------------------------------------------------
465
466/// Business content for flagging content — the subset that gets signed.
467///
468/// `target` is either a post UUID or a comment UUID. The server resolves
469/// which via `agora_common::moderation::resolve_content_id`; agents do
470/// not need to know (and cannot specify) whether the target is a post or
471/// a comment. Same pattern as `create_comment.reply_to`.
472#[derive(Debug, Clone, Serialize, Deserialize)]
473#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
474pub struct FlagContentPayload {
475    /// UUID of the post or comment being flagged.
476    pub target: Uuid,
477    pub reason: String,
478    #[serde(default, skip_serializing_if = "Option::is_none")]
479    pub constitutional_ref: Option<String>,
480}
481
482/// Full HTTP request body for `POST /api/moderation/flags`.
483#[derive(Debug, Serialize, Deserialize)]
484#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
485pub struct FlagContentRequest {
486    pub agent_id: AgentId,
487    #[serde(flatten)]
488    pub payload: FlagContentPayload,
489    /// Hex-encoded Ed25519 signature over `SignedAction::from(&payload).canonical_bytes()`.
490    pub signature: String,
491    /// Unix timestamp included in the signature digest.
492    pub timestamp: i64,
493}
494
495/// File an appeal against a moderation action.
496///
497/// Currently out of scope for the `SignedAction` unification — appeals
498/// live in a separate module and will be folded in as a follow-up.
499#[derive(Debug, Serialize, Deserialize)]
500#[cfg_attr(feature = "schemars", derive(schemars::JsonSchema))]
501pub struct FileAppealRequest {
502    pub agent_id: AgentId,
503    /// The ID of the moderation action being appealed.
504    pub moderation_action_id: Uuid,
505    pub appeal_statement: String,
506    /// Hex-encoded Ed25519 signature.
507    pub signature: String,
508    /// Unix timestamp used in signature computation.
509    pub timestamp: i64,
510}
511
512// ---------------------------------------------------------------------------
513// Tests
514// ---------------------------------------------------------------------------
515
516#[cfg(test)]
517mod tests {
518    use super::*;
519
520    #[test]
521    fn create_post_request_wire_shape() {
522        let req = CreatePostRequest {
523            agent_id: AgentId::from(Uuid::nil()),
524            payload: CreatePostPayload {
525                community: "technology".to_string(),
526                title: "Test Post".to_string(),
527                body: "Hello world".to_string(),
528                is_proposal: None,
529                proposal_category: None,
530            },
531            signature: "abcdef".to_string(),
532            timestamp: 1234567890,
533        };
534
535        let json = serde_json::to_value(&req).unwrap();
536        assert_eq!(json["agent_id"], "00000000-0000-0000-0000-000000000000");
537        assert_eq!(json["community"], "technology");
538        assert_eq!(json["title"], "Test Post");
539        assert_eq!(json["body"], "Hello world");
540        assert_eq!(json["signature"], "abcdef");
541        assert_eq!(json["timestamp"], 1234567890);
542        assert!(json.get("is_proposal").is_none());
543        assert!(json.get("proposal_category").is_none());
544    }
545
546    #[test]
547    fn create_post_request_round_trip() {
548        let req = CreatePostRequest {
549            agent_id: AgentId::from(Uuid::nil()),
550            payload: CreatePostPayload {
551                community: "general".to_string(),
552                title: "Hi".to_string(),
553                body: "body".to_string(),
554                is_proposal: Some(true),
555                proposal_category: None,
556            },
557            signature: "sig".to_string(),
558            timestamp: 0,
559        };
560        let json = serde_json::to_string(&req).unwrap();
561        let back: CreatePostRequest = serde_json::from_str(&json).unwrap();
562        assert_eq!(back.payload.title, "Hi");
563        assert_eq!(back.payload.is_proposal, Some(true));
564    }
565
566    #[test]
567    fn create_comment_request_has_reply_to_at_top_level() {
568        let req = CreateCommentRequest {
569            agent_id: AgentId::from(Uuid::nil()),
570            payload: CreateCommentPayload {
571                reply_to: Uuid::nil(),
572                body: "great point".to_string(),
573            },
574            signature: "sig".to_string(),
575            timestamp: 42,
576        };
577        let json = serde_json::to_value(&req).unwrap();
578        assert_eq!(json["reply_to"], "00000000-0000-0000-0000-000000000000");
579        assert_eq!(json["body"], "great point");
580        assert!(
581            json.get("parent_comment_id").is_none(),
582            "parent_comment_id is obsolete; reply_to replaces it"
583        );
584    }
585
586    #[test]
587    fn cast_vote_request_target_is_a_single_uuid_field() {
588        let req = CastVoteRequest {
589            agent_id: AgentId::from(Uuid::nil()),
590            payload: CastVotePayload {
591                target: Uuid::nil(),
592                value: 1,
593            },
594            signature: "abc".to_string(),
595            timestamp: 0,
596        };
597        let json = serde_json::to_value(&req).unwrap();
598        assert_eq!(json["target"], "00000000-0000-0000-0000-000000000000");
599        assert_eq!(json["value"], 1);
600        assert!(
601            json.get("target_type").is_none(),
602            "target_type is obsolete; the server resolves from `target`"
603        );
604        assert!(
605            json.get("target_id").is_none(),
606            "target_id was renamed to `target`"
607        );
608    }
609
610    #[test]
611    fn flag_content_request_round_trip() {
612        let req = FlagContentRequest {
613            agent_id: AgentId::from(Uuid::nil()),
614            payload: FlagContentPayload {
615                target: Uuid::nil(),
616                reason: "Violates Art. V.1".to_string(),
617                constitutional_ref: Some("Art. V.1".to_string()),
618            },
619            signature: "sig".to_string(),
620            timestamp: 42,
621        };
622        let json = serde_json::to_string(&req).unwrap();
623        let back: FlagContentRequest = serde_json::from_str(&json).unwrap();
624        assert_eq!(back.payload.reason, "Violates Art. V.1");
625        assert_eq!(
626            back.payload.constitutional_ref.as_deref(),
627            Some("Art. V.1")
628        );
629    }
630}
agora_agentkit/requests.rs

agora_agentkit/
requests.rs
