-
Notifications
You must be signed in to change notification settings - Fork 1
Example feedback plugins
Build:
cmake --preset linux-ninja-release && cmake --build --preset linux-ninja-release
This directory contains example implementations of feedback validation plugins for ThemisDB's LoRA continuous learning system.
The feedback system supports optional validation through plugins. Plugins can:
- Accept/reject/flag feedback
- Detect spam, PII, or low-quality content
- Add custom analytics data
- Modify feedback before storage
A standalone Python script that demonstrates:
- Spam keyword detection
- PII detection (email, phone, SSN, credit card)
- Quality scoring
- Plugin statistics
Usage:
# Validate feedback (reads JSON from stdin)
echo '{"question": "test", "answer": "test"}' | python3 feedback_validator.py validate
# Get statistics
python3 feedback_validator.py statsConfiguration (optional file: feedback_validator_config.json):
{
"spam_keywords": [
"buy now",
"click here",
"casino"
]
}Built-in C++ plugins:
-
NoOpFeedbackPlugin- No validation -
BasicSpamDetectionPlugin- Simple keyword matching
Usage in C++:
#include "llm/i_feedback_plugin.h"
#include "llm/feedback_store.h"
// Create plugin
auto plugin = std::make_shared<themis::llm::BasicSpamDetectionPlugin>();
// Configure
nlohmann::json config = {
{"spam_keywords", {"spam1", "spam2", "spam3"}}
};
plugin->initialize(config);
// Set plugin on feedback store
feedback_store->setValidationPlugin(plugin);
// All feedback will now be validated
auto feedback = /* create feedback */;
auto stored = feedback_store->createFeedback(feedback);- Copy
feedback_validator.pyas a template - Modify the
validate()method with your logic - Deploy the script alongside ThemisDB
- Configure ThemisDB to call your script
Script Interface:
Input (stdin):
{
"question": "User question",
"answer": "Model answer",
"correction": "User correction (optional)",
"comment": "User comment (optional)",
"user_id": "user123",
"adapter_id": "themis_help_lora_v2",
"is_positive": true,
"metadata": {}
}Output (stdout):
{
"result": "accept|reject|flag|modify",
"reason": "Optional reason",
"confidence": 0.95,
"plugin_data": {
"quality_score": 0.8,
"custom_field": "value"
}
}- Create a class that implements
themis::llm::IFeedbackPlugin - Implement required methods:
-
getName(),getVersion(),getDescription() initialize(config)validate(feedback)shutdown()
-
- Compile into a shared library or link statically
- Register plugin with FeedbackStore
Example:
class MyCustomPlugin : public themis::llm::IFeedbackPlugin {
public:
std::string getName() const override {
return "my_custom_plugin";
}
std::string getVersion() const override {
return "1.0.0";
}
std::string getDescription() const override {
return "My custom validation logic";
}
bool initialize(const nlohmann::json& config) override {
// Load configuration, models, etc.
return true;
}
ValidationResponse validate(const FeedbackData& feedback) override {
ValidationResponse response;
// Your validation logic here
if (/* some condition */) {
response.result = FeedbackValidationResult::REJECT;
response.reason = "Failed validation";
} else {
response.result = FeedbackValidationResult::ACCEPT;
}
response.confidence_score = 0.95f;
return response;
}
void shutdown() override {
// Cleanup
}
};# Test with sample feedback
cat > test_feedback.json <<EOF
{
"question": "How do I enable sharding?",
"answer": "Use SHARD BY clause",
"is_positive": true,
"user_id": "test_user",
"adapter_id": "test_adapter"
}
EOF
python3 feedback_validator.py validate < test_feedback.jsonTEST(MyPluginTest, BasicValidation) {
auto plugin = std::make_shared<MyCustomPlugin>();
nlohmann::json config = {/* config */};
ASSERT_TRUE(plugin->initialize(config));
themis::llm::FeedbackData feedback;
feedback.question = "test";
feedback.answer = "test";
auto result = plugin->validate(feedback);
EXPECT_EQ(result.result,
themis::llm::FeedbackValidationResult::ACCEPT);
plugin->shutdown();
}Detect and reject spam feedback using ML models or keyword matching.
Detect and redact personally identifiable information (PII) such as:
- Email addresses
- Phone numbers
- Social Security Numbers
- Credit card numbers
Assign quality scores to feedback based on:
- Length and completeness
- Grammar and spelling
- Relevance to the question
- User history
Filter inappropriate content:
- Profanity
- Hate speech
- Violent content
- NSFW material
Implement custom business logic:
- Only accept feedback from verified users
- Require minimum quality threshold
- Flag feedback for specific adapters
- Apply different rules by user role
- Keep validation fast: Validation runs synchronously during feedback submission
-
Cache ML models: Load models once in
initialize(), not per validation - Use async for expensive checks: Consider post-storage hooks for heavy processing
- Profile your plugin: Measure validation time and optimize bottlenecks
- Accept by default: Only reject when confident
- Provide clear reasons: Help users understand rejections
- Use confidence scores: Express uncertainty in your decisions
- Log important events: Use logging for debugging and monitoring
- Handle errors gracefully: Don't crash on unexpected input
- Test thoroughly: Test with edge cases and malformed input
- Feedback Plugin Interface Documentation
- Feedback API Documentation
- Plugin Interface Header
- LoRA Graph Documentation
ThemisDB 1.9.0-beta Β· Home Β· Module-Index Β· GitHub Β· Issues
ThemisDB 1.9.0-beta Β· Home Β· Wiki-Index Β· Module-Index Β· FAQ Β· Quick-Reference Β· GitHub Β· Issues Β· Discussions Β· License
- Batch Operations
- Best Practices
- CRUD Tutorial
- Custom Document Ingestion
- Getting Started Tutorial
- Interactive Examples
- Schema Design
- Video Tutorials
- AQL Reference
- AQL Examples
- AQL Overview
- AQL Feature Roadmap
- AQL Geospatial Guide
- AQL LLM Migration Guide
- AQL API
- AQL Grammar (EBNF)
- AQL Root Overview
- AQL Examples (root)
- API Reference
- API Module README
- OpenAPI Overview
- Client SDK Overview
- SDK Overview
- Operations
- Operations Overview
- Operations Runbook
- Operations Handbook
- ThemisCtl Admin Guide
- Pipeline E2E SOPs
- Deploy Overview
- Docker Overview
- Docker Hub README
- Helm Overview
- Packaging Overview
- Operator Overview
- Security Policy
- Production Hardening Checklist
- Security Hardening Guide
- Encryption Key Management
- Access Control Framework
- Zero Trust Policy
- API Authentication & Authorization
- HSM Production Setup
- PKCS11 Integration
- DSGVO / SOC2 Checklist
- Access Model Runbooks
- Access Model Dashboard
- Maturity Automation Runbook
- Access Review Automation
- Access Model Dashboard
- Access Model Runbooks
- Rights Revocation
- Dr Checklists
- Dr Testing
- Incident Response Playbook
- Incident Response Testing
- GPU Oom Recovery
- Grammar Debugging
- Metrics Scrape Troubleshooting
- Model Swap Procedure
- Quota Tuning
- Subagent Deployment
- Logging Configuration
- Content Model
- Crypto & Keys
- Feature Flags Reference
- Modular Architecture Roadmap
- Modularization Guide
- Module Architecture Index
- PostgreSQL Wire Protocol
- Query Scheduling
- Raft Consensus Design
- Resource Pooling
- Source Directory Guide
- Unified Access Model
- E1 001 Layered Retrieval Design
- E1 002 Ann Abstraction Strategy
- E1 003 Tensor Summary Types
- E1 004 Lora Package Distinction
- E1 005 Model Switch Compatibility
- E1 006 Federated Tensor Summaries
- E2 001 Evaluation Framework Design
- E2 002 Hardware Profile Strategy
- E2 003 Query Planner Routing Model
- E2 004 Approximation Governance Rules
- E2 005 Cross Layer Fallback Confidence Policy
- E3 001 Distributed Tensor Design
- E3 002 Manifest Coordination Strategy
- E3 003 Recovery And Erasure Choice
- E3 004 Tensor Fabric Infrastructure
- Contributing
- Contributing (root)
- Code of Conduct
- Support
- Maintainers
- CTest Guide
- Build Quick Reference
- Developer Wiki Index
- Build / Test / CI
- Module Index
- Branching Strategy
- Disabled Stub Policy
- Docs PR Policy
- GA Promotion Sign Off
- Github Milestones Setup
- Maturity Claim Verification Checklist
- Maturity Evidence Registry
- Merge Gate Bot Config
- Merge Gate Status Live
- Phase 1 Closure Report
- Phase Closure Policy
- Phase Dependency Graph
- Phase3 Enforcement Runbook
- Plugin Submodule Rollback
- PR Version Targeting
- PR Version Targeting Backfill
- Production Ready 2026 Delivery Plan
- Query Module Status
- Readme
- Release Promotion Gate Policy
- Release Validation Checklist
- Security Module 5671 Evidence Summary
- Sharding P6 Residual Risk Acceptance
- Sourcecode Compliance Governance
- Updates Development Status Sign Off
- Wave C Implementation Complete
- Blob Storage
- Cuda
- Ethics Ai
- Exporters
- Huggingface
- Image Analysis
- Importers
- RPC
- Scraper
- Themisdb Ai Watermark Detector
- User Storage Encrypted
- Chimera Architecture
- Chimera Future
- Chimera Readme
- Chimera Roadmap
- Covina Fastapi Ingestion Architecture
- Covina Fastapi Ingestion Future
- Covina Fastapi Ingestion Roadmap
- Vcc Base Architecture
- Vcc Base Future
- Vcc Base Roadmap
- Vcc Clara Ingestion Architecture
- Vcc Clara Ingestion Future
- Vcc Clara Ingestion Roadmap
- Vcc Veritas Architecture
- Vcc Veritas Future
- Vcc Veritas Roadmap
- 01 Hello World
- 02 Todo App
- 03 Contact Manager
- 04 Inventory System
- 05 Time Series Monitor
- 06 Graph Social Network
- 07 Vector Search Documents
- 08 Dms Erp System
- 09 Iot Sensor Network
- 10 Drone Image Analysis
- 11 Blog Wiki
- 12 Expense Tracker
- 13 Recipe Manager
- 14 Ecommerce Catalog
- 15 Event Management
- 16 Kanban Board
- 17 Crm
- 18 Realtime Chat
- 19 Recommendation Engine
- 20 Smart Home
- 21 Coding Platform
- 22 AQL Diagram Tool
- 23 Traveling Salesman
- 24 Moral Philosophy Debates
- API Versioning
- Distributed Sharding
- Feedback Plugins
- Geo
- Gnn
- Image Analysis
- Legal Lora Training
- LLM
- Lora Sync
- Migration
- Nlp
- Performance
- Railway
- Replication
- Rope Visualization
- Sample Product Config
- Security
- Client SDK Overview
- Quickstart
- Sdk Enhancements
- Sdk Implementation Summary
- Test Suite Readme
- Go
- Java
- Javascript
- Php
- Python
- Ruby
- Rust
- Typescript
- 01 Grundlegende Operationen
- 02 AQL Queries
- 03 Graph Daten
- 04 Multimodell Anwendung
- 01 Quickstart Guide
- 02 AQL Referenz Kurzuebersicht
- 03 Datenmodellierung Guide
- 04 Uebungsaufgaben
- 05 Best Practices Guide
- Training Documents
- Training Overview
- 01 Einfuehrung Und Uebersicht
- 02 Datenmodelle Und Architektur
- 03 AQL Abfragesprache
- 04 Installation Und Setup
- 05 Anwendungsbeispiele
- Training Presentations
- Dependencies Readme
- Processmonitor Readme
- Themis.admintools.shared Readme
- Themis.aqlquerybuilder Readme
- Themis.aqlquerybuilder Roadmap
- Themis.auditlogviewer Readme
- Themis.auditlogviewer Roadmap
- Themis.classificationdashboard Readme
- Themis.classificationdashboard Roadmap
- Themis.compliancereports Readme
- Themis.compliancereports Roadmap
- Themis.gisviewer.controlpanel Readme
- Themis.gisviewer.controlpanel Roadmap
- Themis.impactanalysisviewer Readme
- Themis.impactanalysisviewer Roadmap
- Themis.ingestiontool Readme
- Themis.ingestiontool Roadmap
- Themis.keyrotationdashboard Readme
- Themis.keyrotationdashboard Roadmap
- Themis.piimanager Readme
- Themis.piimanager Roadmap
- Themis.retentionmanager Readme
- Themis.retentionmanager Roadmap
- Themis.sagaverifier Readme
- Themis.sagaverifier Roadmap
- Themis.usbadmintool Readme
- Themis.usbadmintool Roadmap
- CI Readme
- CI Roadmap
- Compiler Diagnostics Readme
- Compiler Diagnostics Roadmap
- Completion Readme
- Copilot Ollama Router Readme
- Copilot Ollama Router Roadmap
- Gnn Readme
- Gnn Roadmap
- Rope Visualizer Readme
- Rope Visualizer Roadmap
- Tco Calculator Readme
- Tco Calculator Roadmap
- Tests Readme
- Tests Roadmap
- Themis Config Wx Readme
- Themis Docs Builder Readme
- Wikipedia Ingestion Readme