attendees-matcher.js

const { MIME_TYPES } = require('@semapps/mime-types');
const { ACTIVITY_TYPES } = require('@semapps/activitypub');
const { POST_EVENT_CONTACT_REQUEST, POST_EVENT_ACCEPT_CONTACT_REQUEST } = require('../config/patterns');
const { POST_EVENT_CONTACT_REQUEST_MAPPING } = require('../config/mappings');

module.exports = {
  name: 'events.attendees-matcher',
  dependencies: ['activity-mapping'],
  async started() {
    await this.broker.call('activity-mapping.addMapper', {
      match: POST_EVENT_CONTACT_REQUEST,
      mapping: POST_EVENT_CONTACT_REQUEST_MAPPING,
      priority: 2, // Before regular contact requests
    });

    await this.broker.call('activity-mapping.addMapper', {
      match: POST_EVENT_ACCEPT_CONTACT_REQUEST,
      mapping: false, // Ignore activity
      priority: 2, // Before regular accept contact requests
    });
  },
  events: {
    async 'events.status.finished'(ctx) {
      const { eventUri } = ctx.params;
      const event = await ctx.call('events.event.get', {
        resourceUri: eventUri,
        accept: MIME_TYPES.JSON,
        webId: 'system',
      });

      const collection = await ctx.call('activitypub.collection.get', {
        collectionUri: event['apods:attendees'],
        webId: 'system',
      });

      for (let attendeeUri of collection.items) {
        const attendee = await ctx.call('activitypub.actor.get', { actorUri: attendeeUri });

        let potentialNewContacts = [];
        for (let otherAttendeeUri of collection.items.filter((uri) => uri !== attendeeUri)) {
          const alreadyConnected = await ctx.call('activitypub.collection.includes', {
            collectionUri: attendee['apods:contacts'],
            itemUri: otherAttendeeUri,
          });
          if (!alreadyConnected) potentialNewContacts.push(otherAttendeeUri);
        }

        if (potentialNewContacts.length > 0) {
          await ctx.call('activitypub.outbox.post', {
            collectionUri: attendee.outbox,
            type: ACTIVITY_TYPES.OFFER,
            actor: attendee.id,
            object: {
              type: ACTIVITY_TYPES.ADD,
              object: attendee.url,
            },
            context: event.id,
            target: potentialNewContacts,
            to: potentialNewContacts,
          });
        }
      }
    },
  },
};