impr cian

index.js

@@ -1,4 +1,5 @@
 #!/usr/bin/env node
+'use strict';
 
 const pSettle = require('p-settle');
 const pRetry = require('p-retry');

lib/provider/cian.js

@@ -1,3 +1,5 @@
+'use strict';
+
 const config = require('config');
 const { path } = require('ramda');
 const Ax = require('../ax');
@@ -10,29 +12,20 @@ const ax = Ax.create();
 module.exports.getOffers = async () => {
     const db = await Db.create('cian');
 
-    const urlGetIdx = 'https://api.cian.ru/search-offers/v1/get-infinite-search-result-desktop/';
-    const urlGetItems = 'https://api.cian.ru/search-offers/v1/get-offers-by-ids-desktop/';
+    const urlGetIdx = 'https://api.cian.ru/search-offers/v2/search-offers-desktop/';
     const jsonQuery = config.get('cian.jsonQuery');
-    const queryString = config.get('cian.queryString');
-
-    const rawIdx = [].concat(
-            ...(await Promise.all([
-                        ax.post(urlGetIdx, {jsonQuery, queryString}),
-                        ax.post(urlGetIdx, Object.assign({pageNumber: 2}, {jsonQuery, queryString}))
-            ]))
-            .map(({data}) => data.infiniteSearchResult || [])
-    );
-    const cianOfferIds = rawIdx.map(({itemId}) => itemId);
-
-    let offers = (await ax.post(urlGetItems, {cianOfferIds, jsonQuery})).data.offersSerialized || [];
-    offers = offers.filter((x) => x.roomsCount >= 2 
-                                    && x.childrenAllowed !== false
-                                    && db.data.indexOf(x.cianId) === -1
-                                    && geoFilter(path(['geo', 'userInput'], x))
-                )
-                .map((x) => new CianOffer(x));
-
-    console.log(`[cian] idx: ${cianOfferIds.length}, offers: ${offers.length}`);
+
+    const rawListRes = (await ax.post(urlGetIdx, {jsonQuery}));
+
+    const points = path(['data', 'data', 'offersSerialized'], rawListRes) || [];
+    const offers = points.filter((x) => x.roomsCount >= 2
+                            && x.childrenAllowed !== false
+                            && db.data.indexOf(x.cianId) === -1
+                            && geoFilter(path(['geo', 'userInput'], x))
+                        )
+                        .map((x) => new CianOffer(x));
+
+    console.log(`[cian] idx: ${points.length}, offers: ${offers.length}`);
     if (offers.length > 0) {
         db.data = db.data.concat(offers.map(({cianId}) => cianId));
         await db.save();

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cyanic",
-  "version": "1.0.4",
+  "version": "1.0.5",
   "main": "index.js",
   "license": "MIT",
   "scripts": {