allsource_core/application/dto/
event_dto.rs

1use crate::domain::entities::Event;
2use chrono::{DateTime, Utc};
3use serde::{Deserialize, Serialize};
4use uuid::Uuid;
5
6/// DTO for ingesting a new event
7#[derive(Debug, Deserialize)]
8pub struct IngestEventRequest {
9    pub event_type: String,
10    pub entity_id: String,
11    pub tenant_id: Option<String>, // Optional, defaults to "default"
12    pub payload: serde_json::Value,
13    pub metadata: Option<serde_json::Value>,
14    /// Optional optimistic concurrency control: if set, the write is rejected
15    /// with 409 Conflict unless the entity's current version matches this value.
16    pub expected_version: Option<u64>,
17}
18
19/// DTO for event ingestion response
20#[derive(Debug, Serialize)]
21pub struct IngestEventResponse {
22    pub event_id: Uuid,
23    pub timestamp: DateTime<Utc>,
24    /// The entity's version after this event was appended
25    #[serde(skip_serializing_if = "Option::is_none")]
26    pub version: Option<u64>,
27}
28
29impl IngestEventResponse {
30    pub fn from_event(event: &Event) -> Self {
31        Self {
32            event_id: event.id(),
33            timestamp: event.timestamp(),
34            version: None,
35        }
36    }
37}
38
39/// DTO for querying events
40#[derive(Debug, Default, Deserialize)]
41pub struct QueryEventsRequest {
42    /// Filter by entity ID
43    pub entity_id: Option<String>,
44
45    /// Filter by event type
46    pub event_type: Option<String>,
47
48    /// Tenant ID (required for multi-tenancy)
49    pub tenant_id: Option<String>,
50
51    /// Time-travel: get events as of this timestamp
52    pub as_of: Option<DateTime<Utc>>,
53
54    /// Get events since this timestamp
55    pub since: Option<DateTime<Utc>>,
56
57    /// Get events until this timestamp
58    pub until: Option<DateTime<Utc>>,
59
60    /// Limit number of results
61    pub limit: Option<usize>,
62
63    /// Filter by event type prefix (e.g., "index." matches "index.created", "index.updated")
64    pub event_type_prefix: Option<String>,
65
66    /// Filter by payload fields (JSON string, e.g., `{"user_id":"abc-123"}`).
67    /// Matches events where payload contains ALL specified key-value pairs.
68    pub payload_filter: Option<String>,
69}
70
71/// DTO for query response
72#[derive(Debug, Serialize)]
73pub struct QueryEventsResponse {
74    pub events: Vec<EventDto>,
75    pub count: usize,
76    pub total_count: usize,
77    pub has_more: bool,
78    /// Current version of the entity (present only when query filters by entity_id)
79    #[serde(skip_serializing_if = "Option::is_none")]
80    pub entity_version: Option<u64>,
81}
82
83/// DTO for a single event in responses
84#[derive(Debug, Serialize, Deserialize, Clone)]
85pub struct EventDto {
86    pub id: Uuid,
87    pub event_type: String,
88    pub entity_id: String,
89    pub tenant_id: String,
90    pub payload: serde_json::Value,
91    pub timestamp: DateTime<Utc>,
92    pub metadata: Option<serde_json::Value>,
93    pub version: i64,
94}
95
96impl From<&Event> for EventDto {
97    fn from(event: &Event) -> Self {
98        Self {
99            id: event.id(),
100            event_type: event.event_type().to_string(),
101            entity_id: event.entity_id().to_string(),
102            tenant_id: event.tenant_id().to_string(),
103            payload: event.payload().clone(),
104            timestamp: event.timestamp(),
105            metadata: event.metadata().cloned(),
106            version: event.version(),
107        }
108    }
109}
110
111impl From<Event> for EventDto {
112    fn from(event: Event) -> Self {
113        EventDto::from(&event)
114    }
115}
116
117/// Request parameters for listing entities
118#[derive(Debug, Default, Deserialize)]
119pub struct ListEntitiesRequest {
120    /// Filter entities by event type prefix
121    pub event_type_prefix: Option<String>,
122    /// Filter by payload fields (JSON string)
123    pub payload_filter: Option<String>,
124    /// Limit number of entities returned
125    pub limit: Option<usize>,
126    /// Offset for pagination
127    pub offset: Option<usize>,
128    /// Sort direction by last-event time: `desc` (newest activity first, the
129    /// default) or `asc` (oldest activity first). Entities with the same
130    /// last-event time are tie-broken by `entity_id` ascending so offset
131    /// pagination is stable.
132    pub order: Option<String>,
133}
134
135/// A single entity summary in the list response
136#[derive(Debug, Serialize)]
137pub struct EntitySummary {
138    pub entity_id: String,
139    pub event_count: usize,
140    pub last_event_type: String,
141    pub last_event_at: DateTime<Utc>,
142}
143
144/// Response from listing entities
145#[derive(Debug, Serialize)]
146pub struct ListEntitiesResponse {
147    pub entities: Vec<EntitySummary>,
148    pub total: usize,
149    pub has_more: bool,
150}
151
152/// Request parameters for detecting duplicate entities
153#[derive(Debug, Deserialize)]
154pub struct DetectDuplicatesRequest {
155    /// Required: event type prefix to scope the search (no full-store scans)
156    pub event_type_prefix: String,
157    /// Comma-separated list of payload field names to group by (e.g., "name,user_id")
158    pub group_by: String,
159    /// Limit number of duplicate groups returned
160    pub limit: Option<usize>,
161    /// Offset for pagination
162    pub offset: Option<usize>,
163}
164
165/// A group of entities that share the same payload field values
166#[derive(Debug, Serialize)]
167pub struct DuplicateGroup {
168    /// The shared field values that define this group
169    pub key: serde_json::Value,
170    /// Entity IDs in this group
171    pub entity_ids: Vec<String>,
172    /// Number of entities in this group
173    pub count: usize,
174}
175
176/// Response from duplicate entity detection
177#[derive(Debug, Serialize)]
178pub struct DetectDuplicatesResponse {
179    /// Groups where count > 1
180    pub duplicates: Vec<DuplicateGroup>,
181    /// Total number of duplicate groups found
182    pub total: usize,
183    /// Whether more results are available
184    pub has_more: bool,
185}
186
187/// DTO for batch ingesting multiple events
188#[derive(Debug, Deserialize)]
189pub struct IngestEventsBatchRequest {
190    pub events: Vec<IngestEventRequest>,
191}
192
193/// DTO for batch ingestion response
194#[derive(Debug, Serialize)]
195pub struct IngestEventsBatchResponse {
196    /// Total number of events submitted
197    pub total: usize,
198    /// Number of events successfully ingested
199    pub ingested: usize,
200    /// Individual results for each event
201    pub events: Vec<IngestEventResponse>,
202}
allsource_core/application/dto/event_dto.rs

allsource_core/application/dto/
event_dto.rs
