require_relative 'attributes_helper'
require_relative 'value_helper'
require_relative 'transform'
require 'json'
require 'erb'
require 'yaml'

module CPEE
  module Properties

    def self::implementation(id,opts)
      Proc.new do
        run CPEE::Properties::Get, id, opts if get
        run CPEE::Properties::Patch, id, opts if patch 'set-some-properties'
        run CPEE::Properties::Put, id, opts if put 'set-some-properties'
        on resource 'state' do
          run CPEE::Properties::GetStateMachine, id, opts if get 'machine'
          run CPEE::Properties::GetState, id, opts if get
          run CPEE::Properties::PutState, id, opts if put 'state'
          on resource '@changed' do
            run CPEE::Properties::GetStateChanged, id, opts if get
          end
        end
        on resource 'status' do
          run CPEE::Properties::GetStatus, id, opts if get
          run CPEE::Properties::PutStatus, id, opts if put 'status'
          on resource 'id' do
            run CPEE::Properties::GetStatusID, id, opts if get
          end
          on resource 'message' do
            run CPEE::Properties::GetStatusMessage, id, opts if get
          end
        end
        on resource 'handlerwrapper' do
          run CPEE::Properties::GetHandlerWrapper, id, opts if get
          run CPEE::Properties::PutHandlerWrapper, id, opts if put 'handlerwrapper'
        end
        on resource 'positions' do
          run CPEE::Properties::GetPositions, id, opts if get
          run CPEE::Properties::PatchPositions, id, opts if patch 'positions'
          run CPEE::Properties::PutPositions, id, opts if put 'positions'
          run CPEE::Properties::PostPositions, id, opts if post 'position'
          on resource do
            run CPEE::Properties::GetDetail, 'positions', id, opts if get
            run CPEE::Properties::SetDetail, id, opts if put 'detail'
            run CPEE::Properties::DelDetail, id, opts if delete
            on resource '@passthrough' do
              run CPEE::Properties::GetPt, id, opts if get
            end
          end
        end
        %w{dataelements endpoints attributes}.each do |ele|
          on resource ele do
            run CPEE::Properties::GetItems, ele, id, opts if get
            run CPEE::Properties::PatchItems, ele, id, opts if patch ele
            run CPEE::Properties::PutItems, ele, id, opts if put ele
            run CPEE::Properties::PostItem, ele, id, opts if post ele[0..-2]
            on resource do
              run CPEE::Properties::GetItem, ele, id, opts if get
              run CPEE::Properties::SetItem, ele, id, opts if put 'string'
              run CPEE::Properties::DelItem, ele, id, opts if delete
            end
          end
        end
        on resource 'dsl' do
          run CPEE::Properties::GetComplex, 'dsl', 'text/plain', id, opts if get
        end
        on resource 'dslx' do
          run CPEE::Properties::GetComplex, 'dslx', 'text/xml', id, opts if get
        end
        on resource 'description' do
          run CPEE::Properties::GetComplex, 'description', 'text/xml', id, opts if get
          run CPEE::Properties::PutDescription, id, opts if put 'description'
        end
        on resource 'transformation' do
          run CPEE::Properties::GetTransformation, id, opts if get
          run CPEE::Properties::PutTransformation, id, opts if put 'transformation'
        end
      end
    end

    class Get < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        doc = XML::Smart::open_unprotected(opts[:properties_empty])
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        doc.find('/p:properties/p:state').first.text = CPEE::Persistence::extract_item(id,opts,'state')
        doc.find('/p:properties/p:state/@changed').first.value = CPEE::Persistence::extract_item(id,opts,'state/@changed')
        doc.find('/p:properties/p:status/p:id').first.text = CPEE::Persistence::extract_item(id,opts,'status/id')
        doc.find('/p:properties/p:status/p:message').first.text = CPEE::Persistence::extract_item(id,opts,'status/message')
        %w{dataelements endpoints attributes}.each do |item|
          des = doc.find("/p:properties/p:#{item}").first
          CPEE::Persistence::extract_list(id,opts,item).each{ |de| des.add(*de) }
        end
        des = doc.find("/p:properties/p:positions").first
        CPEE::Persistence::extract_set(id,opts,'positions').each do |de|
          node = des.add(*de)
          if pt = CPEE::Persistence::extract_item(id,opts,File.join('positions',de[0],'@passthrough'))
            node.attributes['passthrough'] = pt
          end
        end
        doc.find('/p:properties/p:dsl').first.text = CPEE::Persistence::extract_item(id,opts,'dsl')
        if val = CPEE::Persistence::extract_item(id,opts,'dslx') #{{{
          doc.find('/p:properties/p:dslx').first.add XML::Smart::string(val).root rescue nil
        end #}}}
        if val = CPEE::Persistence::extract_item(id,opts,'description') #{{{
          doc.find('/p:properties/p:description').first.add XML::Smart::string(val).root rescue nil
        end #}}}
        doc.find('/p:properties/p:transformation/p:description').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/description')
        doc.find('/p:properties/p:transformation/p:dataelements').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/dataelements')
        doc.find('/p:properties/p:transformation/p:endpoints').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/endpoints')
        doc.find('/p:properties/p:transformation/p:description/@type').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/description/@type')
        doc.find('/p:properties/p:transformation/p:dataelements/@type').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/dataelements/@type')
        doc.find('/p:properties/p:transformation/p:endpoints/@type').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/endpoints/@type')
        Riddl::Parameter::Complex.new('properties','application/xml',doc.to_s)
      end
    end #}}}
    class Patch < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 400
        else
          doc = XML::Smart::string(@p[0].value.read)
          doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
          if (node = doc.find('/p:properties/p:status')).any?
            CPEE::Properties::PutStatus::set id, opts, node.first.dump
          end
          if (node = doc.find('/p:properties/p:handlerwrapper')).any?
            CPEE::Properties::PutHandlerWrapper::set id, opts, node.first.text
          end

          %w{dataelements endpoints attributes}.each do |item|
            if (node = doc.find('/p:properties/p:' + item)).any?
              CPEE::Properties::PatchItems::set item, id, opts, node.first.dump
            end
          end

          if (node = doc.find('/p:properties/p:transformation')).any?
            CPEE::Properties::PutTransformation::set id, opts, node.first.dump
          end
          if (node = doc.find('/p:properties/p:description/*')).any?
            CPEE::Properties::PutDescription::set id, opts, node.first.dump
          end

          if (node = doc.find('/p:properties/p:positions')).any?
            if node.first.find('p:*').any?
              CPEE::Properties::PatchPositions::set id, opts, node.first.dump
            end
          end

          if (node = doc.find('/p:properties/p:state')).any?
            CPEE::Properties::PutState::run id, opts, node.first.text
          end
        end
      end
    end #}}}
    class Put < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 400
        else
          doc = XML::Smart::string(@p[0].value.read)
          doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
          if (node = doc.find('/p:properties/p:status')).any?
            CPEE::Properties::PutStatus::set id, opts, node.first.dump
          end
          if (node = doc.find('/p:properties/p:handlerwrapper')).any?
            CPEE::Properties::PutHandlerWrapper::set id, opts, node.first.text
          end

          %w{dataelements endpoints attributes}.each do |item|
            if (node = doc.find('/p:properties/p:' + item)).any?
              CPEE::Properties::PutItems::set item, id, opts, node.first.dump
            end
          end

          if (node = doc.find('/p:properties/p:transformation')).any?
            CPEE::Properties::PutTransformation::set id, opts, node.first.dump
          end
          if (node = doc.find('/p:properties/p:description/*')).any?
            CPEE::Properties::PutDescription::set id, opts, node.first.dump
          end

          if (node = doc.find('/p:properties/p:positions')).any?
            if node.first.find('p:*').any?
              CPEE::Properties::PutPositions::set id, opts, node.first.dump
            end
          end

          if (node = doc.find('/p:properties/p:state')).any?
            CPEE::Properties::PutState::run id, opts, node.first.text
          end
        end
      end
    end #}}}
    class GetState < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        Riddl::Parameter::Simple.new('value',CPEE::Persistence::extract_item(id,opts,'state'))
      end
    end #}}}
    class PutState < Riddl::Implementation #{{{
      def self::set(id,opts,state)
        CPEE::Persistence::set_item(id,opts,'state',:state => state, :timestamp => Time.now.xmlschema(3))
      end

      def self::run(id,opts,state)
        exe = File.join(opts[:instances],id.to_s,File.basename(opts[:backend_run]))
        case state
          when 'running'
            CPEE::Persistence::write_instance id, opts
            pid = Kernel.spawn(exe , :pgroup => true, :in => '/dev/null', :out => exe + '.out', :err => exe + '.err')
            Process.detach pid
            File.write(exe + '.pid',pid)
          when 'stopping'
            pid = File.read(exe + '.pid') rescue nil
            if pid && (Process.kill(0, pid.to_i) rescue false)
              Process.kill('HUP', pid.to_i) rescue nil
            else
              File.unlink(exe + '.pid') rescue nil
              PutState::set id, opts, 'stopped'
            end
          else
            ### Most probably this is never needed. Lets see.
            PutState::set id, opts, state
        end
      end

      def response
        id = @a[0]
        opts = @a[1]
        state = @p[0].value
        if opts[:statemachine].setable? id, state
          PutState::run id, opts, state
        else
          @status = 422
        end
        nil
      end
    end #}}}
    class GetStateMachine < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        Riddl::Parameter::Complex.new('statemachine','text/xml',File.read(opts[:states]))
      end
    end #}}}
    class GetStateChanged < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        Riddl::Parameter::Simple.new('state',CPEE::Persistence::extract_item(id,opts,'state/@changed'))
      end
    end #}}}
    class GetStatus < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        doc = XML::Smart::open_unprotected(opts[:properties_empty])
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        des = doc.find('/p:properties/p:status').first
        des.find('p:id').first.text = CPEE::Persistence::extract_item(id,opts,'status/id')
        des.find('p:message').first.text = CPEE::Persistence::extract_item(id,opts,'status/message')
        Riddl::Parameter::Complex.new('status','text/xml',des.to_doc.to_s)
      end
    end #}}}
    class PutStatus < Riddl::Implementation #{{{
      def self::set(id,opts,xml)
        doc = XML::Smart::string(xml)
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        CPEE::Persistence::set_item(id,opts,'status',:id => doc.find('string(/p:status/p:id)').to_i, :message => doc.find('string(/p:status/p:message)'))
      end

      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 422 # semantic error
        else
          PutStatus::set id, opts, @p[0].value.read
        end
        nil
      end
    end #}}}
    class GetStatusID < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        Riddl::Parameter::Simple.new('value',CPEE::Persistence::extract_item(id,opts,'status/id'))
      end
    end #}}}
    class GetStatusMessage < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        Riddl::Parameter::Simple.new('value',CPEE::Persistence::extract_item(id,opts,'status/message'))
      end
    end #}}}
    class GetHandlerWrapper < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        Riddl::Parameter::Simple.new('value',CPEE::Persistence::extract_item(id,opts,'handlerwrapper'))
      end
    end #}}}
    class PutHandlerWrapper < Riddl::Implementation #{{{
      def self::set(id,opts,hw)
        CPEE::Persistence::set_item(id,opts,'handlerwrapper',:handlerwrapper => hw)
      end
      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          PutHandlerWrapper::set(id,opts,@p[0].value)
        end
        nil
      end
    end #}}}
    class GetItems < Riddl::Implementation #{{{
      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        doc = XML::Smart::open_unprotected(opts[:properties_empty])
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        des = doc.find("/p:properties/p:#{item}").first
        CPEE::Persistence::extract_list(id,opts,item).each{ |de| des.add(*de) }
        Riddl::Parameter::Complex.new(item,'text/xml',des.to_doc.to_s)
      end
    end #}}}
    class PatchItems < Riddl::Implementation #{{{
      def self::set_hash(item, id, opts, val)
        CPEE::Persistence::set_list(id,opts,item,val)
      end
      def self::set(item, id, opts, xml)
        doc = XML::Smart::string(xml)
        val = doc.find("/*/*").map do |ele|
          [ele.qname.name, ele.text]
        end.to_h
        CPEE::Persistence::set_list(id,opts,item,val)
      end

      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          begin
            PatchItems::set(item,id,opts,@p[0].value.read)
          rescue
            @status = 400
          end
        end
        nil
      end
    end #}}}
    class PutItems < Riddl::Implementation #{{{
      def self::set(item,id,opts,xml)
        doc = XML::Smart::string(xml)
        val = {}
        doc.find("/*/*").each do |ele|
          val[ele.qname.name] = ele.text unless val.has_key?(ele.qname.name)
        end
        oldkeys = CPEE::Persistence::extract_list(id,opts,item).to_h.keys
        newkeys = val.keys
        del = oldkeys - newkeys
        CPEE::Persistence::set_list(id,opts,item,val,del)
      end

      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          begin
            PutItems::set(item,id,opts,@p[0].value.read)
          rescue
            @status = 400
          end
        end
        nil
      end
    end #}}}
    class PostItem < Riddl::Implementation #{{{
      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          begin
            doc = XML::Smart::string(@p[0].value.read)
            val = doc.find("/*").map do |ele|
              [ele.qname.name, ele.text]
            end.to_h
            if not CPEE::Persistence::extract_item(id,opts,File.join(@r.first,val.keys.first))
              CPEE::Persistence::set_list(id,opts,item,val)
              Riddl::Parameter::Simple.new('id',val.keys.first)
            else
              @status= 409
            end
          rescue => e
            @status = 400
          end
        end
        nil
      end
    end #}}}
    class GetItem < Riddl::Implementation #{{{
      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        if val = CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          Riddl::Parameter::Simple.new('value',val)
        else
          @status = 404
        end
      end
    end #}}}
    class SetItem < Riddl::Implementation #{{{
      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        val = { @r.last => @p[0].value }
        if CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          CPEE::Persistence::set_list(id,opts,item,val)
        else
          @status = 404
        end
        nil
      end
    end #}}}
    class DelItem < Riddl::Implementation #{{{
      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        val = { @r.last => nil }
        if opts[:statemachine].readonly? id
          @status = 423
        else
          if CPEE::Persistence::extract_item(id,opts,@r.join('/'))
            CPEE::Persistence::set_list(id,opts,item,val,val.keys)
          else
            @status = 404
          end
        end
        nil
      end
    end #}}}

    class GetComplex < Riddl::Implementation #{{{
      def response
        item = @a[0]
        mime = @a[1]
        id = @a[2]
        opts = @a[3]
        if val = CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          Riddl::Parameter::Complex.new(item,mime,val)
        else
          @status = 404
        end
      end
    end #}}}

    class GetPositions < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        doc = XML::Smart::open_unprotected(opts[:properties_empty])
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        des = doc.find("/p:properties/p:positions").first
        CPEE::Persistence::extract_set(id,opts,'positions').each do |de|
          node = des.add(*de)
          if pt = CPEE::Persistence::extract_item(id,opts,File.join('positions',de[0],'@passthrough'))
            node.attributes['passthrough'] = pt
          end
        end
        Riddl::Parameter::Complex.new('positions','text/xml',des.to_doc.to_s)
      end
    end #}}}
    class PatchPositions < Riddl::Implementation #{{{
      def self::set(id,opts,xml)
        doc = XML::Smart::string(xml)
        content = {}
        doc.find("/*/*").map do |ele|
          val = { 'position' => ele.qname.name }
          val['passthrough'] = ele.attributes['passthrough'] if ele.attributes['passthrough']
          content[ele.text] ||= []
          content[ele.text] << val
        end
        CPEE::Persistence::set_item(id,opts,'position',content)
      end

      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          begin
            PatchPositions::set(id,opts,@p[0].value.read)
          rescue => e
            @status = 400
          end
        end
        nil
      end
    end #}}}
    class PutPositions < Riddl::Implementation #{{{
      def PutPositions::set(id,opts,xml)
        doc = XML::Smart::string(xml)
        content = {}
        newkeys = []
        doc.find("/*/*").map do |ele|
          val = { 'position' => ele.qname.name }
          val['passthrough'] = ele.attributes['passthrough'] if ele.attributes['passthrough']
          content[ele.text] ||= []
          content[ele.text] << val
          newkeys << ele.qname.name
        end
        oldkeys = CPEE::Persistence::extract_set(id,opts,'positions').to_h.keys
        del = oldkeys - newkeys
        del.each do |key|
          val = { 'position' => key }
          content['unmark'] ||= []
          content['unmark'] << val
        end
        CPEE::Persistence::set_item(id,opts,'position',content)
      end

      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          begin
            PutPositions::set(id,opts,@p[0].value.read)
          rescue => e
            @status = 400
          end
        end
        nil
      end
    end #}}}
    class PostPositions < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 423
        else
          begin
            doc = XML::Smart::string(@p[0].value.read)
            if not CPEE::Persistence::extract_item(id,opts,File.join('positions',doc.root.qname.name))
              content = {}
              content[doc.root.text] = [{ 'position' => doc.root.qname.name }]
              content[doc.root.text][0]['passthrough'] = doc.root.attributes['passthrough'] if doc.root.attributes['passthrough']
              CPEE::Persistence::set_item(id,opts,'position',content)
            else
              @status= 409
            end
            Riddl::Parameter::Simple.new('id',doc.root.qname.name)
          rescue => e
            @status = 400
          end
        end
        nil
      end
    end #}}}
    class GetDetail < Riddl::Implementation #{{{
      def response
        item = @a[0]
        id = @a[1]
        opts = @a[2]
        if val = CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          Riddl::Parameter::Simple.new('value',val)
        else
          @status = 404
        end
      end
    end #}}}
    class SetDetail < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        if CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          CPEE::Persistence::set_item(id,opts,'position',@p[0].value => [ { 'position' => @r.last } ])
        else
          @status = 404
        end
        nil
      end
    end #}}}
    class DelDetail < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        if CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          CPEE::Persistence::set_position(id,opts,'position','unmark' => [ { 'position' => @r.last } ])
        else
          @status = 404
        end
        nil
      end
    end #}}}
    class GetPt < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        if val = CPEE::Persistence::extract_item(id,opts,@r.join('/'))
          Riddl::Parameter::Simple.new('value',val)
        else
          @status = 404
        end
      end
    end #}}}

    class PutDescription < Riddl::Implementation #{{{
      def self::set(id,opts,xml)
        dslx, dsl, de, ep = transform(
          xml,
          CPEE::Persistence::extract_item(id,opts,'transformation/description'),
          CPEE::Persistence::extract_item(id,opts,'transformation/description/@type'),
          CPEE::Persistence::extract_item(id,opts,'transformation/dataelements'),
          CPEE::Persistence::extract_item(id,opts,'transformation/dataelements/@type'),
          CPEE::Persistence::extract_item(id,opts,'transformation/endpoints'),
          CPEE::Persistence::extract_item(id,opts,'transformation/endpoints/@type'),
          opts
        )
        CPEE::Persistence::set_item(id,opts,'description',
          :description => xml,
          :dslx => dslx,
          :dsl => dsl
        )
        PatchItems::set_hash('dataelements',id,opts,de) unless de.empty?
        PatchItems::set_hash('dataelements',id,opts,ep) unless ep.empty?
      end

      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 422 # semantic error
        else
          begin
            PutDescription::set(id,opts,@p[0].value.read)
          rescue
            @status = 400
          end
        end
        nil
      end
    end #}}}

    class GetTransformation < Riddl::Implementation #{{{
      def response
        id = @a[0]
        opts = @a[1]
        doc = XML::Smart::open_unprotected(opts[:properties_empty])
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        des = doc.find('/p:properties/p:transformation').first
        des.find('p:description').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/description')
        des.find('p:dataelements').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/dataelements')
        des.find('p:endpoints').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/endpoints')
        des.find('p:description/@type').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/description/@type')
        des.find('p:dataelements/@type').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/dataelements/@type')
        des.find('p:endpoints/@type').first.text = CPEE::Persistence::extract_item(id,opts,'transformation/endpoints/@type')
        Riddl::Parameter::Complex.new('status','text/xml',des.to_doc.to_s)
      end
    end #}}}
    class PutTransformation < Riddl::Implementation #{{{
      def self::set(id,opts,xml)
        doc = XML::Smart::string(xml)
        doc.register_namespace 'p', 'http://cpee.org/ns/properties/2.0'
        CPEE::Persistence::set_item(id,opts,'transformation',
          :description => doc.find('string(/p:transformation/p:description)'),
          :description_type => doc.find('string(/p:transformation/p:description/@type)'),
          :dataelements =>doc.find('string(/p:transformation/p:dataelements)'),
          :dataelements_type => doc.find('string(/p:transformation/p:dataelements/@type)'),
          :endpoints =>doc.find('string(/p:transformation/p:endpoints)'),
          :endpoints_type => doc.find('string(/p:transformation/p:endpoints/@type)')
        )
      end
      def response
        id = @a[0]
        opts = @a[1]
        if opts[:statemachine].readonly? id
          @status = 422 # semantic error
        else
          PutTransformation::set(id,opts,@p[0].value.read)
        end
        nil
      end
    end #}}}

  end
end