shishengliang/lingniu-vehicle-ingest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

docs(platform): define vehicle keyword API contract

Browse Source
This commit is contained in:
lingniu
2026-07-04 00:45:29 +08:00
parent 20e2781f35
commit a4ff210c82
3 changed files with 154 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
vehicle-data-platform/apps/api/internal/platform/handler_test.go
View File

@@ -236,3 +236,43 @@ func TestHandlerVehicleDataAPIsResolveVehicleKeyword(t *testing.T) {
})
}
}
func TestHandlerRawFramesPostAcceptsKeyword(t *testing.T) {
handler := NewHandler(NewService(NewMockStore()))
rec := httptest.NewRecorder()
req := httptest.NewRequest(http.MethodPost, "/api/history/raw-frames/query", strings.NewReader(`{"keyword":"川AHTWO1","limit":1}`))
handler.ServeHTTP(rec, req)
if rec.Code != http.StatusOK {
t.Fatalf("status = %d body=%s", rec.Code, rec.Body.String())
}
var body struct {
Data struct {
Items []RawFrameRow `json:"items"`
} `json:"data"`
}
if err := json.Unmarshal(rec.Body.Bytes(), &body); err != nil {
t.Fatalf("response JSON should decode: %v body=%s", err, rec.Body.String())
}
if len(body.Data.Items) != 1 || body.Data.Items[0].VIN != "LNXNEGRR7SR318212" {
t.Fatalf("raw POST should resolve keyword to VIN, got %+v body=%s", body.Data.Items, rec.Body.String())
}
}
func TestHandlerRawFramesKeepsUnresolvedKeywordEmpty(t *testing.T) {
handler := NewHandler(NewService(NewMockStore()))
rec := httptest.NewRecorder()
req := httptest.NewRequest(http.MethodGet, "/api/history/raw-frames?keyword=64646848247&limit=1", nil)
handler.ServeHTTP(rec, req)
if rec.Code != http.StatusOK {
t.Fatalf("status = %d body=%s", rec.Code, rec.Body.String())
}
var body struct {
Data Page[RawFrameRow] `json:"data"`
}
if err := json.Unmarshal(rec.Body.Bytes(), &body); err != nil {
t.Fatalf("response JSON should decode: %v body=%s", err, rec.Body.String())
}
if body.Data.Total != 0 || len(body.Data.Items) != 0 {
t.Fatalf("unresolved keyword should not fabricate raw rows: %+v body=%s", body.Data, rec.Body.String())
}
}

13
vehicle-data-platform/apps/api/internal/platform/mock_store.go
View File

@@ -218,16 +218,21 @@ func (m *MockStore) RawFrames(_ context.Context, query RawFrameQuery) (Page[RawF
if !query.IncludeFields && len(query.Fields) == 0 {
fields = nil
}
protocol := defaultString(query.Protocol, "GB32960")
vin := defaultString(query.VIN, "LB9A32A24R0LS1426")
rows := []RawFrameRow{
{ID: "raw-20260703-001", VIN: vin, Plate: "粤AG18312", Protocol: protocol, FrameType: "realtime", DeviceTime: "2026-07-03 20:12:06", ServerTime: "2026-07-03 20:12:06", RawSizeBytes: 430, ParsedFields: fields},
{ID: "raw-20260703-001", VIN: "LB9A32A24R0LS1426", Plate: "粤AG18312", Protocol: "GB32960", FrameType: "realtime", DeviceTime: "2026-07-03 20:12:06", ServerTime: "2026-07-03 20:12:06", RawSizeBytes: 430, ParsedFields: fields},
{ID: "raw-20260703-002", VIN: "LNXNEGRR7SR318212", Plate: "川AHTWO1", Protocol: "GB32960", FrameType: "realtime", DeviceTime: "2026-07-03 20:12:06", ServerTime: "2026-07-03 20:12:06", RawSizeBytes: 430, ParsedFields: fields},
}
if vin := strings.TrimSpace(query.VIN); vin != "" {
rows = keep(rows, func(row RawFrameRow) bool { return row.VIN == vin })
}
if protocol := strings.TrimSpace(query.Protocol); protocol != "" {
rows = keep(rows, func(row RawFrameRow) bool { return row.Protocol == protocol })
}
limit := query.Limit
if limit <= 0 {
limit = 100
}
return Page[RawFrameRow]{Items: rows, Total: len(rows), Limit: limit, Offset: query.Offset}, nil
return page(rows, url.Values{"limit": {strconv.Itoa(limit)}, "offset": {strconv.Itoa(query.Offset)}}), nil
}
func (m *MockStore) DailyMileage(_ context.Context, query url.Values) (Page[DailyMileageRow], error) {