Function TestJSONRPCTransportConsistency

expr/jsonrpc_validation_test.go:11–203

(t *testing.T)

)

func TestJSONRPCTransportConsistency(t *testing.T) {
	cases := []struct {
		Name     string
		Setup    func() *expr.HTTPServiceExpr
		WantErr  bool
		ErrorMsg string
	}{
		{
			Name: "valid HTTP and SSE mix",
			Setup: func() *expr.HTTPServiceExpr {
				service := &expr.ServiceExpr{
					Name: "TestService",
					Meta: expr.MetaExpr{"jsonrpc:service": []string{}},
				}

				httpService := &expr.HTTPServiceExpr{
					ServiceExpr: service,
					Root:        &expr.HTTPExpr{},
				}

				// Regular HTTP method
				m1 := &expr.MethodExpr{
					Name:    "GetUser",
					Service: service,
					Payload: &expr.AttributeExpr{Type: expr.String},
					Result:  &expr.AttributeExpr{Type: expr.String},
				}
				e1 := &expr.HTTPEndpointExpr{
					MethodExpr: m1,
					Service:    httpService,
					Meta:       expr.MetaExpr{"jsonrpc": []string{}},
					Headers:    &expr.MappedAttributeExpr{AttributeExpr: &expr.AttributeExpr{Type: &expr.Object{}}},
					Cookies:    &expr.MappedAttributeExpr{AttributeExpr: &expr.AttributeExpr{Type: &expr.Object{}}},
					Params:     &expr.MappedAttributeExpr{AttributeExpr: &expr.AttributeExpr{Type: &expr.Object{}}},
				}

				// SSE streaming method
				m2 := &expr.MethodExpr{
					Name:    "WatchUsers",
					Service: service,
					Payload: &expr.AttributeExpr{Type: expr.String},
					Result:  &expr.AttributeExpr{Type: expr.String},
					Stream:  expr.ServerStreamKind,
				}
				e2 := &expr.HTTPEndpointExpr{
					MethodExpr: m2,
					Service:    httpService,
					Meta:       expr.MetaExpr{"jsonrpc": []string{}},
					Headers:    &expr.MappedAttributeExpr{AttributeExpr: &expr.AttributeExpr{Type: &expr.Object{}}},
					Cookies:    &expr.MappedAttributeExpr{AttributeExpr: &expr.AttributeExpr{Type: &expr.Object{}}},
					Params:     &expr.MappedAttributeExpr{AttributeExpr: &expr.AttributeExpr{Type: &expr.Object{}}},
					SSE:        &expr.HTTPSSEExpr{},
				}

				httpService.HTTPEndpoints = []*expr.HTTPEndpointExpr{e1, e2}
				return httpService
			},
			WantErr: false,