Compare commits
2 Commits
mai/linus/
...
118bae1ae3
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
118bae1ae3 | ||
|
|
34dcbb74fe |
@@ -5,9 +5,6 @@ import (
|
|||||||
"net/http"
|
"net/http"
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
"github.com/jmoiron/sqlx"
|
|
||||||
_ "github.com/lib/pq"
|
|
||||||
|
|
||||||
"mgit.msbls.de/m/KanzlAI-mGMT/internal/auth"
|
"mgit.msbls.de/m/KanzlAI-mGMT/internal/auth"
|
||||||
"mgit.msbls.de/m/KanzlAI-mGMT/internal/config"
|
"mgit.msbls.de/m/KanzlAI-mGMT/internal/config"
|
||||||
"mgit.msbls.de/m/KanzlAI-mGMT/internal/db"
|
"mgit.msbls.de/m/KanzlAI-mGMT/internal/db"
|
||||||
@@ -34,21 +31,6 @@ func main() {
|
|||||||
|
|
||||||
authMW := auth.NewMiddleware(cfg.SupabaseJWTSecret, database)
|
authMW := auth.NewMiddleware(cfg.SupabaseJWTSecret, database)
|
||||||
|
|
||||||
// Optional: connect to youpc.org database for similar case finder
|
|
||||||
var youpcDB *sqlx.DB
|
|
||||||
if cfg.YouPCDatabaseURL != "" {
|
|
||||||
youpcDB, err = sqlx.Connect("postgres", cfg.YouPCDatabaseURL)
|
|
||||||
if err != nil {
|
|
||||||
slog.Warn("failed to connect to youpc.org database — similar case finder disabled", "error", err)
|
|
||||||
youpcDB = nil
|
|
||||||
} else {
|
|
||||||
youpcDB.SetMaxOpenConns(5)
|
|
||||||
youpcDB.SetMaxIdleConns(2)
|
|
||||||
defer youpcDB.Close()
|
|
||||||
slog.Info("connected to youpc.org database for similar case finder")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Start CalDAV sync service
|
// Start CalDAV sync service
|
||||||
calDAVSvc := services.NewCalDAVService(database)
|
calDAVSvc := services.NewCalDAVService(database)
|
||||||
calDAVSvc.Start()
|
calDAVSvc.Start()
|
||||||
@@ -59,7 +41,7 @@ func main() {
|
|||||||
notifSvc.Start()
|
notifSvc.Start()
|
||||||
defer notifSvc.Stop()
|
defer notifSvc.Stop()
|
||||||
|
|
||||||
handler := router.New(database, authMW, cfg, calDAVSvc, notifSvc, youpcDB)
|
handler := router.New(database, authMW, cfg, calDAVSvc, notifSvc)
|
||||||
|
|
||||||
slog.Info("starting KanzlAI API server", "port", cfg.Port)
|
slog.Info("starting KanzlAI API server", "port", cfg.Port)
|
||||||
if err := http.ListenAndServe(":"+cfg.Port, handler); err != nil {
|
if err := http.ListenAndServe(":"+cfg.Port, handler); err != nil {
|
||||||
|
|||||||
@@ -43,7 +43,7 @@ func (m *Middleware) RequireAuth(next http.Handler) http.Handler {
|
|||||||
}
|
}
|
||||||
ctx = ContextWithRequestInfo(ctx, ip, r.UserAgent())
|
ctx = ContextWithRequestInfo(ctx, ip, r.UserAgent())
|
||||||
|
|
||||||
// Tenant resolution is handled by TenantResolver middleware for scoped routes.
|
// Tenant/role resolution is handled by TenantResolver middleware for scoped routes.
|
||||||
// Tenant management routes handle their own access control.
|
// Tenant management routes handle their own access control.
|
||||||
next.ServeHTTP(w, r.WithContext(ctx))
|
next.ServeHTTP(w, r.WithContext(ctx))
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -12,7 +12,6 @@ import (
|
|||||||
// Defined as an interface to avoid circular dependency with services.
|
// Defined as an interface to avoid circular dependency with services.
|
||||||
type TenantLookup interface {
|
type TenantLookup interface {
|
||||||
FirstTenantForUser(ctx context.Context, userID uuid.UUID) (*uuid.UUID, error)
|
FirstTenantForUser(ctx context.Context, userID uuid.UUID) (*uuid.UUID, error)
|
||||||
VerifyAccess(ctx context.Context, userID, tenantID uuid.UUID) (bool, error)
|
|
||||||
GetUserRole(ctx context.Context, userID, tenantID uuid.UUID) (string, error)
|
GetUserRole(ctx context.Context, userID, tenantID uuid.UUID) (string, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -42,7 +41,6 @@ func (tr *TenantResolver) Resolve(next http.Handler) http.Handler {
|
|||||||
http.Error(w, `{"error":"invalid X-Tenant-ID"}`, http.StatusBadRequest)
|
http.Error(w, `{"error":"invalid X-Tenant-ID"}`, http.StatusBadRequest)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
// Verify user has access and get their role
|
// Verify user has access and get their role
|
||||||
role, err := tr.lookup.GetUserRole(r.Context(), userID, parsed)
|
role, err := tr.lookup.GetUserRole(r.Context(), userID, parsed)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -58,7 +56,7 @@ func (tr *TenantResolver) Resolve(next http.Handler) http.Handler {
|
|||||||
tenantID = parsed
|
tenantID = parsed
|
||||||
r = r.WithContext(ContextWithUserRole(r.Context(), role))
|
r = r.WithContext(ContextWithUserRole(r.Context(), role))
|
||||||
} else {
|
} else {
|
||||||
// Default to user's first tenant (role already set by middleware)
|
// Default to user's first tenant
|
||||||
first, err := tr.lookup.FirstTenantForUser(r.Context(), userID)
|
first, err := tr.lookup.FirstTenantForUser(r.Context(), userID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
slog.Error("failed to resolve default tenant", "error", err, "user_id", userID)
|
slog.Error("failed to resolve default tenant", "error", err, "user_id", userID)
|
||||||
@@ -70,6 +68,15 @@ func (tr *TenantResolver) Resolve(next http.Handler) http.Handler {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
tenantID = *first
|
tenantID = *first
|
||||||
|
|
||||||
|
// Resolve role for default tenant
|
||||||
|
role, err := tr.lookup.GetUserRole(r.Context(), userID, tenantID)
|
||||||
|
if err != nil {
|
||||||
|
slog.Error("failed to resolve role for default tenant", "error", err)
|
||||||
|
http.Error(w, `{"error":"internal error"}`, http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
r = r.WithContext(ContextWithUserRole(r.Context(), role))
|
||||||
}
|
}
|
||||||
|
|
||||||
ctx := ContextWithTenantID(r.Context(), tenantID)
|
ctx := ContextWithTenantID(r.Context(), tenantID)
|
||||||
|
|||||||
@@ -11,26 +11,17 @@ import (
|
|||||||
|
|
||||||
type mockTenantLookup struct {
|
type mockTenantLookup struct {
|
||||||
tenantID *uuid.UUID
|
tenantID *uuid.UUID
|
||||||
err error
|
|
||||||
hasAccess bool
|
|
||||||
accessErr error
|
|
||||||
role string
|
role string
|
||||||
noAccess bool // when true, GetUserRole returns ""
|
roleSet bool // true means role was explicitly set (even if empty)
|
||||||
|
err error
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *mockTenantLookup) FirstTenantForUser(ctx context.Context, userID uuid.UUID) (*uuid.UUID, error) {
|
func (m *mockTenantLookup) FirstTenantForUser(ctx context.Context, userID uuid.UUID) (*uuid.UUID, error) {
|
||||||
return m.tenantID, m.err
|
return m.tenantID, m.err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (m *mockTenantLookup) VerifyAccess(ctx context.Context, userID, tenantID uuid.UUID) (bool, error) {
|
|
||||||
return m.hasAccess, m.accessErr
|
|
||||||
}
|
|
||||||
|
|
||||||
func (m *mockTenantLookup) GetUserRole(ctx context.Context, userID, tenantID uuid.UUID) (string, error) {
|
func (m *mockTenantLookup) GetUserRole(ctx context.Context, userID, tenantID uuid.UUID) (string, error) {
|
||||||
if m.noAccess {
|
if m.roleSet {
|
||||||
return "", m.err
|
|
||||||
}
|
|
||||||
if m.role != "" {
|
|
||||||
return m.role, m.err
|
return m.role, m.err
|
||||||
}
|
}
|
||||||
return "associate", m.err
|
return "associate", m.err
|
||||||
@@ -38,7 +29,7 @@ func (m *mockTenantLookup) GetUserRole(ctx context.Context, userID, tenantID uui
|
|||||||
|
|
||||||
func TestTenantResolver_FromHeader(t *testing.T) {
|
func TestTenantResolver_FromHeader(t *testing.T) {
|
||||||
tenantID := uuid.New()
|
tenantID := uuid.New()
|
||||||
tr := NewTenantResolver(&mockTenantLookup{role: "partner", hasAccess: true})
|
tr := NewTenantResolver(&mockTenantLookup{role: "partner"})
|
||||||
|
|
||||||
var gotTenantID uuid.UUID
|
var gotTenantID uuid.UUID
|
||||||
next := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
next := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
@@ -67,7 +58,7 @@ func TestTenantResolver_FromHeader(t *testing.T) {
|
|||||||
|
|
||||||
func TestTenantResolver_FromHeader_NoAccess(t *testing.T) {
|
func TestTenantResolver_FromHeader_NoAccess(t *testing.T) {
|
||||||
tenantID := uuid.New()
|
tenantID := uuid.New()
|
||||||
tr := NewTenantResolver(&mockTenantLookup{noAccess: true})
|
tr := NewTenantResolver(&mockTenantLookup{role: "", roleSet: true})
|
||||||
|
|
||||||
next := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
next := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
t.Fatal("next should not be called")
|
t.Fatal("next should not be called")
|
||||||
@@ -87,7 +78,7 @@ func TestTenantResolver_FromHeader_NoAccess(t *testing.T) {
|
|||||||
|
|
||||||
func TestTenantResolver_DefaultsToFirst(t *testing.T) {
|
func TestTenantResolver_DefaultsToFirst(t *testing.T) {
|
||||||
tenantID := uuid.New()
|
tenantID := uuid.New()
|
||||||
tr := NewTenantResolver(&mockTenantLookup{tenantID: &tenantID})
|
tr := NewTenantResolver(&mockTenantLookup{tenantID: &tenantID, role: "owner"})
|
||||||
|
|
||||||
var gotTenantID uuid.UUID
|
var gotTenantID uuid.UUID
|
||||||
next := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
next := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
|
|||||||
@@ -14,7 +14,6 @@ type Config struct {
|
|||||||
SupabaseJWTSecret string
|
SupabaseJWTSecret string
|
||||||
AnthropicAPIKey string
|
AnthropicAPIKey string
|
||||||
FrontendOrigin string
|
FrontendOrigin string
|
||||||
YouPCDatabaseURL string // read-only connection to youpc.org Supabase for similar case finder
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func Load() (*Config, error) {
|
func Load() (*Config, error) {
|
||||||
@@ -27,7 +26,6 @@ func Load() (*Config, error) {
|
|||||||
SupabaseJWTSecret: os.Getenv("SUPABASE_JWT_SECRET"),
|
SupabaseJWTSecret: os.Getenv("SUPABASE_JWT_SECRET"),
|
||||||
AnthropicAPIKey: os.Getenv("ANTHROPIC_API_KEY"),
|
AnthropicAPIKey: os.Getenv("ANTHROPIC_API_KEY"),
|
||||||
FrontendOrigin: getEnv("FRONTEND_ORIGIN", "https://kanzlai.msbls.de"),
|
FrontendOrigin: getEnv("FRONTEND_ORIGIN", "https://kanzlai.msbls.de"),
|
||||||
YouPCDatabaseURL: os.Getenv("YOUPC_DATABASE_URL"),
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if cfg.DatabaseURL == "" {
|
if cfg.DatabaseURL == "" {
|
||||||
|
|||||||
@@ -5,8 +5,6 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"net/http"
|
"net/http"
|
||||||
|
|
||||||
"github.com/google/uuid"
|
|
||||||
|
|
||||||
"mgit.msbls.de/m/KanzlAI-mGMT/internal/auth"
|
"mgit.msbls.de/m/KanzlAI-mGMT/internal/auth"
|
||||||
"mgit.msbls.de/m/KanzlAI-mGMT/internal/services"
|
"mgit.msbls.de/m/KanzlAI-mGMT/internal/services"
|
||||||
)
|
)
|
||||||
@@ -117,139 +115,3 @@ func (h *AIHandler) SummarizeCase(w http.ResponseWriter, r *http.Request) {
|
|||||||
"summary": summary,
|
"summary": summary,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
// DraftDocument handles POST /api/ai/draft-document
|
|
||||||
// Accepts JSON {"case_id": "uuid", "template_type": "string", "instructions": "string", "language": "de|en|fr"}.
|
|
||||||
func (h *AIHandler) DraftDocument(w http.ResponseWriter, r *http.Request) {
|
|
||||||
tenantID, ok := auth.TenantFromContext(r.Context())
|
|
||||||
if !ok {
|
|
||||||
writeError(w, http.StatusForbidden, "missing tenant")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var body struct {
|
|
||||||
CaseID string `json:"case_id"`
|
|
||||||
TemplateType string `json:"template_type"`
|
|
||||||
Instructions string `json:"instructions"`
|
|
||||||
Language string `json:"language"`
|
|
||||||
}
|
|
||||||
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
|
||||||
writeError(w, http.StatusBadRequest, "invalid request body")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if body.CaseID == "" {
|
|
||||||
writeError(w, http.StatusBadRequest, "case_id is required")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if body.TemplateType == "" {
|
|
||||||
writeError(w, http.StatusBadRequest, "template_type is required")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
caseID, err := parseUUID(body.CaseID)
|
|
||||||
if err != nil {
|
|
||||||
writeError(w, http.StatusBadRequest, "invalid case_id")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(body.Instructions) > maxDescriptionLen {
|
|
||||||
writeError(w, http.StatusBadRequest, "instructions exceeds maximum length")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
draft, err := h.ai.DraftDocument(r.Context(), tenantID, caseID, body.TemplateType, body.Instructions, body.Language)
|
|
||||||
if err != nil {
|
|
||||||
internalError(w, "AI document drafting failed", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
writeJSON(w, http.StatusOK, draft)
|
|
||||||
}
|
|
||||||
|
|
||||||
// CaseStrategy handles POST /api/ai/case-strategy
|
|
||||||
// Accepts JSON {"case_id": "uuid"}.
|
|
||||||
func (h *AIHandler) CaseStrategy(w http.ResponseWriter, r *http.Request) {
|
|
||||||
tenantID, ok := auth.TenantFromContext(r.Context())
|
|
||||||
if !ok {
|
|
||||||
writeError(w, http.StatusForbidden, "missing tenant")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var body struct {
|
|
||||||
CaseID string `json:"case_id"`
|
|
||||||
}
|
|
||||||
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
|
||||||
writeError(w, http.StatusBadRequest, "invalid request body")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if body.CaseID == "" {
|
|
||||||
writeError(w, http.StatusBadRequest, "case_id is required")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
caseID, err := parseUUID(body.CaseID)
|
|
||||||
if err != nil {
|
|
||||||
writeError(w, http.StatusBadRequest, "invalid case_id")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
strategy, err := h.ai.CaseStrategy(r.Context(), tenantID, caseID)
|
|
||||||
if err != nil {
|
|
||||||
internalError(w, "AI case strategy analysis failed", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
writeJSON(w, http.StatusOK, strategy)
|
|
||||||
}
|
|
||||||
|
|
||||||
// SimilarCases handles POST /api/ai/similar-cases
|
|
||||||
// Accepts JSON {"case_id": "uuid", "description": "string"}.
|
|
||||||
func (h *AIHandler) SimilarCases(w http.ResponseWriter, r *http.Request) {
|
|
||||||
tenantID, ok := auth.TenantFromContext(r.Context())
|
|
||||||
if !ok {
|
|
||||||
writeError(w, http.StatusForbidden, "missing tenant")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var body struct {
|
|
||||||
CaseID string `json:"case_id"`
|
|
||||||
Description string `json:"description"`
|
|
||||||
}
|
|
||||||
if err := json.NewDecoder(r.Body).Decode(&body); err != nil {
|
|
||||||
writeError(w, http.StatusBadRequest, "invalid request body")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if body.CaseID == "" && body.Description == "" {
|
|
||||||
writeError(w, http.StatusBadRequest, "either case_id or description is required")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(body.Description) > maxDescriptionLen {
|
|
||||||
writeError(w, http.StatusBadRequest, "description exceeds maximum length")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
var caseID uuid.UUID
|
|
||||||
if body.CaseID != "" {
|
|
||||||
var err error
|
|
||||||
caseID, err = parseUUID(body.CaseID)
|
|
||||||
if err != nil {
|
|
||||||
writeError(w, http.StatusBadRequest, "invalid case_id")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
cases, err := h.ai.FindSimilarCases(r.Context(), tenantID, caseID, body.Description)
|
|
||||||
if err != nil {
|
|
||||||
internalError(w, "AI similar case search failed", err)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
writeJSON(w, http.StatusOK, map[string]any{
|
|
||||||
"cases": cases,
|
|
||||||
"count": len(cases),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -356,6 +356,71 @@ func (h *TenantHandler) UpdateMemberRole(w http.ResponseWriter, r *http.Request)
|
|||||||
jsonResponse(w, map[string]string{"status": "updated"}, http.StatusOK)
|
jsonResponse(w, map[string]string{"status": "updated"}, http.StatusOK)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// AutoAssign handles POST /api/tenants/auto-assign — checks if the user's email domain
|
||||||
|
// matches any tenant's auto_assign_domains and assigns them if so.
|
||||||
|
func (h *TenantHandler) AutoAssign(w http.ResponseWriter, r *http.Request) {
|
||||||
|
userID, ok := auth.UserFromContext(r.Context())
|
||||||
|
if !ok {
|
||||||
|
http.Error(w, "unauthorized", http.StatusUnauthorized)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
var req struct {
|
||||||
|
Email string `json:"email"`
|
||||||
|
}
|
||||||
|
if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
|
||||||
|
jsonError(w, "invalid request body", http.StatusBadRequest)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if req.Email == "" {
|
||||||
|
jsonError(w, "email is required", http.StatusBadRequest)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// Extract domain from email
|
||||||
|
parts := splitEmail(req.Email)
|
||||||
|
if parts == "" {
|
||||||
|
jsonError(w, "invalid email format", http.StatusBadRequest)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
result, err := h.svc.AutoAssignByDomain(r.Context(), userID, parts)
|
||||||
|
if err != nil {
|
||||||
|
slog.Error("auto-assign failed", "error", err)
|
||||||
|
jsonError(w, "internal error", http.StatusInternalServerError)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if result == nil {
|
||||||
|
jsonResponse(w, map[string]any{"assigned": false}, http.StatusOK)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
jsonResponse(w, map[string]any{
|
||||||
|
"assigned": true,
|
||||||
|
"tenant_id": result.ID,
|
||||||
|
"name": result.Name,
|
||||||
|
"slug": result.Slug,
|
||||||
|
"role": result.Role,
|
||||||
|
"settings": result.Settings,
|
||||||
|
}, http.StatusOK)
|
||||||
|
}
|
||||||
|
|
||||||
|
// splitEmail extracts the domain part from an email address.
|
||||||
|
func splitEmail(email string) string {
|
||||||
|
at := -1
|
||||||
|
for i, c := range email {
|
||||||
|
if c == '@' {
|
||||||
|
at = i
|
||||||
|
break
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if at < 0 || at >= len(email)-1 {
|
||||||
|
return ""
|
||||||
|
}
|
||||||
|
return email[at+1:]
|
||||||
|
}
|
||||||
|
|
||||||
// GetMe handles GET /api/me — returns the current user's ID and role in the active tenant.
|
// GetMe handles GET /api/me — returns the current user's ID and role in the active tenant.
|
||||||
func (h *TenantHandler) GetMe(w http.ResponseWriter, r *http.Request) {
|
func (h *TenantHandler) GetMe(w http.ResponseWriter, r *http.Request) {
|
||||||
userID, ok := auth.UserFromContext(r.Context())
|
userID, ok := auth.UserFromContext(r.Context())
|
||||||
@@ -370,11 +435,26 @@ func (h *TenantHandler) GetMe(w http.ResponseWriter, r *http.Request) {
|
|||||||
// Get user's permissions for frontend UI
|
// Get user's permissions for frontend UI
|
||||||
perms := auth.GetRolePermissions(role)
|
perms := auth.GetRolePermissions(role)
|
||||||
|
|
||||||
|
// Check if tenant is in demo mode
|
||||||
|
isDemo := false
|
||||||
|
if tenant, err := h.svc.GetByID(r.Context(), tenantID); err == nil && tenant != nil {
|
||||||
|
var settings map[string]json.RawMessage
|
||||||
|
if json.Unmarshal(tenant.Settings, &settings) == nil {
|
||||||
|
if demoRaw, ok := settings["demo"]; ok {
|
||||||
|
var demo bool
|
||||||
|
if json.Unmarshal(demoRaw, &demo) == nil {
|
||||||
|
isDemo = demo
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
jsonResponse(w, map[string]any{
|
jsonResponse(w, map[string]any{
|
||||||
"user_id": userID,
|
"user_id": userID,
|
||||||
"tenant_id": tenantID,
|
"tenant_id": tenantID,
|
||||||
"role": role,
|
"role": role,
|
||||||
"permissions": perms,
|
"permissions": perms,
|
||||||
|
"is_demo": isDemo,
|
||||||
}, http.StatusOK)
|
}, http.StatusOK)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ import (
|
|||||||
"mgit.msbls.de/m/KanzlAI-mGMT/internal/services"
|
"mgit.msbls.de/m/KanzlAI-mGMT/internal/services"
|
||||||
)
|
)
|
||||||
|
|
||||||
func New(db *sqlx.DB, authMW *auth.Middleware, cfg *config.Config, calDAVSvc *services.CalDAVService, notifSvc *services.NotificationService, youpcDB ...*sqlx.DB) http.Handler {
|
func New(db *sqlx.DB, authMW *auth.Middleware, cfg *config.Config, calDAVSvc *services.CalDAVService, notifSvc *services.NotificationService) http.Handler {
|
||||||
mux := http.NewServeMux()
|
mux := http.NewServeMux()
|
||||||
|
|
||||||
// Services
|
// Services
|
||||||
@@ -35,11 +35,7 @@ func New(db *sqlx.DB, authMW *auth.Middleware, cfg *config.Config, calDAVSvc *se
|
|||||||
// AI service (optional — only if API key is configured)
|
// AI service (optional — only if API key is configured)
|
||||||
var aiH *handlers.AIHandler
|
var aiH *handlers.AIHandler
|
||||||
if cfg.AnthropicAPIKey != "" {
|
if cfg.AnthropicAPIKey != "" {
|
||||||
var ydb *sqlx.DB
|
aiSvc := services.NewAIService(cfg.AnthropicAPIKey, db)
|
||||||
if len(youpcDB) > 0 {
|
|
||||||
ydb = youpcDB[0]
|
|
||||||
}
|
|
||||||
aiSvc := services.NewAIService(cfg.AnthropicAPIKey, db, ydb)
|
|
||||||
aiH = handlers.NewAIHandler(aiSvc)
|
aiH = handlers.NewAIHandler(aiSvc)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -77,6 +73,7 @@ func New(db *sqlx.DB, authMW *auth.Middleware, cfg *config.Config, calDAVSvc *se
|
|||||||
api := http.NewServeMux()
|
api := http.NewServeMux()
|
||||||
|
|
||||||
// Tenant management (no tenant resolver — these operate across tenants)
|
// Tenant management (no tenant resolver — these operate across tenants)
|
||||||
|
api.HandleFunc("POST /api/tenants/auto-assign", tenantH.AutoAssign)
|
||||||
api.HandleFunc("POST /api/tenants", tenantH.CreateTenant)
|
api.HandleFunc("POST /api/tenants", tenantH.CreateTenant)
|
||||||
api.HandleFunc("GET /api/tenants", tenantH.ListTenants)
|
api.HandleFunc("GET /api/tenants", tenantH.ListTenants)
|
||||||
api.HandleFunc("GET /api/tenants/{id}", tenantH.GetTenant)
|
api.HandleFunc("GET /api/tenants/{id}", tenantH.GetTenant)
|
||||||
@@ -161,7 +158,7 @@ func New(db *sqlx.DB, authMW *auth.Middleware, cfg *config.Config, calDAVSvc *se
|
|||||||
scoped.HandleFunc("GET /api/dashboard", dashboardH.Get)
|
scoped.HandleFunc("GET /api/dashboard", dashboardH.Get)
|
||||||
|
|
||||||
// Audit log
|
// Audit log
|
||||||
scoped.HandleFunc("GET /api/audit-log", auditH.List)
|
scoped.HandleFunc("GET /api/audit-log", perm(auth.PermViewAuditLog, auditH.List))
|
||||||
|
|
||||||
// Documents — all can upload, delete checked in handler (own vs all)
|
// Documents — all can upload, delete checked in handler (own vs all)
|
||||||
scoped.HandleFunc("GET /api/cases/{id}/documents", docH.ListByCase)
|
scoped.HandleFunc("GET /api/cases/{id}/documents", docH.ListByCase)
|
||||||
@@ -175,9 +172,6 @@ func New(db *sqlx.DB, authMW *auth.Middleware, cfg *config.Config, calDAVSvc *se
|
|||||||
aiLimiter := middleware.NewTokenBucket(5.0/60.0, 10)
|
aiLimiter := middleware.NewTokenBucket(5.0/60.0, 10)
|
||||||
scoped.HandleFunc("POST /api/ai/extract-deadlines", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.ExtractDeadlines)))
|
scoped.HandleFunc("POST /api/ai/extract-deadlines", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.ExtractDeadlines)))
|
||||||
scoped.HandleFunc("POST /api/ai/summarize-case", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.SummarizeCase)))
|
scoped.HandleFunc("POST /api/ai/summarize-case", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.SummarizeCase)))
|
||||||
scoped.HandleFunc("POST /api/ai/draft-document", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.DraftDocument)))
|
|
||||||
scoped.HandleFunc("POST /api/ai/case-strategy", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.CaseStrategy)))
|
|
||||||
scoped.HandleFunc("POST /api/ai/similar-cases", perm(auth.PermAIExtraction, aiLimiter.LimitFunc(aiH.SimilarCases)))
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Notifications
|
// Notifications
|
||||||
|
|||||||
@@ -5,7 +5,6 @@ import (
|
|||||||
"encoding/base64"
|
"encoding/base64"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
"strings"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/anthropics/anthropic-sdk-go"
|
"github.com/anthropics/anthropic-sdk-go"
|
||||||
@@ -19,12 +18,11 @@ import (
|
|||||||
type AIService struct {
|
type AIService struct {
|
||||||
client anthropic.Client
|
client anthropic.Client
|
||||||
db *sqlx.DB
|
db *sqlx.DB
|
||||||
youpcDB *sqlx.DB // read-only connection to youpc.org for similar case finder (may be nil)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewAIService(apiKey string, db *sqlx.DB, youpcDB *sqlx.DB) *AIService {
|
func NewAIService(apiKey string, db *sqlx.DB) *AIService {
|
||||||
client := anthropic.NewClient(option.WithAPIKey(apiKey))
|
client := anthropic.NewClient(option.WithAPIKey(apiKey))
|
||||||
return &AIService{client: client, db: db, youpcDB: youpcDB}
|
return &AIService{client: client, db: db}
|
||||||
}
|
}
|
||||||
|
|
||||||
// ExtractedDeadline represents a deadline extracted by AI from a document.
|
// ExtractedDeadline represents a deadline extracted by AI from a document.
|
||||||
@@ -283,726 +281,3 @@ func (s *AIService) SummarizeCase(ctx context.Context, tenantID, caseID uuid.UUI
|
|||||||
|
|
||||||
return summary, nil
|
return summary, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// --- Document Drafting ---
|
|
||||||
|
|
||||||
// DocumentDraft represents an AI-generated document draft.
|
|
||||||
type DocumentDraft struct {
|
|
||||||
Title string `json:"title"`
|
|
||||||
Content string `json:"content"`
|
|
||||||
Language string `json:"language"`
|
|
||||||
}
|
|
||||||
|
|
||||||
// templateDescriptions maps template type IDs to descriptions for Claude.
|
|
||||||
var templateDescriptions = map[string]string{
|
|
||||||
"klageschrift": "Klageschrift (Statement of Claim) — formal complaint initiating legal proceedings",
|
|
||||||
"klageerwiderung": "Klageerwiderung (Statement of Defence) — formal response to a statement of claim",
|
|
||||||
"abmahnung": "Abmahnung (Cease and Desist Letter) — formal warning letter demanding cessation of an activity",
|
|
||||||
"schriftsatz": "Schriftsatz (Legal Brief) — formal legal submission to the court",
|
|
||||||
"berufung": "Berufungsschrift (Appeal Brief) — formal appeal against a court decision",
|
|
||||||
"antrag": "Antrag (Motion/Application) — formal application or motion to the court",
|
|
||||||
"stellungnahme": "Stellungnahme (Statement/Position Paper) — formal response or position paper",
|
|
||||||
"gutachten": "Gutachten (Legal Opinion/Expert Report) — detailed legal analysis or opinion",
|
|
||||||
"vertrag": "Vertrag (Contract/Agreement) — legal contract or agreement between parties",
|
|
||||||
"vollmacht": "Vollmacht (Power of Attorney) — formal authorization document",
|
|
||||||
"upc_claim": "UPC Statement of Claim — claim filed at the Unified Patent Court",
|
|
||||||
"upc_defence": "UPC Statement of Defence — defence filed at the Unified Patent Court",
|
|
||||||
"upc_counterclaim": "UPC Counterclaim for Revocation — counterclaim for patent revocation at the UPC",
|
|
||||||
"upc_injunction": "UPC Application for Provisional Measures — application for injunctive relief at the UPC",
|
|
||||||
}
|
|
||||||
|
|
||||||
const draftDocumentSystemPrompt = `You are an expert legal document drafter for German and UPC (Unified Patent Court) patent litigation.
|
|
||||||
|
|
||||||
You draft professional legal documents in the requested language, following proper legal formatting conventions.
|
|
||||||
|
|
||||||
Guidelines:
|
|
||||||
- Use proper legal structure with numbered sections and paragraphs
|
|
||||||
- Include standard legal formalities (headers, salutations, signatures block)
|
|
||||||
- Reference relevant legal provisions (BGB, ZPO, UPC Rules of Procedure, etc.)
|
|
||||||
- Use precise legal terminology appropriate for the jurisdiction
|
|
||||||
- Include placeholders in [BRACKETS] for information that needs to be filled in
|
|
||||||
- Base the content on the provided case data and instructions
|
|
||||||
- Output the document as clean text with proper formatting`
|
|
||||||
|
|
||||||
// DraftDocument generates an AI-drafted legal document based on case data and a template type.
|
|
||||||
func (s *AIService) DraftDocument(ctx context.Context, tenantID, caseID uuid.UUID, templateType, instructions, language string) (*DocumentDraft, error) {
|
|
||||||
if language == "" {
|
|
||||||
language = "de"
|
|
||||||
}
|
|
||||||
|
|
||||||
langLabel := "German"
|
|
||||||
if language == "en" {
|
|
||||||
langLabel = "English"
|
|
||||||
} else if language == "fr" {
|
|
||||||
langLabel = "French"
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load case data
|
|
||||||
var c models.Case
|
|
||||||
if err := s.db.GetContext(ctx, &c,
|
|
||||||
"SELECT * FROM cases WHERE id = $1 AND tenant_id = $2", caseID, tenantID); err != nil {
|
|
||||||
return nil, fmt.Errorf("loading case: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load parties
|
|
||||||
var parties []models.Party
|
|
||||||
_ = s.db.SelectContext(ctx, &parties,
|
|
||||||
"SELECT * FROM parties WHERE case_id = $1 AND tenant_id = $2", caseID, tenantID)
|
|
||||||
|
|
||||||
// Load recent events
|
|
||||||
var events []models.CaseEvent
|
|
||||||
_ = s.db.SelectContext(ctx, &events,
|
|
||||||
"SELECT * FROM case_events WHERE case_id = $1 AND tenant_id = $2 ORDER BY created_at DESC LIMIT 15",
|
|
||||||
caseID, tenantID)
|
|
||||||
|
|
||||||
// Load active deadlines
|
|
||||||
var deadlines []models.Deadline
|
|
||||||
_ = s.db.SelectContext(ctx, &deadlines,
|
|
||||||
"SELECT * FROM deadlines WHERE case_id = $1 AND tenant_id = $2 AND status = 'active' ORDER BY due_date ASC LIMIT 10",
|
|
||||||
caseID, tenantID)
|
|
||||||
|
|
||||||
// Load documents metadata for context
|
|
||||||
var documents []models.Document
|
|
||||||
_ = s.db.SelectContext(ctx, &documents,
|
|
||||||
"SELECT id, title, doc_type, created_at FROM documents WHERE case_id = $1 AND tenant_id = $2 ORDER BY created_at DESC LIMIT 10",
|
|
||||||
caseID, tenantID)
|
|
||||||
|
|
||||||
// Build context
|
|
||||||
var b strings.Builder
|
|
||||||
b.WriteString(fmt.Sprintf("Case: %s — %s\nStatus: %s\n", c.CaseNumber, c.Title, c.Status))
|
|
||||||
if c.Court != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Court: %s\n", *c.Court))
|
|
||||||
}
|
|
||||||
if c.CourtRef != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Court Reference: %s\n", *c.CourtRef))
|
|
||||||
}
|
|
||||||
if c.CaseType != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Type: %s\n", *c.CaseType))
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(parties) > 0 {
|
|
||||||
b.WriteString("\nParties:\n")
|
|
||||||
for _, p := range parties {
|
|
||||||
role := "unknown role"
|
|
||||||
if p.Role != nil {
|
|
||||||
role = *p.Role
|
|
||||||
}
|
|
||||||
b.WriteString(fmt.Sprintf("- %s (%s)", p.Name, role))
|
|
||||||
if p.Representative != nil {
|
|
||||||
b.WriteString(fmt.Sprintf(" — represented by %s", *p.Representative))
|
|
||||||
}
|
|
||||||
b.WriteString("\n")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(events) > 0 {
|
|
||||||
b.WriteString("\nRecent Events:\n")
|
|
||||||
for _, e := range events {
|
|
||||||
b.WriteString(fmt.Sprintf("- [%s] %s", e.CreatedAt.Format("2006-01-02"), e.Title))
|
|
||||||
if e.Description != nil {
|
|
||||||
b.WriteString(fmt.Sprintf(": %s", *e.Description))
|
|
||||||
}
|
|
||||||
b.WriteString("\n")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(deadlines) > 0 {
|
|
||||||
b.WriteString("\nUpcoming Deadlines:\n")
|
|
||||||
for _, d := range deadlines {
|
|
||||||
b.WriteString(fmt.Sprintf("- %s: due %s\n", d.Title, d.DueDate))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
templateDesc, ok := templateDescriptions[templateType]
|
|
||||||
if !ok {
|
|
||||||
templateDesc = templateType
|
|
||||||
}
|
|
||||||
|
|
||||||
prompt := fmt.Sprintf(`Draft a %s for this case in %s.
|
|
||||||
|
|
||||||
Document type: %s
|
|
||||||
|
|
||||||
Case context:
|
|
||||||
%s
|
|
||||||
Additional instructions from the lawyer:
|
|
||||||
%s
|
|
||||||
|
|
||||||
Generate the complete document now.`, templateDesc, langLabel, templateDesc, b.String(), instructions)
|
|
||||||
|
|
||||||
msg, err := s.client.Messages.New(ctx, anthropic.MessageNewParams{
|
|
||||||
Model: anthropic.ModelClaudeSonnet4_20250514,
|
|
||||||
MaxTokens: 8192,
|
|
||||||
System: []anthropic.TextBlockParam{
|
|
||||||
{Text: draftDocumentSystemPrompt},
|
|
||||||
},
|
|
||||||
Messages: []anthropic.MessageParam{
|
|
||||||
anthropic.NewUserMessage(anthropic.NewTextBlock(prompt)),
|
|
||||||
},
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("claude API call: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
var content string
|
|
||||||
for _, block := range msg.Content {
|
|
||||||
if block.Type == "text" {
|
|
||||||
content += block.Text
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if content == "" {
|
|
||||||
return nil, fmt.Errorf("empty response from Claude")
|
|
||||||
}
|
|
||||||
|
|
||||||
title := fmt.Sprintf("%s — %s", templateDesc, c.CaseNumber)
|
|
||||||
return &DocumentDraft{
|
|
||||||
Title: title,
|
|
||||||
Content: content,
|
|
||||||
Language: language,
|
|
||||||
}, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// --- Case Strategy ---
|
|
||||||
|
|
||||||
// StrategyRecommendation represents an AI-generated case strategy analysis.
|
|
||||||
type StrategyRecommendation struct {
|
|
||||||
Summary string `json:"summary"`
|
|
||||||
NextSteps []StrategyStep `json:"next_steps"`
|
|
||||||
RiskAssessment []RiskItem `json:"risk_assessment"`
|
|
||||||
Timeline []TimelineItem `json:"timeline"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type StrategyStep struct {
|
|
||||||
Priority string `json:"priority"` // high, medium, low
|
|
||||||
Action string `json:"action"`
|
|
||||||
Reasoning string `json:"reasoning"`
|
|
||||||
Deadline string `json:"deadline,omitempty"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type RiskItem struct {
|
|
||||||
Level string `json:"level"` // high, medium, low
|
|
||||||
Risk string `json:"risk"`
|
|
||||||
Mitigation string `json:"mitigation"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type TimelineItem struct {
|
|
||||||
Date string `json:"date"`
|
|
||||||
Event string `json:"event"`
|
|
||||||
Importance string `json:"importance"` // critical, important, routine
|
|
||||||
}
|
|
||||||
|
|
||||||
type strategyToolInput struct {
|
|
||||||
Summary string `json:"summary"`
|
|
||||||
NextSteps []StrategyStep `json:"next_steps"`
|
|
||||||
RiskAssessment []RiskItem `json:"risk_assessment"`
|
|
||||||
Timeline []TimelineItem `json:"timeline"`
|
|
||||||
}
|
|
||||||
|
|
||||||
var caseStrategyTool = anthropic.ToolParam{
|
|
||||||
Name: "case_strategy",
|
|
||||||
Description: anthropic.String("Provide strategic case analysis with next steps, risk assessment, and timeline optimization."),
|
|
||||||
InputSchema: anthropic.ToolInputSchemaParam{
|
|
||||||
Properties: map[string]any{
|
|
||||||
"summary": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Executive summary of the case situation and strategic outlook (2-4 sentences)",
|
|
||||||
},
|
|
||||||
"next_steps": map[string]any{
|
|
||||||
"type": "array",
|
|
||||||
"description": "Recommended next actions in priority order",
|
|
||||||
"items": map[string]any{
|
|
||||||
"type": "object",
|
|
||||||
"properties": map[string]any{
|
|
||||||
"priority": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"enum": []string{"high", "medium", "low"},
|
|
||||||
},
|
|
||||||
"action": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Specific recommended action",
|
|
||||||
},
|
|
||||||
"reasoning": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Why this action is recommended",
|
|
||||||
},
|
|
||||||
"deadline": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Suggested deadline in YYYY-MM-DD format, if applicable",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
"required": []string{"priority", "action", "reasoning"},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
"risk_assessment": map[string]any{
|
|
||||||
"type": "array",
|
|
||||||
"description": "Key risks and mitigation strategies",
|
|
||||||
"items": map[string]any{
|
|
||||||
"type": "object",
|
|
||||||
"properties": map[string]any{
|
|
||||||
"level": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"enum": []string{"high", "medium", "low"},
|
|
||||||
},
|
|
||||||
"risk": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Description of the risk",
|
|
||||||
},
|
|
||||||
"mitigation": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Recommended mitigation strategy",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
"required": []string{"level", "risk", "mitigation"},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
"timeline": map[string]any{
|
|
||||||
"type": "array",
|
|
||||||
"description": "Optimized timeline of upcoming milestones and events",
|
|
||||||
"items": map[string]any{
|
|
||||||
"type": "object",
|
|
||||||
"properties": map[string]any{
|
|
||||||
"date": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Date in YYYY-MM-DD format",
|
|
||||||
},
|
|
||||||
"event": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Description of the milestone or event",
|
|
||||||
},
|
|
||||||
"importance": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"enum": []string{"critical", "important", "routine"},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
"required": []string{"date", "event", "importance"},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
Required: []string{"summary", "next_steps", "risk_assessment", "timeline"},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
const caseStrategySystemPrompt = `You are a senior litigation strategist specializing in German law and UPC (Unified Patent Court) patent proceedings.
|
|
||||||
|
|
||||||
Analyze the case thoroughly and provide:
|
|
||||||
1. An executive summary of the current strategic position
|
|
||||||
2. Prioritized next steps with clear reasoning
|
|
||||||
3. Risk assessment with mitigation strategies
|
|
||||||
4. An optimized timeline of upcoming milestones
|
|
||||||
|
|
||||||
Consider:
|
|
||||||
- Procedural deadlines and their implications
|
|
||||||
- Strength of the parties' positions based on available information
|
|
||||||
- Potential settlement opportunities
|
|
||||||
- Cost-efficiency of different strategic approaches
|
|
||||||
- UPC-specific procedural peculiarities if applicable (bifurcation, preliminary injunctions, etc.)
|
|
||||||
|
|
||||||
Be practical and actionable. Avoid generic advice — tailor recommendations to the specific case data provided.`
|
|
||||||
|
|
||||||
// CaseStrategy analyzes a case and returns strategic recommendations.
|
|
||||||
func (s *AIService) CaseStrategy(ctx context.Context, tenantID, caseID uuid.UUID) (*StrategyRecommendation, error) {
|
|
||||||
// Load case
|
|
||||||
var c models.Case
|
|
||||||
if err := s.db.GetContext(ctx, &c,
|
|
||||||
"SELECT * FROM cases WHERE id = $1 AND tenant_id = $2", caseID, tenantID); err != nil {
|
|
||||||
return nil, fmt.Errorf("loading case: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Load parties
|
|
||||||
var parties []models.Party
|
|
||||||
_ = s.db.SelectContext(ctx, &parties,
|
|
||||||
"SELECT * FROM parties WHERE case_id = $1 AND tenant_id = $2", caseID, tenantID)
|
|
||||||
|
|
||||||
// Load all events
|
|
||||||
var events []models.CaseEvent
|
|
||||||
_ = s.db.SelectContext(ctx, &events,
|
|
||||||
"SELECT * FROM case_events WHERE case_id = $1 AND tenant_id = $2 ORDER BY created_at DESC LIMIT 25",
|
|
||||||
caseID, tenantID)
|
|
||||||
|
|
||||||
// Load all deadlines (active + completed for context)
|
|
||||||
var deadlines []models.Deadline
|
|
||||||
_ = s.db.SelectContext(ctx, &deadlines,
|
|
||||||
"SELECT * FROM deadlines WHERE case_id = $1 AND tenant_id = $2 ORDER BY due_date ASC LIMIT 20",
|
|
||||||
caseID, tenantID)
|
|
||||||
|
|
||||||
// Load documents metadata
|
|
||||||
var documents []models.Document
|
|
||||||
_ = s.db.SelectContext(ctx, &documents,
|
|
||||||
"SELECT id, title, doc_type, created_at FROM documents WHERE case_id = $1 AND tenant_id = $2 ORDER BY created_at DESC LIMIT 15",
|
|
||||||
caseID, tenantID)
|
|
||||||
|
|
||||||
// Build comprehensive context
|
|
||||||
var b strings.Builder
|
|
||||||
b.WriteString(fmt.Sprintf("Case: %s — %s\nStatus: %s\n", c.CaseNumber, c.Title, c.Status))
|
|
||||||
if c.Court != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Court: %s\n", *c.Court))
|
|
||||||
}
|
|
||||||
if c.CourtRef != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Court Reference: %s\n", *c.CourtRef))
|
|
||||||
}
|
|
||||||
if c.CaseType != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Type: %s\n", *c.CaseType))
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(parties) > 0 {
|
|
||||||
b.WriteString("\nParties:\n")
|
|
||||||
for _, p := range parties {
|
|
||||||
role := "unknown"
|
|
||||||
if p.Role != nil {
|
|
||||||
role = *p.Role
|
|
||||||
}
|
|
||||||
b.WriteString(fmt.Sprintf("- %s (%s)", p.Name, role))
|
|
||||||
if p.Representative != nil {
|
|
||||||
b.WriteString(fmt.Sprintf(" — represented by %s", *p.Representative))
|
|
||||||
}
|
|
||||||
b.WriteString("\n")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(events) > 0 {
|
|
||||||
b.WriteString("\nCase Events (chronological):\n")
|
|
||||||
for _, e := range events {
|
|
||||||
b.WriteString(fmt.Sprintf("- [%s] %s", e.CreatedAt.Format("2006-01-02"), e.Title))
|
|
||||||
if e.Description != nil {
|
|
||||||
b.WriteString(fmt.Sprintf(": %s", *e.Description))
|
|
||||||
}
|
|
||||||
b.WriteString("\n")
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(deadlines) > 0 {
|
|
||||||
b.WriteString("\nDeadlines:\n")
|
|
||||||
for _, d := range deadlines {
|
|
||||||
b.WriteString(fmt.Sprintf("- %s: due %s (status: %s)\n", d.Title, d.DueDate, d.Status))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(documents) > 0 {
|
|
||||||
b.WriteString("\nDocuments on file:\n")
|
|
||||||
for _, d := range documents {
|
|
||||||
docType := ""
|
|
||||||
if d.DocType != nil {
|
|
||||||
docType = fmt.Sprintf(" [%s]", *d.DocType)
|
|
||||||
}
|
|
||||||
b.WriteString(fmt.Sprintf("- %s%s (%s)\n", d.Title, docType, d.CreatedAt.Format("2006-01-02")))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
msg, err := s.client.Messages.New(ctx, anthropic.MessageNewParams{
|
|
||||||
Model: anthropic.ModelClaudeOpus4_6,
|
|
||||||
MaxTokens: 4096,
|
|
||||||
System: []anthropic.TextBlockParam{
|
|
||||||
{Text: caseStrategySystemPrompt},
|
|
||||||
},
|
|
||||||
Messages: []anthropic.MessageParam{
|
|
||||||
anthropic.NewUserMessage(anthropic.NewTextBlock("Analyze this case and provide strategic recommendations:\n\n" + b.String())),
|
|
||||||
},
|
|
||||||
Tools: []anthropic.ToolUnionParam{
|
|
||||||
{OfTool: &caseStrategyTool},
|
|
||||||
},
|
|
||||||
ToolChoice: anthropic.ToolChoiceParamOfTool("case_strategy"),
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("claude API call: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, block := range msg.Content {
|
|
||||||
if block.Type == "tool_use" && block.Name == "case_strategy" {
|
|
||||||
var input strategyToolInput
|
|
||||||
if err := json.Unmarshal(block.Input, &input); err != nil {
|
|
||||||
return nil, fmt.Errorf("parsing strategy output: %w", err)
|
|
||||||
}
|
|
||||||
result := &StrategyRecommendation{
|
|
||||||
Summary: input.Summary,
|
|
||||||
NextSteps: input.NextSteps,
|
|
||||||
RiskAssessment: input.RiskAssessment,
|
|
||||||
Timeline: input.Timeline,
|
|
||||||
}
|
|
||||||
// Cache in database
|
|
||||||
strategyJSON, _ := json.Marshal(result)
|
|
||||||
_, _ = s.db.ExecContext(ctx,
|
|
||||||
"UPDATE cases SET ai_summary = $1, updated_at = $2 WHERE id = $3 AND tenant_id = $4",
|
|
||||||
string(strategyJSON), time.Now(), caseID, tenantID)
|
|
||||||
return result, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil, fmt.Errorf("no tool_use block in response")
|
|
||||||
}
|
|
||||||
|
|
||||||
// --- Similar Case Finder ---
|
|
||||||
|
|
||||||
// SimilarCase represents a UPC case found to be similar.
|
|
||||||
type SimilarCase struct {
|
|
||||||
CaseNumber string `json:"case_number"`
|
|
||||||
Title string `json:"title"`
|
|
||||||
Court string `json:"court"`
|
|
||||||
Date string `json:"date"`
|
|
||||||
Relevance float64 `json:"relevance"` // 0.0-1.0
|
|
||||||
Explanation string `json:"explanation"` // why this case is similar
|
|
||||||
KeyHoldings string `json:"key_holdings"` // relevant holdings
|
|
||||||
URL string `json:"url,omitempty"` // link to youpc.org
|
|
||||||
}
|
|
||||||
|
|
||||||
// youpcCase represents a case from the youpc.org database.
|
|
||||||
type youpcCase struct {
|
|
||||||
ID string `db:"id" json:"id"`
|
|
||||||
CaseNumber *string `db:"case_number" json:"case_number"`
|
|
||||||
Title *string `db:"title" json:"title"`
|
|
||||||
Court *string `db:"court" json:"court"`
|
|
||||||
DecisionDate *string `db:"decision_date" json:"decision_date"`
|
|
||||||
CaseType *string `db:"case_type" json:"case_type"`
|
|
||||||
Outcome *string `db:"outcome" json:"outcome"`
|
|
||||||
PatentNumbers *string `db:"patent_numbers" json:"patent_numbers"`
|
|
||||||
Summary *string `db:"summary" json:"summary"`
|
|
||||||
Claimant *string `db:"claimant" json:"claimant"`
|
|
||||||
Defendant *string `db:"defendant" json:"defendant"`
|
|
||||||
}
|
|
||||||
|
|
||||||
type similarCaseToolInput struct {
|
|
||||||
Cases []struct {
|
|
||||||
CaseID string `json:"case_id"`
|
|
||||||
Relevance float64 `json:"relevance"`
|
|
||||||
Explanation string `json:"explanation"`
|
|
||||||
KeyHoldings string `json:"key_holdings"`
|
|
||||||
} `json:"cases"`
|
|
||||||
}
|
|
||||||
|
|
||||||
var similarCaseTool = anthropic.ToolParam{
|
|
||||||
Name: "rank_similar_cases",
|
|
||||||
Description: anthropic.String("Rank the provided UPC cases by relevance to the query case and explain why each is similar."),
|
|
||||||
InputSchema: anthropic.ToolInputSchemaParam{
|
|
||||||
Properties: map[string]any{
|
|
||||||
"cases": map[string]any{
|
|
||||||
"type": "array",
|
|
||||||
"description": "UPC cases ranked by relevance (most relevant first)",
|
|
||||||
"items": map[string]any{
|
|
||||||
"type": "object",
|
|
||||||
"properties": map[string]any{
|
|
||||||
"case_id": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "The ID of the UPC case from the provided list",
|
|
||||||
},
|
|
||||||
"relevance": map[string]any{
|
|
||||||
"type": "number",
|
|
||||||
"minimum": 0,
|
|
||||||
"maximum": 1,
|
|
||||||
"description": "Relevance score from 0.0 to 1.0",
|
|
||||||
},
|
|
||||||
"explanation": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Why this case is relevant — what legal issues, parties, patents, or procedural aspects are similar",
|
|
||||||
},
|
|
||||||
"key_holdings": map[string]any{
|
|
||||||
"type": "string",
|
|
||||||
"description": "Key holdings or legal principles from this case that are relevant",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
"required": []string{"case_id", "relevance", "explanation", "key_holdings"},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
Required: []string{"cases"},
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
const similarCaseSystemPrompt = `You are a UPC (Unified Patent Court) case law expert.
|
|
||||||
|
|
||||||
Given a case description and a list of UPC cases from the database, rank the cases by relevance and explain why each one is similar or relevant.
|
|
||||||
|
|
||||||
Consider:
|
|
||||||
- Similar patents or technology areas
|
|
||||||
- Same parties or representatives
|
|
||||||
- Similar legal issues (infringement, validity, injunctions, etc.)
|
|
||||||
- Similar procedural situations
|
|
||||||
- Relevant legal principles that could apply
|
|
||||||
|
|
||||||
Only include cases that are genuinely relevant (relevance > 0.3). Order by relevance descending.`
|
|
||||||
|
|
||||||
// FindSimilarCases searches the youpc.org database for similar UPC cases.
|
|
||||||
func (s *AIService) FindSimilarCases(ctx context.Context, tenantID, caseID uuid.UUID, description string) ([]SimilarCase, error) {
|
|
||||||
if s.youpcDB == nil {
|
|
||||||
return nil, fmt.Errorf("youpc.org database not configured")
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build query context from the case (if provided) or description
|
|
||||||
var queryText string
|
|
||||||
if caseID != uuid.Nil {
|
|
||||||
var c models.Case
|
|
||||||
if err := s.db.GetContext(ctx, &c,
|
|
||||||
"SELECT * FROM cases WHERE id = $1 AND tenant_id = $2", caseID, tenantID); err != nil {
|
|
||||||
return nil, fmt.Errorf("loading case: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
var parties []models.Party
|
|
||||||
_ = s.db.SelectContext(ctx, &parties,
|
|
||||||
"SELECT * FROM parties WHERE case_id = $1 AND tenant_id = $2", caseID, tenantID)
|
|
||||||
|
|
||||||
var b strings.Builder
|
|
||||||
b.WriteString(fmt.Sprintf("Case: %s — %s\n", c.CaseNumber, c.Title))
|
|
||||||
if c.CaseType != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Type: %s\n", *c.CaseType))
|
|
||||||
}
|
|
||||||
if c.Court != nil {
|
|
||||||
b.WriteString(fmt.Sprintf("Court: %s\n", *c.Court))
|
|
||||||
}
|
|
||||||
for _, p := range parties {
|
|
||||||
role := ""
|
|
||||||
if p.Role != nil {
|
|
||||||
role = *p.Role
|
|
||||||
}
|
|
||||||
b.WriteString(fmt.Sprintf("Party: %s (%s)\n", p.Name, role))
|
|
||||||
}
|
|
||||||
if description != "" {
|
|
||||||
b.WriteString(fmt.Sprintf("\nAdditional context: %s\n", description))
|
|
||||||
}
|
|
||||||
queryText = b.String()
|
|
||||||
} else if description != "" {
|
|
||||||
queryText = description
|
|
||||||
} else {
|
|
||||||
return nil, fmt.Errorf("either case_id or description must be provided")
|
|
||||||
}
|
|
||||||
|
|
||||||
// Query youpc.org database for candidate cases
|
|
||||||
// Search by text similarity across case titles, summaries, party names
|
|
||||||
var candidates []youpcCase
|
|
||||||
err := s.youpcDB.SelectContext(ctx, &candidates, `
|
|
||||||
SELECT
|
|
||||||
id,
|
|
||||||
case_number,
|
|
||||||
title,
|
|
||||||
court,
|
|
||||||
decision_date,
|
|
||||||
case_type,
|
|
||||||
outcome,
|
|
||||||
patent_numbers,
|
|
||||||
summary,
|
|
||||||
claimant,
|
|
||||||
defendant
|
|
||||||
FROM mlex.cases
|
|
||||||
ORDER BY decision_date DESC NULLS LAST
|
|
||||||
LIMIT 50
|
|
||||||
`)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("querying youpc.org cases: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
if len(candidates) == 0 {
|
|
||||||
return []SimilarCase{}, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build candidate list for Claude
|
|
||||||
var candidateText strings.Builder
|
|
||||||
for _, c := range candidates {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("ID: %s\n", c.ID))
|
|
||||||
if c.CaseNumber != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Case Number: %s\n", *c.CaseNumber))
|
|
||||||
}
|
|
||||||
if c.Title != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Title: %s\n", *c.Title))
|
|
||||||
}
|
|
||||||
if c.Court != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Court: %s\n", *c.Court))
|
|
||||||
}
|
|
||||||
if c.DecisionDate != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Decision Date: %s\n", *c.DecisionDate))
|
|
||||||
}
|
|
||||||
if c.CaseType != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Type: %s\n", *c.CaseType))
|
|
||||||
}
|
|
||||||
if c.Outcome != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Outcome: %s\n", *c.Outcome))
|
|
||||||
}
|
|
||||||
if c.PatentNumbers != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Patents: %s\n", *c.PatentNumbers))
|
|
||||||
}
|
|
||||||
if c.Claimant != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Claimant: %s\n", *c.Claimant))
|
|
||||||
}
|
|
||||||
if c.Defendant != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Defendant: %s\n", *c.Defendant))
|
|
||||||
}
|
|
||||||
if c.Summary != nil {
|
|
||||||
candidateText.WriteString(fmt.Sprintf("Summary: %s\n", *c.Summary))
|
|
||||||
}
|
|
||||||
candidateText.WriteString("---\n")
|
|
||||||
}
|
|
||||||
|
|
||||||
prompt := fmt.Sprintf(`Find UPC cases relevant to this matter:
|
|
||||||
|
|
||||||
%s
|
|
||||||
|
|
||||||
Here are the UPC cases from the database to evaluate:
|
|
||||||
|
|
||||||
%s
|
|
||||||
|
|
||||||
Rank only the genuinely relevant cases by similarity.`, queryText, candidateText.String())
|
|
||||||
|
|
||||||
msg, err := s.client.Messages.New(ctx, anthropic.MessageNewParams{
|
|
||||||
Model: anthropic.ModelClaudeSonnet4_20250514,
|
|
||||||
MaxTokens: 4096,
|
|
||||||
System: []anthropic.TextBlockParam{
|
|
||||||
{Text: similarCaseSystemPrompt},
|
|
||||||
},
|
|
||||||
Messages: []anthropic.MessageParam{
|
|
||||||
anthropic.NewUserMessage(anthropic.NewTextBlock(prompt)),
|
|
||||||
},
|
|
||||||
Tools: []anthropic.ToolUnionParam{
|
|
||||||
{OfTool: &similarCaseTool},
|
|
||||||
},
|
|
||||||
ToolChoice: anthropic.ToolChoiceParamOfTool("rank_similar_cases"),
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("claude API call: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
for _, block := range msg.Content {
|
|
||||||
if block.Type == "tool_use" && block.Name == "rank_similar_cases" {
|
|
||||||
var input similarCaseToolInput
|
|
||||||
if err := json.Unmarshal(block.Input, &input); err != nil {
|
|
||||||
return nil, fmt.Errorf("parsing similar cases output: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Build lookup map for candidate data
|
|
||||||
candidateMap := make(map[string]youpcCase)
|
|
||||||
for _, c := range candidates {
|
|
||||||
candidateMap[c.ID] = c
|
|
||||||
}
|
|
||||||
|
|
||||||
var results []SimilarCase
|
|
||||||
for _, ranked := range input.Cases {
|
|
||||||
if ranked.Relevance < 0.3 {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
c, ok := candidateMap[ranked.CaseID]
|
|
||||||
if !ok {
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
sc := SimilarCase{
|
|
||||||
Relevance: ranked.Relevance,
|
|
||||||
Explanation: ranked.Explanation,
|
|
||||||
KeyHoldings: ranked.KeyHoldings,
|
|
||||||
}
|
|
||||||
if c.CaseNumber != nil {
|
|
||||||
sc.CaseNumber = *c.CaseNumber
|
|
||||||
}
|
|
||||||
if c.Title != nil {
|
|
||||||
sc.Title = *c.Title
|
|
||||||
}
|
|
||||||
if c.Court != nil {
|
|
||||||
sc.Court = *c.Court
|
|
||||||
}
|
|
||||||
if c.DecisionDate != nil {
|
|
||||||
sc.Date = *c.DecisionDate
|
|
||||||
}
|
|
||||||
if c.CaseNumber != nil {
|
|
||||||
sc.URL = fmt.Sprintf("https://youpc.org/cases/%s", *c.CaseNumber)
|
|
||||||
}
|
|
||||||
results = append(results, sc)
|
|
||||||
}
|
|
||||||
|
|
||||||
return results, nil
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil, fmt.Errorf("no tool_use block in response")
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -240,6 +240,54 @@ func (s *TenantService) UpdateMemberRole(ctx context.Context, tenantID, userID u
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// AutoAssignByDomain finds a tenant with a matching auto_assign_domains setting
|
||||||
|
// and adds the user as a member. Returns the tenant and role, or nil if no match.
|
||||||
|
func (s *TenantService) AutoAssignByDomain(ctx context.Context, userID uuid.UUID, emailDomain string) (*models.TenantWithRole, error) {
|
||||||
|
// Find tenant where settings.auto_assign_domains contains this domain
|
||||||
|
var tenant models.Tenant
|
||||||
|
err := s.db.GetContext(ctx, &tenant,
|
||||||
|
`SELECT id, name, slug, settings, created_at, updated_at
|
||||||
|
FROM tenants
|
||||||
|
WHERE settings->'auto_assign_domains' ? $1
|
||||||
|
LIMIT 1`,
|
||||||
|
emailDomain,
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return nil, nil // no match — not an error
|
||||||
|
}
|
||||||
|
|
||||||
|
// Check if already a member
|
||||||
|
var exists bool
|
||||||
|
err = s.db.GetContext(ctx, &exists,
|
||||||
|
`SELECT EXISTS(SELECT 1 FROM user_tenants WHERE user_id = $1 AND tenant_id = $2)`,
|
||||||
|
userID, tenant.ID,
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("check membership: %w", err)
|
||||||
|
}
|
||||||
|
if exists {
|
||||||
|
// Already a member — return the existing membership
|
||||||
|
role, err := s.GetUserRole(ctx, userID, tenant.ID)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("get existing role: %w", err)
|
||||||
|
}
|
||||||
|
return &models.TenantWithRole{Tenant: tenant, Role: role}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Add as member (associate by default for auto-assigned users)
|
||||||
|
role := "associate"
|
||||||
|
_, err = s.db.ExecContext(ctx,
|
||||||
|
`INSERT INTO user_tenants (user_id, tenant_id, role) VALUES ($1, $2, $3)`,
|
||||||
|
userID, tenant.ID, role,
|
||||||
|
)
|
||||||
|
if err != nil {
|
||||||
|
return nil, fmt.Errorf("auto-assign user: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
s.audit.Log(ctx, "create", "auto_membership", &tenant.ID, map[string]any{"domain": emailDomain}, map[string]any{"user_id": userID, "role": role})
|
||||||
|
return &models.TenantWithRole{Tenant: tenant, Role: role}, nil
|
||||||
|
}
|
||||||
|
|
||||||
// RemoveMember removes a user from a tenant. Cannot remove the last owner.
|
// RemoveMember removes a user from a tenant. Cannot remove the last owner.
|
||||||
func (s *TenantService) RemoveMember(ctx context.Context, tenantID, userID uuid.UUID) error {
|
func (s *TenantService) RemoveMember(ctx context.Context, tenantID, userID uuid.UUID) error {
|
||||||
// Check if the user being removed is an owner
|
// Check if the user being removed is an owner
|
||||||
|
|||||||
@@ -1,51 +0,0 @@
|
|||||||
"use client";
|
|
||||||
|
|
||||||
import { useState } from "react";
|
|
||||||
import { useParams } from "next/navigation";
|
|
||||||
import { Brain, FileText, Search } from "lucide-react";
|
|
||||||
import { CaseStrategy } from "@/components/ai/CaseStrategy";
|
|
||||||
import { DocumentDrafter } from "@/components/ai/DocumentDrafter";
|
|
||||||
import { SimilarCaseFinder } from "@/components/ai/SimilarCaseFinder";
|
|
||||||
|
|
||||||
type AITab = "strategy" | "draft" | "similar";
|
|
||||||
|
|
||||||
const TABS: { id: AITab; label: string; icon: typeof Brain }[] = [
|
|
||||||
{ id: "strategy", label: "KI-Strategie", icon: Brain },
|
|
||||||
{ id: "draft", label: "KI-Entwurf", icon: FileText },
|
|
||||||
{ id: "similar", label: "Aehnliche Faelle", icon: Search },
|
|
||||||
];
|
|
||||||
|
|
||||||
export default function CaseAIPage() {
|
|
||||||
const { id } = useParams<{ id: string }>();
|
|
||||||
const [activeTab, setActiveTab] = useState<AITab>("strategy");
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div>
|
|
||||||
{/* Sub-tabs */}
|
|
||||||
<div className="mb-6 flex gap-1 rounded-lg border border-neutral-200 bg-neutral-50 p-1">
|
|
||||||
{TABS.map((tab) => {
|
|
||||||
const isActive = activeTab === tab.id;
|
|
||||||
return (
|
|
||||||
<button
|
|
||||||
key={tab.id}
|
|
||||||
onClick={() => setActiveTab(tab.id)}
|
|
||||||
className={`inline-flex flex-1 items-center justify-center gap-1.5 rounded-md px-3 py-2 text-sm font-medium transition-colors ${
|
|
||||||
isActive
|
|
||||||
? "bg-white text-neutral-900 shadow-sm"
|
|
||||||
: "text-neutral-500 hover:text-neutral-700"
|
|
||||||
}`}
|
|
||||||
>
|
|
||||||
<tab.icon className="h-4 w-4" />
|
|
||||||
{tab.label}
|
|
||||||
</button>
|
|
||||||
);
|
|
||||||
})}
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{/* Content */}
|
|
||||||
{activeTab === "strategy" && <CaseStrategy caseId={id} />}
|
|
||||||
{activeTab === "draft" && <DocumentDrafter caseId={id} />}
|
|
||||||
{activeTab === "similar" && <SimilarCaseFinder caseId={id} />}
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@@ -17,7 +17,6 @@ import {
|
|||||||
StickyNote,
|
StickyNote,
|
||||||
AlertTriangle,
|
AlertTriangle,
|
||||||
ScrollText,
|
ScrollText,
|
||||||
Brain,
|
|
||||||
} from "lucide-react";
|
} from "lucide-react";
|
||||||
import { format } from "date-fns";
|
import { format } from "date-fns";
|
||||||
import { de } from "date-fns/locale";
|
import { de } from "date-fns/locale";
|
||||||
@@ -49,7 +48,6 @@ const TABS = [
|
|||||||
{ segment: "mitarbeiter", label: "Mitarbeiter", icon: UserCheck },
|
{ segment: "mitarbeiter", label: "Mitarbeiter", icon: UserCheck },
|
||||||
{ segment: "notizen", label: "Notizen", icon: StickyNote },
|
{ segment: "notizen", label: "Notizen", icon: StickyNote },
|
||||||
{ segment: "protokoll", label: "Protokoll", icon: ScrollText },
|
{ segment: "protokoll", label: "Protokoll", icon: ScrollText },
|
||||||
{ segment: "ki", label: "KI", icon: Brain },
|
|
||||||
] as const;
|
] as const;
|
||||||
|
|
||||||
const TAB_LABELS: Record<string, string> = {
|
const TAB_LABELS: Record<string, string> = {
|
||||||
@@ -60,7 +58,6 @@ const TAB_LABELS: Record<string, string> = {
|
|||||||
mitarbeiter: "Mitarbeiter",
|
mitarbeiter: "Mitarbeiter",
|
||||||
notizen: "Notizen",
|
notizen: "Notizen",
|
||||||
protokoll: "Protokoll",
|
protokoll: "Protokoll",
|
||||||
ki: "KI",
|
|
||||||
};
|
};
|
||||||
|
|
||||||
function CaseDetailSkeleton() {
|
function CaseDetailSkeleton() {
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
import { Sidebar } from "@/components/layout/Sidebar";
|
import { Sidebar } from "@/components/layout/Sidebar";
|
||||||
import { Header } from "@/components/layout/Header";
|
import { Header } from "@/components/layout/Header";
|
||||||
|
import { DemoBanner } from "@/components/layout/DemoBanner";
|
||||||
|
|
||||||
export const dynamic = "force-dynamic";
|
export const dynamic = "force-dynamic";
|
||||||
|
|
||||||
@@ -12,6 +13,7 @@ export default function AppLayout({
|
|||||||
<div className="flex h-screen overflow-hidden bg-neutral-50">
|
<div className="flex h-screen overflow-hidden bg-neutral-50">
|
||||||
<Sidebar />
|
<Sidebar />
|
||||||
<div className="flex flex-1 flex-col overflow-hidden">
|
<div className="flex flex-1 flex-col overflow-hidden">
|
||||||
|
<DemoBanner />
|
||||||
<Header />
|
<Header />
|
||||||
<main className="flex-1 overflow-y-auto p-4 sm:p-6">{children}</main>
|
<main className="flex-1 overflow-y-auto p-4 sm:p-6">{children}</main>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -5,12 +5,22 @@ import { api } from "@/lib/api";
|
|||||||
import { useRouter } from "next/navigation";
|
import { useRouter } from "next/navigation";
|
||||||
import { useState } from "react";
|
import { useState } from "react";
|
||||||
|
|
||||||
|
interface AutoAssignResponse {
|
||||||
|
assigned: boolean;
|
||||||
|
tenant_id?: string;
|
||||||
|
name?: string;
|
||||||
|
slug?: string;
|
||||||
|
role?: string;
|
||||||
|
settings?: Record<string, unknown>;
|
||||||
|
}
|
||||||
|
|
||||||
export default function RegisterPage() {
|
export default function RegisterPage() {
|
||||||
const [email, setEmail] = useState("");
|
const [email, setEmail] = useState("");
|
||||||
const [password, setPassword] = useState("");
|
const [password, setPassword] = useState("");
|
||||||
const [firmName, setFirmName] = useState("");
|
const [firmName, setFirmName] = useState("");
|
||||||
const [loading, setLoading] = useState(false);
|
const [loading, setLoading] = useState(false);
|
||||||
const [error, setError] = useState<string | null>(null);
|
const [error, setError] = useState<string | null>(null);
|
||||||
|
const [showFirmName, setShowFirmName] = useState(true);
|
||||||
const router = useRouter();
|
const router = useRouter();
|
||||||
const supabase = createClient();
|
const supabase = createClient();
|
||||||
|
|
||||||
@@ -34,8 +44,30 @@ export default function RegisterPage() {
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// 2. Create tenant via backend (the backend adds the user as owner)
|
|
||||||
if (data.session) {
|
if (data.session) {
|
||||||
|
// 2. Check if email domain matches an existing tenant for auto-assignment
|
||||||
|
try {
|
||||||
|
const result = await api.post<AutoAssignResponse>("/tenants/auto-assign", { email });
|
||||||
|
if (result.assigned && result.tenant_id) {
|
||||||
|
// Auto-assigned — store tenant and go to dashboard
|
||||||
|
localStorage.setItem("kanzlai_tenant_id", result.tenant_id);
|
||||||
|
router.push("/");
|
||||||
|
router.refresh();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
} catch {
|
||||||
|
// Auto-assign failed — fall through to manual tenant creation
|
||||||
|
}
|
||||||
|
|
||||||
|
// 3. No auto-assignment — create tenant manually
|
||||||
|
if (!firmName) {
|
||||||
|
// Show firm name field if not yet visible
|
||||||
|
setShowFirmName(true);
|
||||||
|
setError("Bitte geben Sie einen Kanzleinamen ein");
|
||||||
|
setLoading(false);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await api.post("/tenants", { name: firmName });
|
await api.post("/tenants", { name: firmName });
|
||||||
} catch (err: unknown) {
|
} catch (err: unknown) {
|
||||||
@@ -68,6 +100,7 @@ export default function RegisterPage() {
|
|||||||
</div>
|
</div>
|
||||||
|
|
||||||
<form onSubmit={handleRegister} className="space-y-4">
|
<form onSubmit={handleRegister} className="space-y-4">
|
||||||
|
{showFirmName && (
|
||||||
<div>
|
<div>
|
||||||
<label
|
<label
|
||||||
htmlFor="firm"
|
htmlFor="firm"
|
||||||
@@ -80,11 +113,14 @@ export default function RegisterPage() {
|
|||||||
type="text"
|
type="text"
|
||||||
value={firmName}
|
value={firmName}
|
||||||
onChange={(e) => setFirmName(e.target.value)}
|
onChange={(e) => setFirmName(e.target.value)}
|
||||||
required
|
|
||||||
className="mt-1 block w-full rounded-md border border-neutral-300 px-3 py-2 text-sm placeholder-neutral-400 focus:border-neutral-900 focus:outline-none focus:ring-1 focus:ring-neutral-900"
|
className="mt-1 block w-full rounded-md border border-neutral-300 px-3 py-2 text-sm placeholder-neutral-400 focus:border-neutral-900 focus:outline-none focus:ring-1 focus:ring-neutral-900"
|
||||||
placeholder="Muster & Partner Rechtsanwaelte"
|
placeholder="Muster & Partner Rechtsanwaelte"
|
||||||
/>
|
/>
|
||||||
|
<p className="mt-1 text-xs text-neutral-400">
|
||||||
|
Leer lassen, falls Sie zu einer bestehenden Kanzlei eingeladen wurden
|
||||||
|
</p>
|
||||||
</div>
|
</div>
|
||||||
|
)}
|
||||||
|
|
||||||
<div>
|
<div>
|
||||||
<label
|
<label
|
||||||
|
|||||||
@@ -1,226 +0,0 @@
|
|||||||
"use client";
|
|
||||||
|
|
||||||
import { useMutation } from "@tanstack/react-query";
|
|
||||||
import { api } from "@/lib/api";
|
|
||||||
import type { StrategyRecommendation } from "@/lib/types";
|
|
||||||
import {
|
|
||||||
Loader2,
|
|
||||||
Brain,
|
|
||||||
AlertTriangle,
|
|
||||||
ArrowRight,
|
|
||||||
Shield,
|
|
||||||
Calendar,
|
|
||||||
RefreshCw,
|
|
||||||
} from "lucide-react";
|
|
||||||
|
|
||||||
interface CaseStrategyProps {
|
|
||||||
caseId: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
const PRIORITY_STYLES = {
|
|
||||||
high: "bg-red-50 text-red-700 border-red-200",
|
|
||||||
medium: "bg-amber-50 text-amber-700 border-amber-200",
|
|
||||||
low: "bg-emerald-50 text-emerald-700 border-emerald-200",
|
|
||||||
} as const;
|
|
||||||
|
|
||||||
const IMPORTANCE_STYLES = {
|
|
||||||
critical: "border-l-red-500",
|
|
||||||
important: "border-l-amber-500",
|
|
||||||
routine: "border-l-neutral-300",
|
|
||||||
} as const;
|
|
||||||
|
|
||||||
export function CaseStrategy({ caseId }: CaseStrategyProps) {
|
|
||||||
const mutation = useMutation({
|
|
||||||
mutationFn: () =>
|
|
||||||
api.post<StrategyRecommendation>("/ai/case-strategy", {
|
|
||||||
case_id: caseId,
|
|
||||||
}),
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!mutation.data && !mutation.isPending && !mutation.isError) {
|
|
||||||
return (
|
|
||||||
<div className="flex flex-col items-center gap-3 py-8 text-center">
|
|
||||||
<div className="rounded-xl bg-neutral-100 p-3">
|
|
||||||
<Brain className="h-6 w-6 text-neutral-400" />
|
|
||||||
</div>
|
|
||||||
<div>
|
|
||||||
<p className="text-sm font-medium text-neutral-900">
|
|
||||||
KI-Strategieanalyse
|
|
||||||
</p>
|
|
||||||
<p className="mt-1 text-sm text-neutral-500">
|
|
||||||
Claude analysiert die Akte und gibt strategische Empfehlungen.
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
<button
|
|
||||||
onClick={() => mutation.mutate()}
|
|
||||||
className="inline-flex items-center gap-2 rounded-md bg-neutral-900 px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-neutral-800"
|
|
||||||
>
|
|
||||||
<Brain className="h-4 w-4" />
|
|
||||||
Strategie analysieren
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (mutation.isPending) {
|
|
||||||
return (
|
|
||||||
<div className="flex flex-col items-center gap-3 py-12 text-center">
|
|
||||||
<Loader2 className="h-6 w-6 animate-spin text-neutral-400" />
|
|
||||||
<p className="text-sm text-neutral-500">
|
|
||||||
Claude analysiert die Akte...
|
|
||||||
</p>
|
|
||||||
<p className="text-xs text-neutral-400">
|
|
||||||
Dies kann bis zu 30 Sekunden dauern.
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (mutation.isError) {
|
|
||||||
return (
|
|
||||||
<div className="flex flex-col items-center gap-3 py-8 text-center">
|
|
||||||
<div className="rounded-xl bg-red-50 p-3">
|
|
||||||
<AlertTriangle className="h-6 w-6 text-red-500" />
|
|
||||||
</div>
|
|
||||||
<p className="text-sm text-neutral-900">Analyse fehlgeschlagen</p>
|
|
||||||
<button
|
|
||||||
onClick={() => mutation.mutate()}
|
|
||||||
className="inline-flex items-center gap-1 text-sm text-neutral-500 transition-colors hover:text-neutral-700"
|
|
||||||
>
|
|
||||||
<RefreshCw className="h-3.5 w-3.5" />
|
|
||||||
Erneut versuchen
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
const data = mutation.data!;
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="space-y-6">
|
|
||||||
<div className="flex items-center justify-between">
|
|
||||||
<h3 className="text-sm font-semibold text-neutral-900">
|
|
||||||
KI-Strategieanalyse
|
|
||||||
</h3>
|
|
||||||
<button
|
|
||||||
onClick={() => mutation.mutate()}
|
|
||||||
className="inline-flex items-center gap-1 rounded-md border border-neutral-200 px-2.5 py-1.5 text-xs font-medium text-neutral-600 transition-colors hover:bg-neutral-50"
|
|
||||||
>
|
|
||||||
<RefreshCw className="h-3.5 w-3.5" />
|
|
||||||
Aktualisieren
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{/* Summary */}
|
|
||||||
<div className="rounded-md border border-blue-100 bg-blue-50 px-4 py-3 text-sm text-blue-800">
|
|
||||||
{data.summary}
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{/* Next Steps */}
|
|
||||||
{data.next_steps?.length > 0 && (
|
|
||||||
<div>
|
|
||||||
<h4 className="mb-2 flex items-center gap-1.5 text-xs font-semibold uppercase tracking-wide text-neutral-500">
|
|
||||||
<ArrowRight className="h-3.5 w-3.5" />
|
|
||||||
Naechste Schritte
|
|
||||||
</h4>
|
|
||||||
<div className="space-y-2">
|
|
||||||
{data.next_steps.map((step, i) => (
|
|
||||||
<div
|
|
||||||
key={i}
|
|
||||||
className="rounded-md border border-neutral-200 bg-white px-4 py-3"
|
|
||||||
>
|
|
||||||
<div className="flex items-start gap-3">
|
|
||||||
<span
|
|
||||||
className={`mt-0.5 inline-block shrink-0 rounded-full border px-2 py-0.5 text-xs font-medium ${PRIORITY_STYLES[step.priority]}`}
|
|
||||||
>
|
|
||||||
{step.priority === "high"
|
|
||||||
? "Hoch"
|
|
||||||
: step.priority === "medium"
|
|
||||||
? "Mittel"
|
|
||||||
: "Niedrig"}
|
|
||||||
</span>
|
|
||||||
<div className="min-w-0">
|
|
||||||
<p className="text-sm font-medium text-neutral-900">
|
|
||||||
{step.action}
|
|
||||||
</p>
|
|
||||||
<p className="mt-1 text-sm text-neutral-500">
|
|
||||||
{step.reasoning}
|
|
||||||
</p>
|
|
||||||
{step.deadline && (
|
|
||||||
<p className="mt-1 text-xs text-neutral-400">
|
|
||||||
Frist: {step.deadline}
|
|
||||||
</p>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
))}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{/* Risk Assessment */}
|
|
||||||
{data.risk_assessment?.length > 0 && (
|
|
||||||
<div>
|
|
||||||
<h4 className="mb-2 flex items-center gap-1.5 text-xs font-semibold uppercase tracking-wide text-neutral-500">
|
|
||||||
<Shield className="h-3.5 w-3.5" />
|
|
||||||
Risikobewertung
|
|
||||||
</h4>
|
|
||||||
<div className="space-y-2">
|
|
||||||
{data.risk_assessment.map((risk, i) => (
|
|
||||||
<div
|
|
||||||
key={i}
|
|
||||||
className="rounded-md border border-neutral-200 bg-white px-4 py-3"
|
|
||||||
>
|
|
||||||
<div className="flex items-start gap-3">
|
|
||||||
<span
|
|
||||||
className={`mt-0.5 inline-block shrink-0 rounded-full border px-2 py-0.5 text-xs font-medium ${PRIORITY_STYLES[risk.level]}`}
|
|
||||||
>
|
|
||||||
{risk.level === "high"
|
|
||||||
? "Hoch"
|
|
||||||
: risk.level === "medium"
|
|
||||||
? "Mittel"
|
|
||||||
: "Niedrig"}
|
|
||||||
</span>
|
|
||||||
<div className="min-w-0">
|
|
||||||
<p className="text-sm font-medium text-neutral-900">
|
|
||||||
{risk.risk}
|
|
||||||
</p>
|
|
||||||
<p className="mt-1 text-sm text-neutral-500">
|
|
||||||
Massnahme: {risk.mitigation}
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
))}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{/* Timeline */}
|
|
||||||
{data.timeline?.length > 0 && (
|
|
||||||
<div>
|
|
||||||
<h4 className="mb-2 flex items-center gap-1.5 text-xs font-semibold uppercase tracking-wide text-neutral-500">
|
|
||||||
<Calendar className="h-3.5 w-3.5" />
|
|
||||||
Zeitplan
|
|
||||||
</h4>
|
|
||||||
<div className="space-y-1">
|
|
||||||
{data.timeline.map((item, i) => (
|
|
||||||
<div
|
|
||||||
key={i}
|
|
||||||
className={`border-l-2 py-2 pl-4 ${IMPORTANCE_STYLES[item.importance]}`}
|
|
||||||
>
|
|
||||||
<div className="flex items-baseline gap-2">
|
|
||||||
<span className="shrink-0 text-xs font-medium text-neutral-400">
|
|
||||||
{item.date}
|
|
||||||
</span>
|
|
||||||
<span className="text-sm text-neutral-900">{item.event}</span>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
))}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@@ -1,198 +0,0 @@
|
|||||||
"use client";
|
|
||||||
|
|
||||||
import { useState } from "react";
|
|
||||||
import { useMutation } from "@tanstack/react-query";
|
|
||||||
import { api } from "@/lib/api";
|
|
||||||
import type { DocumentDraft, DraftDocumentRequest } from "@/lib/types";
|
|
||||||
import { FileText, Loader2, Copy, Check, Download } from "lucide-react";
|
|
||||||
|
|
||||||
const TEMPLATES = {
|
|
||||||
klageschrift: "Klageschrift",
|
|
||||||
klageerwiderung: "Klageerwiderung",
|
|
||||||
abmahnung: "Abmahnung",
|
|
||||||
schriftsatz: "Schriftsatz",
|
|
||||||
berufung: "Berufungsschrift",
|
|
||||||
antrag: "Antrag",
|
|
||||||
stellungnahme: "Stellungnahme",
|
|
||||||
gutachten: "Gutachten",
|
|
||||||
vertrag: "Vertrag",
|
|
||||||
vollmacht: "Vollmacht",
|
|
||||||
upc_claim: "UPC Statement of Claim",
|
|
||||||
upc_defence: "UPC Statement of Defence",
|
|
||||||
upc_counterclaim: "UPC Counterclaim for Revocation",
|
|
||||||
upc_injunction: "UPC Provisional Measures",
|
|
||||||
} as const;
|
|
||||||
|
|
||||||
const LANGUAGES = [
|
|
||||||
{ value: "de", label: "Deutsch" },
|
|
||||||
{ value: "en", label: "English" },
|
|
||||||
{ value: "fr", label: "Francais" },
|
|
||||||
] as const;
|
|
||||||
|
|
||||||
const inputClass =
|
|
||||||
"w-full rounded-md border border-neutral-200 bg-white px-3 py-2 text-sm text-neutral-900 outline-none transition-colors focus:border-neutral-400 focus:ring-1 focus:ring-neutral-400";
|
|
||||||
|
|
||||||
interface DocumentDrafterProps {
|
|
||||||
caseId: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export function DocumentDrafter({ caseId }: DocumentDrafterProps) {
|
|
||||||
const [templateType, setTemplateType] = useState("");
|
|
||||||
const [instructions, setInstructions] = useState("");
|
|
||||||
const [language, setLanguage] = useState("de");
|
|
||||||
const [copied, setCopied] = useState(false);
|
|
||||||
|
|
||||||
const mutation = useMutation({
|
|
||||||
mutationFn: (req: DraftDocumentRequest) =>
|
|
||||||
api.post<DocumentDraft>("/ai/draft-document", req),
|
|
||||||
});
|
|
||||||
|
|
||||||
function handleSubmit(e: React.FormEvent) {
|
|
||||||
e.preventDefault();
|
|
||||||
if (!templateType) return;
|
|
||||||
mutation.mutate({
|
|
||||||
case_id: caseId,
|
|
||||||
template_type: templateType,
|
|
||||||
instructions,
|
|
||||||
language,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
function handleCopy() {
|
|
||||||
if (mutation.data?.content) {
|
|
||||||
navigator.clipboard.writeText(mutation.data.content);
|
|
||||||
setCopied(true);
|
|
||||||
setTimeout(() => setCopied(false), 2000);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function handleDownload() {
|
|
||||||
if (!mutation.data?.content) return;
|
|
||||||
const blob = new Blob([mutation.data.content], { type: "text/plain;charset=utf-8" });
|
|
||||||
const url = URL.createObjectURL(blob);
|
|
||||||
const a = document.createElement("a");
|
|
||||||
a.href = url;
|
|
||||||
a.download = `${templateType}_entwurf.txt`;
|
|
||||||
a.click();
|
|
||||||
URL.revokeObjectURL(url);
|
|
||||||
}
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="space-y-4">
|
|
||||||
<form onSubmit={handleSubmit} className="space-y-3">
|
|
||||||
<div>
|
|
||||||
<label className="mb-1 block text-xs font-medium text-neutral-500">
|
|
||||||
Dokumenttyp
|
|
||||||
</label>
|
|
||||||
<select
|
|
||||||
value={templateType}
|
|
||||||
onChange={(e) => setTemplateType(e.target.value)}
|
|
||||||
className={inputClass}
|
|
||||||
disabled={mutation.isPending}
|
|
||||||
>
|
|
||||||
<option value="">Dokumenttyp waehlen...</option>
|
|
||||||
{Object.entries(TEMPLATES).map(([key, label]) => (
|
|
||||||
<option key={key} value={key}>
|
|
||||||
{label}
|
|
||||||
</option>
|
|
||||||
))}
|
|
||||||
</select>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<label className="mb-1 block text-xs font-medium text-neutral-500">
|
|
||||||
Sprache
|
|
||||||
</label>
|
|
||||||
<select
|
|
||||||
value={language}
|
|
||||||
onChange={(e) => setLanguage(e.target.value)}
|
|
||||||
className={inputClass}
|
|
||||||
disabled={mutation.isPending}
|
|
||||||
>
|
|
||||||
{LANGUAGES.map((lang) => (
|
|
||||||
<option key={lang.value} value={lang.value}>
|
|
||||||
{lang.label}
|
|
||||||
</option>
|
|
||||||
))}
|
|
||||||
</select>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<div>
|
|
||||||
<label className="mb-1 block text-xs font-medium text-neutral-500">
|
|
||||||
Anweisungen (optional)
|
|
||||||
</label>
|
|
||||||
<textarea
|
|
||||||
value={instructions}
|
|
||||||
onChange={(e) => setInstructions(e.target.value)}
|
|
||||||
placeholder="z.B. 'Fokus auf Patentanspruch 1, besonders die technischen Merkmale...'"
|
|
||||||
rows={3}
|
|
||||||
className={inputClass}
|
|
||||||
disabled={mutation.isPending}
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<button
|
|
||||||
type="submit"
|
|
||||||
disabled={!templateType || mutation.isPending}
|
|
||||||
className="inline-flex items-center gap-2 rounded-md bg-neutral-900 px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-neutral-800 disabled:opacity-50"
|
|
||||||
>
|
|
||||||
{mutation.isPending ? (
|
|
||||||
<>
|
|
||||||
<Loader2 className="h-4 w-4 animate-spin" />
|
|
||||||
Dokument wird erstellt...
|
|
||||||
</>
|
|
||||||
) : (
|
|
||||||
<>
|
|
||||||
<FileText className="h-4 w-4" />
|
|
||||||
KI-Entwurf erstellen
|
|
||||||
</>
|
|
||||||
)}
|
|
||||||
</button>
|
|
||||||
</form>
|
|
||||||
|
|
||||||
{mutation.isError && (
|
|
||||||
<div className="rounded-md border border-red-200 bg-red-50 px-4 py-3 text-sm text-red-700">
|
|
||||||
Fehler beim Erstellen des Entwurfs. Bitte versuchen Sie es erneut.
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{mutation.data && (
|
|
||||||
<div className="space-y-3">
|
|
||||||
<div className="flex items-center justify-between">
|
|
||||||
<h4 className="text-sm font-medium text-neutral-900">
|
|
||||||
{mutation.data.title}
|
|
||||||
</h4>
|
|
||||||
<div className="flex items-center gap-2">
|
|
||||||
<button
|
|
||||||
onClick={handleCopy}
|
|
||||||
className="inline-flex items-center gap-1 rounded-md border border-neutral-200 px-2.5 py-1.5 text-xs font-medium text-neutral-600 transition-colors hover:bg-neutral-50"
|
|
||||||
>
|
|
||||||
{copied ? (
|
|
||||||
<>
|
|
||||||
<Check className="h-3.5 w-3.5 text-emerald-500" />
|
|
||||||
Kopiert
|
|
||||||
</>
|
|
||||||
) : (
|
|
||||||
<>
|
|
||||||
<Copy className="h-3.5 w-3.5" />
|
|
||||||
Kopieren
|
|
||||||
</>
|
|
||||||
)}
|
|
||||||
</button>
|
|
||||||
<button
|
|
||||||
onClick={handleDownload}
|
|
||||||
className="inline-flex items-center gap-1 rounded-md border border-neutral-200 px-2.5 py-1.5 text-xs font-medium text-neutral-600 transition-colors hover:bg-neutral-50"
|
|
||||||
>
|
|
||||||
<Download className="h-3.5 w-3.5" />
|
|
||||||
Download
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
<pre className="max-h-[600px] overflow-auto whitespace-pre-wrap rounded-md border border-neutral-200 bg-neutral-50 p-4 text-sm text-neutral-800">
|
|
||||||
{mutation.data.content}
|
|
||||||
</pre>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
@@ -1,183 +0,0 @@
|
|||||||
"use client";
|
|
||||||
|
|
||||||
import { useState } from "react";
|
|
||||||
import { useMutation } from "@tanstack/react-query";
|
|
||||||
import { api } from "@/lib/api";
|
|
||||||
import type { SimilarCasesResponse } from "@/lib/types";
|
|
||||||
import {
|
|
||||||
Loader2,
|
|
||||||
Search,
|
|
||||||
ExternalLink,
|
|
||||||
AlertTriangle,
|
|
||||||
Scale,
|
|
||||||
RefreshCw,
|
|
||||||
} from "lucide-react";
|
|
||||||
|
|
||||||
interface SimilarCaseFinderProps {
|
|
||||||
caseId: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
const inputClass =
|
|
||||||
"w-full rounded-md border border-neutral-200 bg-white px-3 py-2 text-sm text-neutral-900 outline-none transition-colors focus:border-neutral-400 focus:ring-1 focus:ring-neutral-400";
|
|
||||||
|
|
||||||
function RelevanceBadge({ score }: { score: number }) {
|
|
||||||
const pct = Math.round(score * 100);
|
|
||||||
let color = "bg-neutral-100 text-neutral-600";
|
|
||||||
if (pct >= 80) color = "bg-emerald-50 text-emerald-700";
|
|
||||||
else if (pct >= 60) color = "bg-blue-50 text-blue-700";
|
|
||||||
else if (pct >= 40) color = "bg-amber-50 text-amber-700";
|
|
||||||
return (
|
|
||||||
<span
|
|
||||||
className={`inline-block shrink-0 rounded-full px-2 py-0.5 text-xs font-medium ${color}`}
|
|
||||||
>
|
|
||||||
{pct}%
|
|
||||||
</span>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
|
|
||||||
export function SimilarCaseFinder({ caseId }: SimilarCaseFinderProps) {
|
|
||||||
const [description, setDescription] = useState("");
|
|
||||||
|
|
||||||
const mutation = useMutation({
|
|
||||||
mutationFn: (req: { case_id: string; description: string }) =>
|
|
||||||
api.post<SimilarCasesResponse>("/ai/similar-cases", req),
|
|
||||||
});
|
|
||||||
|
|
||||||
function handleSearch(e?: React.FormEvent) {
|
|
||||||
e?.preventDefault();
|
|
||||||
mutation.mutate({ case_id: caseId, description });
|
|
||||||
}
|
|
||||||
|
|
||||||
return (
|
|
||||||
<div className="space-y-4">
|
|
||||||
<form onSubmit={handleSearch} className="space-y-3">
|
|
||||||
<div>
|
|
||||||
<label className="mb-1 block text-xs font-medium text-neutral-500">
|
|
||||||
Zusaetzliche Beschreibung (optional)
|
|
||||||
</label>
|
|
||||||
<textarea
|
|
||||||
value={description}
|
|
||||||
onChange={(e) => setDescription(e.target.value)}
|
|
||||||
placeholder="z.B. 'SEP-Lizenzierung im Mobilfunkbereich, FRAND-Verteidigung...'"
|
|
||||||
rows={2}
|
|
||||||
className={inputClass}
|
|
||||||
disabled={mutation.isPending}
|
|
||||||
/>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<button
|
|
||||||
type="submit"
|
|
||||||
disabled={mutation.isPending}
|
|
||||||
className="inline-flex items-center gap-2 rounded-md bg-neutral-900 px-4 py-2 text-sm font-medium text-white transition-colors hover:bg-neutral-800 disabled:opacity-50"
|
|
||||||
>
|
|
||||||
{mutation.isPending ? (
|
|
||||||
<>
|
|
||||||
<Loader2 className="h-4 w-4 animate-spin" />
|
|
||||||
Suche laeuft...
|
|
||||||
</>
|
|
||||||
) : (
|
|
||||||
<>
|
|
||||||
<Search className="h-4 w-4" />
|
|
||||||
Aehnliche Faelle suchen
|
|
||||||
</>
|
|
||||||
)}
|
|
||||||
</button>
|
|
||||||
</form>
|
|
||||||
|
|
||||||
{mutation.isError && (
|
|
||||||
<div className="flex flex-col items-center gap-3 py-6 text-center">
|
|
||||||
<div className="rounded-xl bg-red-50 p-3">
|
|
||||||
<AlertTriangle className="h-6 w-6 text-red-500" />
|
|
||||||
</div>
|
|
||||||
<p className="text-sm text-neutral-900">Suche fehlgeschlagen</p>
|
|
||||||
<p className="text-xs text-neutral-500">
|
|
||||||
Die youpc.org-Datenbank ist moeglicherweise nicht verfuegbar.
|
|
||||||
</p>
|
|
||||||
<button
|
|
||||||
onClick={() => handleSearch()}
|
|
||||||
className="inline-flex items-center gap-1 text-sm text-neutral-500 transition-colors hover:text-neutral-700"
|
|
||||||
>
|
|
||||||
<RefreshCw className="h-3.5 w-3.5" />
|
|
||||||
Erneut versuchen
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{mutation.data && (
|
|
||||||
<div className="space-y-3">
|
|
||||||
<div className="flex items-center justify-between">
|
|
||||||
<p className="text-xs text-neutral-500">
|
|
||||||
{mutation.data.count} aehnliche{" "}
|
|
||||||
{mutation.data.count === 1 ? "Fall" : "Faelle"} gefunden
|
|
||||||
</p>
|
|
||||||
<button
|
|
||||||
onClick={() => handleSearch()}
|
|
||||||
disabled={mutation.isPending}
|
|
||||||
className="inline-flex items-center gap-1 rounded-md border border-neutral-200 px-2.5 py-1.5 text-xs font-medium text-neutral-600 transition-colors hover:bg-neutral-50"
|
|
||||||
>
|
|
||||||
<RefreshCw className="h-3.5 w-3.5" />
|
|
||||||
Aktualisieren
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
{mutation.data.cases?.length === 0 && (
|
|
||||||
<div className="flex flex-col items-center gap-2 py-6 text-center">
|
|
||||||
<Scale className="h-6 w-6 text-neutral-300" />
|
|
||||||
<p className="text-sm text-neutral-500">
|
|
||||||
Keine aehnlichen UPC-Faelle gefunden.
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
|
|
||||||
{mutation.data.cases?.map((c, i) => (
|
|
||||||
<div
|
|
||||||
key={i}
|
|
||||||
className="rounded-md border border-neutral-200 bg-white px-4 py-3"
|
|
||||||
>
|
|
||||||
<div className="flex items-start justify-between gap-3">
|
|
||||||
<div className="min-w-0 flex-1">
|
|
||||||
<div className="flex items-center gap-2">
|
|
||||||
<RelevanceBadge score={c.relevance} />
|
|
||||||
<span className="text-xs font-medium text-neutral-400">
|
|
||||||
{c.case_number}
|
|
||||||
</span>
|
|
||||||
{c.url && (
|
|
||||||
<a
|
|
||||||
href={c.url}
|
|
||||||
target="_blank"
|
|
||||||
rel="noopener noreferrer"
|
|
||||||
className="text-neutral-400 transition-colors hover:text-neutral-600"
|
|
||||||
>
|
|
||||||
<ExternalLink className="h-3.5 w-3.5" />
|
|
||||||
</a>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
<p className="mt-1 text-sm font-medium text-neutral-900">
|
|
||||||
{c.title}
|
|
||||||
</p>
|
|
||||||
<div className="mt-1 flex flex-wrap gap-x-3 text-xs text-neutral-400">
|
|
||||||
{c.court && <span>{c.court}</span>}
|
|
||||||
{c.date && <span>{c.date}</span>}
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
</div>
|
|
||||||
|
|
||||||
<p className="mt-2 text-sm text-neutral-600">{c.explanation}</p>
|
|
||||||
|
|
||||||
{c.key_holdings && (
|
|
||||||
<div className="mt-2 rounded border border-neutral-100 bg-neutral-50 px-3 py-2">
|
|
||||||
<p className="text-xs font-medium text-neutral-500">
|
|
||||||
Relevante Entscheidungsgruende
|
|
||||||
</p>
|
|
||||||
<p className="mt-0.5 text-xs text-neutral-600">
|
|
||||||
{c.key_holdings}
|
|
||||||
</p>
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
))}
|
|
||||||
</div>
|
|
||||||
)}
|
|
||||||
</div>
|
|
||||||
);
|
|
||||||
}
|
|
||||||
17
frontend/src/components/layout/DemoBanner.tsx
Normal file
17
frontend/src/components/layout/DemoBanner.tsx
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
"use client";
|
||||||
|
|
||||||
|
import { usePermissions } from "@/lib/hooks/usePermissions";
|
||||||
|
|
||||||
|
export function DemoBanner() {
|
||||||
|
const { isDemo, isLoading } = usePermissions();
|
||||||
|
|
||||||
|
if (isLoading || !isDemo) return null;
|
||||||
|
|
||||||
|
return (
|
||||||
|
<div className="flex items-center justify-center gap-2 bg-amber-50 border-b border-amber-200 px-4 py-2 text-sm text-amber-800">
|
||||||
|
<span className="font-medium">Demo-Modus</span>
|
||||||
|
<span className="text-amber-600">—</span>
|
||||||
|
<span>Keine echten Mandantendaten eingeben</span>
|
||||||
|
</div>
|
||||||
|
);
|
||||||
|
}
|
||||||
@@ -25,5 +25,6 @@ export function usePermissions() {
|
|||||||
isLoading,
|
isLoading,
|
||||||
userId: data?.user_id ?? null,
|
userId: data?.user_id ?? null,
|
||||||
tenantId: data?.tenant_id ?? null,
|
tenantId: data?.tenant_id ?? null,
|
||||||
|
isDemo: data?.is_demo ?? false,
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -202,6 +202,7 @@ export interface UserInfo {
|
|||||||
tenant_id: string;
|
tenant_id: string;
|
||||||
role: UserRole;
|
role: UserRole;
|
||||||
permissions: string[];
|
permissions: string[];
|
||||||
|
is_demo: boolean;
|
||||||
}
|
}
|
||||||
|
|
||||||
export type UserRole = "owner" | "partner" | "associate" | "paralegal" | "secretary";
|
export type UserRole = "owner" | "partner" | "associate" | "paralegal" | "secretary";
|
||||||
@@ -329,81 +330,3 @@ export interface ExtractionResponse {
|
|||||||
deadlines: ExtractedDeadline[];
|
deadlines: ExtractedDeadline[];
|
||||||
count: number;
|
count: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
// AI Document Drafting
|
|
||||||
|
|
||||||
export interface DocumentDraft {
|
|
||||||
title: string;
|
|
||||||
content: string;
|
|
||||||
language: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface DraftDocumentRequest {
|
|
||||||
case_id: string;
|
|
||||||
template_type: string;
|
|
||||||
instructions: string;
|
|
||||||
language: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export const TEMPLATE_TYPES: Record<string, string> = {
|
|
||||||
klageschrift: "Klageschrift",
|
|
||||||
klageerwiderung: "Klageerwiderung",
|
|
||||||
abmahnung: "Abmahnung",
|
|
||||||
schriftsatz: "Schriftsatz",
|
|
||||||
berufung: "Berufungsschrift",
|
|
||||||
antrag: "Antrag",
|
|
||||||
stellungnahme: "Stellungnahme",
|
|
||||||
gutachten: "Gutachten",
|
|
||||||
vertrag: "Vertrag",
|
|
||||||
vollmacht: "Vollmacht",
|
|
||||||
upc_claim: "UPC Statement of Claim",
|
|
||||||
upc_defence: "UPC Statement of Defence",
|
|
||||||
upc_counterclaim: "UPC Counterclaim for Revocation",
|
|
||||||
upc_injunction: "UPC Provisional Measures",
|
|
||||||
};
|
|
||||||
|
|
||||||
// AI Case Strategy
|
|
||||||
|
|
||||||
export interface StrategyStep {
|
|
||||||
priority: "high" | "medium" | "low";
|
|
||||||
action: string;
|
|
||||||
reasoning: string;
|
|
||||||
deadline?: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface RiskItem {
|
|
||||||
level: "high" | "medium" | "low";
|
|
||||||
risk: string;
|
|
||||||
mitigation: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface TimelineItem {
|
|
||||||
date: string;
|
|
||||||
event: string;
|
|
||||||
importance: "critical" | "important" | "routine";
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface StrategyRecommendation {
|
|
||||||
summary: string;
|
|
||||||
next_steps: StrategyStep[];
|
|
||||||
risk_assessment: RiskItem[];
|
|
||||||
timeline: TimelineItem[];
|
|
||||||
}
|
|
||||||
|
|
||||||
// AI Similar Case Finder
|
|
||||||
|
|
||||||
export interface SimilarCase {
|
|
||||||
case_number: string;
|
|
||||||
title: string;
|
|
||||||
court: string;
|
|
||||||
date: string;
|
|
||||||
relevance: number;
|
|
||||||
explanation: string;
|
|
||||||
key_holdings: string;
|
|
||||||
url?: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface SimilarCasesResponse {
|
|
||||||
cases: SimilarCase[];
|
|
||||||
count: number;
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user