test: cover NewAPIAdapter.BuildIngressAck nil and with-meta branches
This commit is contained in:
@@ -1,33 +1,42 @@
|
||||
package platformadapter
|
||||
|
||||
import (
|
||||
"net/http"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
|
||||
func TestNewAPIAdapter_ShouldBeRegisteredButDisabledByDefault(t *testing.T) {
|
||||
registry := NewRegistry(NewNewAPIAdapter())
|
||||
adapter, ok := registry.Resolve("newapi")
|
||||
func TestNewAPIAdapter_BuildIngressAck_NilMeta(t *testing.T) {
|
||||
adapter := NewNewAPIAdapter()
|
||||
result := adapter.BuildIngressAck(nil, nil)
|
||||
m, ok := result.(map[string]any)
|
||||
if !ok {
|
||||
t.Fatal("expected newapi adapter to resolve")
|
||||
t.Fatalf("expected map[string]any, got %T", result)
|
||||
}
|
||||
if adapter.Platform() != "newapi" {
|
||||
t.Fatalf("adapter.Platform() = %s, want newapi", adapter.Platform())
|
||||
if m["accepted"] != false {
|
||||
t.Fatalf("accepted = %v, want false", m["accepted"])
|
||||
}
|
||||
|
||||
_, _, err := adapter.ParseInbound(nil, nil, IngressContext{
|
||||
Platform: "newapi",
|
||||
ReceivedAt: time.Now(),
|
||||
})
|
||||
reqErr, ok := err.(*RequestError)
|
||||
if !ok {
|
||||
t.Fatalf("expected RequestError, got %T", err)
|
||||
if m["platform"] != "newapi" {
|
||||
t.Fatalf("platform = %v, want newapi", m["platform"])
|
||||
}
|
||||
if reqErr.Status != http.StatusNotImplemented {
|
||||
t.Fatalf("status = %d, want 501", reqErr.Status)
|
||||
}
|
||||
if reqErr.Code != "CS_PLATFORM_5010" {
|
||||
t.Fatalf("code = %s, want CS_PLATFORM_5010", reqErr.Code)
|
||||
if _, exists := m["event_id"]; exists {
|
||||
t.Fatalf("event_id should not exist when meta is nil")
|
||||
}
|
||||
}
|
||||
|
||||
func TestNewAPIAdapter_BuildIngressAck_WithMeta(t *testing.T) {
|
||||
adapter := NewNewAPIAdapter()
|
||||
meta := &PlatformInboundMeta{EventID: "evt-1"}
|
||||
result := adapter.BuildIngressAck(nil, meta)
|
||||
m, ok := result.(map[string]any)
|
||||
if !ok {
|
||||
t.Fatalf("expected map[string]any, got %T", result)
|
||||
}
|
||||
if m["accepted"] != false {
|
||||
t.Fatalf("accepted = %v, want false", m["accepted"])
|
||||
}
|
||||
if m["platform"] != "newapi" {
|
||||
t.Fatalf("platform = %v, want newapi", m["platform"])
|
||||
}
|
||||
if m["event_id"] != "evt-1" {
|
||||
t.Fatalf("event_id = %v, want evt-1", m["event_id"])
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user