149 references to Invoke
Aspire.Hosting.Native.Core.Tests (149)
ApplicationRevisionTests.cs (44)
22EnsureSuccess(context.Integration.Invoke("appendResourceLog", 24EnsureSuccess(context.Integration.Invoke("defineResourceCommand", 33Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("inspect", Arguments(("context", context.Composition))))); 34Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("inviteResourceExecution", 38var logs = Result(context.Observer.Invoke("readResourceLogs", 41var execution = Result(context.Author.Invoke("getApplicationExecution", Arguments(("context", context.Workspace)))); 42var invitation = Result(context.Author.Invoke("inviteResourceExecution", 44Assert.Equal("OPERATION_REJECTED", Error(context.Integration.Invoke("joinResourceExecution", 55EnsureSuccess(context.Integration.Invoke("defineResourceCommand", Arguments( 57var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments( 59var confirmation = Result(context.Integration.Invoke("requestConfirmation", Arguments( 63var commands = Result(context.Integration.Invoke("readResourceCommands", Arguments(("context", context.Writer)))); 64var confirmations = Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader)))); 69Assert.Equal(commands.ToJsonString(), Result(context.Integration.Invoke("readResourceCommands", 71Assert.Equal(confirmations.ToJsonString(), Result(context.Observer.Invoke("readConfirmations", 73EnsureSuccess(context.Integration.Invoke("completeResourceCommand", Arguments( 76EnsureSuccess(context.Observer.Invoke("respondConfirmation", Arguments( 114EnsureSuccess(context.Author.Invoke("waitFor", Arguments(("context", a), ("dependency", b)))); 115Assert.Equal("EXECUTION_PREREQUISITE_CYCLE", Error(context.Author.Invoke("waitFor", Arguments(("context", b), ("dependency", a))))); 116Assert.Equal("OPERATION_REJECTED", Error(context.Author.Invoke("beginRevision", Arguments(("context", context.Workspace))))); 117EnsureSuccess(context.Author.Invoke("abortRevision", Arguments(("context", context.Workspace), ("revision", revision)))); 118Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("inspect", Arguments(("context", revision))))); 137Assert.Equal("OPERATION_REJECTED", Error(context.Author.Invoke("beginRevision", Arguments(("context", context.Workspace))))); 157var replacement = Result(context.Author.Invoke("addResource", 163var execution = Result(context.Author.Invoke("getApplicationExecution", Arguments(("context", context.Workspace)))); 164Assert.NotNull(Result(context.Author.Invoke("inviteResourceExecution", 205EnsureSuccess(context.Author.Invoke("waitFor", Arguments(("context", cache), ("dependency", dependency)))); 207var configuration = Result(context.Integration.Invoke("readResourceConfiguration", Arguments(("context", context.Writer)))); 220Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("commitRevision", 222var invitation = Result(context.Author.Invoke("inviteApplicationWorkspace", Arguments(("context", context.Workspace)))); 224Assert.Equal("INVALID_ARGUMENT", Error(context.Integration.Invoke("joinResourceExecution", 226Assert.NotNull(Result(context.Integration.Invoke("joinApplicationWorkspace", Arguments(("context", root), ("invitation", invitation))))); 227Assert.Equal("INVALID_ARGUMENT", Error(context.Integration.Invoke("joinApplicationWorkspace", 240EnsureSuccess(context.Author.Invoke("waitFor", Arguments(("context", dependent), ("dependency", cache)))); 242var execution = Result(context.Author.Invoke("getApplicationExecution", Arguments(("context", context.Workspace)))); 243var writer = Result(context.Integration.Invoke("joinResourceExecution", Arguments( 245("invitation", Result(context.Author.Invoke("inviteResourceExecution", 253Assert.Equal("OPERATION_REJECTED", Error(context.Integration.Invoke("restartContainer", RestartArguments(context.Writer, 1)))); 262var configuration = Result(context.Integration.Invoke("readResourceConfiguration", Arguments(("context", writer)))); 265var dependencies = Result(context.Integration.Invoke("readResourceDependencies", Arguments(("context", writer)))); 267Assert.Equal("OPERATION_REJECTED", Error(context.Integration.Invoke("restartContainer", RestartArguments(context.Writer, 0)))); 347Assert.Equal("OPERATION_REJECTED", Error(context.Author.Invoke("beginRevision", Arguments(("context", context.Workspace))))); 385EnsureSuccess(author.Invoke("setResourceConfiguration", Arguments(("context", resource), ("configuration", new JsonObject 391context.Integration.Invoke("completeResourceConfiguration", Arguments(
DcpWorkloadCleanupTests.cs (3)
77Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("beginRevision", Arguments(("context", context.Workspace))))); 78Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("inviteApplicationWorkspace", Arguments(("context", context.Workspace))))); 82Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("retireApplicationWorkspace", Arguments(("context", context.Workspace)))));
DeclarativeApplicationTests.cs (5)
21var resource = Result(rpc.Invoke("addContainer", Arguments(("context", composition), 24var value = Result(rpc.Invoke("createLiteralValue", Arguments(("context", composition), 27WorkspaceRpcTestContext.EnsureSuccess(rpc.Invoke("withArgument", Arguments(("context", resource), ("value", value))))); 28var configuration = Result(rpc.Invoke("inspectSymbolicConfiguration", Arguments(("context", resource)))); 31WorkspaceRpcTestContext.EnsureSuccess(rpc.Invoke("retireGeneration", Arguments(("context", session), ("composition", composition))));
NativeDashboardTests.cs (9)
52context.Integration.Invoke("defineResourceCommand", Arguments(("context", context.Writer), 54context.Integration.Invoke("appendResourceLog", Arguments(("context", context.Writer), 94context.Integration.Invoke("defineResourceCommand", Arguments(("context", context.Writer), 103context.Integration.Invoke("completeResourceCommand", Arguments(("context", context.Writer), 108var operation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 128operation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 156WorkspaceRpcTestContext.EnsureSuccess(context.Author.Invoke("setResourceConfiguration", Arguments( 171WorkspaceRpcTestContext.EnsureSuccess(context.Integration.Invoke("completeResourceConfiguration", Arguments( 203Result(context.Author.Invoke("createExecution", Arguments(("context", replacement))));
NativeRpcTests.cs (28)
28Assert.Equal("UNAUTHENTICATED", Error(client.Invoke("createSession", []))); 43var wait = client.Invoke("waitFor", Arguments(("context", web), ("dependency", cache))); 46var snapshot = Result(client.Invoke("seal", Arguments(("context", composition)))); 59Assert.Equal(snapshot.ToJsonString(), Result(client.Invoke("inspect", Arguments(("context", composition)))).ToJsonString()); 60Assert.Equal("OPERATION_REJECTED", Error(client.Invoke("addResource", 74Assert.Null(client.Invoke("retireGeneration", Arguments(("context", session), ("composition", composition)))["error"]); 76Assert.Equal("HANDLE_NOT_FOUND", Error(client.Invoke("inspectResource", Arguments(("context", resource))))); 79Assert.Empty(Result(client.Invoke("inspect", Arguments(("context", replacement))))["resources"]!.AsArray()); 97Assert.Null(client.Invoke("retireGeneration", Arguments(("context", retiredSession), ("composition", retired)))["error"]); 101Assert.Equal($"live-{index}", Result(client.Invoke("inspectResource", 106Assert.Equal("replacement", Result(client.Invoke("inspectResource", Arguments(("context", added))))["name"]!.GetValue<string>()); 117Assert.Equal("HANDLE_NOT_FOUND", Error(second.Invoke("inspectResource", Arguments(("context", resource))))); 120Assert.Equal("HANDLE_NOT_FOUND", Error(first.Invoke("inspectResource", Arguments(("context", forged))))); 123Assert.Equal("TYPE_MISMATCH", Error(first.Invoke("inspectResource", Arguments(("context", retagged))))); 124Assert.Equal("cache", Result(first.Invoke("inspectResource", Arguments(("context", resource))))["name"]!.GetValue<string>()); 134var value = Result(first.Invoke("addSecretParameter", Arguments(("context", composition), 137Assert.Equal("HANDLE_NOT_FOUND", Error(second.Invoke("setSymbolicConfiguration", 140Assert.Null(first.Invoke("retireGeneration", Arguments(("context", session), ("composition", composition)))["error"]); 142Assert.Equal("HANDLE_NOT_FOUND", Error(first.Invoke("encodeUriValue", Arguments(("context", value))))); 152Assert.Equal("INVALID_ARGUMENT", Error(client.Invoke("retireGeneration", Arguments(("context", second), ("composition", composition))))); 153Assert.Empty(Result(client.Invoke("inspect", Arguments(("context", composition))))["resources"]!.AsArray()); 162var duplicate = client.Invoke("addResource", Arguments(("context", composition), 166Assert.Single(Result(client.Invoke("inspect", Arguments(("context", composition))))["resources"]!.AsArray()); 167Assert.Equal("INVALID_ARGUMENT", Error(client.Invoke("createSession", new JsonObject { ["unexpected"] = true }))); 168Assert.Equal("CAPABILITY_NOT_FOUND", Error(client.Invoke("doesNotExist", []))); 208var rejected = client.Invoke("addResource", Arguments(("context", composition), 211Assert.Equal(4094, Result(client.Invoke("inspect", Arguments(("context", composition))))["resources"]!.AsArray().Count); 220Assert.Equal(32, Result(client.Invoke("inspect", Arguments(("context", composition))))["resources"]!.AsArray().Count);
NativeSocketIsolationTests.cs (3)
138var session = Result(context.Author.Invoke("openApplication", Arguments(("context", authorServer)))); 141var execution = Result(context.Author.Invoke("createExecution", Arguments(("context", composition)))); 142var invitation = Result(context.Author.Invoke("inviteResourceExecution",
NativeTimeProviderTests.cs (3)
35var workspace = Result(client.Invoke("createApplicationWorkspace", Arguments(("context", root)))); 36var revision = Result(client.Invoke("beginRevision", Arguments(("context", workspace)))); 38Assert.Null(client.Invoke("commitRevision", Arguments(("context", workspace), ("revision", revision)))["error"]);
ResourceWorkloadTests.cs (1)
66Assert.Equal("OPERATION_REJECTED", context.Author.Invoke("startGeneration", Arguments(
RuntimeRpcTests.cs (30)
20context.Integration.Invoke("appendResourceLog", Arguments(("context", context.Writer), 24var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 27Assert.NotNull(Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 29Assert.Equal("OPERATION_REJECTED", Error(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 41Assert.Empty(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader))))["requests"]!.AsArray()); 50Assert.Equal("TYPE_MISMATCH", Error(context.Observer.Invoke("publishObservation", Arguments( 59var invite = Result(context.Author.Invoke("inviteApplicationObserver", Arguments(("context", context.Execution)))); 60Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("joinResourceExecution", Arguments( 62Assert.NotNull(Result(context.Observer.Invoke("joinApplicationObserver", Arguments( 64Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("joinApplicationObserver", Arguments( 66var stale = Result(context.Author.Invoke("inviteApplicationObserver", Arguments(("context", context.Execution)))); 67context.Author.Invoke("retireGeneration", Arguments(("context", context.Session), ("composition", context.Composition))); 68Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("joinApplicationObserver", Arguments( 70Assert.Equal("HANDLE_NOT_FOUND", Error(context.Observer.Invoke("readResourceObservations", Arguments(("context", context.Reader))))); 80context.Integration.Invoke("appendResourceLog", Arguments(("context", context.Writer), 84var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 90var suffix = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 94Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 102context.Integration.Invoke("defineResourceCommand", Arguments(("context", context.Writer), 104var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.Reader), 108var pending = Result(context.Integration.Invoke("readResourceCommands", Arguments(("context", context.Writer))))["commands"]![0]!; 110context.Integration.Invoke("completeResourceCommand", Arguments(("context", context.Writer), 115var confirmation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 118var prompt = Assert.Single(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader))))["requests"]!.AsArray())!; 121context.Observer.Invoke("respondConfirmation", Arguments(("context", context.Reader), 124Assert.Equal("INVALID_ARGUMENT", Error(context.Observer.Invoke("respondConfirmation", Arguments(("context", context.Reader), 133context.Integration.Invoke("defineResourceCommand", Arguments(("context", context.Writer), 135var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.Reader), 151var prompt = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 169Assert.Equal("INVALID_ARGUMENT", Error(context.Integration.Invoke("publishObservation", Arguments(
TestServices\RpcTestClient.cs (3)
75public JsonNode CreateSession() => Result(Invoke("createSession", [])); 78Result(Invoke("startGeneration", Arguments(("context", session)))); 81Result(Invoke("addResource", Arguments(("context", composition), ("name", JsonValue.Create(name)),
TestServices\RuntimeRpcTestContext.cs (8)
41Session = Result(Author.Invoke("openApplication", Arguments(("context", root)))); 44Execution = Result(Author.Invoke("createExecution", Arguments(("context", Composition)))); 45Writer = Result(Integration.Invoke("joinResourceExecution", Arguments( 47("invitation", Result(Author.Invoke("inviteResourceExecution", Arguments(("context", Execution), ("resource", Resource)))))))); 48Reader = Result(Observer.Invoke("joinApplicationObserver", Arguments( 50("invitation", Result(Author.Invoke("inviteApplicationObserver", Arguments(("context", Execution)))))))); 54Integration.Invoke("publishObservation", Arguments(("context", Writer), ("observation", new JsonObject 60public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context", Reader))));
TestServices\WorkspaceRpcTestContext.cs (12)
31Workspace = Result(Author.Invoke("createApplicationWorkspace", 35EnsureSuccess(Author.Invoke("commitRevision", Arguments(("context", Workspace), ("revision", Composition)))); 36Execution = Result(Author.Invoke("getApplicationExecution", Arguments(("context", Workspace)))); 37Writer = Result(Integration.Invoke("joinResourceExecution", Arguments( 39("invitation", Result(Author.Invoke("inviteResourceExecution", 41Reader = Result(Observer.Invoke("joinApplicationObserver", Arguments( 43("invitation", Result(Author.Invoke("inviteApplicationObserver", Arguments(("context", Execution)))))))); 46public JsonNode BeginRevision() => Result(Author.Invoke("beginRevision", Arguments(("context", Workspace)))); 50var invitation = Result(Author.Invoke("inviteApplicationWorkspace", Arguments(("context", Workspace)))); 53Workspace = Result(Author.Invoke("joinApplicationWorkspace", 57public JsonObject PublishHealthy() => Integration.Invoke("publishObservation", 63public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context", Reader))));