fix(tui): lower durable event log level (#36479)
This commit is contained in:
@@ -93,7 +93,7 @@ export const { use: useSDK, provider: SDKProvider } = createSimpleContext({
|
|||||||
if (abort.signal.aborted || controller.signal.aborted) return
|
if (abort.signal.aborted || controller.signal.aborted) return
|
||||||
if (event.done) return new Error("Event stream disconnected")
|
if (event.done) return new Error("Event stream disconnected")
|
||||||
if ("durable" in event.value)
|
if ("durable" in event.value)
|
||||||
log.info("event", {
|
log.debug("event", {
|
||||||
type: event.value.type,
|
type: event.value.type,
|
||||||
aggregateID: event.value.durable.aggregateID,
|
aggregateID: event.value.durable.aggregateID,
|
||||||
seq: event.value.durable.seq,
|
seq: event.value.durable.seq,
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ import { SDKProvider, useSDK } from "../../../src/context/sdk"
|
|||||||
import { useEvent } from "../../../src/context/event"
|
import { useEvent } from "../../../src/context/event"
|
||||||
import { createApi, createClient, createEventStream, createFetch } from "../../fixture/tui-sdk"
|
import { createApi, createClient, createEventStream, createFetch } from "../../fixture/tui-sdk"
|
||||||
import { TestTuiContexts } from "../../fixture/tui-environment"
|
import { TestTuiContexts } from "../../fixture/tui-environment"
|
||||||
import type { LogSink } from "../../../src/context/log"
|
import type { LogLevel, LogSink } from "../../../src/context/log"
|
||||||
|
|
||||||
const projectID = "proj_test"
|
const projectID = "proj_test"
|
||||||
|
|
||||||
@@ -113,9 +113,9 @@ function Probe(props: {
|
|||||||
|
|
||||||
describe("useEvent", () => {
|
describe("useEvent", () => {
|
||||||
test("logs only durable events", async () => {
|
test("logs only durable events", async () => {
|
||||||
const logs: Array<{ message: string; tags: Readonly<Record<string, unknown>> }> = []
|
const logs: Array<{ level: LogLevel; message: string; tags: Readonly<Record<string, unknown>> }> = []
|
||||||
const { app, emit, seen } = await mount(undefined, (_level, message, tags) => {
|
const { app, emit, seen } = await mount(undefined, (level, message, tags) => {
|
||||||
if (message === "event") logs.push({ message, tags })
|
if (message === "event") logs.push({ level, message, tags })
|
||||||
})
|
})
|
||||||
const durable = event(
|
const durable = event(
|
||||||
{
|
{
|
||||||
@@ -135,6 +135,7 @@ describe("useEvent", () => {
|
|||||||
|
|
||||||
expect(logs).toEqual([
|
expect(logs).toEqual([
|
||||||
{
|
{
|
||||||
|
level: "debug",
|
||||||
message: "event",
|
message: "event",
|
||||||
tags: { component: "sdk", type: "session.renamed", aggregateID: "ses_test", seq: 1 },
|
tags: { component: "sdk", type: "session.renamed", aggregateID: "ses_test", seq: 1 },
|
||||||
},
|
},
|
||||||
|
|||||||
Reference in New Issue
Block a user