* Enable resource reference feature by default Unless the PULUMI_DISABLE_RESOURCE_REFERENCES flag is explicitly set to a truthy value, the resource reference feature is now enabled by default. * Set AcceptResources in the language SDKs This can be disabled by setting the `PULUMI_DISABLE_RESOURCE_REFERENCES` environment variable to a truthy value. Co-authored-by: Justin Van Patten <jvp@justinvp.com>
90 lines
3.1 KiB
C#
90 lines
3.1 KiB
C#
// Copyright 2016-2019, Pulumi Corporation
|
|
|
|
using System;
|
|
using System.Threading.Tasks;
|
|
using Google.Protobuf.WellKnownTypes;
|
|
using Pulumi.Serialization;
|
|
using Pulumirpc;
|
|
|
|
namespace Pulumi
|
|
{
|
|
public sealed partial class Deployment
|
|
{
|
|
Task IDeployment.InvokeAsync(string token, InvokeArgs args, InvokeOptions? options)
|
|
=> InvokeAsync<object>(token, args, options, convertResult: false);
|
|
|
|
Task<T> IDeployment.InvokeAsync<T>(string token, InvokeArgs args, InvokeOptions? options)
|
|
=> InvokeAsync<T>(token, args, options, convertResult: true);
|
|
|
|
private async Task<T> InvokeAsync<T>(
|
|
string token, InvokeArgs args, InvokeOptions? options, bool convertResult)
|
|
{
|
|
var result = await InvokeRawAsync(token, args, options);
|
|
|
|
if (!convertResult)
|
|
{
|
|
return default!;
|
|
}
|
|
|
|
var data = Converter.ConvertValue<T>($"{token} result", new Value { StructValue = result });
|
|
return data.Value;
|
|
}
|
|
|
|
private async Task<Struct> InvokeRawAsync(string token, InvokeArgs args, InvokeOptions? options)
|
|
{
|
|
var label = $"Invoking function: token={token} asynchronously";
|
|
Log.Debug(label);
|
|
|
|
// Be resilient to misbehaving callers.
|
|
args ??= InvokeArgs.Empty;
|
|
|
|
// Wait for all values to be available, and then perform the RPC.
|
|
var argsDict = await args.ToDictionaryAsync().ConfigureAwait(false);
|
|
var serialized = await SerializeAllPropertiesAsync(
|
|
$"invoke:{token}",
|
|
argsDict, await this.MonitorSupportsResourceReferences().ConfigureAwait(false)).ConfigureAwait(false);
|
|
Log.Debug($"Invoke RPC prepared: token={token}" +
|
|
(_excessiveDebugOutput ? $", obj={serialized}" : ""));
|
|
|
|
var provider = await ProviderResource.RegisterAsync(GetProvider(token, options)).ConfigureAwait(false);
|
|
|
|
var result = await this.Monitor.InvokeAsync(new InvokeRequest
|
|
{
|
|
Tok = token,
|
|
Provider = provider ?? "",
|
|
Version = options?.Version ?? "",
|
|
Args = serialized,
|
|
AcceptResources = !_disableResourceReferences,
|
|
});
|
|
|
|
if (result.Failures.Count > 0)
|
|
{
|
|
var reasons = "";
|
|
foreach (var reason in result.Failures)
|
|
{
|
|
if (reasons != "")
|
|
{
|
|
reasons += "; ";
|
|
}
|
|
|
|
reasons += $"{reason.Reason} ({reason.Property})";
|
|
}
|
|
|
|
throw new InvokeException($"Invoke of '{token}' failed: {reasons}");
|
|
}
|
|
|
|
return result.Return;
|
|
}
|
|
|
|
private static ProviderResource? GetProvider(string token, InvokeOptions? options)
|
|
=> options?.Provider ?? options?.Parent?.GetProvider(token);
|
|
|
|
private class InvokeException : Exception
|
|
{
|
|
public InvokeException(string error)
|
|
: base(error)
|
|
{
|
|
}
|
|
}
|
|
}
|
|
}
|