const pull = require('../server/node_modules/pull-stream');
const moment = require('../server/node_modules/moment');
const { getConfig } = require('../configs/config-manager.js');

const logLimit = getConfig().ssbLogStream?.limit || 1000;
const TERM_DAYS = 60;
const PROPOSAL_DAYS = 7;
const REVOCATION_DAYS = 15;
const METHODS = ['DEMOCRACY', 'MAJORITY', 'MINORITY', 'DICTATORSHIP', 'KARMATOCRACY'];
const FEED_ID_RE = /^@.+\.ed25519$/;

module.exports = ({ cooler, services = {} }) => {
  let ssb;
  let userId;

  const openSsb = async () => {
    if (!ssb) {
      ssb = await cooler.open();
      userId = ssb.id;
    }
    return ssb;
  };

  const nowISO = () => new Date().toISOString();
  const parseISO = (s) => moment(s, moment.ISO_8601, true);
  const ensureArray = (x) => (Array.isArray(x) ? x : x ? [x] : []);
  const normMs = (t) => (t && t < 1e12 ? t * 1000 : t || 0);

  async function readLog() {
    const ssbClient = await openSsb();
    return new Promise((res, rej) => {
      pull(ssbClient.createLogStream({ limit: logLimit }), pull.collect((err, arr) => (err ? rej(err) : res(arr))));
    });
  }

  async function listByType(type) {
    const msgs = await readLog();
    const tomb = new Set();
    const rep = new Map();
    const map = new Map();
    for (const m of msgs) {
      const k = m.key;
      const c = m.value?.content;
      if (!c) continue;
      if (c.type === 'tombstone' && c.target) tomb.add(c.target);
      if (c.type === type) {
        if (c.replaces) rep.set(c.replaces, k);
        map.set(k, { id: k, ...c });
      }
    }
    for (const oldId of rep.keys()) map.delete(oldId);
    for (const tId of tomb) map.delete(tId);
    return [...map.values()];
  }

  async function listTribesAny() {
    if (services.tribes?.listAll) return await services.tribes.listAll();
    return await listByType('tribe');
  }

  async function getLatestAboutFromLog(feedId) {
    const msgs = await readLog();
    let latest = null;
    for (let i = msgs.length - 1; i >= 0; i--) {
      const v = msgs[i].value || {};
      const c = v.content || {};
      if (!c || c.type !== 'about') continue;
      const bySelf = v.author === feedId && typeof c.name === 'string';
      const aboutTarget = c.about === feedId && (typeof c.name === 'string' || typeof c.description === 'string' || typeof c.image === 'string');
      if (bySelf || aboutTarget) {
        const ts = normMs(v.timestamp || msgs[i].timestamp || Date.now());
        if (!latest || ts > latest.ts) latest = { ts, content: c };
      }
    }
    return latest ? latest.content : null;
  }

  async function getTribeMetaById(tribeId) {
    let tribe = null;
    if (services.tribes?.getTribeById) {
      try { tribe = await services.tribes.getTribeById(tribeId); } catch {}
    }
    if (!tribe) return { isTribe: true, name: tribeId, avatarUrl: '/assets/images/default-tribe.png', bio: '' };
    const imgId = tribe.image || null;
    const avatarUrl = imgId ? `/image/256/${encodeURIComponent(imgId)}` : '/assets/images/default-tribe.png';
    return { isTribe: true, name: tribe.title || tribe.name || tribeId, avatarUrl, bio: tribe.description || '' };
  }

  async function getInhabitantMetaById(feedId) {
    let aboutRec = null;
    if (services.inhabitants?.getLatestAboutById) {
      try { aboutRec = await services.inhabitants.getLatestAboutById(feedId); } catch {}
    }
    if (!aboutRec) {
      try { aboutRec = await getLatestAboutFromLog(feedId); } catch {}
    }
    const name = (aboutRec && typeof aboutRec.name === 'string' && aboutRec.name.trim()) ? aboutRec.name.trim() : feedId;
    const imgField = aboutRec && aboutRec.image;
    const imgId = typeof imgField === 'string' ? imgField : (imgField && (imgField.link || imgField.url)) ? (imgField.link || imgField.url) : null;
    const avatarUrl = imgId ? `/image/256/${encodeURIComponent(imgId)}` : '/assets/images/default-avatar.png';
    const bio = (aboutRec && typeof aboutRec.description === 'string') ? aboutRec.description : '';
    return { isTribe: false, name, avatarUrl, bio };
  }

  async function actorMeta({ targetType, targetId }) {
    const t = String(targetType || '').toLowerCase();
    if (t === 'tribe') return await getTribeMetaById(targetId);
    return await getInhabitantMetaById(targetId);
  }

  async function getInhabitantTitleSSB(feedId) {
    const msgs = await readLog();
    for (let i = msgs.length - 1; i >= 0; i--) {
      const v = msgs[i].value || {};
      const c = v.content || {};
      if (!c || c.type !== 'about') continue;
      if (c.about === feedId && typeof c.name === 'string' && c.name.trim()) return c.name.trim();
      if (v.author === feedId && typeof c.name === 'string' && c.name.trim()) return c.name.trim();
    }
    return null;
  }

  async function findFeedIdByName(name) {
    const q = String(name || '').trim().toLowerCase();
    if (!q) return null;
    const msgs = await readLog();
    let best = null;
    for (let i = msgs.length - 1; i >= 0; i--) {
      const v = msgs[i].value || {};
      const c = v.content || {};
      if (!c || c.type !== 'about' || typeof c.name !== 'string') continue;
      if (c.name.trim().toLowerCase() !== q) continue;
      const fid = typeof c.about === 'string' && FEED_ID_RE.test(c.about) ? c.about : v.author;
      const ts = normMs(v.timestamp || msgs[i].timestamp || Date.now());
      if (!best || ts > best.ts) best = { id: fid, ts };
    }
    return best ? best.id : null;
  }

  async function resolveTarget(candidateInput) {
    const s = String(candidateInput || '').trim();
    if (!s) return null;
    const tribes = await listTribesAny();
    const t = tribes.find(tr =>
      tr.id === s ||
      (tr.title && tr.title.toLowerCase() === s.toLowerCase()) ||
      (tr.name && tr.name.toLowerCase() === s.toLowerCase())
    );
    if (t) {
      return { type: 'tribe', id: t.id, title: t.title || t.name || t.id, members: ensureArray(t.members) };
    }
    if (FEED_ID_RE.test(s)) {
      const title = await getInhabitantTitleSSB(s);
      return { type: 'inhabitant', id: s, title: title || s, members: [] };
    }
    const fid = await findFeedIdByName(s);
    if (fid) {
      const title = await getInhabitantTitleSSB(fid);
      return { type: 'inhabitant', id: fid, title: title || s, members: [] };
    }
    return null;
  }

  function majorityThreshold(total) { return Math.ceil(Number(total || 0) * 0.8); }
  function minorityThreshold(total) { return Math.ceil(Number(total || 0) * 0.2); }
  function democracyThreshold(total) { return Math.floor(Number(total || 0) / 2) + 1; }
  function passesThreshold(method, total, yes) {
    const m = String(method || '').toUpperCase();
    if (m === 'DEMOCRACY' || m === 'ANARCHY') return yes >= democracyThreshold(total);
    if (m === 'MAJORITY') return yes >= majorityThreshold(total);
    if (m === 'MINORITY') return yes >= minorityThreshold(total);
    return false;
  }
  function requiredVotes(method, total) {
    const m = String(method || '').toUpperCase();
    if (m === 'DEMOCRACY' || m === 'ANARCHY') return democracyThreshold(total);
    if (m === 'MAJORITY') return majorityThreshold(total);
    if (m === 'MINORITY') return minorityThreshold(total);
    return 0;
  }

  async function listCandidaturesOpenRaw() {
    const all = await listByType('parliamentCandidature');
    const filtered = all.filter(c => (c.status || 'OPEN') === 'OPEN');
    return filtered.sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));
  }

  async function getFirstUserTimestamp(feedId) {
    const ssbClient = await openSsb();
    return new Promise((resolve) => {
      pull(
        ssbClient.createUserStream({ id: feedId, reverse: false }),
        pull.filter(m => m && m.value && m.value.content && m.value.content.type !== 'tombstone'),
        pull.take(1),
        pull.collect((err, arr) => {
          if (err || !arr || !arr.length) return resolve(Date.now());
          const m = arr[0];
          const ts = normMs((m.value && m.value.timestamp) || m.timestamp);
          resolve(ts || Date.now());
        })
      );
    });
  }

  async function getInhabitantKarma(feedId) {
    if (services.banking?.getUserEngagementScore) {
      try { return Number(await services.banking.getUserEngagementScore(feedId)) || 0; } catch { return 0; }
    }
    return 0;
  }

  async function getTribeSince(tribeId) {
    if (services.tribes?.getTribeById) {
      try {
        const t = await services.tribes.getTribeById(tribeId);
        if (t?.createdAt) return new Date(t.createdAt).getTime();
      } catch {}
    }
    return Date.now();
  }

  async function listCandidaturesOpen() {
    const rows = await listCandidaturesOpenRaw();
    const enriched = await Promise.all(rows.map(async c => {
      if (c.targetType === 'inhabitant') {
        const karma = await getInhabitantKarma(c.targetId);
        const since = await getFirstUserTimestamp(c.targetId);
        return { ...c, karma, profileSince: since };
      } else {
        const since = await getTribeSince(c.targetId);
        return { ...c, karma: 0, profileSince: since };
      }
    }));
    return enriched;
  }

  async function listTermsBase(filter = 'all') {
    const all = await listByType('parliamentTerm');
    const collapsed = collapseOverlappingTerms(all);
    let arr = collapsed.map(t => ({ ...t, status: moment().isAfter(parseISO(t.endAt)) ? 'EXPIRED' : 'ACTIVE' }));
    if (filter === 'active') arr = arr.filter(t => t.status === 'ACTIVE');
    if (filter === 'expired') arr = arr.filter(t => t.status === 'EXPIRED');
    return arr.sort((a, b) => new Date(b.startAt) - new Date(a.startAt));
  }

  async function getCurrentTermBase() {
    const active = await listTermsBase('active');
    return active[0] || null;
  }

  function currentCycleStart(term) {
    return term ? term.startAt : moment().subtract(TERM_DAYS, 'days').toISOString();
  }

  async function archiveAllCandidatures() {
    const ssbClient = await openSsb();
    const all = await listCandidaturesOpenRaw();
    for (const c of all) {
      const tomb = { type: 'tombstone', target: c.id, deletedAt: nowISO(), author: userId };
      await new Promise((resolve) => ssbClient.publish(tomb, () => resolve()));
    }
  }

  async function chooseWinnerFromCandidaturesAsync(cands) {
    if (!cands.length) return null;
    const norm = cands.map(c => ({
      ...c,
      votes: Number(c.votes || 0),
      karma: Number(c.karma || 0),
      since: Number(c.profileSince || 0),
      createdAtMs: new Date(c.createdAt).getTime() || 0
    }));
    const totalVotes = norm.reduce((s, c) => s + c.votes, 0);
    if (totalVotes > 0) {
      const maxVotes = Math.max(...norm.map(c => c.votes));
      let tied = norm.filter(c => c.votes === maxVotes);
      if (tied.length === 1) return { chosen: tied[0], totalVotes, winnerVotes: maxVotes };
      const maxKarma = Math.max(...tied.map(c => c.karma));
      tied = tied.filter(c => c.karma === maxKarma);
      if (tied.length === 1) return { chosen: tied[0], totalVotes, winnerVotes: maxVotes };
      tied.sort((a, b) => (a.since || 0) - (b.since || 0));
      const oldestSince = tied[0].since || 0;
      tied = tied.filter(c => c.since === oldestSince);
      if (tied.length === 1) return { chosen: tied[0], totalVotes, winnerVotes: maxVotes };
      tied.sort((a, b) => a.createdAtMs - b.createdAtMs);
      const earliest = tied[0].createdAtMs;
      tied = tied.filter(c => c.createdAtMs === earliest);
      if (tied.length === 1) return { chosen: tied[0], totalVotes, winnerVotes: maxVotes };
      tied.sort((a, b) => String(a.targetId).localeCompare(String(b.targetId)));
      return { chosen: tied[0], totalVotes, winnerVotes: maxVotes };
    }
    const latest = norm.sort((a, b) => b.createdAtMs - a.createdAtMs)[0];
    return { chosen: latest, totalVotes: 0, winnerVotes: 0 };
  }

  async function summarizePoliciesForTerm(termOrId) {
    let termId = null;
    let termStartMs = null;
    let termEndMs = null;
    if (termOrId && typeof termOrId === 'object') {
      termId = termOrId.id || termOrId.startAt;
      if (termOrId.startAt) termStartMs = new Date(termOrId.startAt).getTime();
      if (termOrId.endAt) termEndMs = new Date(termOrId.endAt).getTime();
    } else {
      termId = termOrId;
    }
    const proposals = await listByType('parliamentProposal');
    const mine = proposals.filter(p => {
      if (termId && p.termId === termId) return true;
      if (termStartMs != null && termEndMs != null && p.createdAt) {
        const t = new Date(p.createdAt).getTime();
        return t >= termStartMs && t <= termEndMs;
      }
      return false;
    });
    const proposed = mine.length;
    let approved = 0;
    let declined = 0;
    let discarded = 0;
    for (const p of mine) {
      const baseStatus = String(p.status || 'OPEN').toUpperCase();
      let finalStatus = baseStatus;
      let isDiscarded = false;
      if (p.voteId && services.votes?.getVoteById) {
        try {
          const v = await services.votes.getVoteById(p.voteId);
          const votesMap = v.votes || {};
          const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
          const total = Number(v.totalVotes ?? v.total ?? sum);
          const yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
          const dl = v.deadline || v.endAt || v.expiresAt || null;
          const closed = v.status === 'CLOSED' || (dl && moment(dl).isBefore(moment()));
          const reached = passesThreshold(p.method, total, yes);
          if (!closed) {
            if (dl && moment(dl).isBefore(moment()) && !reached) {
              isDiscarded = true;
            } else {
              finalStatus = 'OPEN';
            }
          } else {
            if (reached) finalStatus = 'APPROVED';
            else finalStatus = 'REJECTED';
          }
        } catch {}
      } else {
        if (baseStatus === 'OPEN' && p.deadline && moment(p.deadline).isBefore(moment())) {
          isDiscarded = true;
        }
      }
      if (isDiscarded) {
        discarded++;
        continue;
      }
      if (finalStatus === 'ENACTED') {
        approved++;
        continue;
      }
      if (finalStatus === 'APPROVED') {
        approved++;
        continue;
      }
      if (finalStatus === 'REJECTED') {
        declined++;
        continue;
      }
    }
    const revs = await listByType('parliamentRevocation');
    const revocated = revs.filter(r => {
      if (r.status !== 'ENACTED') return false;
      if (termId && r.termId === termId) return true;
      if (termStartMs != null && termEndMs != null && r.createdAt) {
        const t = new Date(r.createdAt).getTime();
        return t >= termStartMs && t <= termEndMs;
      }
      return false;
    }).length;
    return { proposed, approved, declined, discarded, revocated };
  }

  async function computeGovernmentCard(term) {
    if (!term) return null;
    const method = term.method || 'DEMOCRACY';
    const isTribe = term.powerType === 'tribe';
    let members = 1;
    if (isTribe && term.powerId) {
      const tribe = services.tribes ? await services.tribes.getTribeById(term.powerId) : null;
      members = tribe && Array.isArray(tribe.members) ? tribe.members.length : 0;
    }
    const pol = await summarizePoliciesForTerm({ ...term });
    const eff = pol.proposed > 0 ? Math.round((pol.approved / pol.proposed) * 100) : 0;
    return {
      method,
      powerType: term.powerType,
      powerId: term.powerId,
      powerTitle: term.powerTitle,
      votesReceived: term.winnerVotes || 0,
      totalVotes: term.totalVotes || 0,
      members,
      since: term.startAt,
      end: term.endAt,
      proposed: pol.proposed,
      approved: pol.approved,
      declined: pol.declined,
      discarded: pol.discarded,
      revocated: pol.revocated,
      efficiency: eff
    };
  }

  async function countMyProposalsThisTerm(term) {
    const termId = term.id || term.startAt;
    const proposals = await listByType('parliamentProposal');
    const laws = await listByType('parliamentLaw');
    const nProp = proposals.filter(p => p.termId === termId && p.proposer === userId).length;
    const nLaw = laws.filter(l => l.termId === termId && l.proposer === userId).length;
    return nProp + nLaw;
  }

  async function getGroupMembers(term) {
    if (!term) return [];
    if (term.powerType === 'inhabitant') return [term.powerId];
    if (term.powerType === 'tribe') {
      const tribe = services.tribes ? await services.tribes.getTribeById(term.powerId) : null;
      return ensureArray(tribe?.members || []);
    }
    return [];
  }

  async function closeExpiredKarmatocracy(term) {
    const termId = term.id || term.startAt;
    const all = await listByType('parliamentProposal');
    const pending = all.filter(p =>
      p.termId === termId &&
      String(p.method).toUpperCase() === 'KARMATOCRACY' &&
      (p.status || 'OPEN') !== 'ENACTED' &&
      p.deadline && moment().isAfter(parseISO(p.deadline))
    );
    if (!pending.length) return;
    const withKarma = await Promise.all(pending.map(async p => ({
      ...p,
      karma: await getInhabitantKarma(p.proposer),
      createdAtMs: new Date(p.createdAt).getTime() || 0
    })));
    withKarma.sort((a, b) => {
      if (b.karma !== a.karma) return b.karma - a.karma;
      if (a.createdAtMs !== b.createdAtMs) return a.createdAtMs - b.createdAtMs;
      return String(a.proposer).localeCompare(String(b.proposer));
    });
    const winner = withKarma[0];
    const losers = withKarma.slice(1);
    const ssbClient = await openSsb();
    const approve = { ...winner, replaces: winner.id, status: 'APPROVED', updatedAt: nowISO() };
    await new Promise((resolve, reject) => ssbClient.publish(approve, (e, r) => (e ? reject(e) : resolve(r))));
    for (const lo of losers) {
      const rej = { ...lo, replaces: lo.id, status: 'REJECTED', updatedAt: nowISO() };
      await new Promise((resolve) => ssbClient.publish(rej, () => resolve()));
    }
  }

  async function closeExpiredDictatorship(term) {
    const termId = term.id || term.startAt;
    const all = await listByType('parliamentProposal');
    const pending = all.filter(p =>
      p.termId === termId &&
      String(p.method).toUpperCase() === 'DICTATORSHIP' &&
      (p.status || 'OPEN') !== 'ENACTED' &&
      p.deadline && moment().isAfter(parseISO(p.deadline))
    );
    if (!pending.length) return;
    const ssbClient = await openSsb();
    for (const p of pending) {
      const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
      await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
    }
  }

  async function closeExpiredRevocationKarmatocracy(term) {
    const termId = term.id || term.startAt;
    const all = await listByType('parliamentRevocation');
    const pending = all.filter(p =>
      p.termId === termId &&
      String(p.method).toUpperCase() === 'KARMATOCRACY' &&
      (p.status || 'OPEN') !== 'ENACTED' &&
      p.deadline && moment().isAfter(parseISO(p.deadline))
    );
    if (!pending.length) return;
    const ssbClient = await openSsb();
    for (const p of pending) {
      const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
      await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
    }
  }

  async function closeExpiredRevocationDictatorship(term) {
    const termId = term.id || term.startAt;
    const all = await listByType('parliamentRevocation');
    const pending = all.filter(p =>
      p.termId === termId &&
      String(p.method).toUpperCase() === 'DICTATORSHIP' &&
      (p.status || 'OPEN') !== 'ENACTED' &&
      p.deadline && moment().isAfter(parseISO(p.deadline))
    );
    if (!pending.length) return;
    const ssbClient = await openSsb();
    for (const p of pending) {
      const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
      await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
    }
  }

  async function createRevocation({ lawId, title, reasons }) {
    const term = await getCurrentTermBase();
    if (!term) throw new Error('No active government');
    const allowed = await this.canPropose();
    if (!allowed) throw new Error('You are not in the goverment, yet.');
    const lawIdStr = String(lawId || '').trim();
    if (!lawIdStr) throw new Error('Law required');
    const laws = await listByType('parliamentLaw');
    const law = laws.find(l => l.id === lawIdStr);
    if (!law) throw new Error('Law not found');
    const method = String(term.method || 'DEMOCRACY').toUpperCase();
    const ssbClient = await openSsb();
    const deadline = moment().add(REVOCATION_DAYS, 'days').toISOString();
    if (method === 'DICTATORSHIP' || method === 'KARMATOCRACY') {
      const rev = {
        type: 'parliamentRevocation',
        lawId: lawIdStr,
        title: title || law.question || '',
        reasons: reasons || '',
        method,
        termId: term.id || term.startAt,
        proposer: userId,
        status: 'OPEN',
        deadline,
        createdAt: nowISO()
      };
      return await new Promise((resolve, reject) =>
        ssbClient.publish(rev, (e, r) => (e ? reject(e) : resolve(r)))
      );
    }
    const voteMsg = await services.votes.createVote(
      `Revoke: ${title || law.question || ''}`,
      deadline,
      ['YES', 'NO', 'ABSTENTION'],
      [`gov:${term.id || term.startAt}`, `govMethod:${method}`, 'revocation']
    );
    const rev = {
      type: 'parliamentRevocation',
      lawId: lawIdStr,
      title: title || law.question || '',
      reasons: reasons || '',
      method,
      voteId: voteMsg.key || voteMsg.id,
      termId: term.id || term.startAt,
      proposer: userId,
      status: 'OPEN',
      createdAt: nowISO()
    };
    return await new Promise((resolve, reject) =>
      ssbClient.publish(rev, (e, r) => (e ? reject(e) : resolve(r)))
    );
  }

  async function closeRevocation(revId) {
    const ssbClient = await openSsb();
    const msg = await new Promise((resolve, reject) => ssbClient.get(revId, (e, m) => (e || !m) ? reject(new Error('Revocation not found')) : resolve(m)));
    if (msg.content?.type !== 'parliamentRevocation') throw new Error('Revocation not found');
    const p = msg.content;
    if (p.method === 'DICTATORSHIP') {
      const updated = { ...p, replaces: revId, status: 'APPROVED', updatedAt: nowISO() };
      return await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
    }
    if (p.method === 'KARMATOCRACY') {
      return p;
    }
    const v = await services.votes.getVoteById(p.voteId);
    const votesMap = v.votes || {};
    const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
    const total = Number(v.totalVotes ?? v.total ?? sum);
    const yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
    let ok = false;
    const m = String(p.method || '').toUpperCase();
    if (m === 'DEMOCRACY' || m === 'ANARCHY') ok = yes >= democracyThreshold(total);
    else if (m === 'MAJORITY') ok = yes >= majorityThreshold(total);
    else if (m === 'MINORITY') ok = yes >= minorityThreshold(total);
    const updated = { ...p, replaces: revId, status: ok ? 'APPROVED' : 'REJECTED', updatedAt: nowISO() };
    return await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
  }

  async function proposeCandidature({ candidateId, method }) {
    const m = String(method || '').toUpperCase();
    if (!METHODS.includes(m)) throw new Error('Invalid method');
    const target = await resolveTarget(candidateId);
    if (!target) throw new Error('Candidate not found');
    const term = await getCurrentTermBase();
    const since = currentCycleStart(term);
    const myAll = await listByType('parliamentCandidature');
    const mineThisCycle = myAll.filter(c => c.proposer === userId && new Date(c.createdAt) >= new Date(since));
    if (mineThisCycle.length >= 3) throw new Error('Candidate limit reached');
    const open = await listCandidaturesOpenRaw();
    const duplicate = open.find(c => c.targetType === target.type && c.targetId === target.id && new Date(c.createdAt) >= new Date(since));
    if (duplicate) throw new Error('Candidate already proposed this cycle');
    const content = {
      type: 'parliamentCandidature',
      targetType: target.type,
      targetId: target.id,
      targetTitle: target.title,
      method: m,
      votes: 0,
      voters: [],
      proposer: userId,
      status: 'OPEN',
      createdAt: nowISO()
    };
    const ssbClient = await openSsb();
    return new Promise((resolve, reject) => ssbClient.publish(content, (e, r) => (e ? reject(e) : resolve(r))));
  }

  async function voteCandidature(candidatureMsgId) {
    const ssbClient = await openSsb();
    const open = await listCandidaturesOpenRaw();
    const already = open.some(c => ensureArray(c.voters).includes(userId));
    if (already) throw new Error('Already voted this cycle');
    return new Promise((resolve, reject) => {
      ssbClient.get(candidatureMsgId, (err, msg) => {
        if (err || !msg || msg.content?.type !== 'parliamentCandidature') return reject(new Error('Candidate not found'));
        const c = msg.content;
        if ((c.status || 'OPEN') !== 'OPEN') return reject(new Error('Closed'));
        const updated = { ...c, replaces: candidatureMsgId, votes: Number(c.votes || 0) + 1, voters: [...ensureArray(c.voters), userId], updatedAt: nowISO() };
        ssbClient.publish(updated, (e2, r2) => (e2 ? reject(e2) : resolve(r2)));
      });
    });
  }

  async function createProposal({ title, description }) {
    let term = await getCurrentTermBase();
    if (!term) {
      await this.resolveElection();
      term = await getCurrentTermBase();
    }
    if (!term) throw new Error('No active government');
    const allowed = await this.canPropose();
    if (!allowed) throw new Error('You are not in the goverment, yet.');
    if (!title || !title.trim()) throw new Error('Title required');
    if (String(description || '').length > 1000) throw new Error('Description too long');
    const used = await countMyProposalsThisTerm(term);
    if (used >= 3) throw new Error('Proposal limit reached');
    const method = String(term.method || 'DEMOCRACY').toUpperCase();
    const ssbClient = await openSsb();
    if (method === 'DICTATORSHIP') {
      const deadline = moment().add(PROPOSAL_DAYS, 'days').toISOString();
      const proposal = { type: 'parliamentProposal', title, description: description || '', method, termId: term.id || term.startAt, proposer: userId, status: 'OPEN', deadline, createdAt: nowISO() };
      return await new Promise((resolve, reject) => ssbClient.publish(proposal, (e, r) => (e ? reject(e) : resolve(r))));
    }
    if (method === 'KARMATOCRACY') {
      const deadline = moment().add(PROPOSAL_DAYS, 'days').toISOString();
      const proposal = { type: 'parliamentProposal', title, description: description || '', method, termId: term.id || term.startAt, proposer: userId, status: 'OPEN', deadline, createdAt: nowISO() };
      return await new Promise((resolve, reject) => ssbClient.publish(proposal, (e, r) => (e ? reject(e) : resolve(r))));
    }
    const deadline = moment().add(PROPOSAL_DAYS, 'days').toISOString();
    const voteMsg = await services.votes.createVote(title, deadline, ['YES', 'NO', 'ABSTENTION'], [`gov:${term.id || term.startAt}`, `govMethod:${method}`, 'proposal']);
    const proposal = { type: 'parliamentProposal', title, description: description || '', method, voteId: voteMsg.key || voteMsg.id, termId: term.id || term.startAt, proposer: userId, status: 'OPEN', createdAt: nowISO() };
    return await new Promise((resolve, reject) => ssbClient.publish(proposal, (e, r) => (e ? reject(e) : resolve(r))));
  }

  async function closeProposal(proposalId) {
    const ssbClient = await openSsb();
    const msg = await new Promise((resolve, reject) => ssbClient.get(proposalId, (e, m) => (e || !m) ? reject(new Error('Proposal not found')) : resolve(m)));
    if (msg.content?.type !== 'parliamentProposal') throw new Error('Proposal not found');
    const p = msg.content;
    if (p.method === 'DICTATORSHIP') {
      const updated = { ...p, replaces: proposalId, status: 'APPROVED', updatedAt: nowISO() };
      return await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
    }
    if (p.method === 'KARMATOCRACY') {
      return p;
    }
    const v = await services.votes.getVoteById(p.voteId);
    const votesMap = v.votes || {};
    const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
    const total = Number(v.totalVotes ?? v.total ?? sum);
    const yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
    let ok = false;
    const m = String(p.method || '').toUpperCase();
    if (m === 'DEMOCRACY' || m === 'ANARCHY') ok = yes >= democracyThreshold(total);
    else if (m === 'MAJORITY') ok = yes >= majorityThreshold(total);
    else if (m === 'MINORITY') ok = yes >= minorityThreshold(total);
    const updated = { ...p, replaces: proposalId, status: ok ? 'APPROVED' : 'REJECTED', updatedAt: nowISO() };
    return await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
  }

  async function sweepProposals() {
    const term = await getCurrentTermBase();
    if (!term) return;
    await closeExpiredKarmatocracy(term);
    await closeExpiredDictatorship(term);
    const ssbClient = await openSsb();
    const allProps = await listByType('parliamentProposal');
    const voteProps = allProps.filter(p => {
      const m = String(p.method || '').toUpperCase();
      return (m === 'DEMOCRACY' || m === 'ANARCHY' || m === 'MAJORITY' || m === 'MINORITY') && p.voteId;
    });
    for (const p of voteProps) {
      try {
        const v = await services.votes.getVoteById(p.voteId);
        const votesMap = v.votes || {};
        const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
        const total = Number(v.totalVotes ?? v.total ?? sum);
        const yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
        const closed = v.status === 'CLOSED' || (v.deadline && moment(v.deadline).isBefore(moment()));
        if (closed) { try { await this.closeProposal(p.id); } catch {} ; continue; }
        if ((p.status || 'OPEN') === 'OPEN' && passesThreshold(p.method, total, yes)) {
          const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
          await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
        }
      } catch {}
    }
    await closeExpiredRevocationKarmatocracy(term);
    await closeExpiredRevocationDictatorship(term);
    const revs = await listByType('parliamentRevocation');
    const voteRevs = revs.filter(p => {
      const m = String(p.method || '').toUpperCase();
      return (m === 'DEMOCRACY' || m === 'ANARCHY' || m === 'MAJORITY' || m === 'MINORITY') && p.voteId;
    });
    for (const p of voteRevs) {
      try {
        const v = await services.votes.getVoteById(p.voteId);
        const votesMap = v.votes || {};
        const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
        const total = Number(v.totalVotes ?? v.total ?? sum);
        const yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
        const closed = v.status === 'CLOSED' || (v.deadline && moment(v.deadline).isBefore(moment()));
        if (closed) { try { await closeRevocation(p.id); } catch {} ; continue; }
        if ((p.status || 'OPEN') === 'OPEN' && passesThreshold(p.method, total, yes)) {
          const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
          await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
        }
      } catch {}
    }
  }

  async function getActorMeta({ targetType, targetId }) {
    return await actorMeta({ targetType, targetId });
  }

  async function listCandidatures(filter = 'OPEN') {
    if (filter === 'OPEN') return await listCandidaturesOpen();
    const all = await listByType('parliamentCandidature');
    return all.sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));
  }

  async function listTerms(filter = 'all') {
    return await listTermsBase(filter);
  }

  async function getCurrentTerm() {
    return await getCurrentTermBase();
  }

  async function listLeaders() {
    const terms = await listTermsBase('all');
    const map = new Map();
    for (const t of terms) {
      if (!(t.powerType === 'tribe' || t.powerType === 'inhabitant')) continue;
      const k = `${t.powerType}:${t.powerId}`;
      if (!map.has(k)) map.set(k, { powerType: t.powerType, powerId: t.powerId, powerTitle: t.powerTitle, inPower: 0, presented: 0, proposed: 0, approved: 0, declined: 0, discarded: 0, revocated: 0 });
      const rec = map.get(k);
      rec.inPower += 1;
      const sum = await summarizePoliciesForTerm(t);
      rec.proposed += sum.proposed;
      rec.approved += sum.approved;
      rec.declined += sum.declined;
      rec.discarded += sum.discarded;
      rec.revocated += sum.revocated;
    }
    const cands = await listByType('parliamentCandidature');
    for (const c of cands) {
      const k = `${c.targetType}:${c.targetId}`;
      if (!map.has(k)) map.set(k, { powerType: c.targetType, powerId: c.targetId, powerTitle: c.targetTitle, inPower: 0, presented: 0, proposed: 0, approved: 0, declined: 0, discarded: 0, revocated: 0 });
      const rec = map.get(k);
      rec.presented = (rec.presented || 0) + 1;
    }
    const rows = [...map.values()].map(r => ({ ...r, presented: r.presented || 0, efficiency: (r.proposed > 0 ? r.approved / r.proposed : 0) }));
    rows.sort((a, b) => {
      if (b.approved !== a.approved) return b.approved - a.approved;
      if ((b.efficiency || 0) !== (a.efficiency || 0)) return (b.efficiency || 0) - (a.efficiency || 0);
      if (b.inPower !== a.inPower) return b.inPower - a.inPower;
      if (b.proposed !== a.proposed) return b.proposed - a.proposed;
      return String(a.powerId).localeCompare(String(b.powerId));
    });
    return rows;
  }

  async function listProposalsCurrent() {
    const all = await listByType('parliamentProposal');
    const rows = all
      .sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));
    const out = [];
    for (const p of rows) {
      const status = String(p.status || 'OPEN').toUpperCase();
      if (status === 'ENACTED' || status === 'REJECTED' || status === 'DISCARDED') continue;
      let deadline = p.deadline || null;
      let yes = 0;
      let total = 0;
      let voteClosed = false;
      if (p.voteId && services.votes?.getVoteById) {
        try {
          const v = await services.votes.getVoteById(p.voteId);
          const votesMap = v.votes || {};
          const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
          total = Number(v.totalVotes ?? v.total ?? sum);
          yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
          deadline = deadline || v.deadline || v.endAt || v.expiresAt || null;
          voteClosed = v.status === 'CLOSED' || (deadline && moment(deadline).isBefore(moment()));
          if (voteClosed) {
            try { await this.closeProposal(p.id); } catch {}
            continue;
          }
          const reached = passesThreshold(p.method, total, yes);
          if (reached && status !== 'APPROVED') {
            const ssbClient = await openSsb();
            const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
            await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
          }
        } catch {}
      }
      const needed = requiredVotes(p.method, total);
      const onTrack = passesThreshold(p.method, total, yes);
      out.push({ ...p, deadline, yes, total, needed, onTrack });
    }
    return out;
  }

 async function listFutureLawsCurrent() {
  const term = await getCurrentTermBase();
  if (!term) return [];
  const termId = term.id || term.startAt;
  const all = await listByType('parliamentProposal');
  const rows = all
    .filter(p => p.termId === termId)
    .filter(p => p.status === 'APPROVED')
    .sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));
  const out = [];
  for (const p of rows) {
    let yes = 0;
    let total = 0;
    let deadline = p.deadline || null;
    let voteClosed = true;
    if (p.voteId && services.votes?.getVoteById) {
      try {
        const v = await services.votes.getVoteById(p.voteId);
        const votesMap = v.votes || {};
        const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
        total = Number(v.totalVotes ?? v.total ?? sum);
        yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
        deadline = deadline || v.deadline || v.endAt || v.expiresAt || null;
        voteClosed = v.status === 'CLOSED' || (deadline && moment(deadline).isBefore(moment()));
        if (!voteClosed) continue;
      } catch {}
    }
    const needed = requiredVotes(p.method, total);
    out.push({ ...p, deadline, yes, total, needed });
  }
  return out;
 }

 async function listRevocationsCurrent() {
  const all = await listByType('parliamentRevocation');
  const rows = all
    .sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));
  const out = [];
  for (const p of rows) {
    const status = String(p.status || 'OPEN').toUpperCase();
    if (status === 'ENACTED' || status === 'REJECTED' || status === 'DISCARDED') continue;
    let deadline = p.deadline || null;
    let yes = 0;
    let total = 0;
    let voteClosed = false;
    if (p.voteId && services.votes?.getVoteById) {
      try {
        const v = await services.votes.getVoteById(p.voteId);
        const votesMap = v.votes || {};
        const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
        total = Number(v.totalVotes ?? v.total ?? sum);
        yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
        deadline = deadline || v.deadline || v.endAt || v.expiresAt || null;
        voteClosed = v.status === 'CLOSED' || (deadline && moment(deadline).isBefore(moment()));
        if (voteClosed) {
          try { await closeRevocation(p.id); } catch {}
          continue;
        }
        const reached = passesThreshold(p.method, total, yes);
        if (reached && status !== 'APPROVED') {
          const ssbClient = await openSsb();
          const updated = { ...p, replaces: p.id, status: 'APPROVED', updatedAt: nowISO() };
          await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
        }
      } catch {}
    }
    const needed = requiredVotes(p.method, total);
    const onTrack = passesThreshold(p.method, total, yes);
    out.push({ ...p, deadline, yes, total, needed, onTrack });
  }
  return out;
}
  
