gev referrals v1

Author: kkartunov

src/server/services/growsurf.js

@@ -20,6 +20,30 @@ export default class GrowsurfService {
     };
   }
 
+  /**
+   * Gets get participant.
+   * @return {Promise}
+   * @param {String} idOrEmail growsurf id or email
+   */
+  async getParticipantByIdOREmail(idOrEmail) {
+    const response = await fetch(`${this.private.baseUrl}/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${idOrEmail}`, {
+      method: 'GET',
+      headers: {
+        'Content-Type': 'application/json',
+        Authorization: this.private.authorization,
+      },
+    });
+    if (response.status >= 300) {
+      return {
+        error: await response.json(),
+        code: response.status,
+        url: `${this.private.baseUrl}/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${idOrEmail}`,
+      };
+    }
+    const data = await response.json();
+    return data;
+  }
+
   /**
    * Gets get participant by email or id.
    * @return {Promise}
@@ -67,7 +91,6 @@ export default class GrowsurfService {
         code: response.status,
         url: `${this.private.baseUrl}/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant`,
         body,
-        private: this.private, // to remove in final release
       };
     }
     const data = await response.json();
@@ -96,4 +119,31 @@ export default class GrowsurfService {
     }
     return result;
   }
+
+  /**
+   * Update participant in growSurf
+   * @param {string} idOrEmail id or email
+   * @param {string} body payload
+   * @returns {Promise}
+   */
+  async updateParticipant(idOrEmail, body) {
+    const response = await fetch(`${this.private.baseUrl}/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${idOrEmail}`, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+        Authorization: this.private.authorization,
+      },
+      body,
+    });
+    if (response.status >= 300) {
+      return {
+        error: await response.json(),
+        code: response.status,
+        url: `${this.private.baseUrl}/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${idOrEmail}`,
+        body,
+      };
+    }
+    const data = await response.json();
+    return data;
+  }
 }

src/server/services/recruitCRM.js

@@ -270,34 +270,61 @@ export default class RecruitCRMService {
       fileData.append('resume', file.buffer, file.originalname);
     }
     let candidateSlug;
+    let isNewCandidate = true;
+    let isReferred = false;
     let referralCookie = req.cookies[config.GROWSURF_COOKIE];
     if (referralCookie) referralCookie = JSON.parse(referralCookie);
     try {
       // referral tracking via growsurf
       if (referralCookie) {
         const gs = new GrowsurfService();
         const tcHandle = _.findIndex(form.custom_fields, { field_id: 2 });
-        const growRes = await gs.addParticipant(JSON.stringify({
-          email: form.email,
-          referredBy: referralCookie.referralId,
-          referralStatus: 'CREDIT_PENDING',
-          firstName: form.first_name,
-          lastName: form.last_name,
-          metadata: {
-            gigId: id,
-            tcHandle: form.custom_fields[tcHandle].value,
-          },
-        }));
-        // If everything set in Growsurf
-        // add referral link to candidate profile in recruitCRM
-        if (!growRes.error) {
-          form.custom_fields.push({
-            field_id: 6, value: `https://app.growsurf.com/dashboard/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${growRes.id}`,
-          });
+        // check if candidate exists in growsurf
+        const existRes = await gs.getParticipantByIdOREmail(form.email);
+        if (existRes.id) {
+          // candidate exists in growsurf
+          // update candidate to set referrer only if it is not set already
+          if (!existRes.referrer) {
+            isReferred = true;
+            const updateRes = await gs.updateParticipant(form.email, JSON.stringify({
+              referredBy: referralCookie.referralId,
+              referralStatus: 'CREDIT_PENDING',
+              metadata: {
+                gigID: id,
+              },
+            }));
+            // add referral link to candidate profile in recruitCRM
+            if (!updateRes.error) {
+              form.custom_fields.push({
+                field_id: 6, value: `https://app.growsurf.com/dashboard/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${updateRes.id}`,
+              });
+            } else {
+              notifyKirilAndNick(updateRes);
+            }
+          }
         } else {
-          notifyKirilAndNick(growRes);
+          isReferred = true;
+          const growRes = await gs.addParticipant(JSON.stringify({
+            email: form.email,
+            referredBy: referralCookie.referralId,
+            referralStatus: 'CREDIT_PENDING',
+            firstName: form.first_name,
+            lastName: form.last_name,
+            metadata: {
+              gigId: id,
+              tcHandle: form.custom_fields[tcHandle].value,
+            },
+          }));
+          // add referral link to candidate profile in recruitCRM
+          if (!growRes.error) {
+            form.custom_fields.push({
+              field_id: 6, value: `https://app.growsurf.com/dashboard/campaign/${config.GROWSURF_CAMPAIGN_ID}/participant/${growRes.id}`,
+            });
+          } else {
+            notifyKirilAndNick(growRes);
+          }
         }
-        // clear the cookie
+        // finally, clear the cookie
         res.cookie(config.GROWSURF_COOKIE, '', {
           maxAge: 0,
           overwrite: true,
@@ -326,6 +353,7 @@ export default class RecruitCRMService {
         // Candidate exists in recruitCRM
         // We will update profile fields, otherwise we create new candidate below
         // Check if candidate is placed in gig currently
+        isNewCandidate = false;
         const candStatusIndex = _.findIndex(
           candidateData.data[0].custom_fields, { field_id: 12 },
         );
@@ -450,6 +478,11 @@ export default class RecruitCRMService {
         notifyKirilAndNick(error);
         return res.send(error);
       }
+      // For new candidates that apply via referral link
+      // aka triggered referral state step 1 - notify and etc.
+      if (isNewCandidate && isReferred) {
+        // console.log('isNewCandidate');
+      }
       // respond to API call
       const data = await applyResponse.json();
       return res.send(data);

src/shared/actions/growSurf.js

@@ -0,0 +1,59 @@
+/**
+ * Actions related to growsurf (gig referrals)
+ */
+/* global fetch */
+import { redux, config } from 'topcoder-react-utils';
+
+const PROXY_ENDPOINT = `${config.URL.COMMUNITY_APP}/api`;
+
+/**
+ * Fetch init
+ */
+function getReferralIdInit() {
+  return {
+    loading: true,
+  };
+}
+
+/**
+ * Get referral id for the logged user
+ * if this member does not exist in growsurf it creates it in the system
+ */
+async function getReferralIdDone(profile) {
+  if (profile.email) {
+    const res = await fetch(`${PROXY_ENDPOINT}/growsurf/participants?participantId=${profile.email}`, {
+      method: 'POST',
+      body: JSON.stringify({
+        email: profile.email,
+        firstName: profile.firstName,
+        lastName: profile.lastName,
+        tcHandle: profile.handle,
+      }),
+      headers: {
+        'Content-Type': 'application/json',
+      },
+    });
+    if (res.status >= 300) {
+      return {
+        error: true,
+        details: await res.json(),
+      };
+    }
+    const data = await res.json();
+    return {
+      data,
+    };
+  }
+  // no referral id without email
+  return {
+    error: true,
+    details: 'No profile email found',
+  };
+}
+
+export default redux.createActions({
+  GROWSURF: {
+    GET_REFERRALID_INIT: getReferralIdInit,
+    GET_REFERRALID_DONE: getReferralIdDone,
+  },
+});