Function TestCanvasAdapter_DispatchesToHandler

go/canvas_test.go:126–196

(t *testing.T)

}

func TestCanvasAdapter_DispatchesToHandler(t *testing.T) {
	title := "Echo"
	url := "https://example.test/echo"
	handler := &recordingCanvasHandler{
		openResult: rpc.CanvasProviderOpenResult{URL: &url, Title: &title},
		actionResult: map[string]any{
			"count": float64(2),
		},
	}

	session := newTestCanvasSession("s1")
	session.registerCanvasHandler(handler)

	openResp, err := session.clientSessionAPIs.Canvas.Open(&rpc.CanvasProviderOpenRequest{
		SessionID:   "s1",
		ExtensionID: "project:echo",
		CanvasID:    "echo",
		InstanceID:  "echo-1",
		Input:       map[string]any{"x": float64(1)},
	})
	if err != nil {
		t.Fatalf("unexpected open error: %v", err)
	}
	if handler.openCtx == nil {
		t.Fatalf("handler.OnOpen was not called")
	}
	if handler.openCtx.CanvasID != "echo" || handler.openCtx.InstanceID != "echo-1" {
		t.Fatalf("unexpected open ctx: %+v", handler.openCtx)
	}
	if openResp.URL == nil || *openResp.URL != url {
		t.Fatalf("response URL not propagated: %+v", openResp)
	}

	actionResp, err := session.clientSessionAPIs.Canvas.Invoke(&rpc.CanvasProviderInvokeActionRequest{
		SessionID:   "s1",
		ExtensionID: "project:echo",
		CanvasID:    "echo",
		InstanceID:  "echo-1",
		ActionName:  "increment",
		Input:       map[string]any{"amount": float64(1)},
	})
	if err != nil {
		t.Fatalf("unexpected action error: %v", err)
	}
	if handler.actionCtx == nil {
		t.Fatalf("handler.OnAction was not called")
	}
	if handler.actionCtx.ActionName != "increment" {
		t.Fatalf("unexpected action ctx: %+v", handler.actionCtx)
	}
	result, ok := actionResp.(map[string]any)
	if !ok || result["count"] != float64(2) {
		t.Fatalf("unexpected action result: %#v", actionResp)
	}

	closeResp, err := session.clientSessionAPIs.Canvas.Close(&rpc.CanvasProviderCloseRequest{
		SessionID:   "s1",
		ExtensionID: "project:echo",