async function listFutureRevocationsCurrent() {
  const term = await getCurrentTermBase();
  if (!term) return [];
  const termId = term.id || term.startAt;
  const all = await listByType('parliamentRevocation');
  const rows = all
    .filter(p => p.termId === termId)
    .filter(p => p.status === 'APPROVED')
    .sort((a, b) => new Date(b.createdAt) - new Date(a.createdAt));
  const out = [];
  for (const p of rows) {
    let yes = 0;
    let total = 0;
    let deadline = p.deadline || null;
    let voteClosed = true;
    if (p.voteId && services.votes?.getVoteById) {
      try {
        const v = await services.votes.getVoteById(p.voteId);
        const votesMap = v.votes || {};
        const sum = Object.values(votesMap).reduce((s, n) => s + Number(n || 0), 0);
        total = Number(v.totalVotes ?? v.total ?? sum);
        yes = Number(votesMap.YES ?? votesMap.Yes ?? votesMap.yes ?? 0);
        deadline = deadline || v.deadline || v.endAt || v.expiresAt || null;
        voteClosed = v.status === 'CLOSED' || (deadline && moment(deadline).isBefore(moment()));
        if (!voteClosed) continue;
      } catch {}
    }
    const needed = requiredVotes(p.method, total);
    out.push({ ...p, deadline, yes, total, needed });
  }
  return out;
}

  async function countRevocationsEnacted() {
    const all = await listByType('parliamentRevocation');
    return all.filter(r => r.status === 'ENACTED').length;
  }

  async function enactApprovedChanges(expiringTerm) {
    if (!expiringTerm) return;
    const termId = expiringTerm.id || expiringTerm.startAt;
    const ssbClient = await openSsb();
    const proposals = await listByType('parliamentProposal');
    const revocations = await listByType('parliamentRevocation');
    const approvedProps = proposals.filter(p => p.termId === termId && p.status === 'APPROVED');
    for (const p of approvedProps) {
      const law = {
        type: 'parliamentLaw',
        question: p.title,
        description: p.description || '',
        method: p.method,
        proposer: p.proposer,
        termId: p.termId,
        votes: p.votes || (p.voteId ? {} : { YES: 1, NO: 0, ABSTENTION: 0, total: 1 }),
        proposedAt: p.createdAt,
        proposalId: p.id,
        enactedAt: nowISO()
      };
      await new Promise((resolve, reject) => ssbClient.publish(law, (e, r) => (e ? reject(e) : resolve(r))));
      const updated = { ...p, replaces: p.id, status: 'ENACTED', updatedAt: nowISO() };
      await new Promise((resolve, reject) => ssbClient.publish(updated, (e, r) => (e ? reject(e) : resolve(r))));
    }
    const approvedRevs = revocations.filter(r => r.termId === termId && r.status === 'APPROVED');
    for (const r of approvedRevs) {
      const tomb = { type: 'tombstone', target: r.lawId, deletedAt: nowISO(), author: userId };
      await new Promise((resolve) => ssbClient.publish(tomb, () => resolve()));
      const updated = { ...r, replaces: r.id, status: 'ENACTED', updatedAt: nowISO() };
      await new Promise((resolve, reject) => ssbClient.publish(updated, (e, rs) => (e ? reject(e) : resolve(rs))));
    }
  }

  async function resolveElection() {
    const now = moment();
    const current = await getCurrentTermBase();
    if (current && now.isBefore(parseISO(current.endAt))) return current;
    if (current) {
      try { await enactApprovedChanges(current); } catch {}
    }
    const open = await listCandidaturesOpen();
    let chosen = null;
    let totalVotes = 0;
    let winnerVotes = 0;
    if (open.length) {
      const pick = await chooseWinnerFromCandidaturesAsync(open);
      chosen = pick && pick.chosen;
      totalVotes = (pick && pick.totalVotes) || 0;
      winnerVotes = (pick && pick.winnerVotes) || 0;
    }
    const startAt = now.toISOString();
    const endAt = moment(startAt).add(TERM_DAYS, 'days').toISOString();
    if (!chosen) {
      const termAnarchy = {
        type: 'parliamentTerm',
        method: 'ANARCHY',
        powerType: 'none',
        powerId: null,
        powerTitle: 'ANARCHY',
        winnerTribeId: null,
        winnerInhabitantId: null,
        winnerVotes: 0,
        totalVotes: 0,
        startAt,
        endAt,
        createdBy: userId,
        createdAt: nowISO()
      };
      const ssbClient = await openSsb();
      const resAnarchy = await new Promise((resolve, reject) =>
        ssbClient.publish(termAnarchy, (e, r) => (e ? reject(e) : resolve(r)))
      );
      try {
        await sleep(250);
        const canonical = await getCurrentTermBase();
        if (canonical && canonical.id !== (resAnarchy.key || resAnarchy.id)) {
          const tomb = { type: 'tombstone', target: resAnarchy.key || resAnarchy.id, deletedAt: nowISO(), author: userId };
          await new Promise((resolve) => ssbClient.publish(tomb, () => resolve()));
          return canonical;
        }
      } catch {}
      await archiveAllCandidatures();
      return resAnarchy;
    }
    const term = {
      type: 'parliamentTerm',
      method: chosen.method,
      powerType: chosen.targetType,
      powerId: chosen.targetId,
      powerTitle: chosen.targetTitle,
      winnerTribeId: chosen.targetType === 'tribe' ? chosen.targetId : null,
      winnerInhabitantId: chosen.targetType === 'inhabitant' ? chosen.targetId : null,
      winnerVotes,
      totalVotes,
      startAt,
      endAt,
      createdBy: userId,
      createdAt: nowISO()
    };
    const ssbClient = await openSsb();
    const res = await new Promise((resolve, reject) =>
      ssbClient.publish(term, (e, r) => (e ? reject(e) : resolve(r)))
    );
    try {
      await sleep(250);
      const canonical = await getCurrentTermBase();
      if (canonical && canonical.id !== (res.key || res.id)) {
        const tomb = { type: 'tombstone', target: res.key || res.id, deletedAt: nowISO(), author: userId };
        await new Promise((resolve) => ssbClient.publish(tomb, () => resolve()));
        return canonical;
      }
    } catch {}
    await archiveAllCandidatures();
    return res;
  }

  async function getGovernmentCard() {
    let term = await getCurrentTermBase();
    if (!term) {
      await this.resolveElection();
      term = await getCurrentTermBase();
    }
    if (!term) return null;
    try { await this.sweepProposals(); } catch {}
    const full = await computeGovernmentCard({ ...term, id: term.id || term.startAt });
    return full;
  }

  async function listLaws() {
    const items = await listByType('parliamentLaw');
    return items.sort((a, b) => new Date(b.enactedAt) - new Date(a.enactedAt));
  }

  async function listHistorical() {
    const list = await listTermsBase('expired');
    const out = [];
    for (const t of list) {
      const card = await computeGovernmentCard({ ...t, id: t.id || t.startAt });
      if (card) out.push(card);
    }
    return out;
  }

  async function canPropose() {
    const term = await getCurrentTermBase();
    if (!term) return true;
    if (String(term.method || '').toUpperCase() === 'ANARCHY') return true;
    if (term.powerType === 'inhabitant') return term.powerId === userId;
    if (term.powerType === 'tribe') {
      const tribe = services.tribes ? await services.tribes.getTribeById(term.powerId) : null;
      const members = ensureArray(tribe?.members);
      return members.includes(userId);
    }
    return false;
  }

  return {
    proposeCandidature,
    voteCandidature,
    resolveElection,
    getGovernmentCard,
    listLaws,
    listHistorical,
    canPropose,
    listProposalsCurrent,
    listFutureLawsCurrent,
    createProposal,
    closeProposal,
    listCandidatures,
    listTerms,
    getCurrentTerm,
    listLeaders,
    sweepProposals,
    getActorMeta,
    createRevocation,
    listRevocationsCurrent,
    listFutureRevocationsCurrent,
    closeRevocation,
    countRevocationsEnacted
  };
};

