feat: add delete-subscription writer

Author: wa0x6e

src/writer/delete-subscription.ts

@@ -0,0 +1,22 @@
+import { envelopDB } from '../helpers/mysql';
+
+type Message = { address: string };
+
+export async function verify(message: Message): Promise<any> {
+  const result = await envelopDB.queryAsync(
+    `SELECT * FROM subscribers WHERE address = ? AND verified > 0 LIMIT 1`,
+    [message.address]
+  );
+
+  if (!result[0]) {
+    return Promise.reject('user not subscribed');
+  }
+
+  return result[0];
+}
+
+export async function action(message: Message): Promise<void> {
+  await envelopDB.queryAsync(`DELETE FROM subscribers WHERE address = ? AND verified > 0 LIMIT 1`, [
+    message.address
+  ]);
+}

src/writer/index.ts

@@ -1,6 +1,7 @@
 import * as alias from './alias';
 import * as deleteProposal from './delete-proposal';
 import * as deleteSpace from './delete-space';
+import * as deleteSubscription from './delete-subscription';
 import * as flagProposal from './flag-proposal';
 import * as follow from './follow';
 import * as profile from './profile';
@@ -25,6 +26,7 @@ export default {
   unfollow,
   subscribe,
   unsubscribe,
+  'delete-subscription': deleteSubscription,
   alias,
   profile,
   statement

test/integration/writer/delete-subscription.test.ts

@@ -0,0 +1,71 @@
+import db, { envelopDB, sequencerDB } from '../../../src/helpers/mysql';
+import { action, verify } from '../../../src/writer/delete-subscription';
+
+describe('writer/delete-subscription', () => {
+  const TEST_PREFIX = 'test-delete-subscription';
+
+  afterAll(async () => {
+    await envelopDB.queryAsync('DELETE FROM subscribers');
+    await envelopDB.endAsync();
+    await db.endAsync();
+    await sequencerDB.endAsync();
+  });
+
+  describe('verify()', () => {
+    beforeAll(async () => {
+      await Promise.all([
+        envelopDB.queryAsync(
+          'INSERT INTO subscribers SET address = ?, email = ?, subscriptions = ?, created = ?, verified = ?',
+          [`${TEST_PREFIX}-0x0`, '[email protected]', '[]', 0, 0]
+        ),
+        envelopDB.queryAsync(
+          'INSERT INTO subscribers SET address = ?, email = ?, subscriptions = ?, created = ?, verified = ?',
+          [`${TEST_PREFIX}-0x1`, '[email protected]', '[]', 0, 1]
+        )
+      ]);
+    });
+
+    it('rejects when the address is not subscribed', () => {
+      return expect(verify({ address: '0x0' })).rejects.toEqual(`user not subscribed`);
+    });
+
+    it('rejects when the address is not verified', () => {
+      return expect(verify({ address: `${TEST_PREFIX}-0x0` })).rejects.toEqual(
+        `user not subscribed`
+      );
+    });
+
+    it('resolves when the address is verified', () => {
+      return expect(verify({ address: `${TEST_PREFIX}-0x1` })).resolves.toHaveProperty('address');
+    });
+  });
+
+  describe('action()', () => {
+    const address = `${TEST_PREFIX}-0x3`;
+
+    beforeAll(async () => {
+      await Promise.all([
+        envelopDB.queryAsync(
+          'INSERT INTO subscribers SET address = ?, email = ?, subscriptions = ?, created = ?, verified = ?',
+          [address, '[email protected]', '[]', 0, 0]
+        ),
+        envelopDB.queryAsync(
+          'INSERT INTO subscribers SET address = ?, email = ?, subscriptions = ?, created = ?, verified = ?',
+          [address, '[email protected]', '[]', 0, 1]
+        )
+      ]);
+    });
+
+    it('deletes the subscription', async () => {
+      await action({ address: address });
+
+      const results = await envelopDB.queryAsync('SELECT * FROM subscribers WHERE address = ?', [
+        address
+      ]);
+
+      // Only delete the verified subscription
+      expect(results.length).toBe(1);
+      expect(results[0].email).toEqual('[email protected]');
+    });
+  });
+});