1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
import {
isMetricsTraceSupplier,
type ITrace,
type ITraceWith,
LogTrace,
type LogTraceSupplier,
MetricsTrace,
type MetricsTraceSupplier,
type MetricValue,
TraceableImpl,
} from "@emprespresso/pengueno";
export class LogTraceable<T> extends TraceableImpl<T, LogTraceSupplier> {
public static LogTrace = new LogTrace();
static from<T>(t: T) {
return new LogTraceable(t, LogTraceable.LogTrace);
}
}
const getEmbeddedMetricConsumer =
(logTrace: LogTrace) => (metrics: Array<MetricValue>) =>
logTrace.addTrace("<metrics>").trace(
JSON.stringify(metrics, null, 2) + "</metrics>",
);
export class EmbeddedMetricsTraceable<T>
extends TraceableImpl<T, MetricsTraceSupplier> {
public static MetricsTrace = new MetricsTrace(
getEmbeddedMetricConsumer(LogTraceable.LogTrace),
);
static from<T>(t: T) {
return new EmbeddedMetricsTraceable(
t,
EmbeddedMetricsTraceable.MetricsTrace,
);
}
}
export type LogMetricTraceSupplier = ITraceWith<
LogTraceSupplier | MetricsTraceSupplier
>;
export class LogMetricTrace implements ITrace<LogMetricTraceSupplier> {
constructor(
private readonly logTrace: ITrace<LogTraceSupplier>,
private readonly metricsTrace: ITrace<MetricsTraceSupplier>,
) {}
public addTrace(
trace: LogTraceSupplier | MetricsTraceSupplier,
): LogMetricTrace {
if (isMetricsTraceSupplier(trace)) {
this.metricsTrace.addTrace(trace);
return this;
}
this.logTrace.addTrace(trace);
return this;
}
public trace(trace: LogTraceSupplier | MetricsTraceSupplier) {
if (isMetricsTraceSupplier(trace)) {
this.metricsTrace.trace(trace);
return this;
}
this.logTrace.trace(trace);
return this;
}
}
export class LogMetricTraceable<T>
extends TraceableImpl<T, MetricsTraceSupplier | LogTraceSupplier> {
public static LogMetricTrace = new LogMetricTrace(
LogTraceable.LogTrace,
EmbeddedMetricsTraceable.MetricsTrace,
);
static from<T>(t: T) {
return new LogMetricTraceable(
t,
LogMetricTraceable.LogMetricTrace,
);
}
}
|
