Permite a criação de conteúdos do tipo ad

models/authorization.js

@@ -118,6 +118,7 @@ function filterInput(user, feature, input, target) {
       title: input.title,
       body: input.body,
       status: input.status,
+      type: input.type,
       source_url: input.source_url,
     };
   }

models/balance.js

@@ -49,14 +49,17 @@ async function findAllByOriginatorId(originatorId, options) {
 async function create({ balanceType, recipientId, amount, originatorType, originatorId }, options = {}) {
   const tableName = tableNameMap[balanceType] || tableNameMap.default;
   const hasBalanceTypeColum = balanceType.startsWith('content:tabcoin');
+  const totalBalanceFunction = sqlFunctionMap[balanceType] || sqlFunctionMap.default;
+
+  const returning = options.withBalance ? `*, ${totalBalanceFunction}($1) as total` : '*';
 
   const query = {
     text: `
       INSERT INTO ${tableName}
         (recipient_id, amount, originator_type, originator_id${hasBalanceTypeColum ? ', balance_type' : ''})
       VALUES
         ($1, $2, $3, $4${hasBalanceTypeColum ? ', $5' : ''})
-      RETURNING * ;
+      RETURNING ${returning};
       `,
     values: [recipientId, amount, originatorType, originatorId],
   };

models/content.js

@@ -1,7 +1,7 @@
 import { randomUUID as uuidV4 } from 'node:crypto';
 import slug from 'slug';
 
-import { ForbiddenError, ValidationError } from 'errors';
+import { ForbiddenError, UnprocessableEntityError, ValidationError } from 'errors';
 import database from 'infra/database.js';
 import balance from 'models/balance.js';
 import pagination from 'models/pagination.js';
@@ -113,6 +113,7 @@ async function findAll(values = {}, options = {}) {
         contents.title,
         ${!values.attributes?.exclude?.includes('body') ? 'contents.body,' : ''}
         contents.status,
+        contents.type,
         contents.source_url,
         contents.created_at,
         contents.updated_at,
@@ -286,6 +287,11 @@ async function create(postedContent, options = {}) {
     transaction: options.transaction,
   });
 
+  await updateTabCashBalance(null, newContent, {
+    eventId: options.eventId,
+    transaction: options.transaction,
+  });
+
   const tabcoinsCount = await balance.getContentTabcoinsCreditDebit(
     {
       recipientId: newContent.id,
@@ -317,8 +323,8 @@ async function create(postedContent, options = {}) {
         ),
         inserted_content as (
           INSERT INTO
-            contents (id, parent_id, owner_id, slug, title, body, status, source_url, published_at, path)
-            SELECT $1, $2, $3, $4, $5, $6, $7, $8, $9, parent.child_path
+            contents (id, parent_id, owner_id, slug, title, body, status, source_url, published_at, type, path)
+            SELECT $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, parent.child_path
             FROM parent
             RETURNING *
         )
@@ -330,6 +336,7 @@ async function create(postedContent, options = {}) {
         inserted_content.title,
         inserted_content.body,
         inserted_content.status,
+        inserted_content.type,
         inserted_content.source_url,
         inserted_content.created_at,
         inserted_content.updated_at,
@@ -355,6 +362,7 @@ async function create(postedContent, options = {}) {
         content.status,
         content.source_url,
         content.published_at,
+        content.type,
       ],
     };
 
@@ -440,6 +448,7 @@ function validateCreateSchema(content) {
     title: 'optional',
     body: 'required',
     status: 'required',
+    content_type: 'optional',
     source_url: 'optional',
   });
 
@@ -550,6 +559,11 @@ async function creditOrDebitTabCoins(oldContent, newContent, options = {}) {
       });
     }
 
+    // We should not credit TabCoins to the user if the "type" is not "content".
+    if (newContent.type !== 'content') {
+      userEarnings = 0;
+    }
+
     // We should not credit if the content has little or no value.
     if (newContent.body.split(/[a-z]{5,}/i, 6).length < 6) return;
 
@@ -602,6 +616,36 @@ async function creditOrDebitTabCoins(oldContent, newContent, options = {}) {
   }
 }
 
