Class: SDM::ApprovalWorkflows

Inherits:

Object

• Object
• SDM::ApprovalWorkflows

Extended by:

Gem::Deprecate

Defined in:

lib/svc.rb

Overview

ApprovalWorkflows are the mechanism by which requests for access can be viewed by authorized approvers and be approved or denied.

See ApprovalWorkflow.

Instance Method Summary

• #create(approval_workflow, deadline: nil) ⇒ Object

  Create creates a new approval workflow and requires a name and approval mode for the approval workflow.

• #delete(id, deadline: nil) ⇒ Object

  Delete deletes an existing approval workflow.

• #get(id, deadline: nil) ⇒ Object

  Get reads one approval workflow by ID.

• #initialize(channel, parent) ⇒ ApprovalWorkflows constructor

  A new instance of ApprovalWorkflows.

• #list(filter, *args, deadline: nil) ⇒ Object

  Lists existing approval workflows.

• #update(approval_workflow, deadline: nil) ⇒ Object

  Update updates an existing approval workflow.

Constructor Details

#initialize(channel, parent) ⇒ ApprovalWorkflows

# File 'lib/svc.rb', line 2088

def initialize(channel, parent)
  begin
    @stub = V1::ApprovalWorkflows::Stub.new(nil, nil, channel_override: channel)
  rescue => exception
    raise Plumbing::convert_error_to_porcelain(exception)
  end
  @parent = parent
end

Instance Method Details

#create(approval_workflow, deadline: nil) ⇒ Object

Create creates a new approval workflow and requires a name and approval mode for the approval workflow.

# File 'lib/svc.rb', line 2098

def create(
  approval_workflow,
  deadline: nil
)
  req = V1::ApprovalWorkflowCreateRequest.new()

  req.approval_workflow = Plumbing::convert_approval_workflow_to_plumbing(approval_workflow)
  # Execute before interceptor hooks
  req = @parent.interceptor.execute_before("ApprovalWorkflows.Create", self, req)
  tries = 0
  plumbing_response = nil
  loop do
    begin
      plumbing_response = @stub.create(req, metadata: @parent.get_metadata("ApprovalWorkflows.Create", req), deadline: deadline)
    rescue => exception
      if (@parent.shouldRetry(tries, exception, deadline))
        tries + +sleep(@parent.exponentialBackoff(tries, deadline))
        next
      end
      raise Plumbing::convert_error_to_porcelain(exception)
    end
    break
  end

  # Execute after interceptor hooks
  plumbing_response = @parent.interceptor.execute_after("ApprovalWorkflows.Create", self, req, plumbing_response)

  resp = ApprovalWorkflowCreateResponse.new()
  resp.approval_workflow = Plumbing::convert_approval_workflow_to_porcelain(plumbing_response.approval_workflow)
  resp.rate_limit = Plumbing::convert_rate_limit_metadata_to_porcelain(plumbing_response.rate_limit)
  resp
end

#delete(id, deadline: nil) ⇒ Object

Delete deletes an existing approval workflow.

# File 'lib/svc.rb', line 2171

def delete(
  id,
  deadline: nil
)
  req = V1::ApprovalWorkflowDeleteRequest.new()

  req.id = (id)
  # Execute before interceptor hooks
  req = @parent.interceptor.execute_before("ApprovalWorkflows.Delete", self, req)
  tries = 0
  plumbing_response = nil
  loop do
    begin
      plumbing_response = @stub.delete(req, metadata: @parent.get_metadata("ApprovalWorkflows.Delete", req), deadline: deadline)
    rescue => exception
      if (@parent.shouldRetry(tries, exception, deadline))
        tries + +sleep(@parent.exponentialBackoff(tries, deadline))
        next
      end
      raise Plumbing::convert_error_to_porcelain(exception)
    end
    break
  end

  # Execute after interceptor hooks
  plumbing_response = @parent.interceptor.execute_after("ApprovalWorkflows.Delete", self, req, plumbing_response)

  resp = ApprovalWorkflowDeleteResponse.new()
  resp.id = (plumbing_response.id)
  resp.rate_limit = Plumbing::convert_rate_limit_metadata_to_porcelain(plumbing_response.rate_limit)
  resp
end

#get(id, deadline: nil) ⇒ Object

Get reads one approval workflow by ID.

# File 'lib/svc.rb', line 2132

