fix: stop formatting app property

src/helpers/utils.ts

@@ -208,3 +208,9 @@ export function captureError(e: any, context?: any, ignoredErrorCodes?: number[]
 export async function clearStampCache(type: string, id: string) {
   return fetch(`https://cdn.stamp.fyi/clear/${type}/${type === 'avatar' ? 'eth:' : ''}${id}`);
 }
+
+export function formatApp(app: string | undefined): string {
+  if (!app || app?.length > 128) return '';
+
+  return app;
+}

src/ingestor.ts

@@ -4,7 +4,6 @@ import { capture } from '@snapshot-labs/snapshot-sentry';
 import snapshot from '@snapshot-labs/snapshot.js';
 import hashTypes from '@snapshot-labs/snapshot.js/src/sign/hashedTypes.json';
 import castArray from 'lodash/castArray';
-import kebabCase from 'lodash/kebabCase';
 import { getProposal, getSpace } from './helpers/actions';
 import { isValidAlias } from './helpers/alias';
 import envelope from './helpers/envelope.json';
@@ -13,7 +12,7 @@ import log from './helpers/log';
 import { timeIngestorProcess } from './helpers/metrics';
 import { flaggedIps } from './helpers/moderation';
 import relayer, { issueReceipt } from './helpers/relayer';
-import { getIp, jsonParse, sha256 } from './helpers/utils';
+import { formatApp, getIp, jsonParse, sha256 } from './helpers/utils';
 import writer from './writer';
 
 const NETWORK_METADATA = {
@@ -151,7 +150,7 @@ export default async function ingestor(req) {
           plugins: JSON.parse(message.plugins)
         },
         type: message.type,
-        app: kebabCase(message.app || '')
+        app: formatApp(message.app)
       };
     if (type === 'alias') payload = { alias: message.alias };
     if (type === 'statement')
@@ -200,7 +199,7 @@ export default async function ingestor(req) {
         proposal: message.proposal,
         choice,
         reason: message.reason || '',
-        app: kebabCase(message.app || ''),
+        app: formatApp(message.app),
         metadata: jsonParse(message.metadata, {})
       };
       type = 'vote';

src/writer/proposal.ts

@@ -1,7 +1,6 @@
 import { capture } from '@snapshot-labs/snapshot-sentry';
 import snapshot from '@snapshot-labs/snapshot.js';
 import networks from '@snapshot-labs/snapshot.js/src/networks.json';
-import kebabCase from 'lodash/kebabCase';
 import { validateSpaceSettings } from './settings';
 import { getSpace } from '../helpers/actions';
 import { ACTIVE_PROPOSAL_BY_AUTHOR_LIMIT, getSpaceLimits } from '../helpers/limits';
@@ -240,7 +239,7 @@ export async function action(body, ipfs, receipt, id): Promise<void> {
     quorum_type: (quorum && spaceSettings.voting?.quorumType) || '',
     privacy: spaceSettings.voting?.privacy || '',
     snapshot: proposalSnapshot || 0,
-    app: kebabCase(msg.payload.app || ''),
+    app: msg.payload.app,
     scores: JSON.stringify([]),
     scores_by_strategy: JSON.stringify([]),
     scores_state: 'pending',

src/writer/vote.ts

@@ -1,5 +1,4 @@
 import snapshot from '@snapshot-labs/snapshot.js';
-import kebabCase from 'lodash/kebabCase';
 import { getProposal } from '../helpers/actions';
 import log from '../helpers/log';
 import db from '../helpers/mysql';
@@ -108,7 +107,7 @@ export async function action(body, ipfs, receipt, id, context): Promise<void> {
   const created = parseInt(msg.timestamp);
   const choice = JSON.stringify(msg.payload.choice);
   const metadata = JSON.stringify(msg.payload.metadata || {});
-  const app = kebabCase(msg.payload.app || '');
+  const app = msg.payload.app;
   const reason = msg.payload.reason || '';
   const proposalId = msg.payload.proposal;
 

test/schema.sql

@@ -52,7 +52,7 @@ CREATE TABLE proposals (
   quorum_type VARCHAR(24) NOT NULL DEFAULT '',
   privacy VARCHAR(24) NOT NULL,
   snapshot INT(24) NOT NULL,
-  app VARCHAR(24) NOT NULL,
+  app VARCHAR(128) NOT NULL,
   scores JSON NOT NULL,
   scores_by_strategy JSON NOT NULL,
   scores_state VARCHAR(24) NOT NULL,
@@ -86,7 +86,7 @@ CREATE TABLE votes (
   choice JSON NOT NULL,
   metadata JSON NOT NULL,
   reason TEXT NOT NULL,
-  app VARCHAR(24) NOT NULL,
+  app VARCHAR(128) NOT NULL,
   vp DECIMAL(64,30) NOT NULL,
   vp_by_strategy JSON NOT NULL,
   vp_state VARCHAR(24) NOT NULL,

test/unit/helpers/utils.ts

@@ -0,0 +1,20 @@
+import { formatApp } from '../../../src/helpers/utils';
+
+describe('utils', () => {
+  describe('formatApp()', () => {
+    it('returns an empty string on empty', () => {
+      expect(formatApp(undefined)).toEqual('');
+      expect(formatApp('')).toEqual('');
+    });
+
+    it('returns the input when valid', () => {
+      expect('0xAaB').toBe('0xAaB');
+    });
+
+    it('returns an empty string exceeding the chars limit', () => {
+      expect(
+        'abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz!'
+      ).toBe('');
+    });
+  });
+});