Sha256: a6766b1e55dd03cf197453e895ed3c549c395026665dd974850d9ecbaac5a4aa
Contents?: true
Size: 1.21 KB
Versions: 7
Compression:
Stored size: 1.21 KB
Contents
require 'fcntl'
require 'multi_json'
require 'leeroy/helpers'
module Leeroy
module Helpers
module State
include Leeroy::Helpers
attr_accessor :state
def state_from_pipe(state = {}, global_options = self.global_options)
begin
state.merge(load_state)
rescue StandardError => e
raise e
end
end
def load_state
begin
logger.debug "loading state from stdin if available"
_stdin? ? MultiJson.load($stdin.read, :symbolize_keys => true) : {}
rescue StandardError => e
raise e
end
end
def dump_state
logger.debug "dumping state to stdout"
$stdout.puts self.state.dump
end
def rotate_task_metadata
logger.debug "rotating task metadata"
if self.state.metadata.task?
self.state.metadata.previous = self.state.metadata.task
end
self.state.metadata.task = self.class.to_s
end
def to_s
"#{self.metadata},#{self.data}"
end
private
# this is preposterous BS and doubtless not portable to Windows
def _stdin?
$stdin.fcntl(Fcntl::F_GETFL, 0) == 0
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems