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
83
|
import {
isMetricsTraceSupplier,
type ITrace,
type ITraceable,
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 of<T>(t: T) {
return new LogTraceable(t, LogTraceable.LogTrace);
}
}
const getEmbeddedMetricConsumer =
(logTrace: ITrace<LogTraceSupplier>) => (metrics: Array<MetricValue>) =>
logTrace.trace(`<metrics>${JSON.stringify(metrics, null)}</metrics>`);
export class EmbeddedMetricsTraceable<T> extends TraceableImpl<
T,
MetricsTraceSupplier
> {
public static MetricsTrace = new MetricsTrace(
getEmbeddedMetricConsumer(LogTraceable.LogTrace),
);
static of<T>(t: T, metricsTrace = EmbeddedMetricsTraceable.MetricsTrace) {
return new EmbeddedMetricsTraceable(t, metricsTrace);
}
}
export type LogMetricTraceSupplier = ITraceWith<
LogTraceSupplier | MetricsTraceSupplier
>;
export class LogMetricTrace implements ITrace<LogMetricTraceSupplier> {
constructor(
private logTrace: ITrace<LogTraceSupplier>,
private metricsTrace: ITrace<MetricsTraceSupplier>,
) {}
public addTrace(
trace: LogTraceSupplier | MetricsTraceSupplier,
): LogMetricTrace {
if (isMetricsTraceSupplier(trace)) {
this.metricsTrace = this.metricsTrace.addTrace(trace);
return this;
}
this.logTrace = 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
> {
static ofLogTraceable<T>(t: ITraceable<T, LogTraceSupplier>) {
const metricsTrace = new MetricsTrace(getEmbeddedMetricConsumer(t.trace));
return new LogMetricTraceable(
t.get(),
new LogMetricTrace(t.trace, metricsTrace),
);
}
static of<T>(t: T) {
const logTrace = LogTraceable.of(t);
return LogMetricTraceable.ofLogTraceable(logTrace);
}
}
|