function sleep(ms) { return new Promise(r => setTimeout(r, ms)); }
function collapseOverlappingTerms(terms = []) {
  if (!terms.length) return [];
  const sorted = [...terms].sort((a, b) => new Date(a.startAt) - new Date(b.startAt));
  const groups = [];
  for (const t of sorted) {
    const tStart = new Date(t.startAt).getTime();
    const tEnd = new Date(t.endAt).getTime();
    let placed = false;
    for (const g of groups) {
      if (tStart < g.maxEnd && tEnd > g.minStart) {
        g.items.push(t);
        if (tStart < g.minStart) g.minStart = tStart;
        if (tEnd > g.maxEnd) g.maxEnd = tEnd;
        placed = true;
        break;
      }
    }
    if (!placed) groups.push({ items: [t], minStart: tStart, maxEnd: tEnd });
  }
  const winners = groups.map(g => {
    g.items.sort((a, b) => {
      const aAn = String(a.method || '').toUpperCase() === 'ANARCHY' ? 1 : 0;
      const bAn = String(b.method || '').toUpperCase() === 'ANARCHY' ? 1 : 0;
      if (aAn !== bAn) return aAn - bAn;
      const aC = new Date(a.createdAt || a.startAt).getTime();
      const bC = new Date(b.createdAt || b.startAt).getTime();
      if (aC !== bC) return aC - bC;
      const aS = new Date(a.startAt).getTime();
      const bS = new Date(b.startAt).getTime();
      if (aS !== bS) return aS - bS;
      return String(a.id || '').localeCompare(String(b.id || ''));
    });
    return g.items[0];
  });
  return winners.sort((a, b) => new Date(b.startAt) - new Date(a.startAt));
}