# coding: utf-8

"""

LiveAgent API

This page contains complete API documentation for LiveAgent software. To display additional info and examples for specific API method, just click on the method name in the list below.<br/><br/>To be able to make API requests you need to generate an API key in your admin panel first. [See this article for detailed info.](https://support.liveagent.com/741982-API-key)<br/><br/>Additional info about more advanced agent, contact or ticket API filters can be found [in this article](https://support.liveagent.com/513528-APIv3-advanced-filter-examples).<br/><br/>If you have any question or doubts regarding this API, please do not hesitate to contact our support team. # noqa: E501

OpenAPI spec version: 3.0.0

Contact: support@qualityunit.com

Generated by: https://github.com/swagger-api/swagger-codegen.git

"""

from __future__ import absolute_import

import re # noqa: F401

# python 2 and python 3 compatibility library

import six

from liveagent_api.api_client import ApiClient

class ElasticApi(object):

"""NOTE: This class is auto generated by the swagger code generator program.

Do not edit the class manually.

Ref: https://github.com/swagger-api/swagger-codegen

"""

def __init__(self, api_client=None):

if api_client is None:

api_client = ApiClient()

self.api_client = api_client

def clean_tickets(self, type, **kwargs): # noqa: E501

"""Remove all es-documents that dont exist in primary db # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.clean_tickets(type, async_req=True)

>>> result = thread.get()

:param async_req bool

:param str type: Type of index (required)

:return: ElasticMessage

If the method is called asynchronously,

returns the request thread.

"""

kwargs['_return_http_data_only'] = True

if kwargs.get('async_req'):

return self.clean_tickets_with_http_info(type, **kwargs) # noqa: E501

else:

(data) = self.clean_tickets_with_http_info(type, **kwargs) # noqa: E501

return data

def clean_tickets_with_http_info(self, type, **kwargs): # noqa: E501

"""Remove all es-documents that dont exist in primary db # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.clean_tickets_with_http_info(type, async_req=True)

>>> result = thread.get()

:param async_req bool

:param str type: Type of index (required)

:return: ElasticMessage

If the method is called asynchronously,

returns the request thread.

"""

all_params = ['type'] # noqa: E501

all_params.append('async_req')

all_params.append('_return_http_data_only')

all_params.append('_preload_content')

all_params.append('_request_timeout')

params = locals()

for key, val in six.iteritems(params['kwargs']):

if key not in all_params:

raise TypeError(

"Got an unexpected keyword argument '%s'"

" to method clean_tickets" % key

)

params[key] = val

del params['kwargs']

# verify the required parameter 'type' is set

if self.api_client.client_side_validation and ('type' not in params or

params['type'] is None): # noqa: E501

raise ValueError("Missing the required parameter `type` when calling `clean_tickets`") # noqa: E501

collection_formats = {}

path_params = {}

query_params = []

header_params = {}

form_params = []

local_var_files = {}

if 'type' in params:

form_params.append(('type', params['type'])) # noqa: E501

body_params = None

# HTTP header `Accept`

header_params['Accept'] = self.api_client.select_header_accept(

['application/json']) # noqa: E501

# HTTP header `Content-Type`

header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501

['application/json']) # noqa: E501

# Authentication setting

auth_settings = ['apikey', 'privileges'] # noqa: E501

return self.api_client.call_api(

'/elastic/cleanDeletedData', 'POST',

path_params,

query_params,

header_params,

body=body_params,

post_params=form_params,

files=local_var_files,

response_type='ElasticMessage', # noqa: E501

auth_settings=auth_settings,

async_req=params.get('async_req'),

_return_http_data_only=params.get('_return_http_data_only'),

_preload_content=params.get('_preload_content', True),

_request_timeout=params.get('_request_timeout'),

collection_formats=collection_formats)

def get_index_status(self, **kwargs): # noqa: E501

"""Get reindex status # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.get_index_status(async_req=True)

>>> result = thread.get()

:param async_req bool

:return: IndexStatusData

If the method is called asynchronously,

returns the request thread.

"""

kwargs['_return_http_data_only'] = True

if kwargs.get('async_req'):

return self.get_index_status_with_http_info(**kwargs) # noqa: E501

else:

(data) = self.get_index_status_with_http_info(**kwargs) # noqa: E501

return data

def get_index_status_with_http_info(self, **kwargs): # noqa: E501

