Nova konverzace se tady zvyrazni a pusti zvuk.
- Zakaznik pise...
diff --git a/public/admin.js b/public/admin.js
index 3f29cf9..6ad5b6e 100644
--- a/public/admin.js
+++ b/public/admin.js
@@ -4,7 +4,8 @@ const state = {
conversations: [],
activeId: null,
active: null,
- events: null
+ events: null,
+ statusFilter: "active"
};
const $ = (selector) => document.querySelector(selector);
@@ -78,13 +79,30 @@ $("#replyForm textarea").addEventListener("input", debounce(() => {
api(`/api/admin/conversations/${state.activeId}/typing`, { method: "POST" }).catch(() => {});
}, 600));
-$("#statusSelect").addEventListener("change", async () => {
- if (!state.activeId) return;
- await api(`/api/admin/conversations/${state.activeId}/status`, {
- method: "PATCH",
- body: { status: $("#statusSelect").value }
- });
- await loadConversations();
+$("#conversationFilter").addEventListener("change", () => {
+ state.statusFilter = $("#conversationFilter").value;
+ renderConversations();
+});
+
+$("#conversationList").addEventListener("click", async (event) => {
+ const photoButton = event.target.closest("[data-photo-url]");
+ const openButton = event.target.closest("[data-open]");
+ const deleteButton = event.target.closest("[data-delete]");
+ if (photoButton) {
+ openPhotoPreview(photoButton.dataset.photoUrl, photoButton.dataset.photoName);
+ return;
+ }
+ if (deleteButton) {
+ await deleteConversation(deleteButton.dataset.delete);
+ return;
+ }
+ if (openButton) await openConversation(openButton.dataset.open);
+});
+
+$("#conversationList").addEventListener("change", async (event) => {
+ const statusSelect = event.target.closest("[data-status-for]");
+ if (!statusSelect) return;
+ await updateConversationStatus(statusSelect.dataset.statusFor, statusSelect.value);
});
$("#messages").addEventListener("click", (event) => {
@@ -140,7 +158,11 @@ function connectEvents() {
return;
}
await loadConversations();
- if (state.activeId) await openConversation(state.activeId);
+ if (data.type === "conversation:delete" && data.conversationId === state.activeId) {
+ clearActiveConversation();
+ return;
+ }
+ if (state.activeId) await openConversation(state.activeId).catch(() => clearActiveConversation());
if (data.type === "conversation:new" || data.type === "message:new") notify();
});
}
@@ -164,21 +186,29 @@ function renderSite() {
}
function renderConversations() {
- $("#conversationList").innerHTML = state.conversations.map((item) => `
- Zadny chat pro vybrany filtr.
`;
}
function renderActive() {
const { conversation, messages } = state.active;
- const statusSelect = $("#statusSelect");
$("#conversationHeader").innerHTML = `
@@ -200,6 +227,55 @@ function renderActive() {
$("#messages").scrollTop = $("#messages").scrollHeight;
}
+function filteredConversations() {
+ if (state.statusFilter === "all") return state.conversations;
+ if (state.statusFilter === "active") return state.conversations.filter((item) => item.status === "new" || item.status === "open");
+ return state.conversations.filter((item) => item.status === state.statusFilter);
+}
+
+function statusOptions(currentStatus) {
+ return [
+ ["new", "nove"],
+ ["open", "otevrene"],
+ ["resolved", "vyresene"],
+ ["spam", "spam"]
+ ].map(([value, label]) => ``).join("");
+}
+
+async function updateConversationStatus(id, status) {
+ await api(`/api/admin/conversations/${id}/status`, {
+ method: "PATCH",
+ body: { status }
+ });
+ const item = state.conversations.find((conversation) => conversation.id === id);
+ if (item) item.status = status;
+ if (state.active?.conversation?.id === id) state.active.conversation.status = status;
+ renderConversations();
+}
+
+async function deleteConversation(id) {
+ const item = state.conversations.find((conversation) => conversation.id === id);
+ const label = item?.visitor?.name || item?.lastBody || "tento chat";
+ if (!confirm(`Smazat ${label}? Tahle akce nejde vratit.`)) return;
+ await api(`/api/admin/conversations/${id}`, { method: "DELETE" });
+ state.conversations = state.conversations.filter((conversation) => conversation.id !== id);
+ if (state.activeId === id) clearActiveConversation();
+ renderConversations();
+}
+
+function clearActiveConversation() {
+ state.activeId = null;
+ state.active = null;
+ $("#conversationHeader").innerHTML = `
+
+
Vyber konverzaci
+
Nova konverzace se tady zvyrazni a pusti zvuk.
+
${attachments.map((attachment) => {
diff --git a/server.js b/server.js
index e51569c..bb30dc8 100644
--- a/server.js
+++ b/server.js
@@ -77,6 +77,7 @@ async function adminApi(req, res, url) {
if (url.pathname === "/api/admin/site" && req.method === "PATCH") return updateSite(req, res);
if (url.pathname === "/api/admin/conversations" && req.method === "GET") return adminConversations(res);
if (url.pathname.match(/^\/api\/admin\/conversations\/[^/]+$/) && req.method === "GET") return adminConversation(res, url);
+ if (url.pathname.match(/^\/api\/admin\/conversations\/[^/]+$/) && req.method === "DELETE") return deleteConversation(res, url);
if (url.pathname.match(/^\/api\/admin\/conversations\/[^/]+\/messages$/) && req.method === "POST") return createAdminMessage(req, res, url);
if (url.pathname.match(/^\/api\/admin\/conversations\/[^/]+\/status$/) && req.method === "PATCH") return updateConversationStatus(req, res, url);
if (url.pathname.match(/^\/api\/admin\/conversations\/[^/]+\/typing$/) && req.method === "POST") return adminTyping(req, res, url);
@@ -256,7 +257,9 @@ function adminConversations(res) {
const rows = db.prepare(`
SELECT c.*, s.site_key,
(SELECT body FROM messages WHERE conversation_id = c.id ORDER BY id DESC LIMIT 1) AS last_body,
- (SELECT COUNT(*) FROM messages WHERE conversation_id = c.id) AS message_count
+ (SELECT COUNT(*) FROM messages WHERE conversation_id = c.id) AS message_count,
+ (SELECT COUNT(*) FROM attachments WHERE conversation_id = c.id AND mime_type LIKE 'image/%') AS image_count,
+ (SELECT public_url FROM attachments WHERE conversation_id = c.id AND mime_type LIKE 'image/%' ORDER BY id DESC LIMIT 1) AS first_image_url
FROM conversations c
JOIN sites s ON s.id = c.site_id
ORDER BY datetime(c.last_message_at) DESC, c.id DESC
@@ -297,6 +300,24 @@ async function updateConversationStatus(req, res, url) {
return json(res, 200, { conversation: formatConversationSummary(updated) });
}
+function deleteConversation(res, url) {
+ const conversation = findConversation(publicIdFrom(url));
+ if (!conversation) return json(res, 404, { error: "conversation_not_found" });
+ const attachments = db.prepare("SELECT storage_path FROM attachments WHERE conversation_id = ?").all(conversation.id);
+ db.transaction(() => {
+ db.prepare("DELETE FROM attachments WHERE conversation_id = ?").run(conversation.id);
+ db.prepare("DELETE FROM messages WHERE conversation_id = ?").run(conversation.id);
+ db.prepare("DELETE FROM conversations WHERE id = ?").run(conversation.id);
+ })();
+ for (const attachment of attachments) {
+ if (attachment.storage_path && path.resolve(attachment.storage_path).startsWith(path.resolve(UPLOAD_DIR))) {
+ fs.rmSync(attachment.storage_path, { force: true });
+ }
+ }
+ publish("admin", { type: "conversation:delete", conversationId: conversation.public_id });
+ return json(res, 200, { ok: true });
+}
+
function widgetConfig(res, url) {
const siteKey = url.searchParams.get("siteKey") || process.env.DEFAULT_SITE_KEY || "9b-plus";
const site = db.prepare("SELECT * FROM sites WHERE site_key = ?").get(siteKey);
@@ -501,6 +522,8 @@ function formatConversationSummary(row) {
vpnRisk: Boolean(row.vpn_risk),
lastBody: row.last_body,
messageCount: row.message_count,
+ imageCount: row.image_count || 0,
+ firstImageUrl: row.first_image_url,
lastMessageAt: row.last_message_at,
createdAt: row.created_at
};
@@ -582,7 +605,7 @@ function json(res, status, payload) {
function setCommonHeaders(res) {
res.setHeader("Access-Control-Allow-Origin", "*");
res.setHeader("Access-Control-Allow-Headers", "Content-Type");
- res.setHeader("Access-Control-Allow-Methods", "GET,POST,PATCH,OPTIONS");
+ res.setHeader("Access-Control-Allow-Methods", "GET,POST,PATCH,DELETE,OPTIONS");
}
function endCors(res) {