mirror of
https://github.com/openfaas/faasd.git
synced 2025-06-08 16:06:47 +00:00
35e017b526
**What** - Fix the test to match the new logs command builder, without the output fields flag Signed-off-by: Lucas Roesler <roesler.lucas@gmail.com>
74 lines
2.1 KiB
Go
74 lines
2.1 KiB
Go
package logs
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/openfaas/faas-provider/logs"
|
|
)
|
|
|
|
func Test_parseEntry(t *testing.T) {
|
|
rawEntry := `{ "__CURSOR" : "s=71c4550142d14ace8e2959e3540cc15c;i=133c;b=44864010f0d94baba7b6bf8019f82a56;m=2945cd3;t=5a00d4eb59180;x=8ed47f7f9b3d798", "__REALTIME_TIMESTAMP" : "1583353899094400", "__MONOTONIC_TIMESTAMP" : "43277523", "_BOOT_ID" : "44864010f0d94baba7b6bf8019f82a56", "SYSLOG_IDENTIFIER" : "openfaas-fn:nodeinfo", "_PID" : "2254", "MESSAGE" : "2020/03/04 20:31:39 POST / - 200 OK - ContentLength: 83", "_SOURCE_REALTIME_TIMESTAMP" : "1583353899094372" }`
|
|
expectedEntry := logs.Message{
|
|
Name: "nodeinfo",
|
|
Namespace: "openfaas-fn",
|
|
Text: "2020/03/04 20:31:39 POST / - 200 OK - ContentLength: 83",
|
|
Timestamp: time.Unix(0, 1583353899094400*1000).UTC(),
|
|
}
|
|
|
|
value := map[string]string{}
|
|
json.Unmarshal([]byte(rawEntry), &value)
|
|
|
|
entry, err := parseEntry(value)
|
|
if err != nil {
|
|
t.Fatalf("unexpected error %s", err)
|
|
}
|
|
|
|
if entry.Name != expectedEntry.Name {
|
|
t.Fatalf("want Name: %q, got %q", expectedEntry.Name, entry.Name)
|
|
}
|
|
|
|
if entry.Namespace != expectedEntry.Namespace {
|
|
t.Fatalf("want Namespace: %q, got %q", expectedEntry.Namespace, entry.Namespace)
|
|
}
|
|
|
|
if entry.Timestamp != expectedEntry.Timestamp {
|
|
t.Fatalf("want Timestamp: %q, got %q", expectedEntry.Timestamp, entry.Timestamp)
|
|
}
|
|
|
|
if entry.Text != expectedEntry.Text {
|
|
t.Fatalf("want Text: %q, got %q", expectedEntry.Text, entry.Text)
|
|
}
|
|
}
|
|
|
|
func Test_buildCmd(t *testing.T) {
|
|
ctx := context.TODO()
|
|
now := time.Now()
|
|
req := logs.Request{
|
|
Name: "loggyfunc",
|
|
Namespace: "spacetwo",
|
|
Follow: true,
|
|
Since: &now,
|
|
Tail: 5,
|
|
}
|
|
|
|
expectedArgs := fmt.Sprintf(
|
|
"--utc --no-pager --output=json --identifier=spacetwo:loggyfunc --since=%s --follow --lines=5",
|
|
now.UTC().Format("2006-01-02 15:04:05"),
|
|
)
|
|
|
|
cmd := buildCmd(ctx, req).String()
|
|
wantCmd := "journalctl"
|
|
if !strings.Contains(cmd, wantCmd) {
|
|
t.Fatalf("cmd want: %q, got: %q", wantCmd, cmd)
|
|
}
|
|
|
|
if !strings.HasSuffix(cmd, expectedArgs) {
|
|
t.Fatalf("arg want: %q\ngot: %q", expectedArgs, cmd)
|
|
}
|
|
}
|