Commit 3c00a569 authored by Roque's avatar Roque

Update urls renamed in server side

parent 428caf79
...@@ -7,7 +7,7 @@ require 'open-uri' ...@@ -7,7 +7,7 @@ require 'open-uri'
class DatasetUtils class DatasetUtils
begin begin
uri = URI(URI.escape("https://wendelin.io/getIngestionConstantsJson")) uri = URI(URI.escape("https://wendelin.io/ERP5Site_getIngestionConstantsJson"))
res = open(uri).read res = open(uri).read
json = JSON.parse(res) json = JSON.parse(res)
EOF = json['split_end_suffix'] EOF = json['split_end_suffix']
......
...@@ -34,7 +34,7 @@ class WendelinClient ...@@ -34,7 +34,7 @@ class WendelinClient
def exists(reference) def exists(reference)
checkReferenceChars(reference) checkReferenceChars(reference)
uri = URI(URI.escape("#{@erp5_url}/ingestionReferenceExists?reference=#{reference}")) uri = URI(URI.escape("#{@erp5_url}/ERP5Site_checkIngestionReferenceExists?reference=#{reference}"))
begin begin
response = handleRequest(uri) response = handleRequest(uri)
rescue Exception => e rescue Exception => e
...@@ -146,7 +146,7 @@ class WendelinClient ...@@ -146,7 +146,7 @@ class WendelinClient
while not done while not done
start_offset = n_part*chunk_size start_offset = n_part*chunk_size
end_offset = n_part*chunk_size+chunk_size end_offset = n_part*chunk_size+chunk_size
uri = URI(URI.escape("#{@erp5_url}getDataStreamChunk?id=#{id}&start_offset=#{start_offset}&end_offset=#{end_offset}")) uri = URI(URI.escape("#{@erp5_url}ERP5Site_getDataStreamChunk?id=#{id}&start_offset=#{start_offset}&end_offset=#{end_offset}"))
success = FALSE success = FALSE
n_retry = 0 n_retry = 0
while ! success && n_retry < 10 while ! success && n_retry < 10
...@@ -181,7 +181,7 @@ class WendelinClient ...@@ -181,7 +181,7 @@ class WendelinClient
end end
def getDataStreams(data_set_reference) def getDataStreams(data_set_reference)
uri = URI(URI.escape("#{@erp5_url}getDataStreamList?data_set_reference=#{data_set_reference}")) uri = URI(URI.escape("#{@erp5_url}ERP5Site_getDataStreamList?data_set_reference=#{data_set_reference}"))
response = handleRequest(uri) response = handleRequest(uri)
if response["success"] == FALSE if response["success"] == FALSE
@logger.abortExecution() @logger.abortExecution()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment