|
class SerialNoAdaptor extends ODataAdaptor {
processQuery(dm: DataManager, query: Query, hierarchyFilters?: Object[]) {
let queries: Requests = this.getQueryRequest(query);
let singles: QueryList = Query.filterQueryLists(query.queries, ['onSelect', 'onPage', 'onSkip', 'onTake', 'onRange']);
let params: ParamOption[] = query.params;
let url: string = dm.dataSource.url;
let temp: QueryOptions;
let skip: number;
let take: number = null;
let options: RemoteOptions = this.options;
let request: Requests = { sorts: [], groups: [], filters: [], searches: [], aggregates: [] };
// calc Paging & Range
if ('onPage' in singles) {
temp = singles.onPage;
skip = DataUtil.getValue(temp.pageIndex, query);
take = DataUtil.getValue(temp.pageSize, query);
skip = (skip - 1) * take;
} else if ('onRange' in singles) {
temp = singles.onRange;
skip = temp.start;
take = temp.end - temp.start;
}
// Sorting
for (let i: number = 0; i < queries.sorts.length; i++) {
temp = DataUtil.getValue(queries.sorts[i].e.fieldName, query) as QueryOptions;
request.sorts.push(DataUtil.callAdaptorFunction(this, 'onEachSort', { name: temp, direction: queries.sorts[i].e.direction }, query));
}
// hierarchy
if (hierarchyFilters) {
temp = (<Object>this.getFiltersFrom(hierarchyFilters, query));
if (temp) {
request.filters.push(DataUtil.callAdaptorFunction(this, 'onEachWhere', (<Predicate>temp).toJson(), query));
}
}
// Filters
for (let i: number = 0; i < queries.filters.length; i++) {
request.filters.push(DataUtil.callAdaptorFunction(this, 'onEachWhere', (<Predicate>queries.filters[i].e).toJson(), query));
let keys: string[] = typeof request.filters[i] === 'object' ? Object.keys(request.filters[i]) : [];
for (let prop of keys) {
if (DataUtil.isNull((request)[prop])) {
delete request[prop];
}
}
}
// Searches
for (let i: number = 0; i < queries.searches.length; i++) {
temp = queries.searches[i].e;
request.searches.push(DataUtil.callAdaptorFunction(this, 'onEachSearch', {
fields: temp.fieldNames,
operator: temp.operator,
key: temp.searchKey,
ignoreCase: temp.ignoreCase
}, query));
}
// Grouping
for (let i: number = 0; i < queries.groups.length; i++) {
request.groups.push(DataUtil.getValue(queries.groups[i].e.fieldName, query) as QueryOptions);
}
// Aggregates
for (let i: number = 0; i < queries.aggregates.length; i++) {
temp = queries.aggregates[i].e;
request.aggregates.push({type: temp.type, field: DataUtil.getValue(temp.field, query) });
}
let req: {[key: string]: Object } = {};
(this as any).getRequestQuery(options, query, singles, request, req);
// Params
DataUtil.callAdaptorFunction(this, 'addParams', {dm: dm, query: query, params: params, reqParams: req });
// cleanup
let keys: string[] = Object.keys(req);
for (let prop of keys) {
if (DataUtil.isNull(req[prop]) || req[prop] === '' || (<Object[]>req[prop]).length === 0) {
delete req[prop];
}
}
if (!(options.skip in req && options.take in req) && take !== null) {
req[options.skip] = DataUtil.callAdaptorFunction(this, 'onSkip', skip, query);
req[options.take] = DataUtil.callAdaptorFunction(this, 'onTake', take, query);
}
let p: PvtOptions = this.pvt;
this.pvt = {};
if (this.options.requestType === 'json') {
return {
data: JSON.stringify(req),
url: url,
pvtData: p,
type: 'POST',
contentType: 'application/json; charset=utf-8'
};
}
temp = this.convertToQueryString(req, query, dm) as QueryOptions;
temp = (dm.dataSource.url.indexOf('?') !== -1 ? '&' : '/') + temp as QueryOptions;
// Here you can modify the request url as per your requirement
return {
type: 'GET', url: (<string>temp).length ? url.replace(/\/*$/,<string>temp) : url, pvtData: p
};
}
} | 
