feat: start implementation

Author: m1s0g1

backend/src/dal/sqliteCampaignRepository.js

@@ -175,12 +175,54 @@ export function createSqliteCampaignRepository({
     return info.changes > 0;
   }
 
+  function clone(id, overrides = {}) {
+    const source = getById(id);
+    if (!source) {
+      return undefined;
+    }
+
+    const clonedName = overrides.name !== undefined ? overrides.name : `Copy of ${source.name}`;
+    const clonedSlug = overrides.slug !== undefined ? overrides.slug : generateSlug(clonedName);
+    const clonedDescription = overrides.description !== undefined ? overrides.description : source.description;
+    const clonedRewardPerAction = overrides.rewardPerAction !== undefined ? overrides.rewardPerAction : source.rewardPerAction;
+    const clonedCategory = overrides.category !== undefined ? overrides.category : (source.category || null);
+    const clonedImageUrl = overrides.imageUrl !== undefined ? overrides.imageUrl : (source.imageUrl || null);
+    const clonedTags = overrides.tags !== undefined ? overrides.tags : (source.tags || null);
+
+    const createdAt = new Date().toISOString();
+    const info = db
+      .prepare(
+        'INSERT INTO campaigns (name, slug, description, active, reward_per_action, start_date, end_date, featured, hidden, hidden_reason, created_at, updated_at) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)',
+      )
+      .run(
+        clonedName,
+        clonedSlug,
+        clonedDescription,
+        0, // status: draft (active = false)
+        clonedRewardPerAction,
+        null, // startDate not copied
+        null, // endDate not copied
+        0, // featured = false
+        source.hidden ? 1 : 0,
+        source.hiddenReason,
+        createdAt,
+        createdAt
+      );
+
+    const newCampaign = getById(info.lastInsertRowid);
+    if (newCampaign) {
+      newCampaign.clonedFrom = source.id;
+    }
+    return newCampaign;
+  }
+
   return {
     list,
     getById,
     getBySlug,
     create,
     update,
     delete: remove,
+    clone,
   };
 }

backend/src/dal/sqliteCampaignRepository.test.js

