update owner flow changed

Author: Percocco

Minio-SQL-connector/api/controllers/controller.js

@@ -3,7 +3,7 @@ const common = require("../../utils/common.js")
 const Log = require('../../utils/logger.js')//.app(module);
 const { Logger } = Log
 const logger = new Logger("controller")
-
+const config = require('../../config')
 
 const queryMongo = async (req, res) => {
     logger.info(req.body, req.query)
@@ -66,8 +66,8 @@ module.exports = {
     getEntries: async (req, res) => {
         logger.info("values")
         let email = req.body.prefix.split("/")[0]
-        if (process.queryEngine.updateOwner && !process.queryEngine.updatedOwners[email]) {
-            service.updateOwner(req.headers.authorization, email) 
+        if (config.updateOwner == "later" && !process.queryEngine.updatedOwners[email]) {
+            service.updateOwner(req.headers.authorization, email)
         }
         try {
             res.send(await service.getEntries(req.body.prefix, req.body.bucketName, req.headers.visibility, req.query.key, req.query.value))

Minio-SQL-connector/utils/minioWriter.js

@@ -13,14 +13,6 @@ const { Logger } = Log
 const logger = new Logger("miniowriter")
 const log = logger.info
 const axios = require('axios')
-const login = require('./login.js')
-let bearer, authMetod //= login.authenticate()
-exports.bearer = bearer
-exports.authMetod = authMetod
-async function getBearer() {
-  bearer = await login.authenticate()
-}
-getBearer()
 process.queryEngine = {updatedOwners: {}}
 
 function logSizeChecker() {
@@ -221,38 +213,15 @@ module.exports = {
       data = JSON.stringify(data)
     let owner
     try {
-      if (authMetod == "frontend")
+      if (config.updateOwner == "later")
         owner = "unknown"
       else {
-        if (!bearer)
-          bearer = await login.authenticate()
-        owner = (await axios.get(config.minioConfig.ownerInfoEndpoint + "/createdBy?filePath=" + queryName + "&etag=" + record.etag,
-          {
-            headers: {
-              Authorization: bearer
-            }
-          })).data
+        owner = (await axios.get(config.minioConfig.ownerInfoEndpoint + "/createdBy?filePath=" + queryName + "&etag=" + record.etag)).data
       }
     }
     catch (error) {
       logger.error("Error getting owner")
       logger.error(error)
-      bearer = await login.authenticate()
-      try {
-        owner = (await axios.get(config.minioConfig.ownerInfoEndpoint + "/createdBy?filePath=" + queryName + "&etag=" + record.etag,
-          {
-            headers: {
-              Authorization: bearer
-            }
-          })).data
-      }
-      catch (error) {
-        logger.error("Error getting owner")
-        logger.error(error)
-        owner = "unknown"
-        authMetod = "frontend"
-        process.queryEngine.updateOwner = true
-      }
     }
     log("Owner ", owner)
     record = { ...record, insertedBy: owner }