FEATURE: forward LK stuff

Author: dimaip

app.js

@@ -19,7 +19,9 @@ function validateHmac(body, requestHmac, referer = null) {
   var hmac = crypto.createHmac('sha256', hmacKey);
   hmac.update(body);
   const calculatedHmac = hmac.digest('base64');
-  console.log('Request HMAC, calculated HMAC:', requestHmac, calculatedHmac)
+  if (requestHmac !== calculatedHmac) {
+    console.log('HMAC mismatch, requestHmac, calculatedHmac:', requestHmac, calculatedHmac);
+  }
   return requestHmac === calculatedHmac;
 }
 
@@ -32,9 +34,24 @@ const handleHook = (req, res, eventType, skipHmac = false, json = false) => {
         if (referer) {
           dataArray.Referer = referer;
         }
+
+        try {
+          if (dataArray.Data) {
+            const parsedData = JSON.parse(dataArray.Data);
+            if (parsedData.userid && parsedData.contextid && dataArray.Amount) {
+              const url = config.kabinetHostname + '/local/cohortautoenrol/approve.php?contextid=' + parsedData.contextid + '&userid=' + parsedData.userid + '&key=' + config.autoenrolKey + '&amount=' + dataArray.Amount;
+              getContent(url)
+                .then(result => console.info(result))
+                .catch(error => console.error('Problem registring payment in LK:', url, error.message, dataArray.Data))
+            }
+          }
+        } catch (e) {
+          console.error('Problem registring payment in LK:', dataArray.Data);
+        }
+
         return publishEvent(eventType, dataArray);
       } else {
-        console.log('HMAC failed for request:', req.url, data);
+        console.error('HMAC failed for request:', req.url, data);
         throw new Error('HMAC not valid');
       }
     })
@@ -195,5 +212,5 @@ const server = http.createServer((req, res) => {
 });
 
 server.listen(config.port, config.hostname, () => {
-  console.log(`Server running at http://${config.hostname}:${config.port}/`);
+  console.info(`Server running at http://${config.hostname}:${config.port}/`);
 });

config.js

@@ -4,6 +4,7 @@
 const hostname = '0.0.0.0';
 const port = process.env.PORT || 3000;
 const eventStoreHostname = process.env.ES_HOST || '127.0.0.1';
+const kabinetHostname = process.env.KABINET_HOST || 'https://kabinet.sfi.ru';
 // legacy, to be removed
 const hmacKey = process.env.HMAC_KEY;
 const hmacKeys = {
@@ -16,4 +17,6 @@ const eventStorePass = process.env.ES_PASS || 'changeit';
 const stream = process.env.ES_STREAM || 'data';
 const apiAuth = process.env.SFI_API_AUTH || 'api:changeit';
 
-export default {hostname, port, eventStoreHostname, hmacKey, hmacKeys, eventStorePass, apiAuth, stream};
+const autoenrolKey = process.env.AUTOENROL_KEY || 'changeit';
+
+export default {hostname, port, eventStoreHostname, kabinetHostname, hmacKey, hmacKeys, eventStorePass, apiAuth, stream, autoenrolKey};