Use triple in profile

Author: michielbdejong

lib/payment-pointer-discovery.js

@@ -5,10 +5,11 @@
 const express = require('express')
 const { promisify } = require('util')
 const fs = require('fs')
+const rdf = require('rdflib')
 
 module.exports = paymentPointerDiscovery
 
-const SETTING_FILE_PATH = '/settings/paymentPointer.json'
+const PROFILE_PATH = '/profile/card'
 
 /**
  * Returns a set of routes to deal with server payment pointer discovery
@@ -35,9 +36,9 @@ function paymentPointerDocument () {
   return async (req, res) => {
     try {
       const ldp = req.app.locals.ldp
-      const url = ldp.resourceMapper.resolveUrl(req.hostname, SETTING_FILE_PATH)
-      const contentType = 'application/json'
-      const createIfNotExists = true
+      const url = ldp.resourceMapper.resolveUrl(req.hostname, PROFILE_PATH)
+      const contentType = 'text/turtle'
+      const createIfNotExists = false
       const { path } = await ldp.resourceMapper.mapUrlToFile({ url, contentType, createIfNotExists })
       let body
       try {
@@ -46,20 +47,31 @@ function paymentPointerDocument () {
       } catch (e) {
         if (e.message.startsWith('ENOENT: no such file or directory,')) {
           res.json({
-            error: `Please create ${SETTING_FILE_PATH} on your pod`
+            error: `Please create ${PROFILE_PATH} on your pod`
           })
         }
       }
-      let obj
+      const webid = rdf.Namespace(`${url}#`)('me')
+      const pp = rdf.Namespace('http://paymentpointers.org/ns#')('PaymentPointer')
+      let paymentPointer
       try {
-        // Read the file from disk
-        obj = JSON.parse(body)
+        const graph = rdf.graph()
+        // Parse the file as Turtle
+        rdf.parse(body, graph, url, contentType)
+        paymentPointer = graph.any(webid, pp)
       } catch (e) {
+        console.error(e)
         res.json({
-          error: `Please make sure ${SETTING_FILE_PATH} contains valid JSON`
+          error: `Please make sure ${PROFILE_PATH} contains valid Turtle`
         })
       }
-      res.json(obj)
+      if (paymentPointer === null) {
+        res.json({ fail: 'Add triple', subject: `<${webid.value}>`, predicate: `<${pp.value}>`, object: '$alice.example' })
+      }
+      if (paymentPointer.value.startsWith('$')) {
+        paymentPointer.value = `https://${paymentPointer.value.substring(1)}`
+      }
+      res.redirect(paymentPointer.value)
     } catch (e) {
       res.json({ fail: e.message })
     }