Class: ManageEngine::APMUtil

Inherits:
Object
  • Object
show all
Defined in:
lib/agent/util/am_util.rb

Instance Method Summary collapse

Instance Method Details

#copyFiles(src, dest) ⇒ Object 



85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
 
# File 'lib/agent/util/am_util.rb', line 85

def copyFiles src, dest
	result = false
	begin
	srcFile = File.open(src)
	destFile = File.open(dest , "w")
	destFile.write( srcFile.read(100) ) while not srcFile.eof?
	result = true
	rescue	Exception=>e
		@log.info "Problem in Copying File : \n File : #{src} to #{dest}"
		@log.logException "#{e.message}",e
		result = false;
	ensure
		srcFile.close
		destFile.close
	end

	result
end

#currenttimemillis ⇒ Object 



113
114
115
 
# File 'lib/agent/util/am_util.rb', line 113

def currenttimemillis
	(Time.now.to_f*1000).to_i
end

#decrypt(cipher_text, key) ⇒ Object 



31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/agent/util/am_util.rb', line 31

def decrypt cipher_text, key
    if (cipher_text == nil || key == nil)
      return nil
    end
  plain_text = nil
  begin
      key = key.length > 16 ? key[(key.length-16)..-1] : key
  		cipher = OpenSSL::Cipher.new('AES-128-CBC').decrypt
  		cipher.key = key
  		cipher.iv = ManageEngine::APMObjectHolder.instance.constants.en_alphabets + ManageEngine::APMObjectHolder.instance.constants.en_numerals
  		plain_text = cipher.update(Base64.decode64(cipher_text)) + cipher.final
  rescue Exception=>e
      plain_text = nil
  end
    return plain_text
end

#encrypt(text, key) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/agent/util/am_util.rb', line 14

def encrypt text, key
  if (text == nil || key == nil)
    return nil
  end
    cipher_text = nil
  begin
    key = key.length > 16 ? key[(key.length-16)..-1] : key
  		cipher = OpenSSL::Cipher.new('AES-128-CBC').encrypt
  		cipher.key = key
  		cipher.iv = ManageEngine::APMObjectHolder.instance.constants.en_alphabets + ManageEngine::APMObjectHolder.instance.constants.en_numerals
  		cipher_text = Base64.encode64(cipher.update(text) + cipher.final)
  rescue Exception=>e
    cipher_text = nil
  end
    return cipher_text
end

#formatStacktrace(stacktrace) ⇒ Object 



167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
 
# File 'lib/agent/util/am_util.rb', line 167

def formatStacktrace(stacktrace)
  strace = Array.new
  
  if (stacktrace != nil)
    begin
      stacktrace.each do |stackelement|
        temp = Array.new
        temp[0] = stackelement
        temp[1] = ""
        temp[2] = ""
        temp[3] = ""
        strace.push(temp)
        if (strace.size == 10)
          break;
        end
      end
    rescue Exception=>e
      @log.logException "Error while formatting stack trace. #{e.message}", e
    end
  end
  
  strace
end

#getArray(value, sep) ⇒ Object 



118
119
120
121
122
123
124
 
# File 'lib/agent/util/am_util.rb', line 118

def getArray value,sep
	arr = Array.new
	if(value!=nil && value.length>0)
		arr = value.split(sep)
	end
	arr
end

#getBooleanValue(str) ⇒ Object 



105
106
107
108
109
110
111
 
# File 'lib/agent/util/am_util.rb', line 105

def getBooleanValue(str)
 	if str == true || str == "true" || str == "True" || str == "TRUE"
	return true
		else
return false
		end
end

#is_float(val) ⇒ Object 



146
147
148
149
150
151
152
 
# File 'lib/agent/util/am_util.rb', line 146

def is_float(val)
	Float(val)
	rescue ArgumentError
 			false
	else
 			true
end

#is_integer(val) ⇒ Object 



138
139
140
141
142
143
144
 
# File 'lib/agent/util/am_util.rb', line 138

def is_integer(val)
 		Integer(val)
	rescue ArgumentError
 			false
	else
 			true
end

#isPortBusy(port) ⇒ Object 



125
126
127
128
129
130
131
132
133
134
135
136
 
# File 'lib/agent/util/am_util.rb', line 125

def isPortBusy(port)
    Timeout::timeout(1) do
     begin
TCPSocket.new('localhost', port).close
        true
     rescue Errno::ECONNREFUSED, Errno::EHOSTUNREACH
        false
		end
		end
		rescue Timeout::Error
			false
end

#parametrizeQuery(qry) ⇒ Object 



154
155
156
157
158
159
160
161
162
163
164
165
 
# File 'lib/agent/util/am_util.rb', line 154

def parametrizeQuery qry
	begin
		qry.gsub!(/'(.*?[^'])??'/,"?")
		qry.gsub!(/\"(.*?[^\"])??\"/,"?")
		qry.gsub!(/=.\d+/,"=?")
           qry.gsub!(/,.\d+/,", ?")
	rescue Exception=>e
		@log.info "Problem in Parameterizing query:  #{e.message} "
		@log.logException "#{e.message}",e
	end
	qry
end

#readProperties(filepath) ⇒ Object

Reads the Property Files and returns a Hashes



49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/agent/util/am_util.rb', line 49

def	readProperties filepath
	props = {}
	begin
		propsFile=File.open(filepath, 'r') 
  		propsFile.read.each_line do |line|
			line.strip!
			if (line[0] != ?# and line[0] != ?=)
  				i = line.index('=')
	  			if (i)
      			props[line[0..i - 1].strip] = line[i + 1..-1].strip
    			else
    				props[line] = ''
   				end
  			end
    	end
      propsFile.close
	rescue Exception=>e
		@log.info "Problem in Reading Property File :  #{e.message} "
		@log.error "#{e.backtrace}"
	end
	props
end

#setLogger(log) ⇒ Object 



10
11
12
 
# File 'lib/agent/util/am_util.rb', line 10

def setLogger log
	@log = log
end

#writeProperties(f, props) ⇒ Object

write the Properties into the Property file



73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/agent/util/am_util.rb', line 73

def writeProperties(f,props)
	begin 
		file = File.new(f,"w+")
		props.each {|key,value| file.puts "#{key}=#{value}\n"}
	rescue Exception=>e
		@log.info "Problem in Writing Property File : \n File : #{f}"
		@log.logException "#{e.message}",e
	ensure
		file.close
	end
end