User metadata node

creator-node/docker-compose/development.env

@@ -30,7 +30,10 @@ delegatePrivateKey=
 ethWallets=
 spOwnerWalletIndex=1
 
+# Run as creator node by default
+isUserMetadataNode=false
+
 debounceTime=5000
 
 # not part of the config itself, but required for docker to know when ports are available
-WAIT_HOSTS=docker.for.mac.localhost:4379,docker.for.mac.localhost:4432
+WAIT_HOSTS=docker.for.mac.localhost:4379,docker.for.mac.localhost:4432

creator-node/src/app.js

@@ -4,6 +4,7 @@ const cors = require('cors')
 
 const { sendResponse, errorResponseServerError } = require('./apiHelpers')
 const { logger, loggingMiddleware } = require('./logging')
+const { userNodeMiddleware } = require('./userNodeMiddleware')
 const { userReqLimiter, trackReqLimiter, audiusUserReqLimiter, metadataReqLimiter, imageReqLimiter } = require('./reqLimiter')
 const redisClient = require('./redis')
 
@@ -12,6 +13,7 @@ const app = express()
 // - loggingMiddleware must be first to ensure proper error handling
 app.use(loggingMiddleware)
 app.use(bodyParser.json())
+app.use(userNodeMiddleware)
 app.use(cors())
 
 // Initialize private IPFS gateway counters

creator-node/src/config.js

@@ -218,7 +218,12 @@ const config = convict({
  env: 'spOwnerWalletIndex',
  default: null
  },
-
+ isUserMetadataNode: {
+ doc: 'Flag indicating whether to run this node for user metadata (non creators) only',
+ format: Boolean,
+ env: 'isUserMetadataNode',
+ default: false
+ },
  debounceTime: {
  doc: 'sync debounce time',
  format: 'nat',

creator-node/src/userNodeMiddleware.js

@@ -0,0 +1,18 @@
+const { sendResponse, errorResponseUnauthorized } = require('./apiHelpers')
+const config = require('./config')
+
+async function userNodeMiddleware (req, res, next) {
+ let isUserMetadataNode = config.get('isUserMetadataNode')
+ let userNodeRegex = new RegExp(/(users|version|health_check|image_upload|ipfs|export)/gm)
+ if (isUserMetadataNode) {
+ let isValidUrl = userNodeRegex.test(req.url)
+ if (!isValidUrl) {
+ return sendResponse(req, res, errorResponseUnauthorized('Invalid route for user metadata node'))
+ }
+ next()
+ } else {
+ next()
+ }
+}
+
+module.exports = { userNodeMiddleware }