110 references to Result
Aspire.Hosting.Native.Core.Tests (110)
ApplicationRevisionTests.cs (26)
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", 45Arguments(("context", Result(context.Integration.Call("getApplicationServer", null))), ("invitation", invitation))))); 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", 79Assert.Equal("pong", Result(await commandResult)["message"]!.GetValue<string>()); 80Assert.Equal("accepted", Result(await confirmationResult)["status"]!.GetValue<string>()); 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", 179var change = Result(await waiting); 207var configuration = Result(context.Integration.Invoke("readResourceConfiguration", Arguments(("context", context.Writer)))); 222var invitation = Result(context.Author.Invoke("inviteApplicationWorkspace", Arguments(("context", context.Workspace)))); 223var root = Result(context.Integration.Call("getApplicationServer", null)); 226Assert.NotNull(Result(context.Integration.Invoke("joinApplicationWorkspace", Arguments(("context", root), ("invitation", invitation))))); 242var execution = Result(context.Author.Invoke("getApplicationExecution", Arguments(("context", context.Workspace)))); 243var writer = Result(context.Integration.Invoke("joinResourceExecution", Arguments( 244("context", Result(context.Integration.Call("getApplicationServer", null))), 245("invitation", Result(context.Author.Invoke("inviteResourceExecution", 262var configuration = Result(context.Integration.Invoke("readResourceConfiguration", Arguments(("context", writer)))); 265var dependencies = Result(context.Integration.Invoke("readResourceDependencies", Arguments(("context", writer))));
DeclarativeApplicationTests.cs (3)
21var resource = Result(rpc.Invoke("addContainer", Arguments(("context", composition), 24var value = Result(rpc.Invoke("createLiteralValue", Arguments(("context", composition), 28var configuration = Result(rpc.Invoke("inspectSymbolicConfiguration", Arguments(("context", resource))));
NativeCliControlTests.cs (4)
23var spec = Result(client.Call("getRuntimeSpec", new JsonArray("typescript/nodejs"))); 24var sdk = Result(client.Call("generateCode", new JsonArray("TypeScript", null))).AsObject(); 56Assert.NotEmpty(Result(client.Call("getCapabilities", null))["Capabilities"]!.AsArray()); 57Assert.Empty(Result(client.Call("getAppHostServerConfiguration", null)).AsArray());
NativeDashboardTests.cs (6)
102var pending = Assert.Single(Result(await ready)["commands"]!.AsArray())!; 108var operation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 124Assert.Equal(accepted ? "accepted" : "rejected", Result(await completion.WaitAsync(timeout.Token))["status"]!.GetValue<string>()); 128operation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 138Assert.Equal("accepted", Result(await completion.WaitAsync(timeout.Token))["status"]!.GetValue<string>()); 203Result(context.Author.Invoke("createExecution", Arguments(("context", replacement))));
NativeRpcTests.cs (12)
19var contract = Result(client.Call("getCapabilities", null)); 46var snapshot = Result(client.Invoke("seal", Arguments(("context", composition)))); 59Assert.Equal(snapshot.ToJsonString(), Result(client.Invoke("inspect", Arguments(("context", composition)))).ToJsonString()); 79Assert.Empty(Result(client.Invoke("inspect", Arguments(("context", replacement))))["resources"]!.AsArray()); 101Assert.Equal($"live-{index}", Result(client.Invoke("inspectResource", 106Assert.Equal("replacement", Result(client.Invoke("inspectResource", Arguments(("context", added))))["name"]!.GetValue<string>()); 124Assert.Equal("cache", Result(first.Invoke("inspectResource", Arguments(("context", resource))))["name"]!.GetValue<string>()); 134var value = Result(first.Invoke("addSecretParameter", Arguments(("context", composition), 153Assert.Empty(Result(client.Invoke("inspect", Arguments(("context", composition))))["resources"]!.AsArray()); 166Assert.Single(Result(client.Invoke("inspect", Arguments(("context", composition))))["resources"]!.AsArray()); 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 (6)
136var server = Result(await failing.CallAsync("getApplicationServer", null, timeout.Token)); 137var authorServer = Result(context.Author.Call("getApplicationServer", null)); 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", 144var writer = Result(await failing.CallAsync("invokeCapability", new JsonArray("Aspire.Hosting.Native.Api/joinResourceExecution",
NativeTimeProviderTests.cs (3)
34var root = Result(client.Call("getApplicationServer", null)); 35var workspace = Result(client.Invoke("createApplicationWorkspace", Arguments(("context", root)))); 36var revision = Result(client.Invoke("beginRevision", Arguments(("context", workspace))));
ResourceWorkloadTests.cs (2)
34var endpoint = Result(await context.Integration.InvokeAsync("startContainer", Arguments( 54var endpoint = Result(await context.Integration.InvokeAsync("startContainer", Arguments(
RuntimeRpcTests.cs (20)
24var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 27Assert.NotNull(Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 41Assert.Empty(Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader))))["requests"]!.AsArray()); 43var updated = Result(await wait.WaitAsync(TimeSpan.FromSeconds(10))); 58var root = Result(context.Observer.Call("getApplicationServer", null)); 59var invite = Result(context.Author.Invoke("inviteApplicationObserver", Arguments(("context", context.Execution)))); 62Assert.NotNull(Result(context.Observer.Invoke("joinApplicationObserver", Arguments( 66var stale = Result(context.Author.Invoke("inviteApplicationObserver", Arguments(("context", context.Execution)))); 84var logs = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 90var suffix = Result(context.Observer.Invoke("readResourceLogs", Arguments(("context", context.Reader), 104var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.Reader), 108var pending = Result(context.Integration.Invoke("readResourceCommands", Arguments(("context", context.Writer))))["commands"]![0]!; 112var result = Result(await completion.WaitAsync(TimeSpan.FromSeconds(10))); 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())!; 123Assert.Equal("accepted", Result(await answer.WaitAsync(TimeSpan.FromSeconds(10)))["status"]!.GetValue<string>()); 135var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments(("context", context.Reader), 139Assert.Equal("cancelled", Result(await result.WaitAsync(TimeSpan.FromSeconds(10)))["status"]!.GetValue<string>()); 151var prompt = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 155Assert.Equal("cancelled", Result(await answer.WaitAsync(TimeSpan.FromSeconds(10)))["status"]!.GetValue<string>());
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 (10)
40var root = Result(Author.Call("getApplicationServer", null)); 41Session = Result(Author.Invoke("openApplication", Arguments(("context", root)))); 44Execution = Result(Author.Invoke("createExecution", Arguments(("context", Composition)))); 45Writer = Result(Integration.Invoke("joinResourceExecution", Arguments( 46("context", Result(Integration.Call("getApplicationServer", null))), 47("invitation", Result(Author.Invoke("inviteResourceExecution", Arguments(("context", Execution), ("resource", Resource)))))))); 48Reader = Result(Observer.Invoke("joinApplicationObserver", Arguments( 49("context", Result(Observer.Call("getApplicationServer", null))), 50("invitation", Result(Author.Invoke("inviteApplicationObserver", Arguments(("context", Execution)))))))); 60public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context", Reader))));
TestServices\WorkspaceRpcTestContext.cs (14)
31Workspace = Result(Author.Invoke("createApplicationWorkspace", 32Arguments(("context", Result(Author.Call("getApplicationServer", null)))))); 36Execution = Result(Author.Invoke("getApplicationExecution", Arguments(("context", Workspace)))); 37Writer = Result(Integration.Invoke("joinResourceExecution", Arguments( 38("context", Result(Integration.Call("getApplicationServer", null))), 39("invitation", Result(Author.Invoke("inviteResourceExecution", 41Reader = Result(Observer.Invoke("joinApplicationObserver", Arguments( 42("context", Result(Observer.Call("getApplicationServer", null))), 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", 54Arguments(("context", Result(Author.Call("getApplicationServer", null))), ("invitation", invitation)))); 63public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context", Reader))));
WorkloadDefinitionTests.cs (1)
20var allocation = Result(await context.Integration.InvokeAsync("startContainerWorkload", Arguments(