+async function updateTabCashBalance(oldContent, newContent, options = {}) {
+  if (newContent.type === 'content') {
+    return;
+  }
+
+  const tabCashToDebitFromUser = -100;
+
+  const balanceResult = await balance.create(
+    {
+      balanceType: 'user:tabcash',
+      recipientId: newContent.owner_id,
+      amount: tabCashToDebitFromUser,
+      originatorType: options.eventId ? 'event' : 'content',
+      originatorId: options.eventId ? options.eventId : newContent.id,
+    },
+    {
+      transaction: options.transaction,
+      withBalance: true,
+    },
+  );
+
+  if (balanceResult.total < 0) {
+    throw new UnprocessableEntityError({
+      message: `Não foi possível criar a publicação.`,
+      action: `Você precisa de pelo menos ${Math.abs(tabCashToDebitFromUser)} TabCash para realizar esta ação.`,
+      errorLocationCode: 'MODEL:CONTENT:UPDATE_TABCASH:NOT_ENOUGH',
+    });
+  }
+}
+
 async function update(contentId, postedContent, options = {}) {
   const validPostedContent = validateUpdateSchema(postedContent);
 
@@ -674,6 +718,7 @@ async function update(contentId, postedContent, options = {}) {
         updated_content.title,
         updated_content.body,
         updated_content.status,
+        updated_content.type,
         updated_content.source_url,
         updated_content.created_at,
         updated_content.updated_at,

models/validator.js

@@ -251,6 +251,16 @@ const schemas = {
     });
   },
 
