Bug/memory issue

.gitignore

@@ -57,7 +57,7 @@ typings/
 # dotenv environment variables file
 production.env
 development.env
-.env
+*.env
 
 # next.js build output
 .next

config/.env.example

@@ -1,10 +1,13 @@
+HOST=
 DEFAULT_IPFS_SERVICE=
 DEFAULT_STORAGE_LIMIT=
 ETH_GOERLI_RPC_URL=
+ETH_MAINNET_RPC_URL=
 ETH_SEPOLIA_RPC_URL=
-FILEVERSE_TESTNET_RPC_URL=
 GNOSIS_MAINNET_RPC_URL=
 GNOSIS_TESTNET_RPC_URL=
+FILEVERSE_TESTNET_RPC_URL=
+GITCOIN_API_KEY=
 MONGOURI=
 NETWORK_PROVIDER_URL=
 NODE_ENV=
@@ -13,4 +16,8 @@ PINATA_SECRET_KEY=
 SERVICE_DID=
 SLACK_REPORTER=
 WEB3STORAGE_TOKEN=
+FILEBASE_ACCESS_KEY=
+FILEBASE_SECRET=
+FILEBASE_BUCKET_NAME=
 GITCOIN_API_KEY=
+X_API_KEY=

src/domain/log/index.js

@@ -2,5 +2,6 @@ const create = require('./create');
 const getByFile = require('./getByFile');
 const getByContract = require('./getByContract');
 const { ddocCreate, ddocSignup } = require('./ddoc');
+const upsertComment = require('./upsertComment');
 
-module.exports = { create, getByFile, getByContract, ddocCreate, ddocSignup };
+module.exports = { create, getByFile, getByContract, upsertComment, ddocCreate, ddocSignup };

src/domain/log/upsertComment.js

@@ -0,0 +1,31 @@
+const { Log } = require('../../infra/database/models');
+const completeMultipleTask = require('../task/completeMultipleTask')
+
+async function upsertComment({ contractAddress, invokerAddress, file }) {
+    let resp = {
+        success: false,
+        task_completed: false
+    }
+    const portalLogs = await Log.findOneAndUpdate({
+        eventName: "comment",
+        contractAddress,
+        invokerAddress,
+    }, {
+        "$addToSet": { "tags": file }
+    }, {
+        "new": true, "upsert": true
+    });
+
+
+    resp.success = true;
+
+
+    if (portalLogs.tags.length >= 10) {
+        await completeMultipleTask({ contractAddress, invokerAddress, taskIds: ["COMMENT_ON_10_FILES"] });
+        resp.task_completed = true;
+    }
+
+    return resp;
+}
+
+module.exports = upsertComment;

src/infra/reporter.js

@@ -2,9 +2,19 @@ const config = require('../../config');
 const axios = require('axios');
 
 async function reportError(message) {
-  if (config.SLACK_REPORTER) {
-    await axios.post(config.SLACK_REPORTER, {
-      text: message,
+  env = config.HOST ? config.HOST : 'local';
+  slackHook = config.SLACK_REPORTER;
+  if (env !== 'local') {
+    await axios.post(slackHook, {
+      "blocks": [
+        {
+          "type": "section",
+          "text": {
+            "type": "mrkdwn",
+            "text": "*Error* ```" + message + "```\n*Environment:* " + env.toUpperCase()
+          }
+        }
+      ]
     });
   }
 }

src/interface/log/index.js

@@ -5,14 +5,16 @@ const {
 const express = require('express');
 const router = express.Router();
 
-const canView = require('../middleware/canView');
+const { canView, isAuthenticated } = require('../middleware');
 
+const logComments = require('./logComments');
 const create = require('./create');
 const ddocCreate = require('./ddoc');
 const ddocSignUp = require('./ddocSignup');
 
 router.post('/create', asyncHandler(canView), asyncHandlerArray(create));
-router.get('/create/ddoc', asyncHandlerArray(ddocCreate));
-router.post('/signup/ddoc', asyncHandlerArray(ddocSignUp));
+router.put('/comment', asyncHandler(isAuthenticated), asyncHandlerArray(logComments));
+// router.get('/create/ddoc', asyncHandlerArray(ddocCreate));
+// router.post('/signup/ddoc', asyncHandlerArray(ddocSignUp));
 
 module.exports = router;

src/interface/log/logComments.js

@@ -0,0 +1,29 @@
+const { log } = require("../../domain");
+const { validator } = require("../middleware");
+const { Joi, validate } = validator;
+
+const logCommentValidation = {
+    headers: Joi.object({
+        contract: Joi.string().required(),
+        invoker: Joi.string().required(),
+    }).unknown(true)
+};
+
+async function logComments(req, res) {
+    const { contractAddress, invokerAddress } = req;
+    const { file } = req.query;
+
+    try {
+        const data = await log.upsertComment({ contractAddress, invokerAddress, file });
+        res.json({
+            success: data.success,
+            task_completed: data.task_completed
+        });
+    }
+    catch (error) {
+        console.log(error);
+        res.status(500).json({ error: "Internal Server Error" });
+    }
+}
+
+module.exports = [validate(logCommentValidation), logComments];

src/interface/middleware/canUpload.js

@@ -25,7 +25,7 @@ async function canUpload(req, res, next) {
 
   const storageLimitBreached = await checkStorageLimit(contractAddress, invokerAddress);
   if (storageLimitBreached) {
-    const statusCode = 507;
+    const statusCode = 400;
     const message = `Storage for ${contractAddress} is full, please either claim more storage or contact us on twitter @fileverse`;
     return ErrorHandler.throwError({ code: statusCode, message, req });
   }

src/interface/portal/indexPortal/enable.js

@@ -1,6 +1,7 @@
 const Job = require('../../../domain/jobs');
 const constants = require('../../../domain/contants');
 const Task = require('../../../domain/task')
+const publish = require('./publish');
 
 async function enablePortalHadler(req, res) {
     let resp = { ...constants.Response.GenericResp };
@@ -13,6 +14,7 @@ async function enablePortalHadler(req, res) {
     }
 
     try {
+        await publish({ contractAddress, chainId, publicLayoutFileId });
         const newJob = await Job.createJob(constants.JobConst.Type.PublicPortal, jobBody, contractAddress);
         resp.message = constants.Response.RespMsg.SUCCESS;
         resp.data = {

src/interface/portal/indexPortal/publish.js

@@ -0,0 +1,43 @@
+const axios = require('axios');
+const url = process.env.PRODUCER_HOST;
+const apiKey = process.env.PRODUCER_API_KEY;
+
+// Custom serializer for BigInt values
+function customStringify(obj) {
+    return JSON.stringify(obj, (key, value) =>
+        typeof value === 'bigint' ? value.toString() : value,
+        2
+    );
+}
+
+
+async function publish(respObj) {
+
+    const message = customStringify(respObj);
+    if (url === undefined || apiKey === undefined) {
+        throw new Error('PRODUCER_HOST is not defined');
+    }
+
+    const endpoint = url + '/api/v1/producer/public-portal';
+
+    let config = {
+        method: 'post',
+        maxBodyLength: Infinity,
+        url: endpoint,
+        headers: {
+            'x-api-key': apiKey
+        },
+        data: message
+    };
+
+    const resp = await axios.request(config)
+
+    if (resp.status !== 200) {
+        throw new Error('Error in creating job: ' + resp.data);
+    } else {
+        console.log('Job created successfully');
+    }
+
+}
+
+module.exports = publish;