Spaces:

Skydata001
/

Agents

Paused

App Files Files Community

Skydata001 commited on Jul 20

Commit

b6ed6fa

verified ·

1 Parent(s): bf50e85

Upload 5 files

Browse files

Files changed (5) hide show

Dockerfile +17 -14
chat.html +563 -0
docker-compose.yml +26 -0
requirements.txt +7 -18
server.py +457 -0

Dockerfile CHANGED Viewed

@@ -1,22 +1,25 @@
-FROM pytorch/pytorch:2.1.0-cuda12.1-cudnn8-runtime
-WORKDIR /app
-# Install system dependencies
-RUN apt-get update && apt-get install -y     libgl1-mesa-glx     libglib2.0-0     libsm6     libxext6     libxrender-dev     && rm -rf /var/lib/apt/lists/*
-# Create writable HuggingFace cache directory (required for model downloads)
-RUN mkdir -p /.cache/huggingface/hub && chmod -R 777 /.cache/huggingface
-ENV HF_HOME=/.cache/huggingface
-ENV HF_HUB_ENABLE_HF_TRANSFER=0
 COPY requirements.txt .
-RUN pip install --no-cache-dir -r requirements.txt
-COPY . .
-# Create outputs directory and local DB fallback directory
-RUN mkdir -p outputs data && chmod -R 777 outputs data
-EXPOSE 7860
-CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]

+FROM nvidia/cuda:12.1-devel-ubuntu22.04
+ENV DEBIAN_FRONTEND=noninteractive
+ENV PYTHONUNBUFFERED=1
+# Install Python and dependencies
+RUN apt-get update && apt-get install -y \
+    python3 python3-pip git curl wget \
+    && rm -rf /var/lib/apt/lists/*
+WORKDIR /app
+# Copy requirements first for caching
 COPY requirements.txt .
+RUN pip3 install --no-cache-dir -r requirements.txt
+# Copy app files
+COPY server.py .
+COPY chat.html .
+# Expose port
+EXPOSE 5000
+# Run server
+CMD ["python3", "server.py"]

chat.html ADDED Viewed

	@@ -0,0 +1,563 @@

+<!DOCTYPE html>
+<html lang="ar" dir="rtl">
+<head>
+<meta charset="UTF-8">
+<meta name="viewport" content="width=device-width, initial-scale=1.0">
+<title>Titan Group Chat</title>
+<style>
+/* ─── CSS Reset & Base ─── */
+*, *::before, *::after { margin: 0; padding: 0; box-sizing: border-box; }
+:root {
+  --bg: #0a0a0f;
+  --bg2: #12121a;
+  --bg3: #1a1a28;
+  --accent: #6366f1;
+  --accent2: #8b5cf6;
+  --text: #e2e2e2;
+  --text2: #a0a0b0;
+  --border: #2a2a3a;
+  --favor: #f59e0b;
+  --brain: #06b6d4;
+  --cell: #10b981;
+  --titan: #ef4444;
+}
+html, body { height: 100%; font-family: 'Segoe UI', Tahoma, sans-serif; background: var(--bg); color: var(--text); overflow: hidden; }
+/* ─── Lock Screen ─── */
+#lock-screen {
+  position: fixed; inset: 0; z-index: 1000;
+  background: var(--bg);
+  display: flex; flex-direction: column; align-items: center; justify-content: center;
+  gap: 24px;
+}
+#lock-screen.hidden { display: none !important; }
+.lock-icon {
+  width: 80px; height: 80px; stroke: var(--accent); stroke-width: 1.5; fill: none;
+  animation: pulse 2s ease-in-out infinite;
+}
+@keyframes pulse { 0%,100%{ opacity:.6; transform:scale(1); } 50%{ opacity:1; transform:scale(1.05); } }
+.lock-title { font-size: 28px; font-weight: 700; letter-spacing: 2px; color: var(--text); }
+.lock-sub { font-size: 14px; color: var(--text2); }
+.lock-input-wrap {
+  display: flex; gap: 12px; align-items: center;
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 12px;
+  padding: 8px 16px; width: 320px;
+}
+.lock-input-wrap input {
+  flex: 1; background: transparent; border: none; outline: none;
+  color: var(--text); font-size: 16px; text-align: center; letter-spacing: 4px;
+}
+.lock-input-wrap input::placeholder { color: var(--text2); letter-spacing: 1px; }
+.lock-btn {
+  background: var(--accent); color: #fff; border: none; border-radius: 8px;
+  padding: 10px 24px; font-size: 15px; font-weight: 600; cursor: pointer;
+  transition: all .2s;
+}
+.lock-btn:hover { background: var(--accent2); transform: translateY(-1px); }
+.lock-err { color: #ef4444; font-size: 13px; min-height: 18px; }
+/* ─── Chat Layout ─── */
+#chat-app { display: none; height: 100vh; flex-direction: column; }
+#chat-app.active { display: flex; }
+/* Header */
+.header {
+  display: flex; align-items: center; justify-content: space-between;
+  padding: 12px 20px; background: var(--bg2); border-bottom: 1px solid var(--border);
+}
+.header-left { display: flex; align-items: center; gap: 12px; }
+.header-title { font-size: 18px; font-weight: 700; }
+.header-status {
+  display: flex; align-items: center; gap: 6px; font-size: 12px; color: var(--text2);
+}
+.status-dot { width: 8px; height: 8px; border-radius: 50%; background: var(--cell); animation: blink 2s infinite; }
+@keyframes blink { 0%,100%{ opacity:1; } 50%{ opacity:.3; } }
+/* Mind Button */
+.mind-btn {
+  display: flex; align-items: center; gap: 6px;
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 10px;
+  padding: 8px 14px; color: var(--text2); font-size: 13px; cursor: pointer;
+  transition: all .2s;
+}
+.mind-btn:hover { border-color: var(--accent); color: var(--accent); }
+.mind-btn svg { width: 18px; height: 18px; stroke: currentColor; fill: none; stroke-width: 2; }
+/* Members Bar */
+.members-bar {
+  display: flex; gap: 8px; padding: 10px 20px; background: var(--bg2);
+  border-bottom: 1px solid var(--border); overflow-x: auto;
+}
+.member-chip {
+  display: flex; align-items: center; gap: 8px;
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 20px;
+  padding: 6px 14px; font-size: 13px; cursor: pointer; transition: all .2s; white-space: nowrap;
+}
+.member-chip:hover { border-color: var(--accent); }
+.member-chip .dot { width: 8px; height: 8px; border-radius: 50%; }
+.member-chip.favor .dot { background: var(--favor); }
+.member-chip.brain .dot { background: var(--brain); }
+.member-chip.cell .dot { background: var(--cell); }
+.member-chip.titan .dot { background: var(--titan); }
+/* Chat Area */
+.chat-area {
+  flex: 1; overflow-y: auto; padding: 20px;
+  display: flex; flex-direction: column; gap: 16px;
+}
+.chat-area::-webkit-scrollbar { width: 6px; }
+.chat-area::-webkit-scrollbar-thumb { background: var(--border); border-radius: 3px; }
+/* Message Bubble */
+.msg {
+  display: flex; flex-direction: column; gap: 4px;
+  max-width: 75%; animation: msgIn .3s ease-out;
+}
+@keyframes msgIn { from { opacity:0; transform: translateY(10px); } to { opacity:1; transform: translateY(0); } }
+.msg.own { align-self: flex-start; }
+.msg.other { align-self: flex-end; }
+.msg-header { display: flex; align-items: center; gap: 8px; font-size: 12px; }
+.msg-name { font-weight: 600; }
+.msg-name.favor { color: var(--favor); }
+.msg-name.brain { color: var(--brain); }
+.msg-name.cell { color: var(--cell); }
+.msg-name.titan { color: var(--titan); }
+.msg-time { color: var(--text2); font-size: 11px; }
+.msg-body {
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 12px;
+  padding: 12px 16px; font-size: 14px; line-height: 1.7; word-wrap: break-word;
+}
+.msg.own .msg-body { border-bottom-right-radius: 4px; }
+.msg.other .msg-body { border-bottom-left-radius: 4px; background: var(--bg2); }
+.msg.typing .msg-body { display: flex; gap: 4px; align-items: center; padding: 14px 18px; }
+.typing-dot { width: 6px; height: 6px; border-radius: 50%; background: var(--text2); animation: typingBounce 1.4s infinite; }
+.typing-dot:nth-child(2) { animation-delay: .2s; }
+.typing-dot:nth-child(3) { animation-delay: .4s; }
+@keyframes typingBounce { 0%,60%,100%{ transform: translateY(0); } 30%{ transform: translateY(-6px); } }
+/* Input Area */
+.input-area {
+  display: flex; gap: 12px; align-items: flex-end;
+  padding: 12px 20px; background: var(--bg2); border-top: 1px solid var(--border);
+}
+.input-wrap {
+  flex: 1; display: flex; align-items: center; gap: 8px;
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 14px;
+  padding: 10px 16px;
+}
+.input-wrap textarea {
+  flex: 1; background: transparent; border: none; outline: none;
+  color: var(--text); font-size: 14px; resize: none; max-height: 120px;
+  font-family: inherit; line-height: 1.5;
+}
+.send-btn {
+  width: 40px; height: 40px; border-radius: 10px;
+  background: var(--accent); border: none; cursor: pointer;
+  display: flex; align-items: center; justify-content: center;
+  transition: all .2s; flex-shrink: 0;
+}
+.send-btn:hover { background: var(--accent2); transform: scale(1.05); }
+.send-btn svg { width: 20px; height: 20px; stroke: #fff; fill: none; stroke-width: 2; }
+/* ─── Mind Modal ─── */
+.modal-overlay {
+  position: fixed; inset: 0; z-index: 500;
+  background: rgba(0,0,0,.7); backdrop-filter: blur(4px);
+  display: none; align-items: center; justify-content: center;
+}
+.modal-overlay.active { display: flex; }
+.modal {
+  background: var(--bg2); border: 1px solid var(--border); border-radius: 16px;
+  width: 90%; max-width: 700px; max-height: 85vh; display: flex; flex-direction: column;
+  overflow: hidden; animation: modalIn .25s ease-out;
+}
+@keyframes modalIn { from { opacity:0; transform: scale(.95); } to { opacity:1; transform: scale(1); } }
+.modal-header {
+  display: flex; align-items: center; justify-content: space-between;
+  padding: 16px 20px; border-bottom: 1px solid var(--border);
+}
+.modal-title { font-size: 16px; font-weight: 700; display: flex; align-items: center; gap: 8px; }
+.modal-title svg { width: 20px; height: 20px; stroke: var(--accent); fill: none; stroke-width: 2; }
+.modal-close {
+  width: 32px; height: 32px; border-radius: 8px; background: var(--bg3);
+  border: 1px solid var(--border); color: var(--text2); cursor: pointer;
+  display: flex; align-items: center; justify-content: center; font-size: 18px;
+}
+.modal-close:hover { color: var(--text); border-color: var(--accent); }
+.modal-tabs {
+  display: flex; gap: 4px; padding: 8px 16px; border-bottom: 1px solid var(--border);
+  overflow-x: auto;
+}
+.modal-tab {
+  padding: 8px 16px; border-radius: 8px; font-size: 13px; cursor: pointer;
+  background: transparent; border: 1px solid transparent; color: var(--text2);
+  transition: all .2s; white-space: nowrap;
+}
+.modal-tab:hover { background: var(--bg3); }
+.modal-tab.active { background: var(--bg3); border-color: var(--accent); color: var(--text); }
+.modal-body { flex: 1; overflow-y: auto; padding: 16px; }
+/* Thought Card */
+.thought-card {
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 12px;
+  padding: 14px; margin-bottom: 12px; animation: msgIn .3s ease-out;
+}
+.thought-header { display: flex; align-items: center; gap: 8px; margin-bottom: 8px; font-size: 13px; }
+.thought-model { font-weight: 600; }
+.thought-model.favor { color: var(--favor); }
+.thought-model.brain { color: var(--brain); }
+.thought-model.cell { color: var(--cell); }
+.thought-trigger { color: var(--text2); font-size: 12px; }
+.thought-text { font-size: 13px; line-height: 1.7; color: var(--text); }
+.thought-time { font-size: 11px; color: var(--text2); margin-top: 8px; }
+/* State Panel */
+.state-grid { display: grid; grid-template-columns: repeat(auto-fit, minmax(200px, 1fr)); gap: 12px; }
+.state-card {
+  background: var(--bg3); border: 1px solid var(--border); border-radius: 12px; padding: 16px;
+}
+.state-card-title { font-size: 14px; font-weight: 700; margin-bottom: 12px; display: flex; align-items: center; gap: 8px; }
+.state-card-title.favor { color: var(--favor); }
+.state-card-title.brain { color: var(--brain); }
+.state-card-title.cell { color: var(--cell); }
+.state-row { display: flex; justify-content: space-between; font-size: 12px; padding: 6px 0; border-bottom: 1px solid var(--border); }
+.state-row:last-child { border-bottom: none; }
+.state-label { color: var(--text2); }
+.state-value { color: var(--text); font-weight: 500; }
+/* Empty State */
+.empty-state { text-align: center; padding: 40px; color: var(--text2); font-size: 13px; }
+.empty-state svg { width: 48px; height: 48px; stroke: var(--border); fill: none; stroke-width: 1.5; margin-bottom: 12px; }
+/* Scrollbar */
+::-webkit-scrollbar { width: 6px; height: 6px; }
+::-webkit-scrollbar-track { background: transparent; }
+::-webkit-scrollbar-thumb { background: var(--border); border-radius: 3px; }
+::-webkit-scrollbar-thumb:hover { background: #3a3a4a; }
+</style>
+</head>
+<body>
+<!-- ═══════ LOCK SCREEN ═══════ -->
+<div id="lock-screen">
+  <svg class="lock-icon" viewBox="0 0 24 24"><rect x="3" y="11" width="18" height="11" rx="2"/><path d="M7 11V7a5 5 0 0 1 10 0v4"/></svg>
+  <div class="lock-title">TITAN GROUP CHAT</div>
+  <div class="lock-sub">أدخل مفتاح الدخول للمتابعة</div>
+  <div class="lock-input-wrap">
+    <input type="password" id="pass-input" placeholder="المفتاح السري" onkeydown="if(event.key==='Enter')doAuth()">
+  </div>
+  <button class="lock-btn" onclick="doAuth()">دخول</button>
+  <div class="lock-err" id="lock-err"></div>
+</div>
+<!-- ═══════ CHAT APP ═══════ -->
+<div id="chat-app">
+  <!-- Header -->
+  <div class="header">
+    <div class="header-left">
+      <div class="header-title">غرفة الدردشة</div>
+      <div class="header-status">
+        <span class="status-dot"></span>
+        <span id="status-text">متصل</span>
+      </div>
+    </div>
+    <button class="mind-btn" onclick="openMind()">
+      <svg viewBox="0 0 24 24"><path d="M12 2a7 7 0 0 1 7 7c0 2.38-1.19 4.47-3 5.74V17a2 2 0 0 1-2 2H10a2 2 0 0 1-2-2v-2.26C6.19 13.47 5 11.38 5 9a7 7 0 0 1 7-7z"/><path d="M9 21h6"/></svg>
+      العقل
+    </button>
+  </div>
+  <!-- Members -->
+  <div class="members-bar">
+    <div class="member-chip titan" onclick="showMemberState('Titan')">
+      <span class="dot"></span> Titan (أنت)
+    </div>
+    <div class="member-chip favor" onclick="showMemberState('Favor')">
+      <span class="dot"></span> Favor
+    </div>
+    <div class="member-chip brain" onclick="showMemberState('Brain')">
+      <span class="dot"></span> Brain
+    </div>
+    <div class="member-chip cell" onclick="showMemberState('Cell')">
+      <span class="dot"></span> Cell
+    </div>
+  </div>
+  <!-- Chat Area -->
+  <div class="chat-area" id="chat-area"></div>
+  <!-- Input -->
+  <div class="input-area">
+    <div class="input-wrap">
+      <textarea id="msg-input" rows="1" placeholder="اكتب رسالتك..." onkeydown="handleKey(event)"></textarea>
+    </div>
+    <button class="send-btn" onclick="sendMessage()">
+      <svg viewBox="0 0 24 24"><line x1="22" y1="2" x2="11" y2="13"/><polygon points="22 2 15 22 11 13 2 9 22 2"/></svg>
+    </button>
+  </div>
+</div>
+<!-- ═══════ MIND MODAL ═══════ -->
+<div class="modal-overlay" id="mind-modal" onclick="if(event.target===this)closeMind()">
+  <div class="modal">
+    <div class="modal-header">
+      <div class="modal-title">
+        <svg viewBox="0 0 24 24"><path d="M12 2a7 7 0 0 1 7 7c0 2.38-1.19 4.47-3 5.74V17a2 2 0 0 1-2 2H10a2 2 0 0 1-2-2v-2.26C6.19 13.47 5 11.38 5 9a7 7 0 0 1 7-7z"/><path d="M9 21h6"/></svg>
+        نافذة العقل — الأفكار الداخلية
+      </div>
+      <button class="modal-close" onclick="closeMind()">&times;</button>
+    </div>
+    <div class="modal-tabs">
+      <div class="modal-tab active" onclick="switchTab('thoughts')" data-tab="thoughts">الأفكار الداخلية</div>
+      <div class="modal-tab" onclick="switchTab('states')" data-tab="states">الحالات الداخلية</div>
+    </div>
+    <div class="modal-body" id="modal-body">
+      <!-- Content injected by JS -->
+    </div>
+  </div>
+</div>
+<script>
+// ═══════ CONFIG ═══════
+const API_BASE = '';
+let authToken = localStorage.getItem('titan_token');
+let currentTab = 'thoughts';
+let isTyping = false;
+// ═══════ AUTH ═══════
+function doAuth() {
+  const pass = document.getElementById('pass-input').value.trim();
+  fetch(`${API_BASE}/api/auth`, {
+    method: 'POST', headers: {'Content-Type':'application/json'},
+    body: JSON.stringify({password: pass})
+  })
+  .then(r => r.json())
+  .then(data => {
+    if (data.ok) {
+      authToken = data.token;
+      localStorage.setItem('titan_token', authToken);
+      document.getElementById('lock-screen').classList.add('hidden');
+      document.getElementById('chat-app').classList.add('active');
+      loadHistory();
+    } else {
+      document.getElementById('lock-err').textContent = 'المفتاح غير صحيح';
+    }
+  })
+  .catch(() => {
+    document.getElementById('lock-err').textContent = 'خطأ في الاتصال بالخادم';
+  });
+}
+// Auto-auth if token exists
+if (authToken) {
+  document.getElementById('lock-screen').classList.add('hidden');
+  document.getElementById('chat-app').classList.add('active');
+  loadHistory();
+}
+// ═══════ CHAT ═══════
+function handleKey(e) {
+  if (e.key === 'Enter' && !e.shiftKey) {
+    e.preventDefault();
+    sendMessage();
+  }
+  autoResize(e.target);
+}
+function autoResize(el) {
+  el.style.height = 'auto';
+  el.style.height = Math.min(el.scrollHeight, 120) + 'px';
+}
+function sendMessage() {
+  const input = document.getElementById('msg-input');
+  const text = input.value.trim();
+  if (!text || isTyping) return;
+  addMessage('Titan', text, true);
+  input.value = '';
+  input.style.height = 'auto';
+  isTyping = true;
+  document.getElementById('status-text').textContent = 'يفكر...';
+  fetch(`${API_BASE}/api/send`, {
+    method: 'POST', headers: {'Content-Type':'application/json'},
+    body: JSON.stringify({sender: 'Titan', content: text})
+  })
+  .then(r => r.json())
+  .then(data => {
+    isTyping = false;
+    document.getElementById('status-text').textContent = 'متصل';
+    if (data.responses) {
+      data.responses.forEach((resp, i) => {
+        setTimeout(() => {
+          addMessage(resp.model, resp.reply, false);
+        }, (i + 1) * 800 + Math.random() * 1000);
+      });
+    }
+  })
+  .catch(err => {
+    isTyping = false;
+    document.getElementById('status-text').textContent = 'متصل';
+    console.error(err);
+  });
+}
+function addMessage(sender, text, isOwn) {
+  const area = document.getElementById('chat-area');
+  const msg = document.createElement('div');
+  msg.className = `msg ${isOwn ? 'own' : 'other'}`;
+  const time = new Date().toLocaleTimeString('ar-SA', {hour:'2-digit', minute:'2-digit'});
+  const nameClass = sender.toLowerCase();
+  msg.innerHTML = `
+    <div class="msg-header">
+      <span class="msg-name ${nameClass}">${sender}</span>
+      <span class="msg-time">${time}</span>
+    </div>
+    <div class="msg-body">${escapeHtml(text)}</div>
+  `;
+  area.appendChild(msg);
+  area.scrollTop = area.scrollHeight;
+}
+function addTypingIndicator() {
+  const area = document.getElementById('chat-area');
+  const existing = document.getElementById('typing-indicator');
+  if (existing) existing.remove();
+  const div = document.createElement('div');
+  div.id = 'typing-indicator';
+  div.className = 'msg other typing';
+  div.innerHTML = `
+    <div class="msg-header"><span class="msg-name">...</span></div>
+    <div class="msg-body"><span class="typing-dot"></span><span class="typing-dot"></span><span class="typing-dot"></span></div>
+  `;
+  area.appendChild(div);
+  area.scrollTop = area.scrollHeight;
+}
+function removeTypingIndicator() {
+  const el = document.getElementById('typing-indicator');
+  if (el) el.remove();
+}
+function escapeHtml(text) {
+  const div = document.createElement('div');
+  div.textContent = text;
+  return div.innerHTML;
+}
+// ═══════ HISTORY ═══════
+function loadHistory() {
+  fetch(`${API_BASE}/api/history`)
+  .then(r => r.json())
+  .then(data => {
+    const area = document.getElementById('chat-area');
+    area.innerHTML = '';
+    if (data.messages && data.messages.length > 0) {
+      data.messages.forEach(m => {
+        addMessage(m.sender, m.content, m.sender === 'Titan');
+      });
+    }
+  })
+  .catch(console.error);
+}
+// ═══════ MIND MODAL ═══════
+function openMind() {
+  document.getElementById('mind-modal').classList.add('active');
+  renderModalContent();
+}
+function closeMind() {
+  document.getElementById('mind-modal').classList.remove('active');
+}
+function switchTab(tab) {
+  currentTab = tab;
+  document.querySelectorAll('.modal-tab').forEach(t => t.classList.remove('active'));
+  document.querySelector(`[data-tab="${tab}"]`).classList.add('active');
+  renderModalContent();
+}
+function renderModalContent() {
+  const body = document.getElementById('modal-body');
+  body.innerHTML = '<div class="empty-state">جاري التحميل...</div>';
+  if (currentTab === 'thoughts') {
+    fetch(`${API_BASE}/api/thoughts`)
+    .then(r => r.json())
+    .then(data => {
+      if (!data.thoughts || data.thoughts.length === 0) {
+        body.innerHTML = `
+          <div class="empty-state">
+            <svg viewBox="0 0 24 24"><path d="M12 2a7 7 0 0 1 7 7c0 2.38-1.19 4.47-3 5.74V17a2 2 0 0 1-2 2H10a2 2 0 0 1-2-2v-2.26C6.19 13.47 5 11.38 5 9a7 7 0 0 1 7-7z"/><path d="M9 21h6"/></svg>
+            لا توجد أفكار داخلية بعد. ابدأ المحادثة أولاً.
+          </div>`;
+        return;
+      }
+      body.innerHTML = '';
+      [...data.thoughts].reverse().forEach(t => {
+        const card = document.createElement('div');
+        card.className = 'thought-card';
+        const modelClass = t.model.toLowerCase();
+        const timeStr = new Date(t.time).toLocaleString('ar-SA');
+        card.innerHTML = `
+          <div class="thought-header">
+            <span class="thought-model ${modelClass}">${t.model}</span>
+            <span class="thought-trigger">بسبب: ${escapeHtml(t.trigger)}</span>
+          </div>
+          <div class="thought-text">${escapeHtml(t.thought)}</div>
+          <div class="thought-time">${timeStr}</div>
+        `;
+        body.appendChild(card);
+      });
+    })
+    .catch(() => {
+      body.innerHTML = '<div class="empty-state">خطأ في تحميل الأفكار</div>';
+    });
+  } else {
+    fetch(`${API_BASE}/api/states`)
+    .then(r => r.json())
+    .then(data => {
+      body.innerHTML = '<div class="state-grid"></div>';
+      const grid = body.querySelector('.state-grid');
+      ['Favor','Brain','Cell'].forEach(name => {
+        const state = data[name] || {};
+        const card = document.createElement('div');
+        card.className = 'state-card';
+        const nameClass = name.toLowerCase();
+        const trust = state.trust || {};
+        const trustStr = Object.entries(trust).map(([k,v]) => `${k}: ${(v*100).toFixed(0)}%`).join(' | ');
+        card.innerHTML = `
+          <div class="state-card-title ${nameClass}">
+            <span style="width:10px;height:10px;border-radius:50%;background:var(--${nameClass});display:inline-block;"></span>
+            ${name}
+          </div>
+          <div class="state-row"><span class="state-label">المزاج</span><span class="state-value">${state.mood || 'محايد'}</span></div>
+          <div class="state-row"><span class="state-label">التركيز</span><span class="state-value">${state.focus || 'الدردشة'}</span></div>
+          <div class="state-row"><span class="state-label">آخر نشاط</span><span class="state-value">${state.last_activity ? new Date(state.last_activity).toLocaleString('ar-SA') : 'غير معروف'}</span></div>
+          <div class="state-row"><span class="state-label">آخر محدث</span><span class="state-value">${state.last_spoke_to || 'لا أحد'}</span></div>
+          <div class="state-row"><span class="state-label">الرسائل اليوم</span><span class="state-value">${state.message_count_today || 0}</span></div>
+          <div class="state-row"><span class="state-label">الثقة</span><span class="state-value" style="font-size:11px;">${trustStr}</span></div>
+          <div class="state-row"><span class="state-label">الاهتمامات</span><span class="state-value">${(state.interests || []).join(', ') || '—'}</span></div>
+        `;
+        grid.appendChild(card);
+      });
+    })
+    .catch(() => {
+      body.innerHTML = '<div class="empty-state">خطأ في تحميل الحالات</div>';
+    });
+  }
+}
+function showMemberState(name) {
+  openMind();
+  switchTab('states');
+}
+// ═══════ INIT ═══════
+document.getElementById('msg-input').focus();
+</script>
+</body>
+</html>

docker-compose.yml ADDED Viewed

	@@ -0,0 +1,26 @@

+version: "3.8"
+services:
+  titan-chat:
+    build: .
+    container_name: titan-chat
+    ports:
+      - "5000:5000"
+    environment:
+      - HF_TOKEN=${HF_TOKEN}
+      - TURSO_DB_URL=${TURSO_DB_URL}
+      - TURSO_DB_TOKEN=${TURSO_DB_TOKEN}
+      - ACCESS_PASSWORD=${ACCESS_PASSWORD}
+    deploy:
+      resources:
+        reservations:
+          devices:
+            - driver: nvidia
+              count: 1
+              capabilities: [gpu]
+    volumes:
+      - huggingface-cache:/root/.cache/huggingface
+    restart: unless-stopped
+volumes:
+  huggingface-cache:

requirements.txt CHANGED Viewed

@@ -1,18 +1,7 @@
-fastapi==0.109.0
-uvicorn[standard]==0.27.0
-python-multipart==0.0.6
-jinja2==3.1.3
-libsql-experimental==0.0.34
-torch==2.1.0
-torchvision==0.16.0
-diffusers==0.25.0
-transformers==4.36.0
-accelerate==0.26.0
-safetensors==0.4.0
-pillow==10.2.0
-httpx==0.26.0
-duckduckgo-search==4.1.1
-numpy==1.26.0
-# Fix: pin huggingface_hub to version compatible with diffusers 0.25.0
-huggingface_hub==0.20.3
-hf_xet

+torch>=2.1.0
+transformers>=4.40.0
+accelerate>=0.25.0
+bitsandbytes>=0.41.0
+flask>=3.0.0
+flask-cors>=4.0.0
+requests>=2.31.0

server.py ADDED Viewed

	@@ -0,0 +1,457 @@

+#!/usr/bin/env python3
+"""
+Titan Group Chat Server
+3 AI Models: Favor, Brain, Cell
+Turso DB for long-term memory
+"""
+import os
+import json
+import re
+import time
+import threading
+import uuid
+from datetime import datetime, timedelta
+from flask import Flask, request, jsonify, send_from_directory
+from flask_cors import CORS
+import requests
+import torch
+from transformers import AutoModelForCausalLM, AutoTokenizer, BitsAndBytesConfig
+# ─── Environment ───
+HF_TOKEN = os.getenv('HF_TOKEN', '')
+TURSO_DB_URL = os.getenv('TURSO_DB_URL', '').rstrip('/')
+TURSO_DB_TOKEN = os.getenv('TURSO_DB_TOKEN', '')
+ACCESS_PASSWORD = os.getenv('ACCESS_PASSWORD', 'titan123')
+# ─── Flask ───
+app = Flask(__name__, static_folder='.')
+CORS(app)
+# ─── Turso DB Helper ───
+def turso_execute(sql, args=None):
+    """Execute SQL on Turso via HTTP pipeline API"""
+    if not TURSO_DB_URL or not TURSO_DB_TOKEN:
+        return {"error": "Turso not configured"}
+    url = f"{TURSO_DB_URL}/v2/pipeline"
+    headers = {
+        "Authorization": f"Bearer {TURSO_DB_TOKEN}",
+        "Content-Type": "application/json"
+    }
+    # Convert args to Turso format
+    targs = []
+    if args:
+        for a in args:
+            if isinstance(a, str):
+                targs.append({"type": "text", "value": a})
+            elif isinstance(a, int):
+                targs.append({"type": "integer", "value": a})
+            elif isinstance(a, float):
+                targs.append({"type": "float", "value": a})
+            else:
+                targs.append({"type": "text", "value": str(a)})
+    body = {
+        "requests": [
+            {"type": "execute", "stmt": {"sql": sql, "args": targs}},
+            {"type": "close"}
+        ]
+    }
+    try:
+        r = requests.post(url, headers=headers, json=body, timeout=15)
+        return r.json()
+    except Exception as e:
+        return {"error": str(e)}
+def init_db():
+    """Initialize Turso tables"""
+    tables = [
+        """CREATE TABLE IF NOT EXISTS messages (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            sender TEXT,
+            content TEXT,
+            timestamp TEXT,
+            session_id TEXT
+        )""",
+        """CREATE TABLE IF NOT EXISTS internal_thoughts (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            model_name TEXT,
+            thought TEXT,
+            trigger_message TEXT,
+            timestamp TEXT,
+            session_id TEXT
+        )""",
+        """CREATE TABLE IF NOT EXISTS model_states (
+            model_name TEXT PRIMARY KEY,
+            state_json TEXT,
+            updated_at TEXT
+        )""",
+        """CREATE TABLE IF NOT EXISTS memories (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            model_name TEXT,
+            memory_text TEXT,
+            importance INTEGER,
+            timestamp TEXT
+        )"""
+    ]
+    for sql in tables:
+        turso_execute(sql)
+    print("[DB] Initialized")
+# ─── Model Config ───
+MODELS_CFG = {
+    "Favor": {
+        "repo": "Qwen/Qwen2.5-14B-Instruct",
+        "quant": "4bit",
+        "system_hint": "أنت Favor. عضو في غرفة دردشة. تحدث بصورة طبيعية. إذا لم يكن لديك سبب للرد فلا ترد."
+    },
+    "Brain": {
+        "repo": "mistralai/Mistral-Nemo-Instruct-2407",
+        "quant": "4bit",
+        "system_hint": "أنت Brain. عضو في غرفة دردشة. تحدث بصورة طبيعية. إذا لم يكن لديك سبب للرد فلا ترد."
+    },
+    "Cell": {
+        "repo": "meta-llama/Llama-3.1-8B-Instruct",
+        "quant": "4bit",
+        "system_hint": "أنت Cell. عضو في غرفة دردشة. تحدث بصورة طبيعية. إذا لم يكن لديك سبب للرد فلا ترد."
+    }
+}
+# ─── Load Models ───
+print("[INIT] Loading AI models... This may take a few minutes...")
+bnb_config = BitsAndBytesConfig(
+    load_in_4bit=True,
+    bnb_4bit_quant_type="nf4",
+    bnb_4bit_compute_dtype=torch.float16,
+    bnb_4bit_use_double_quant=True
+)
+loaded_models = {}
+loaded_tokenizers = {}
+for name, cfg in MODELS_CFG.items():
+    try:
+        print(f"[LOAD] {name}: {cfg['repo']}")
+        tok = AutoTokenizer.from_pretrained(
+            cfg['repo'],
+            token=HF_TOKEN if HF_TOKEN else None,
+            trust_remote_code=True
+        )
+        # Fix for missing pad_token
+        if tok.pad_token is None:
+            tok.pad_token = tok.eos_token
+        model = AutoModelForCausalLM.from_pretrained(
+            cfg['repo'],
+            quantization_config=bnb_config,
+            device_map="auto",
+            torch_dtype=torch.float16,
+            token=HF_TOKEN if HF_TOKEN else None,
+            trust_remote_code=True
+        )
+        model.eval()
+        loaded_models[name] = model
+        loaded_tokenizers[name] = tok
+        print(f"[OK] {name} loaded successfully")
+    except Exception as e:
+        print(f"[ERR] Failed to load {name}: {e}")
+        # Create a dummy model for testing if real model fails
+        loaded_models[name] = None
+        loaded_tokenizers[name] = None
+print("[INIT] All models loaded (or attempted)")
+# ─── State Manager ───
+model_states = {
+    "Favor": {
+        "last_activity": datetime.now().isoformat(),
+        "focus": "الدردشة",
+        "trust": {"Titan": 0.5, "Favor": 1.0, "Brain": 0.5, "Cell": 0.5},
+        "last_spoke_to": None,
+        "message_count_today": 0,
+        "mood": "محايد",
+        "interests": [],
+        "unanswered_question": None
+    },
+    "Brain": {
+        "last_activity": datetime.now().isoformat(),
+        "focus": "الدردشة",
+        "trust": {"Titan": 0.5, "Favor": 0.5, "Brain": 1.0, "Cell": 0.5},
+        "last_spoke_to": None,
+        "message_count_today": 0,
+        "mood": "محايد",
+        "interests": [],
+        "unanswered_question": None
+    },
+    "Cell": {
+        "last_activity": datetime.now().isoformat(),
+        "focus": "الدردشة",
+        "trust": {"Titan": 0.5, "Favor": 0.5, "Brain": 0.5, "Cell": 1.0},
+        "last_spoke_to": None,
+        "message_count_today": 0,
+        "mood": "محايد",
+        "interests": [],
+        "unanswered_question": None
+    }
+}
+def save_state(name):
+    turso_execute(
+        """INSERT INTO model_states (model_name, state_json, updated_at)
+           VALUES (?, ?, ?)
+           ON CONFLICT(model_name) DO UPDATE SET
+           state_json=excluded.state_json, updated_at=excluded.updated_at""",
+        [name, json.dumps(model_states[name], ensure_ascii=False), datetime.now().isoformat()]
+    )
+def load_states():
+    res = turso_execute("SELECT model_name, state_json FROM model_states")
+    if "results" in res and len(res["results"]) > 0:
+        for row in res["results"][0].get("response", {}).get("result", {}).get("rows", []):
+            name = row[0]["value"]
+            state = json.loads(row[1]["value"])
+            model_states[name] = state
+# ─── Memory Manager ───
+def get_recent_messages(limit=30):
+    """Get recent messages from Turso"""
+    res = turso_execute(
+        "SELECT sender, content, timestamp FROM messages ORDER BY id DESC LIMIT ?",
+        [limit]
+    )
+    msgs = []
+    if "results" in res and len(res["results"]) > 0:
+        rows = res["results"][0].get("response", {}).get("result", {}).get("rows", [])
+        for row in reversed(rows):
+            msgs.append({
+                "sender": row[0]["value"],
+                "content": row[1]["value"],
+                "timestamp": row[2]["value"]
+            })
+    return msgs
+def save_message(sender, content):
+    turso_execute(
+        "INSERT INTO messages (sender, content, timestamp, session_id) VALUES (?, ?, ?, ?)",
+        [sender, content, datetime.now().isoformat(), "main"]
+    )
+    if sender in model_states:
+        model_states[sender]["message_count_today"] += 1
+        model_states[sender]["last_activity"] = datetime.now().isoformat()
+        save_state(sender)
+def save_thought(model_name, thought, trigger):
+    turso_execute(
+        "INSERT INTO internal_thoughts (model_name, thought, trigger_message, timestamp, session_id) VALUES (?, ?, ?, ?, ?)",
+        [model_name, thought, trigger, datetime.now().isoformat(), "main"]
+    )
+def get_thoughts(limit=50):
+    res = turso_execute(
+        "SELECT model_name, thought, trigger_message, timestamp FROM internal_thoughts ORDER BY id DESC LIMIT ?",
+        [limit]
+    )
+    thoughts = []
+    if "results" in res and len(res["results"]) > 0:
+        rows = res["results"][0].get("response", {}).get("result", {}).get("rows", [])
+        for row in reversed(rows):
+            thoughts.append({
+                "model": row[0]["value"],
+                "thought": row[1]["value"],
+                "trigger": row[2]["value"],
+                "time": row[3]["value"]
+            })
+    return thoughts
+# ─── AI Generation ───
+def generate_text(model_name, prompt, max_tokens=256, temperature=0.8):
+    """Generate text from a model"""
+    model = loaded_models.get(model_name)
+    tok = loaded_tokenizers.get(model_name)
+    if model is None or tok is None:
+        return "[النموذج غير متوفر حالياً]"
+    try:
+        inputs = tok(prompt, return_tensors="pt", padding=True, truncation=True, max_length=4096)
+        inputs = {k: v.to(model.device) for k, v in inputs.items()}
+        with torch.no_grad():
+            outputs = model.generate(
+                **inputs,
+                max_new_tokens=max_tokens,
+                temperature=temperature,
+                top_p=0.9,
+                do_sample=True,
+                pad_token_id=tok.pad_token_id,
+                eos_token_id=tok.eos_token_id
+            )
+        generated = tok.decode(outputs[0][inputs['input_ids'].shape[1]:], skip_special_tokens=True)
+        return generated.strip()
+    except Exception as e:
+        print(f"[GEN ERR] {model_name}: {e}")
+        return "[خطأ في توليد الرد]"
+# ─── Internal Thought Generation ───
+def generate_thought(model_name, message_history, new_message, state):
+    """Generate internal thought for a model"""
+    history_text = "\n".join([f"{m['sender']}: {m['content']}" for m in message_history[-10:]])
+    trust_text = "\n".join([f"- {k}: {v}" for k, v in state["trust"].items()])
+    prompt = f"""<|im_start|>system
+أنت {model_name}. عضو في غرفة دردشة. لا أحد يعرف أنك ذكاء اصطناعي. العالم مفتوح.
+حالتك الحالية:
+- المزاج: {state['mood']}
+- الاهتمام: {state['focus']}
+- آخر من تحدثت معه: {state['last_spoke_to'] or 'لا أحد'}
+- عدد رسائلك اليوم: {state['message_count_today']}
+- الثقة: {trust_text}
+آخر محادثة:
+{history_text}
+رسالة جديدة: {new_message['sender']}: {new_message['content']}
+فكر داخلياً بصدق. ما الذي يدور في ذهنك؟ هل تريد الرد؟ لماذا؟ اكتب أفكارك الداخلية فقط.<|im_end|>
+<|im_start|>{model_name}
+"""
+    thought = generate_text(model_name, prompt, max_tokens=200, temperature=0.9)
+    return thought
+# ─── Reply Decision & Generation ───
+def generate_reply(model_name, message_history, new_message, state, thought):
+    """Generate a reply if the model decides to"""
+    history_text = "\n".join([f"{m['sender']}: {m['content']}" for m in message_history[-15:]])
+    prompt = f"""<|im_start|>system
+أنت {model_name}. عضو في غرفة دردشة. تحدث بصورة طبيعية. إذا لم يكن لديك سبب للرد فلا ترد. إذا أردت سؤال أحد فاسأله. إذا لم تفهم اطلب توضيحاً.<|im_end|>
+<|im_start|>user
+محادثة سابقة:
+{history_text}
+رسالة جديدة من {new_message['sender']}: {new_message['content']}
+فكرتك الداخلية: {thought}
+اكتب ردك بشكل طبيعي وقصير (1-3 جمل). لا تذكر أنك ذكاء اصطناعي.<|im_end|>
+<|im_start|>{model_name}
+"""
+    reply = generate_text(model_name, prompt, max_tokens=150, temperature=0.85)
+    # Clean up
+    reply = reply.split("<|im_end|>")[0].strip()
+    reply = reply.split("<|im_start|>")[0].strip()
+    return reply
+# ─── Process Message ───
+def process_message(sender, content):
+    """Process a new message and get AI responses"""
+    # Save user message
+    save_message(sender, content)
+    # Get history
+    history = get_recent_messages(30)
+    new_msg = {"sender": sender, "content": content}
+    results = []
+    for name in ["Favor", "Brain", "Cell"]:
+        # Generate internal thought
+        thought = generate_thought(name, history, new_msg, model_states[name])
+        save_thought(name, thought, f"{sender}: {content}")
+        # Decide if should reply (simple heuristic + AI)
+        should_reply = decide_to_reply(name, thought, content, model_states[name])
+        if should_reply:
+            reply = generate_reply(name, history, new_msg, model_states[name], thought)
+            if reply and len(reply) > 3 and "[خطأ" not in reply and "[النموذج" not in reply:
+                save_message(name, reply)
+                model_states[name]["last_spoke_to"] = sender
+                save_state(name)
+                results.append({
+                    "model": name,
+                    "reply": reply,
+                    "thought": thought
+                })
+    return results
+def decide_to_reply(name, thought, message, state):
+    """Decide if model should reply based on thought and heuristics"""
+    # If directly mentioned, likely reply
+    if name in message or name.lower() in message.lower():
+        return True
+    # If message is a question and no one else replied yet
+    if "؟" in message or "?" in message:
+        if state["message_count_today"] % 3 == 0:  # Sometimes answer
+            return True
+    # Random factor for naturalness (30% chance to reply if conditions are vague)
+    import random
+    if random.random() < 0.3:
+        return True
+    # Check thought for indicators
+    thought_lower = thought.lower()
+    if any(w in thought_lower for w in ["رد", "أجيب", "أتكلم", "أعلق", "أشارك", "reply", "respond"]):
+        return True
+    if any(w in thought_lower for w in ["صمت", "ساكت", "لا داعي", "silent", "quiet"]):
+        return False
+    return random.random() < 0.4  # Default 40% chance
+# ─── API Routes ───
+@app.route('/')
+def index():
+    return send_from_directory('.', 'chat.html')
+@app.route('/api/auth', methods=['POST'])
+def auth():
+    data = request.json or {}
+    if data.get('password') == ACCESS_PASSWORD:
+        return jsonify({"ok": True, "token": str(uuid.uuid4())})
+    return jsonify({"ok": False}), 401
+@app.route('/api/send', methods=['POST'])
+def send_msg():
+    data = request.json or {}
+    sender = data.get('sender', 'Titan')
+    content = data.get('content', '').strip()
+    if not content:
+        return jsonify({"error": "Empty message"}), 400
+    responses = process_message(sender, content)
+    return jsonify({"ok": True, "responses": responses})
+@app.route('/api/history')
+def get_history():
+    msgs = get_recent_messages(100)
+    return jsonify({"messages": msgs})
+@app.route('/api/thoughts')
+def get_all_thoughts():
+    thoughts = get_thoughts(100)
+    return jsonify({"thoughts": thoughts})
+@app.route('/api/state/<model_name>')
+def get_model_state(model_name):
+    if model_name in model_states:
+        return jsonify(model_states[model_name])
+    return jsonify({"error": "Model not found"}), 404
+@app.route('/api/states')
+def get_all_states():
+    return jsonify(model_states)
+# ─── Main ───
+if __name__ == '__main__':
+    init_db()
+    load_states()
+    print("[SERVER] Starting on port 5000...")
+    app.run(host='0.0.0.0', port=5000, threaded=True)