Remove ramda dependency

Author: alex-friedl

package-lock.json

@@ -55,7 +55,6 @@
     "firebase-admin": "12.1.1",
     "node-adm": "0.9.1",
     "node-gcm": "1.1.4",
-    "ramda": "0.32.0",
     "web-push": "3.6.7",
     "wns": "0.5.4"
   },

package.json

@@ -1,13 +1,11 @@
 const apn = require('@parse/node-apn');
-const R = require('ramda');
 const { APN_METHOD } = require('./constants');
 const { buildApnsMessage } = require('./utils/tools');
 
-const getDeviceTokenOrSelf = R.ifElse(
-  R.has('device'),
-  R.prop('device'),
-  R.identity
-);
+const getDeviceTokenOrSelf = (token) =>
+  token && typeof token === 'object' && 'device' in token
+    ? token.device
+    : token;
 
 class APN {
   constructor(settings) {

src/sendAPN.js

@@ -1,8 +1,7 @@
 const webPush = require('web-push');
-const { is, unless, assoc } = require('ramda');
 const { WEB_METHOD } = require('./constants');
 
-const stringify = unless(is(String), JSON.stringify);
+const stringify = (data) => typeof data === 'string' ? data : JSON.stringify(data);
 
 const sendWebPush = async (regIds, data, settings) => {
   const payload = stringify(data);
@@ -39,7 +38,7 @@ const sendWebPush = async (regIds, data, settings) => {
     failure: acc.failure + current.failure,
     message: [...acc.message, ...current.message],
   }));
-  return assoc('method', WEB_METHOD, reduced);
+  return { ...reduced, method: WEB_METHOD };
 };
 
 module.exports = sendWebPush;

src/sendWeb.js

@@ -1,31 +1,34 @@
-const R = require('ramda');
 const { Notification: ApnsMessage } = require('@parse/node-apn');
 const { Message: GcmMessage } = require('node-gcm');
 
 const { DEFAULT_TTL, GCM_MAX_TTL } = require('../constants');
 
-const ttlFromExpiry = R.compose(
-  R.min(GCM_MAX_TTL),
-  R.max(0),
-  (expiry) => expiry - Math.floor(Date.now() / 1000)
-);
+const ttlFromExpiry = (expiry) => {
+  const ttl = expiry - Math.floor(Date.now() / 1000);
+  return Math.min(Math.max(ttl, 0), GCM_MAX_TTL);
+};
 
-const extractTimeToLive = R.cond([
-  [R.propIs(Number, 'expiry'), ({ expiry }) => ttlFromExpiry(expiry)],
-  [R.propIs(Number, 'timeToLive'), R.prop('timeToLive')],
-  [R.T, R.always(DEFAULT_TTL)],
-]);
+const extractTimeToLive = (data) => {
+  if (typeof data.expiry === 'number') {
+    return ttlFromExpiry(data.expiry);
+  }
+  if (typeof data.timeToLive === 'number') {
+    return data.timeToLive;
+  }
+  return DEFAULT_TTL;
+};
 
 const expiryFromTtl = (ttl) => ttl + Math.floor(Date.now() / 1000);
 
-const extractExpiry = R.cond([
-  [R.propIs(Number, 'expiry'), R.prop('expiry')],
-  [
-    R.propIs(Number, 'timeToLive'),
-    ({ timeToLive }) => expiryFromTtl(timeToLive),
-  ],
-  [R.T, () => expiryFromTtl(DEFAULT_TTL)],
-]);
+const extractExpiry = (data) => {
+  if (typeof data.expiry === 'number') {
+    return data.expiry;
+  }
+  if (typeof data.timeToLive === 'number') {
+    return expiryFromTtl(data.timeToLive);
+  }
+  return expiryFromTtl(DEFAULT_TTL);
+};
 
 const getPropValueOrUndefinedIfIsSilent = (propName, data) => {
   if (data.silent) {
@@ -34,17 +37,28 @@ const getPropValueOrUndefinedIfIsSilent = (propName, data) => {
   return data[propName];
 };
 
-const toJSONorUndefined = R.when(
-  R.is(String),
-  R.tryCatch(JSON.parse, R.always(undefined))
-);
+const toJSONorUndefined = (value) => {
+  if (typeof value !== 'string') {
+    return value;
+  }
+  try {
+    return JSON.parse(value);
+  } catch (e) {
+    return undefined;
+  }
+};
 
-const alertLocArgsToJSON = R.evolve({
-  alert: {
-    'title-loc-args': toJSONorUndefined,
-    'loc-args': toJSONorUndefined,
-  },
-});
+const alertLocArgsToJSON = (data) => {
+  const alert = data.alert || {};
+  return {
+    ...data,
+    alert: {
+      ...alert,
+      'title-loc-args': toJSONorUndefined(alert['title-loc-args']),
+      'loc-args': toJSONorUndefined(alert['loc-args']),
+    },
+  };
+};
 
 const getDefaultAlert = (data) => ({
   title: data.title,
@@ -57,21 +71,33 @@ const getDefaultAlert = (data) => ({
   action: data.action,
 });
 
-const alertOrDefault = (data) =>
-  R.when(
-    R.propSatisfies(R.isNil, 'alert'),
-    R.assoc('alert', getDefaultAlert(data))
-  );
+const alertOrDefault = (data) => {
+  if (data.alert !== null && data.alert !== undefined) {
+    return data;
+  }
+  return { ...data, alert: getDefaultAlert(data) };
+};
 
-const getParsedAlertOrDefault = (data) =>
-  R.pipe(alertOrDefault(data), alertLocArgsToJSON)(data);
+const getParsedAlertOrDefault = (data) => {
+  const withAlert = alertOrDefault(data);
+  return alertLocArgsToJSON(withAlert);
+};
 
-const pathIsString = R.pathSatisfies(R.is(String));
+const pathIsString = (path) => (val) => {
+  const current = path.reduce((acc, key) => {
+    if (acc && typeof acc === 'object') {
+      return acc[key];
+    }
+    return null;
+  }, val);
+  return typeof current === 'string';
+};
 
-const containsValidRecipients = R.either(
-  pathIsString(['recipients', 'to']),
-  pathIsString(['recipients', 'condition'])
-);
+const containsValidRecipients = (obj) => {
+  const checkTo = pathIsString(['recipients', 'to'])(obj);
+  const checkCondition = pathIsString(['recipients', 'condition'])(obj);
+  return checkTo || checkCondition;
+};
 
 const buildGcmNotification = (data) => {
   const notification = data.fcm_notification || {