Module: Validation

Included in:
Streamdal::Client, Streamdal::TestClient
Defined in:
lib/validation.rb

Instance Method Summary collapse

Instance Method Details

#validate_kv_command(cmd) ⇒ Object 



26
27
28
29
30
31
32
33
34
 
# File 'lib/validation.rb', line 26

def validate_kv_command(cmd)
  if cmd.nil?
    raise "cmd is required"
  end

  if cmd.kv.nil?
    raise "kv command is required"
  end
end

#validate_kv_instruction(inst) ⇒ Object 



36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/validation.rb', line 36

def validate_kv_instruction(inst)
  if inst.nil?
    raise "instruction is required"
  end

  if inst.id == ""
    raise "instruction id is required"
  end

  if inst.action.nil?
    raise "instruction action is required"
  end

  if inst.action == :KV_ACTION_UNSET
    raise "instruction action is required"
  end

  if inst.object.nil? and inst.action != :KV_ACTION_DELETE_ALL
    raise "instruction object is required"
  end

  validate_kv_object(inst.object)
end

#validate_kv_object(obj) ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
# File 'lib/validation.rb', line 60

def validate_kv_object(obj)
  if obj.nil?
    raise "object is required"
  end

  if obj.key == ""
    raise "kv object key is required"
  end

  if obj.value == ""
    raise "kv object value is required"
  end

end

#validate_set_pipelines(cmd) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/validation.rb', line 6

def validate_set_pipelines(cmd)
  if cmd.nil?
    raise "cmd is required"
  end

  if cmd.audience.nil?
    raise "audience is required"
  end

  if cmd.set_pipelines.nil?
    raise "set_pipelines command is required"
  end

  cmd.set_pipelines.each do |pipeline|
    if pipeline.id == ""
      raise "pipeline id is required"
    end
  end
end

#validate_tail_request(cmd) ⇒ Object 



75
76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'lib/validation.rb', line 75

def validate_tail_request(cmd)
  if cmd.nil?
    raise "cmd is required"
  end

  if cmd.audience.nil?
    raise "audience is required"
  end

  if cmd.tail.nil?
    raise "tail is required"
  end
end