23Arguments(("context", context.Writer), ("stream", JsonValue.Create("stdout")), ("message", JsonValue.Create("retained"))))); 25Arguments(("context", context.Writer), ("name", JsonValue.Create("ping")), ("displayName", JsonValue.Create("Ping"))))); 33Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("inspect", Arguments(("context", context.Composition))))); 35Arguments(("context", context.Execution), ("resource", context.Resource))))); 39Arguments(("context", context.Reader), ("resourceId", resourceId), ("afterSequence", JsonValue.Create(0))))); 41var execution = Result(context.Author.Invoke("getApplicationExecution", Arguments(("context", context.Workspace)))); 43Arguments(("context", execution), ("resource", resource)))); 45Arguments(("context", Result(context.Integration.Call("getApplicationServer", null))), ("invitation", invitation))))); 55EnsureSuccess(context.Integration.Invoke("defineResourceCommand", Arguments( 57var command = Result(context.Observer.Invoke("invokeResourceCommand", Arguments( 59var confirmation = Result(context.Integration.Invoke("requestConfirmation", Arguments( 61var commandResult = context.Observer.InvokeAsync("awaitRuntimeOperation", Arguments(("context", command))); 62var confirmationResult = context.Integration.InvokeAsync("awaitRuntimeOperation", Arguments(("context", confirmation))); 63var commands = Result(context.Integration.Invoke("readResourceCommands", Arguments(("context", context.Writer)))); 64var confirmations = Result(context.Observer.Invoke("readConfirmations", Arguments(("context", context.Reader)))); 70Arguments(("context", context.Writer)))).ToJsonString()); 72Arguments(("context", context.Reader)))).ToJsonString()); 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))))); 158Arguments(("context", revision), ("name", JsonValue.Create("cache")), ("typeId", JsonValue.Create("other/Resource"))))); 163var execution = Result(context.Author.Invoke("getApplicationExecution", Arguments(("context", context.Workspace)))); 165Arguments(("context", execution), ("resource", replacement))))); 174Arguments(("context", context.Writer), ("revision", JsonValue.Create(1L)), ("timeoutMilliseconds", JsonValue.Create(10000)))); 205EnsureSuccess(context.Author.Invoke("waitFor", Arguments(("context", cache), ("dependency", dependency)))); 207var configuration = Result(context.Integration.Invoke("readResourceConfiguration", Arguments(("context", context.Writer)))); 221Arguments(("context", context.Workspace), ("revision", revision))))); 222var invitation = Result(context.Author.Invoke("inviteApplicationWorkspace", Arguments(("context", context.Workspace)))); 225Arguments(("context", root), ("invitation", invitation))))); 226Assert.NotNull(Result(context.Integration.Invoke("joinApplicationWorkspace", Arguments(("context", root), ("invitation", invitation))))); 228Arguments(("context", root), ("invitation", invitation))))); 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( 246Arguments(("context", execution), ("resource", dependent)))))))); 262var configuration = Result(context.Integration.Invoke("readResourceConfiguration", Arguments(("context", writer)))); 265var dependencies = Result(context.Integration.Invoke("readResourceDependencies", Arguments(("context", writer)))); 307var retire = context.Author.InvokeAsync("retireApplicationWorkspace", Arguments(("context", context.Workspace))); 327var configuration = context.Integration.InvokeAsync("waitResourceConfiguration", Arguments( 329var commands = context.Integration.InvokeAsync("waitResourceCommands", Arguments( 347Assert.Equal("OPERATION_REJECTED", Error(context.Author.Invoke("beginRevision", Arguments(("context", context.Workspace))))); 350Arguments(("context", context.Workspace))))); 367Arguments(("context", writer), ("revision", JsonValue.Create(revision)), ("container", new JsonObject 375Arguments(("context", context.Writer), ("container", new JsonObject 382context.Author.InvokeAsync("commitRevision", Arguments(("context", context.Workspace), ("revision", revision))); 385EnsureSuccess(author.Invoke("setResourceConfiguration", Arguments(("context", resource), ("configuration", new JsonObject 391context.Integration.Invoke("completeResourceConfiguration", Arguments(

67EnsureSuccess(await context.Integration.InvokeAsync("startContainer", Arguments( 74var first = await context.Author.InvokeAsync("retireApplicationWorkspace", Arguments(("context", context.Workspace))); 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))))); 79EnsureSuccess(await context.Author.InvokeAsync("retireApplicationWorkspace", Arguments(("context", context.Workspace)))); 82Assert.Equal("HANDLE_NOT_FOUND", Error(context.Author.Invoke("retireApplicationWorkspace", Arguments(("context", context.Workspace)))));

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))));

52context.Integration.Invoke("defineResourceCommand", Arguments(("context", context.Writer), 54context.Integration.Invoke("appendResourceLog", Arguments(("context", context.Writer), 94context.Integration.Invoke("defineResourceCommand", Arguments(("context", context.Writer), 96var ready = context.Integration.InvokeAsync("waitResourceCommands", Arguments(("context", context.Writer), 103context.Integration.Invoke("completeResourceCommand", Arguments(("context", context.Writer), 108var operation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 110var completion = context.Integration.InvokeAsync("awaitRuntimeOperation", Arguments(("context", operation))); 128operation = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 130completion = context.Integration.InvokeAsync("awaitRuntimeOperation", Arguments(("context", operation))); 156WorkspaceRpcTestContext.EnsureSuccess(context.Author.Invoke("setResourceConfiguration", Arguments( 162Arguments(("context", context.Workspace), ("revision", revision)))); 171WorkspaceRpcTestContext.EnsureSuccess(context.Integration.Invoke("completeResourceConfiguration", Arguments( 182Arguments(("context", context.Workspace), ("revision", next)))); 198await context.Author.InvokeAsync("retireGeneration", Arguments(("context", context.Session), ("composition", context.Composition))); 203Result(context.Author.Invoke("createExecution", Arguments(("context", replacement))));

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()); 61Arguments(("context", composition), ("name", JsonValue.Create("late")), ("typeId", JsonValue.Create("example/Resource")))))); 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"]); 102Arguments(("context", liveResources[index]))))["name"]!.GetValue<string>()); 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), 138Arguments(("context", resource), ("name", JsonValue.Create("password")), ("value", value))))); 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()); 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);

138var session = Result(context.Author.Invoke("openApplication", Arguments(("context", authorServer)))); 141var execution = Result(context.Author.Invoke("createExecution", Arguments(("context", composition)))); 143Arguments(("context", execution), ("resource", resource)))); 145Arguments(("context", server), ("invitation", invitation))), timeout.Token)); 147Arguments(("context", writer), ("container", new JsonObject

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"]);

34var endpoint = Result(await context.Integration.InvokeAsync("startContainer", Arguments( 42await context.Author.InvokeAsync("retireGeneration", Arguments( 54var endpoint = Result(await context.Integration.InvokeAsync("startContainer", Arguments( 61var retiring = context.Author.InvokeAsync("retireGeneration", Arguments( 66Assert.Equal("OPERATION_REJECTED", context.Author.Invoke("startGeneration", Arguments(

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), 38var wait = context.Observer.InvokeAsync("waitResourceObservations", Arguments( 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), 106var completion = context.Observer.InvokeAsync("awaitRuntimeOperation", Arguments(("context", command))); 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), 117var answer = context.Integration.InvokeAsync("awaitRuntimeOperation", Arguments(("context", confirmation))); 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), 137var result = context.Observer.InvokeAsync("awaitRuntimeOperation", Arguments(("context", command))); 151var prompt = Result(context.Integration.Invoke("requestConfirmation", Arguments(("context", context.Writer), 153var answer = context.Integration.InvokeAsync("awaitRuntimeOperation", Arguments(("context", prompt))); 169Assert.Equal("INVALID_ARGUMENT", Error(context.Integration.Invoke("publishObservation", Arguments(

78Result(Invoke("startGeneration", Arguments(("context", session)))); 81Result(Invoke("addResource", Arguments(("context", composition), ("name", JsonValue.Create(name)),

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))));

32Arguments(("context", Result(Author.Call("getApplicationServer", null)))))); 35EnsureSuccess(Author.Invoke("commitRevision", Arguments(("context", Workspace), ("revision", Composition)))); 36Execution = Result(Author.Invoke("getApplicationExecution", Arguments(("context", Workspace)))); 37Writer = Result(Integration.Invoke("joinResourceExecution", Arguments( 40Arguments(("context", Execution), ("resource", Resource)))))))); 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)))); 54Arguments(("context", Result(Author.Call("getApplicationServer", null))), ("invitation", invitation)))); 58Arguments(("context", Writer), ("observation", new JsonObject 63public JsonNode Read() => Result(Observer.Invoke("readResourceObservations", Arguments(("context", Reader))));

20var allocation = Result(await context.Integration.InvokeAsync("startContainerWorkload", Arguments( 31await context.Author.InvokeAsync("retireGeneration", Arguments( 68var response = await context.Integration.InvokeAsync("startContainerWorkload", Arguments(