vkteams-bot 0.11.5

High-performance VK Teams Bot API toolkit with CLI and MCP server support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

//! Database models for VK Teams Bot events

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use uuid::Uuid;

#[cfg(feature = "database")]
use sqlx::FromRow;

#[cfg(feature = "vector-search")]
use pgvector::Vector;

/// Event record in the database
#[derive(Debug, Clone, Serialize, Deserialize)]
#[cfg_attr(feature = "database", derive(FromRow))]
pub struct Event {
    pub id: i64,
    pub event_id: String,
    pub event_type: String,
    pub chat_id: String,
    pub user_id: Option<String>,
    pub timestamp: DateTime<Utc>,
    pub raw_payload: serde_json::Value,
    pub processed_data: Option<serde_json::Value>,
    pub embedding_id: Option<Uuid>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

/// Message record with detailed information
#[derive(Debug, Clone, Serialize, Deserialize)]
#[cfg_attr(feature = "database", derive(FromRow))]
pub struct Message {
    pub id: i64,
    pub event_id: i64,
    pub message_id: String,
    pub chat_id: String,
    pub user_id: String,
    pub text: Option<String>,
    pub formatted_text: Option<String>,
    pub reply_to_message_id: Option<String>,
    pub forward_from_chat_id: Option<String>,
    pub forward_from_message_id: Option<String>,
    pub file_attachments: Option<serde_json::Value>,
    pub has_mentions: bool,
    pub mentions: Option<serde_json::Value>,
    pub timestamp: DateTime<Utc>,
    pub created_at: DateTime<Utc>,
}

/// Context record for MCP server
#[derive(Debug, Clone, Serialize, Deserialize)]
#[cfg_attr(feature = "database", derive(FromRow))]
pub struct Context {
    pub id: Uuid,
    pub chat_id: String,
    pub context_type: String,
    pub summary: String,
    pub key_points: Option<serde_json::Value>,
    pub related_events: Option<serde_json::Value>,
    pub relevance_score: f64,
    pub valid_until: Option<DateTime<Utc>>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

/// Embedding record for vector search
#[cfg(feature = "vector-search")]
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Embedding {
    pub id: Uuid,
    pub event_id: i64,
    pub content_type: String,
    pub text_content: String,
    pub embedding: Vector,
    pub metadata: Option<serde_json::Value>,
    pub created_at: DateTime<Utc>,
}

/// Statistics about stored events
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct EventStats {
    pub total_events: i64,
    pub total_messages: i64,
    pub unique_chats: i64,
    pub unique_users: i64,
    pub events_last_24h: i64,
    pub events_last_week: i64,
    pub oldest_event: Option<DateTime<Utc>>,
    pub newest_event: Option<DateTime<Utc>>,
    pub storage_size_bytes: Option<i64>,
}

/// Input structs for creating new records
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct NewEvent {
    pub event_id: String,
    pub event_type: String,
    pub chat_id: String,
    pub user_id: Option<String>,
    pub timestamp: DateTime<Utc>,
    pub raw_payload: serde_json::Value,
    pub processed_data: Option<serde_json::Value>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct NewMessage {
    pub event_id: i64,
    pub message_id: String,
    pub chat_id: String,
    pub user_id: String,
    pub text: Option<String>,
    pub formatted_text: Option<String>,
    pub reply_to_message_id: Option<String>,
    pub forward_from_chat_id: Option<String>,
    pub forward_from_message_id: Option<String>,
    pub file_attachments: Option<serde_json::Value>,
    pub has_mentions: bool,
    pub mentions: Option<serde_json::Value>,
    pub timestamp: DateTime<Utc>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct NewContext {
    pub chat_id: String,
    pub context_type: String,
    pub summary: String,
    pub key_points: Option<serde_json::Value>,
    pub related_events: Option<serde_json::Value>,
    pub relevance_score: f64,
    pub valid_until: Option<DateTime<Utc>>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct NewEmbedding {
    pub event_id: i64,
    pub content_type: String,
    pub text_content: String,
    pub embedding: Vec<f32>,
    pub metadata: Option<serde_json::Value>,
}