+  content_type: function () {
+    return Joi.object({
+      type: Joi.string()
+        .trim()
+        .valid('content', 'ad')
+        .default('content')
+        .when('$required.content_type', { is: 'required', then: Joi.required(), otherwise: Joi.optional() }),
+    });
+  },
+
   source_url: function () {
     return Joi.object({
       source_url: Joi.string()
@@ -482,6 +492,7 @@ const schemas = {
       'title',
       'body',
       'status',
+      'content_type',
       'source_url',
       'created_at',
       'updated_at',

pages/api/v1/contents/index.public.js

@@ -89,6 +89,7 @@ function postValidationHandler(request, response, next) {
     title: 'optional',
     body: 'required',
     status: 'optional',
+    content_type: 'optional',
     source_url: 'optional',
   });
 

tests/constants-for-tests.js

@@ -1,2 +1,3 @@
+export const defaultTabCashForAdCreation = 100;
 export const maxSlugLength = 160;
 export const maxTitleLength = 255;

tests/integration/api/v1/contents/[username]/[slug]/children/get.test.js

@@ -154,6 +154,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
           tabcoins_credit: 0,
           tabcoins_debit: 0,
           status: childBranchBLevel1.status,
+          type: 'content',
           source_url: childBranchBLevel1.source_url,
           created_at: childBranchBLevel1.created_at.toISOString(),
           updated_at: childBranchBLevel1.updated_at.toISOString(),
@@ -172,6 +173,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
               tabcoins_credit: 0,
               tabcoins_debit: 0,
               status: childBranchBLevel2Content1.status,
+              type: 'content',
               source_url: childBranchBLevel2Content1.source_url,
               created_at: childBranchBLevel2Content1.created_at.toISOString(),
               updated_at: childBranchBLevel2Content1.updated_at.toISOString(),
@@ -192,6 +194,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
               tabcoins_credit: 0,
               tabcoins_debit: 0,
               status: childBranchBLevel2Content2.status,
+              type: 'content',
               source_url: childBranchBLevel2Content2.source_url,
               created_at: childBranchBLevel2Content2.created_at.toISOString(),
               updated_at: childBranchBLevel2Content2.updated_at.toISOString(),
@@ -212,6 +215,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
           title: childBranchALevel1.title,
           body: childBranchALevel1.body,
           status: childBranchALevel1.status,
+          type: 'content',
           tabcoins: 1,
           tabcoins_credit: 0,
           tabcoins_debit: 0,
@@ -230,6 +234,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
               title: childBranchALevel2.title,
               body: childBranchALevel2.body,
               status: childBranchALevel2.status,
+              type: 'content',
               tabcoins: 1,
               tabcoins_credit: 0,
               tabcoins_debit: 0,
@@ -251,6 +256,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
                   tabcoins_credit: 0,
                   tabcoins_debit: 0,
                   status: childBranchALevel3.status,
+                  type: 'content',
                   source_url: childBranchALevel3.source_url,
                   created_at: childBranchALevel3.created_at.toISOString(),
                   updated_at: childBranchALevel3.updated_at.toISOString(),
@@ -346,6 +352,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
           title: childBranchBLevel2Content2.title,
           body: childBranchBLevel2Content2.body,
           status: childBranchBLevel2Content2.status,
+          type: 'content',
           tabcoins: 1,
           tabcoins_credit: 0,
           tabcoins_debit: 0,
@@ -366,6 +373,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
           title: childBranchBLevel2Content1.title,
           body: childBranchBLevel2Content1.body,
           status: childBranchBLevel2Content1.status,
+          type: 'content',
           tabcoins: 0,
           tabcoins_credit: 0,
           tabcoins_debit: 0,
@@ -436,6 +444,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
           tabcoins_credit: 2,
           tabcoins_debit: -1,
           status: childBranchBLevel1.status,
+          type: 'content',
           source_url: childBranchBLevel1.source_url,
           created_at: childBranchBLevel1.created_at.toISOString(),
           updated_at: childBranchBLevel1.updated_at.toISOString(),
@@ -453,6 +462,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
           title: childBranchALevel1.title,
           body: childBranchALevel1.body,
           status: childBranchALevel1.status,
+          type: 'content',
           tabcoins: 1,
           tabcoins_credit: 0,
           tabcoins_debit: 0,
@@ -471,6 +481,7 @@ describe('GET /api/v1/contents/[username]/[slug]/children', () => {
               title: childBranchALevel2.title,
               body: childBranchALevel2.body,
               status: childBranchALevel2.status,
+              type: 'content',
               tabcoins: 5,
               tabcoins_credit: 4,
               tabcoins_debit: 0,

tests/integration/api/v1/contents/[username]/[slug]/get.test.js

@@ -96,6 +96,7 @@ describe('GET /api/v1/contents/[username]/[slug]', () => {
         title: 'Conteúdo publicamente disponível',
         body: 'Conteúdo relevante deveria estar disponível para todos.',
         status: 'published',
+        type: 'content',
         tabcoins: 1,
         tabcoins_credit: 0,
         tabcoins_debit: 0,
@@ -203,6 +204,7 @@ describe('GET /api/v1/contents/[username]/[slug]', () => {
         title: 'Conteúdo root',
         body: 'Body with relevant texts needs to contain a good amount of words',
         status: 'published',
+        type: 'content',
         tabcoins: 1,
         tabcoins_credit: 0,
         tabcoins_debit: 0,
@@ -285,6 +287,7 @@ describe('GET /api/v1/contents/[username]/[slug]', () => {
         title: null,
         body: 'Conteúdo child',
         status: 'published',
+        type: 'content',
         tabcoins: 0,
         tabcoins_credit: 0,
         tabcoins_debit: 0,
@@ -355,6 +358,7 @@ describe('GET /api/v1/contents/[username]/[slug]', () => {
         title: null,
         body: 'Conteúdo child',
         status: 'published',
+        type: 'content',
         tabcoins: 0,
         tabcoins_credit: 0,
         tabcoins_debit: 0,
@@ -441,6 +445,7 @@ describe('GET /api/v1/contents/[username]/[slug]', () => {
         title: 'Conteúdo com TabCoins',
         body: 'Conteúdo que foi avaliado positiva e negativamente.',
         status: 'published',
+        type: 'content',
         tabcoins: 2,
         tabcoins_credit: 3,
         tabcoins_debit: -1,

tests/integration/api/v1/contents/[username]/[slug]/parent/get.test.js

@@ -224,6 +224,7 @@ describe('GET /api/v1/contents/[username]/[slug]/parent', () => {
         body: 'Root - Body with relevant texts needs to contain a good amount of words',
         children_deep_count: 1,
         status: 'published',
+        type: 'content',
         source_url: null,
         published_at: rootContent.published_at.toISOString(),
         created_at: rootContent.created_at.toISOString(),
@@ -287,6 +288,7 @@ describe('GET /api/v1/contents/[username]/[slug]/parent', () => {
         body: 'Child content body Level 2 - relevant content',
         children_deep_count: 1,
         status: 'published',
+        type: 'content',
         source_url: null,
         published_at: childContentLevel2.published_at.toISOString(),
         created_at: childContentLevel2.created_at.toISOString(),
@@ -354,6 +356,7 @@ describe('GET /api/v1/contents/[username]/[slug]/parent', () => {
         body: '[Não disponível]',
         children_deep_count: 0,
         status: 'draft',
+        type: 'content',
         source_url: null,
         published_at: null,
         created_at: childContentLevel2.created_at.toISOString(),
@@ -422,6 +425,7 @@ describe('GET /api/v1/contents/[username]/[slug]/parent', () => {
         body: '[Não disponível]',
         children_deep_count: 0,
         status: 'deleted',
+        type: 'content',
         source_url: null,
         published_at: childContentLevel2.published_at.toISOString(),
         created_at: childContentLevel2.created_at.toISOString(),
@@ -472,6 +476,7 @@ describe('GET /api/v1/contents/[username]/[slug]/parent', () => {
         body: 'Root - Body with relevant texts needs to contain a good amount of words',
         children_deep_count: 1,
         status: 'published',
+        type: 'content',
         source_url: null,
         published_at: rootContent.published_at.toISOString(),
         created_at: rootContent.created_at.toISOString(),