e297b98f72
* Add event data structures This adds the data structures required to start syncing events, rather than syncing history directly. Adjust event Fix Add event data structure to client * Add server event table sql * Add client event table migration Adjust migration * Insert into event table from client * Add event merge function Right now this just ensures we have the right amount of events given the history we have BUT it will also be used to merge CREATE/DELETE events, resulting in history being deleted :) * Make CI happy * Adjust * we don't limit history length any more * Update atuin-client/src/database.rs Co-authored-by: Conrad Ludgate <conradludgate@gmail.com> * fix usage * Fix typo * New Rust, new clippy stuff Co-authored-by: Conrad Ludgate <conradludgate@gmail.com>
96 lines
2.2 KiB
Rust
96 lines
2.2 KiB
Rust
use chrono::Utc;
|
|
use serde::{Deserialize, Serialize};
|
|
use std::borrow::Cow;
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct UserResponse {
|
|
pub username: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct RegisterRequest {
|
|
pub email: String,
|
|
pub username: String,
|
|
pub password: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct RegisterResponse {
|
|
pub session: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct LoginRequest {
|
|
pub username: String,
|
|
pub password: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct LoginResponse {
|
|
pub session: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct AddHistoryRequest {
|
|
pub id: String,
|
|
pub timestamp: chrono::DateTime<Utc>,
|
|
pub data: String,
|
|
pub hostname: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct CountResponse {
|
|
pub count: i64,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct SyncHistoryRequest {
|
|
pub sync_ts: chrono::DateTime<chrono::FixedOffset>,
|
|
pub history_ts: chrono::DateTime<chrono::FixedOffset>,
|
|
pub host: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct SyncHistoryResponse {
|
|
pub history: Vec<String>,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct ErrorResponse<'a> {
|
|
pub reason: Cow<'a, str>,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct IndexResponse {
|
|
pub homage: String,
|
|
pub version: String,
|
|
}
|
|
|
|
// Doubled up with the history sync stuff, because atm we need to support BOTH.
|
|
// People are still running old clients, and in some cases _very_ old clients.
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub enum AddEventRequest {
|
|
Create(AddHistoryRequest),
|
|
|
|
Delete {
|
|
id: String,
|
|
timestamp: chrono::DateTime<Utc>,
|
|
hostname: chrono::DateTime<Utc>,
|
|
|
|
// When we delete a history item, we push up an event marking its client
|
|
// id as being deleted.
|
|
history_id: String,
|
|
},
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct SyncEventRequest {
|
|
pub sync_ts: chrono::DateTime<chrono::FixedOffset>,
|
|
pub event_ts: chrono::DateTime<chrono::FixedOffset>,
|
|
pub host: String,
|
|
}
|
|
|
|
#[derive(Debug, Serialize, Deserialize)]
|
|
pub struct SyncEventResponse {
|
|
pub events: Vec<String>,
|
|
}
|