#!/usr/bin/env ruby
#
#  Created by Luke A. Kanies on 2006-11-24.
#  Copyright (c) 2006. All rights reserved.

# subscriptions are permanent associations determining how different
# objects react to an event

require 'puppet/util/json'

# This is Puppet's class for modeling edges in its configuration graph.
# It used to be a subclass of GRATR::Edge, but that class has weird hash
# overrides that dramatically slow down the graphing.
class Puppet::Relationship
    extend Puppet::Util::Json
    attr_accessor :source, :target, :callback

    attr_reader :event

    def self.from_json(json)
        source = json["source"]
        target = json["target"]

        args = {}
        if event = json["event"]
            args[:event] = event
        end
        if callback = json["callback"]
            args[:callback] = callback
        end

        new(source, target, args)
    end
    
    def event=(event)
        if event != :NONE and ! callback
            raise ArgumentError, "You must pass a callback for non-NONE events"
        end
        @event = event
    end

    def initialize(source, target, options = {})
        @source, @target = source, target

        options = (options || {}).inject({}) { |h,a| h[a[0].to_sym] = a[1]; h }
        [:callback, :event].each do |option|
            if value = options[option]
                send(option.to_s + "=", value)
            end
        end
    end

    # Does the passed event match our event?  This is where the meaning
    # of :NONE comes from.
    def match?(event)
        if self.event.nil? or event == :NONE or self.event == :NONE
            return false
        elsif self.event == :ALL_EVENTS or event == self.event
            return true
        else
            return false
        end
    end

    def label
        result = {}
        result[:callback] = callback if callback
        result[:event] = event if event
        result
    end

    def ref
        "%s => %s" % [source, target]
    end

    def to_json(*args)
        data = {
            'source' => source.to_s,
            'target' => target.to_s
        }

        ["event", "callback"].each do |attr|
            next unless value = send(attr)
            data[attr] = value
        end

        {
            'json_class' => self.class.to_s,
            'data' => data
        }.to_json(*args)
    end

    def to_s
        ref
    end
end