Sha256: 0889f93a9b1bed2e05bb22bbed19d5e1991cb0dc31ae9ef5389f71d292f2694b
Contents?: true
Size: 1.58 KB
Versions: 4
Compression:
Stored size: 1.58 KB
Contents
module VagrantPlugins module CommandServe class Mappers class StateBagProtoFromSpec < Mapper def initialize super( inputs: [ Input.new(type: SDK::FuncSpec::Value) { |arg| arg.type == "hashicorp.vagrant.sdk.Args.StateBag" && !arg&.value&.value.nil? } ], output: SDK::Args::StateBag, func: method(:converter), ) end def converter(fv) SDK::Args::StateBag.decode(fv.value.value) end end class StateBagFromProto < Mapper def initialize super( inputs: [ Input.new(type: SDK::Args::StateBag), Input.new(type: Broker), ], output: Client::StateBag, func: method(:converter) ) end def converter(proto, broker) Client::StateBag.load(proto, broker: broker) end end # Extracts a statebag from a Funcspec value class StateBagFromSpec < Mapper def initialize inputs = [].tap do |i| i << Input.new(type: SDK::FuncSpec::Value) { |arg| arg.type == "hashicorp.vagrant.sdk.Args.StateBag" && !arg&.value&.value.nil? } i << Input.new(type: Broker) end super(inputs: inputs, output: Client::StateBag, func: method(:converter)) end def converter(proto, broker) Client::StateBag.load(proto.value.value, broker: broker) end end end end end
Version data entries
4 entries across 4 versions & 2 rubygems