def get(
  id,
  deadline: nil
)
  req = V1::ApprovalWorkflowGetRequest.new()
  if not @parent.snapshot_time.nil?
    req.meta = V1::GetRequestMetadata.new()
    req.meta.snapshot_at = @parent.snapshot_time
  end

  req.id = (id)
  # Execute before interceptor hooks
  req = @parent.interceptor.execute_before("ApprovalWorkflows.Get", self, req)
  tries = 0
  plumbing_response = nil
  loop do
    begin
      plumbing_response = @stub.get(req, metadata: @parent.get_metadata("ApprovalWorkflows.Get", req), deadline: deadline)
    rescue => exception
      if (@parent.shouldRetry(tries, exception, deadline))
        tries + +sleep(@parent.exponentialBackoff(tries, deadline))
        next
      end
      raise Plumbing::convert_error_to_porcelain(exception)
    end
    break
  end

  # Execute after interceptor hooks
  plumbing_response = @parent.interceptor.execute_after("ApprovalWorkflows.Get", self, req, plumbing_response)

  resp = ApprovalWorkflowGetResponse.new()
  resp.approval_workflow = Plumbing::convert_approval_workflow_to_porcelain(plumbing_response.approval_workflow)
  resp.meta = Plumbing::convert_get_response_metadata_to_porcelain(plumbing_response.meta)
  resp.rate_limit = Plumbing::convert_rate_limit_metadata_to_porcelain(plumbing_response.rate_limit)
  resp
end

#list(filter, *args, deadline: nil) ⇒ Object

Lists existing approval workflows.

# File 'lib/svc.rb', line 2239

def list(
  filter,
  *args,
  deadline: nil
)
  req = V1::ApprovalWorkflowListRequest.new()
  req.meta = V1::ListRequestMetadata.new()
  if not @parent.page_limit.nil?
    req.meta.limit = @parent.page_limit
  end
  if not @parent.snapshot_time.nil?
    req.meta.snapshot_at = @parent.snapshot_time
  end

  req.filter = Plumbing::quote_filter_args(filter, *args)
  resp = Enumerator::Generator.new { |g|
    tries = 0
    loop do
      begin
        plumbing_response = @stub.list(req, metadata: @parent.get_metadata("ApprovalWorkflows.List", req), deadline: deadline)
      rescue => exception
        if (@parent.shouldRetry(tries, exception, deadline))
          tries + +sleep(@parent.exponentialBackoff(tries, deadline))
          next
        end
        raise Plumbing::convert_error_to_porcelain(exception)
      end
      tries = 0
      plumbing_response.approval_workflows.each do |plumbing_item|
        g.yield Plumbing::convert_approval_workflow_to_porcelain(plumbing_item)
      end
      break if plumbing_response.meta.next_cursor == ""
      req.meta.cursor = plumbing_response.meta.next_cursor
    end
  }
  resp
end

#update(approval_workflow, deadline: nil) ⇒ Object

Update updates an existing approval workflow.

# File 'lib/svc.rb', line 2205

def update(
  approval_workflow,
  deadline: nil
)
  req = V1::ApprovalWorkflowUpdateRequest.new()

  req.approval_workflow = Plumbing::convert_approval_workflow_to_plumbing(approval_workflow)
  # Execute before interceptor hooks
  req = @parent.interceptor.execute_before("ApprovalWorkflows.Update", self, req)
  tries = 0
  plumbing_response = nil
  loop do
    begin
      plumbing_response = @stub.update(req, metadata: @parent.get_metadata("ApprovalWorkflows.Update", req), deadline: deadline)
    rescue => exception
      if (@parent.shouldRetry(tries, exception, deadline))
        tries + +sleep(@parent.exponentialBackoff(tries, deadline))
        next
      end
      raise Plumbing::convert_error_to_porcelain(exception)
    end
    break
  end

  # Execute after interceptor hooks
  plumbing_response = @parent.interceptor.execute_after("ApprovalWorkflows.Update", self, req, plumbing_response)

  resp = ApprovalWorkflowUpdateResponse.new()
  resp.approval_workflow = Plumbing::convert_approval_workflow_to_porcelain(plumbing_response.approval_workflow)
  resp.rate_limit = Plumbing::convert_rate_limit_metadata_to_porcelain(plumbing_response.rate_limit)
  resp
end