"""Get reindex status # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.get_index_status_with_http_info(async_req=True)

>>> result = thread.get()

:param async_req bool

:return: IndexStatusData

If the method is called asynchronously,

returns the request thread.

"""

all_params = [] # noqa: E501

all_params.append('async_req')

all_params.append('_return_http_data_only')

all_params.append('_preload_content')

all_params.append('_request_timeout')

params = locals()

for key, val in six.iteritems(params['kwargs']):

if key not in all_params:

raise TypeError(

"Got an unexpected keyword argument '%s'"

" to method get_index_status" % key

)

params[key] = val

del params['kwargs']

collection_formats = {}

path_params = {}

query_params = []

header_params = {}

form_params = []

local_var_files = {}

body_params = None

# HTTP header `Accept`

header_params['Accept'] = self.api_client.select_header_accept(

['application/json']) # noqa: E501

# HTTP header `Content-Type`

header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501

['application/json']) # noqa: E501

# Authentication setting

auth_settings = ['apikey', 'privileges'] # noqa: E501

return self.api_client.call_api(

'/elastic/status', 'GET',

path_params,

query_params,

header_params,

body=body_params,

post_params=form_params,

files=local_var_files,

response_type='IndexStatusData', # noqa: E501

auth_settings=auth_settings,

async_req=params.get('async_req'),

_return_http_data_only=params.get('_return_http_data_only'),

_preload_content=params.get('_preload_content', True),

_request_timeout=params.get('_request_timeout'),

collection_formats=collection_formats)

def reindex(self, **kwargs): # noqa: E501

"""Reindex selected fields # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.reindex(async_req=True)

>>> result = thread.get()

:param async_req bool

:param ReindexData reindex_data:

:return: ElasticMessage

If the method is called asynchronously,

returns the request thread.

"""

kwargs['_return_http_data_only'] = True

if kwargs.get('async_req'):

return self.reindex_with_http_info(**kwargs) # noqa: E501

else:

(data) = self.reindex_with_http_info(**kwargs) # noqa: E501

return data

def reindex_with_http_info(self, **kwargs): # noqa: E501

"""Reindex selected fields # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.reindex_with_http_info(async_req=True)

>>> result = thread.get()

:param async_req bool

:param ReindexData reindex_data:

:return: ElasticMessage

If the method is called asynchronously,

returns the request thread.

"""

all_params = ['reindex_data'] # noqa: E501

all_params.append('async_req')

all_params.append('_return_http_data_only')

all_params.append('_preload_content')

all_params.append('_request_timeout')

params = locals()

for key, val in six.iteritems(params['kwargs']):

if key not in all_params:

raise TypeError(

"Got an unexpected keyword argument '%s'"

" to method reindex" % key

)

params[key] = val

del params['kwargs']

collection_formats = {}

path_params = {}

query_params = []

header_params = {}

form_params = []

local_var_files = {}

body_params = None

if 'reindex_data' in params:

body_params = params['reindex_data']

# HTTP header `Accept`

header_params['Accept'] = self.api_client.select_header_accept(

['application/json']) # noqa: E501

# HTTP header `Content-Type`

header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501

['application/json']) # noqa: E501

# Authentication setting

auth_settings = ['apikey', 'privileges'] # noqa: E501

return self.api_client.call_api(

'/elastic/reindex', 'POST',

path_params,

query_params,

header_params,

body=body_params,

post_params=form_params,

files=local_var_files,

response_type='ElasticMessage', # noqa: E501

auth_settings=auth_settings,

async_req=params.get('async_req'),

_return_http_data_only=params.get('_return_http_data_only'),

_preload_content=params.get('_preload_content', True),

_request_timeout=params.get('_request_timeout'),

collection_formats=collection_formats)

def reindex_all(self, **kwargs): # noqa: E501

"""Reindex all fields # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.reindex_all(async_req=True)

>>> result = thread.get()

:param async_req bool

:return: ElasticMessage

If the method is called asynchronously,

returns the request thread.

"""

kwargs['_return_http_data_only'] = True

if kwargs.get('async_req'):

return self.reindex_all_with_http_info(**kwargs) # noqa: E501

else:

(data) = self.reindex_all_with_http_info(**kwargs) # noqa: E501

return data

def reindex_all_with_http_info(self, **kwargs): # noqa: E501

