subscribeToJourney() WIP

Author: derhuerst

index.js

@@ -656,6 +656,60 @@ const createClient = (profile, userAgent, opt = {}) => {
 		}
 	}
 
+	const subscribeToJourney = async (userId, channelIds, journeyRefreshToken, todo) => { // todo
+		if (!isNonEmptyString(userId)) {
+			throw new TypeError('userId must be a non-empty string')
+		}
+		if (!Array.isArray(channelIds) || channelIds.length === 0) {
+			throw new TypeError('channelIds must be a non-empty array')
+		}
+		for (let i = 0; i < channelIds.length; i++) {
+			if (!isNonEmptyString(channelIds[i])) {
+				throw new TypeError(`channelIds[${i}] must be a non-empty string`)
+			}
+		}
+		if (!isNonEmptyString(journeyRefreshToken)) {
+			throw new TypeError('journeyRefreshToken must be a non-empty string')
+		}
+
+		// todo: make customizable
+		const hysteresis = {
+			minDeviationInterval: 5, // todo: what exactly is this?
+			notificationStart: 20, // todo: what exactly is this?
+		}
+		const monitorFlags = [
+			// todo: what exactly are these?
+			'OF',
+			'PF',
+			'DF',
+			'AF',
+			'DV',
+			'FTF',
+		]
+		const serviceDays = {
+			beginDate: '20191215',
+			endDate: '20211211',
+			selectedDays: '00011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011111001111100111110011110000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000',
+		}
+
+		const {res} = await profile.request({profile, opt}, userAgent, {
+			meth: 'SubscrCreate',
+			req: {
+				userId,
+				channels: channelIds.map((channelId) => ({channelId})),
+				conSubscr: {
+					ctxRecon: journeyRefreshToken,
+					// todo: `data`?
+					hysteresis,
+					monitorFlags,
+					serviceDays,
+				},
+			},
+		})
+		_checkSubscriptionsResultCode(res)
+		return res.subscrId
+	}
+
 	const client = {
 		departures,
 		arrivals,
@@ -676,6 +730,7 @@ const createClient = (profile, userAgent, opt = {}) => {
 		client.createSubscriptionsUser = createSubscriptionsUser
 		client.subscriptions = subscriptions
 		client.subscription = subscription
+		client.subscribeToJourney = subscribeToJourney
 	}
 	Object.defineProperty(client, 'profile', {value: profile})
 	return client