@@ -170,6 +170,8 @@ test('computeCampaignStatus prioritises ended over upcoming', () => {
 
 test('campaign repository attaches computed status to returned campaigns', async () => {
   const repository = await setupTestRepository();
+  const future = new Date(Date.now() + 86_400_000).toISOString();
+  const past = new Date(Date.now() - 86_400_000).toISOString();
 
   const upcoming = repository.create({
     name: 'Future Campaign',
@@ -290,3 +292,72 @@ test('list includeHidden option exposes hidden campaigns', async () => {
   assert.equal(repository.list().length, 1);
   assert.equal(repository.list({ includeHidden: true }).length, 2);
 });
+
+// #458 — clone campaign functionality
+test('clone creates a new campaign with copied metadata', async () => {
+  const repository = await setupTestRepository();
+
+  const original = repository.create({
+    name: 'Weekly Challenge',
+    description: 'Complete tasks to earn rewards',
+    rewardPerAction: 50,
+    active: true,
+    featured: true,
+  });
+
+  const cloned = repository.clone(original.id);
+
+  assert.ok(cloned);
+  assert.notEqual(cloned.id, original.id);
+  assert.equal(cloned.name, `Copy of ${original.name}`);
+  assert.equal(cloned.description, original.description);
+  assert.equal(cloned.rewardPerAction, original.rewardPerAction);
+  assert.equal(cloned.active, false); // cloned campaigns are draft
+  assert.equal(cloned.startDate, null); // dates not copied
+  assert.equal(cloned.endDate, null);
+  assert.equal(cloned.clonedFrom, original.id);
+});
+
+test('clone with overrides applies custom values', async () => {
+  const repository = await setupTestRepository();
+
+  const original = repository.create({
+    name: 'Original Campaign',
+    description: 'Original description',
+    rewardPerAction: 100,
+  });
+
+  const cloned = repository.clone(original.id, {
+    name: 'Custom Name',
+    description: 'Custom description',
+  });
+
+  assert.ok(cloned);
+  assert.equal(cloned.name, 'Custom Name');
+  assert.equal(cloned.description, 'Custom description');
+  assert.equal(cloned.rewardPerAction, original.rewardPerAction); // not overridden
+  assert.equal(cloned.clonedFrom, original.id);
+});
+
+test('clone returns undefined for non-existent campaign', async () => {
+  const repository = await setupTestRepository();
+
+  const cloned = repository.clone('99999');
+  assert.equal(cloned, undefined);
+});
+
+test('clone generates unique slug for cloned campaign', async () => {
+  const repository = await setupTestRepository();
+
+  const original = repository.create({
+    name: 'Test Campaign',
+    slug: 'test-campaign',
+    rewardPerAction: 10,
+  });
+
+  const cloned = repository.clone(original.id);
+
+  assert.ok(cloned);
+  assert.notEqual(cloned.slug, original.slug);
+  assert.equal(cloned.slug, 'copy-of-test-campaign');
+});

backend/src/index.js

@@ -394,6 +394,7 @@ export async function createApp(options = {}) {
         campaignById: `GET ${API_V1_PREFIX}/campaigns/:id`,
         campaignBySlug: `GET ${API_V1_PREFIX}/campaigns/by-slug/:slug`,
         createCampaign: `POST ${API_V1_PREFIX}/campaigns`,
+        cloneCampaign: `POST ${API_V1_PREFIX}/campaigns/:id/clone`,
         updateCampaign: `PUT ${API_V1_PREFIX}/campaigns/:id`,
         deleteCampaign: `DELETE ${API_V1_PREFIX}/campaigns/:id`,
         auditLogs: `GET ${API_V1_PREFIX}/audit-logs`,
@@ -597,6 +598,45 @@ export async function createApp(options = {}) {
     return res.status(204).end();
   }
 
+  /** @param {import('express').Request} req @param {import('express').Response} res */
+  function cloneCampaign(req, res) {
+    const sourceId = req.params.id;
+    const source = campaignRepository.getById(sourceId);
+    
+    if (!source) {
+      return res.status(404).json({ error: 'Campaign not found', code: 'CAMPAIGN_NOT_FOUND' });
+    }
+
+    const overrides = req.body?.overrides || {};
+    
+    try {
+      const clonedCampaign = campaignRepository.clone(sourceId, overrides);
+      
+      if (!clonedCampaign) {
+        return res.status(500).json({ error: 'Failed to clone campaign', code: 'CLONE_FAILED' });
+      }
+
+      recordAuditEntry(req, {
+        action: 'clone',
+        entity: 'campaign',
+        entityId: clonedCampaign.id,
+        diff: { cloned_from: sourceId, overrides },
+      });
+
+      shortCache.clear();
+      return res.status(201).json(clonedCampaign);
+    } catch (error) {
+      if (/** @type {any} */ (error).message?.includes('UNIQUE constraint failed')) {
+        return res.status(409).json({
+          error: 'Slug already exists',
+          code: 'SLUG_CONFLICT',
+          details: ['A campaign with this slug already exists'],
+        });
+      }
+      throw error;
+    }
+  }
+
   /** @param {import('express').Request} req @param {import('express').Response} res */
   function listAuditLogs(req, res) {
     const entity = typeof req.query.entity === 'string' ? req.query.entity.trim() : '';
@@ -651,6 +691,7 @@ export async function createApp(options = {}) {
     app.get(`${prefix}/indexer/cursor`, rateLimiter, getIndexerCursorState);
     app.post(`${prefix}/indexer/cursor`, rateLimiter, requireApiKey, setIndexerCursorState);
     app.post(`${prefix}/campaigns`, rateLimiter, requireApiKey, createCampaign);
+    app.post(`${prefix}/campaigns/:id/clone`, rateLimiter, requireApiKey, cloneCampaign);
     app.put(`${prefix}/campaigns/:id`, rateLimiter, requireApiKey, updateCampaign);
     app.delete(`${prefix}/campaigns/:id`, rateLimiter, requireApiKey, deleteCampaign);
   }