"""Reindex all fields # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.reindex_all_with_http_info(async_req=True)

>>> result = thread.get()

:param async_req bool

:return: ElasticMessage

If the method is called asynchronously,

returns the request thread.

"""

all_params = [] # noqa: E501

all_params.append('async_req')

all_params.append('_return_http_data_only')

all_params.append('_preload_content')

all_params.append('_request_timeout')

params = locals()

for key, val in six.iteritems(params['kwargs']):

if key not in all_params:

raise TypeError(

"Got an unexpected keyword argument '%s'"

" to method reindex_all" % key

)

params[key] = val

del params['kwargs']

collection_formats = {}

path_params = {}

query_params = []

header_params = {}

form_params = []

local_var_files = {}

body_params = None

# HTTP header `Accept`

header_params['Accept'] = self.api_client.select_header_accept(

['application/json']) # noqa: E501

# HTTP header `Content-Type`

header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501

['application/json']) # noqa: E501

# Authentication setting

auth_settings = ['apikey', 'privileges'] # noqa: E501

return self.api_client.call_api(

'/elastic/reindexAll', 'POST',

path_params,

query_params,

header_params,

body=body_params,

post_params=form_params,

files=local_var_files,

response_type='ElasticMessage', # noqa: E501

auth_settings=auth_settings,

async_req=params.get('async_req'),

_return_http_data_only=params.get('_return_http_data_only'),

_preload_content=params.get('_preload_content', True),

_request_timeout=params.get('_request_timeout'),

collection_formats=collection_formats)

def update_ticket_check_task(self, date_from, **kwargs): # noqa: E501

"""Update ticket check task # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.update_ticket_check_task(date_from, async_req=True)

>>> result = thread.get()

:param async_req bool

:param datetime date_from: Y-m-d H:i:s (required)

:return: OkResponse

If the method is called asynchronously,

returns the request thread.

"""

kwargs['_return_http_data_only'] = True

if kwargs.get('async_req'):

return self.update_ticket_check_task_with_http_info(date_from, **kwargs) # noqa: E501

else:

(data) = self.update_ticket_check_task_with_http_info(date_from, **kwargs) # noqa: E501

return data

def update_ticket_check_task_with_http_info(self, date_from, **kwargs): # noqa: E501

"""Update ticket check task # noqa: E501

This method makes a synchronous HTTP request by default. To make an

asynchronous HTTP request, please pass async_req=True

>>> thread = api.update_ticket_check_task_with_http_info(date_from, async_req=True)

>>> result = thread.get()

:param async_req bool

:param datetime date_from: Y-m-d H:i:s (required)

:return: OkResponse

If the method is called asynchronously,

returns the request thread.

"""

all_params = ['date_from'] # noqa: E501

all_params.append('async_req')

all_params.append('_return_http_data_only')

all_params.append('_preload_content')

all_params.append('_request_timeout')

params = locals()

for key, val in six.iteritems(params['kwargs']):

if key not in all_params:

raise TypeError(

"Got an unexpected keyword argument '%s'"

" to method update_ticket_check_task" % key

)

params[key] = val

del params['kwargs']

# verify the required parameter 'date_from' is set

if self.api_client.client_side_validation and ('date_from' not in params or

params['date_from'] is None): # noqa: E501

raise ValueError("Missing the required parameter `date_from` when calling `update_ticket_check_task`") # noqa: E501

collection_formats = {}

path_params = {}

query_params = []

if 'date_from' in params:

query_params.append(('dateFrom', params['date_from'])) # noqa: E501

header_params = {}

form_params = []

local_var_files = {}

body_params = None

# HTTP header `Accept`

header_params['Accept'] = self.api_client.select_header_accept(

['application/json']) # noqa: E501

# HTTP header `Content-Type`

header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501

['application/json']) # noqa: E501

# Authentication setting

auth_settings = ['apikey', 'privileges'] # noqa: E501

return self.api_client.call_api(

'/elastic/updateTicketCheckTask', 'POST',

path_params,

query_params,

header_params,

body=body_params,

post_params=form_params,

files=local_var_files,

response_type='OkResponse', # noqa: E501

auth_settings=auth_settings,

async_req=params.get('async_req'),

_return_http_data_only=params.get('_return_http_data_only'),

_preload_content=params.get('_preload_content', True),

_request_timeout=params.get('_request_timeout'),

collection_formats=collection_formats)