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