Skip to content

Feat/improved logging #3833

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
TheodoreSpeaks wants to merge 9 commits into
base: staging
Choose a base branch
from
Draft

Feat/improved logging #3833

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
1235625
feat(logs): add additional metadata for workflow execution logs
Mar 28, 2026
584ac10
Revert "Feat(logs) upgrade mothership chat messages to error (#3772)"
Mar 28, 2026
c64795b
Fix lint, address greptile comments
Mar 28, 2026
dc6d0e9
improvement(sidebar): expand sidebar by hovering and clicking the edg…
waleedlatif1 Mar 28, 2026
223e2d8
feat(ui): handle image paste (#3826)
TheodoreSpeaks Mar 28, 2026
f181d1f
feat(files): interactive markdown checkbox toggling in preview (#3829)
waleedlatif1 Mar 28, 2026
de8f53e
improvement(home): position @ mention popup at caret and fix icon con…
waleedlatif1 Mar 28, 2026
eaaf644
improvement(ui): sidebar (#3832)
waleedlatif1 Mar 28, 2026
f8fe447
Fix logger tests
Mar 29, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions apps/sim/app/api/copilot/chat/route.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ export async function POST(req: NextRequest) {

const userMessageIdToUse = userMessageId || crypto.randomUUID()
try {
logger.error(
logger.info(
appendCopilotLogContext('Received chat POST', {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand Down Expand Up @@ -251,7 +251,7 @@ export async function POST(req: NextRequest) {
actualChatId
)
agentContexts = processed
logger.error(
logger.info(
appendCopilotLogContext('Contexts processed for request', {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand Down Expand Up @@ -358,7 +358,7 @@ export async function POST(req: NextRequest) {
)

try {
logger.error(
logger.info(
appendCopilotLogContext('About to call Sim Agent', {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand Down Expand Up @@ -572,7 +572,7 @@ export async function POST(req: NextRequest) {
provider: typeof requestPayload?.provider === 'string' ? requestPayload.provider : undefined,
}

logger.error(
logger.info(
appendCopilotLogContext('Non-streaming response from orchestrator', {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand Down Expand Up @@ -617,7 +617,7 @@ export async function POST(req: NextRequest) {

// Start title generation in parallel if this is first message (non-streaming)
if (actualChatId && !currentChat.title && conversationHistory.length === 0) {
logger.error(
logger.info(
appendCopilotLogContext('Starting title generation for non-streaming response', {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand All @@ -633,7 +633,7 @@ export async function POST(req: NextRequest) {
updatedAt: new Date(),
})
.where(eq(copilotChats.id, actualChatId!))
logger.error(
logger.info(
appendCopilotLogContext(`Generated and saved title: ${title}`, {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand Down Expand Up @@ -662,7 +662,7 @@ export async function POST(req: NextRequest) {
.where(eq(copilotChats.id, actualChatId!))
}

logger.error(
logger.info(
appendCopilotLogContext('Returning non-streaming response', {
requestId: tracker.requestId,
messageId: userMessageIdToUse,
Expand Down Expand Up @@ -795,7 +795,7 @@ export async function GET(req: NextRequest) {
...(streamSnapshot ? { streamSnapshot } : {}),
}

logger.error(
logger.info(
appendCopilotLogContext(`Retrieved chat ${chatId}`, {
messageId: chat.conversationId || undefined,
})
Expand Down
8 changes: 4 additions & 4 deletions apps/sim/app/api/copilot/chat/stream/route.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ export async function GET(request: NextRequest) {
const toParam = url.searchParams.get('to')
const toEventId = toParam ? Number(toParam) : undefined

logger.error(
logger.info(
appendCopilotLogContext('[Resume] Received resume request', {
messageId: streamId || undefined,
}),
Expand All @@ -53,7 +53,7 @@ export async function GET(request: NextRequest) {
}

const meta = (await getStreamMeta(streamId)) as StreamMeta | null
logger.error(appendCopilotLogContext('[Resume] Stream lookup', { messageId: streamId }), {
logger.info(appendCopilotLogContext('[Resume] Stream lookup', { messageId: streamId }), {
streamId,
fromEventId,
toEventId,
Expand All @@ -72,7 +72,7 @@ export async function GET(request: NextRequest) {
if (batchMode) {
const events = await readStreamEvents(streamId, fromEventId)
const filteredEvents = toEventId ? events.filter((e) => e.eventId <= toEventId) : events
logger.error(appendCopilotLogContext('[Resume] Batch response', { messageId: streamId }), {
logger.info(appendCopilotLogContext('[Resume] Batch response', { messageId: streamId }), {
streamId,
fromEventId,
toEventId,
Expand Down Expand Up @@ -124,7 +124,7 @@ export async function GET(request: NextRequest) {
const flushEvents = async () => {
const events = await readStreamEvents(streamId, lastEventId)
if (events.length > 0) {
logger.error(
logger.info(
appendCopilotLogContext('[Resume] Flushing events', { messageId: streamId }),
{
streamId,
Expand Down
2 changes: 1 addition & 1 deletion apps/sim/app/api/mothership/chat/route.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ export async function POST(req: NextRequest) {
const userMessageId = providedMessageId || crypto.randomUUID()
userMessageIdForLogs = userMessageId

logger.error(
logger.info(
appendCopilotLogContext('Received mothership chat start request', {
requestId: tracker.requestId,
messageId: userMessageId,
Expand Down
2 changes: 1 addition & 1 deletion apps/sim/app/api/v1/copilot/chat/route.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ export async function POST(req: NextRequest) {
const chatId = parsed.chatId || crypto.randomUUID()

messageId = crypto.randomUUID()
logger.error(
logger.info(
appendCopilotLogContext('Received headless copilot chat start request', { messageId }),
{
workflowId: resolved.workflowId,
Expand Down
10 changes: 6 additions & 4 deletions apps/sim/app/api/workflows/[id]/execute/route.async.test.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -82,14 +82,16 @@ vi.mock('@/background/workflow-execution', () => ({
executeWorkflowJob: vi.fn(),
}))

vi.mock('@sim/logger', () => ({
createLogger: vi.fn().mockReturnValue({
vi.mock('@sim/logger', () => {
const createMockLogger = (): Record<string, any> => ({
info: vi.fn(),
warn: vi.fn(),
error: vi.fn(),
debug: vi.fn(),
}),
}))
withMetadata: vi.fn(() => createMockLogger()),
})
return { createLogger: vi.fn(() => createMockLogger()) }
})

vi.mock('uuid', () => ({
validate: vi.fn().mockReturnValue(true),
Expand Down
Loading
Loading