[+] Europa Park app update changes

Author: cubehouse

lib/parks/europa/europaparkdb.js

@@ -1,8 +1,6 @@
 import Database from '../database.js';
-import crypto from 'crypto';
 import {URL} from 'url';
 import {tagType, attractionType, entityType} from '../parkTypes.js';
-import {Blowfish} from 'egoroof-blowfish';
 
 const poiEntityTypes = [
   'attraction',
@@ -33,30 +31,22 @@ export class DatabaseEuropaPark extends Database {
    * @param {object} options
    */
   constructor(options = {}) {
-    options.fbAppId = '';
-    options.fbApiKey = '';
-    options.fbProjectId = '';
     options.apiBase = '';
-    options.encKey = '';
-    options.encIV = '';
     options.authURL = '';
-    options.userKey = options.userKey || 'v3_live_android_exozet_api_username';
-    options.passKey = options.passKey || 'v3_live_android_exozet_api_password';
-    options.appVersion = options.appVersion || '10.1.0';
+    options.clientId = '';
+    options.clientSecret = '';
+    options.appVersion = options.appVersion || '16.0.0';
 
     options.configPrefixes = ['EUROPAPARK'].concat(options.configPrefixes || []);
 
     super(options);
 
-    if (!this.config.fbApiKey) throw new Error('Missing Europa Park Firebase API Key');
-    if (!this.config.fbAppId) throw new Error('Missing Europa Park Firebase App ID');
-    if (!this.config.fbProjectId) throw new Error('Missing Europa Park Firebase Project ID');
     if (!this.config.apiBase) throw new Error('Missing Europa Park API Base');
-    if (!this.config.encKey) throw new Error('Missing Europa Park Encryption Key');
-    if (!this.config.encIV) throw new Error('Missing Europa Park Encryption IV');
     if (!this.config.authURL) throw new Error('Missing Europa Park Token URL');
+    if (!this.config.clientId) throw new Error('Missing Europa Park Client ID');
+    if (!this.config.clientSecret) throw new Error('Missing Europa Park Client Secret');
 
-    this.cache.version = 2;
+    this.cache.version = 3;
 
     this.http.injectForDomain({
       hostname: new URL(this.config.authURL).hostname,
@@ -69,17 +59,17 @@ export class DatabaseEuropaPark extends Database {
     }, async (method, url, data, options) => {
       options.headers['user-agent'] = `EuropaParkApp/${this.config.appVersion} (Android)`;
 
-      const jwtToken = await this.getToken();
-      if (jwtToken === undefined) {
-        // refetch Firebase settings and try again
-        await this.cache.set('auth', undefined, -1);
-        const jwtTokenRetry = await this.getToken();
-        options.headers['jwtauthorization'] = `Bearer ${jwtTokenRetry}`;
+      const token = await this.getToken();
+      if (token === undefined) {
+        // retry token fetch
+        await this.cache.set('access_token', undefined, -1);
+        const tokenRetry = await this.getToken();
+        options.headers['authorization'] = `Bearer ${tokenRetry}`;
       } else {
-        options.headers['jwtauthorization'] = `Bearer ${jwtToken}`;
-
-        options.headers['Accept-Language'] = 'en';
+        options.headers['authorization'] = `Bearer ${token}`;
       }
+
+      options.headers['accept-language'] = 'en';
     });
 
     this.http.injectForDomainResponse({
@@ -95,65 +85,6 @@ export class DatabaseEuropaPark extends Database {
 
       return response;
     });
-
-    this.bf = new Blowfish(this.config.encKey, Blowfish.MODE.CBC, Blowfish.PADDING.PKCS5);
-    this.bf.setIv(this.config.encIV);
-  }
-
-  /**
-   * Get or generate a Firebase device ID
-   */
-  async getFirebaseID() {
-    return await this.cache.wrap('fid', async () => {
-      try {
-        const fidByteArray = crypto.randomBytes(17).toJSON().data;
-        fidByteArray[0] = 0b01110000 + (fidByteArray[0] % 0b00010000);
-        const b64String = Buffer.from(String.fromCharCode(...fidByteArray))
-          .toString('base64')
-          .replace(/\+/g, '-')
-          .replace(/\//g, '_');
-        const fid = b64String.substr(0, 22);
-        return /^[cdef][\w-]{21}$/.test(fid) ? fid : '';
-      } catch (e) {
-        this.emit('error', e);
-        console.log(e);
-        return '';
-      }
-    }, 1000 * 60 * 60 * 24 * 8); // 8days
-  }
-
-  /**
-   * Get Europa Park config keys
-   */
-  async getConfig() {
-    return await this.cache.wrap('auth', async () => {
-      const fid = await this.getFirebaseID();
-
-      const resp = await this.http(
-        'POST',
-        `https://firebaseremoteconfig.googleapis.com/v1/projects/${this.config.fbProjectId}/namespaces/firebase:fetch`,
-        {
-          'appInstanceId': fid,
-          'appId': this.config.fbAppId,
-          'packageName': 'com.EuropaParkMackKG.EPGuide',
-          'languageCode': 'en_GB',
-        }, {
-        headers: {
-          'X-Goog-Api-Key': this.config.fbApiKey,
-        },
-      },
-      );
-
-      const decrypt = (str) => {
-        return this.bf.decode(Buffer.from(str, 'base64'), Blowfish.TYPE.STRING);
-      };
-
-      const ret = {};
-      Object.keys(resp.body.entries).forEach((key) => {
-        ret[key] = decrypt(resp.body.entries[key]);
-      });
-      return ret;
-    }, 1000 * 60 * 60 * 6); // 6 hours
   }
 
   /**
@@ -162,13 +93,12 @@ export class DatabaseEuropaPark extends Database {
   async getToken() {
     let expiresIn = 1000 * 60 * 60 * 24; // default: 1 day
     return await this.cache.wrap('access_token', async () => {
-      const config = await this.getConfig();
       const resp = await this.http(
         'POST',
         this.config.authURL,
         {
-          client_id: config[this.config.userKey],
-          client_secret: config[this.config.passKey],
+          client_id: this.config.clientId,
+          client_secret: this.config.clientSecret,
           grant_type: 'client_credentials',
         },
         {
@@ -200,9 +130,7 @@ export class DatabaseEuropaPark extends Database {
 
     // if we haven't fetched in 12 hours or ever, fetch new data
     if (!existingData || !lastUpdated || (Date.now() - lastUpdated) > 1000 * 60 * 60 * 12) {
-      const newPOIData = (await this.http('GET', `${this.config.apiBase}/api/v2/poi-group`, {
-        status: ['live'],
-      }, undefined, {
+      const newPOIData = (await this.http('GET', `${this.config.apiBase}/api/v2/poi-group?status%5B%5D=live`, null, {
         open_timeout: 60 * 1000, // 1 minute timeout for this request
         response_timeout: 60 * 1000, // 1 minute timeout for this request
         read_timeout: 2 * 60 * 1000, // 2 minute timeout for reading this request
@@ -244,9 +172,7 @@ export class DatabaseEuropaPark extends Database {
    */
   async getCalendar() {
     return this.cache.wrap('seasons', async () => {
-      return (await this.http('GET', `${this.config.apiBase}/api/v2/seasons`, {
-        status: ['live'],
-      })).body;
+      return (await this.http('GET', `${this.config.apiBase}/api/v2/seasons?status%5B%5D=live`)).body;
     }, 1000 * 60 * 60 * 6);
   }
 
@@ -265,9 +191,7 @@ export class DatabaseEuropaPark extends Database {
   async getShowTimes() {
     return this.cache.wrap('showtimes', async () => {
       // TODO - other languages? does this only include English performances?
-      return (await this.http('GET', `${this.config.apiBase}/api/v2/show-times`, {
-        status: 'live',
-      })).body;
+      return (await this.http('GET', `${this.config.apiBase}/api/v2/show-times?status%5B%5D=live`)).body;
     }, 1000 * 60 * 60 * 6);
   }