apunkt/SurfSense
1
0
Fork 0
mirror of https://github.com/MODSetter/SurfSense.git synced 2026-04-27 09:46:25 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Revert "feat: added posthog"

Browse source 
This reverts commit c96be7d9e1.
This commit is contained in:
DESKTOP-RTLN3BA\$punk 2025-12-25 13:37:35 -08:00
parent c96be7d9e1
commit d9e6947fbd
18 changed files with 19 additions and 506 deletions
Download patch file Download diff file Expand all files Collapse all files

41
surfsense_web/lib/chat/thread-persistence.ts
View file

@ -3,7 +3,6 @@
* Provides API functions and thread list management.
*/
import { trackChatCreated, trackChatDeleted, trackMessageSent } from "@/lib/analytics";
import { baseApiService } from "@/lib/apis/base-api.service";
// =============================================================================
@ -81,18 +80,13 @@ export async function createThread(
searchSpaceId: number,
title = "New Chat"
): Promise<ThreadRecord> {
const thread = await baseApiService.post<ThreadRecord>("/api/v1/threads", undefined, {
return baseApiService.post<ThreadRecord>("/api/v1/threads", undefined, {
body: {
title,
archived: false,
search_space_id: searchSpaceId,
},
});
// Track chat creation event
trackChatCreated({ search_space_id: searchSpaceId, thread_id: thread.id });
return thread;
}
/**
@ -107,27 +101,11 @@ export async function getThreadMessages(threadId: number): Promise<ThreadHistory
*/
export async function appendMessage(
threadId: number,
message: { role: "user" | "assistant" | "system"; content: unknown },
searchSpaceId?: number
message: { role: "user" | "assistant" | "system"; content: unknown }
): Promise<MessageRecord> {
const result = await baseApiService.post<MessageRecord>(
`/api/v1/threads/${threadId}/messages`,
undefined,
{
body: message,
}
);
// Track message sent event (only for user messages to avoid double-counting)
if (message.role === "user" && searchSpaceId) {
trackMessageSent({
search_space_id: searchSpaceId,
thread_id: threadId,
role: message.role,
});
}
return result;
return baseApiService.post<MessageRecord>(`/api/v1/threads/${threadId}/messages`, undefined, {
body: message,
});
}
/**
@ -145,13 +123,8 @@ export async function updateThread(
/**
* Delete a thread
*/
export async function deleteThread(threadId: number, searchSpaceId?: number): Promise<void> {
export async function deleteThread(threadId: number): Promise<void> {
await baseApiService.delete(`/api/v1/threads/${threadId}`);
// Track chat deletion event
if (searchSpaceId) {
trackChatDeleted({ search_space_id: searchSpaceId, thread_id: threadId });
}
}
// =============================================================================
@ -245,7 +218,7 @@ export function createThreadListManager(config: ThreadListAdapterConfig) {
async deleteThread(threadId: number): Promise<boolean> {
try {
await deleteThread(threadId, config.searchSpaceId);
await deleteThread(threadId);
return true;
} catch (error) {
console.error("[ThreadListManager] Failed to delete thread:", error);