Outbox not working

[redimongo]

I am just trying to get the basic functions working. A Hello world note that shows when a mastodon server goes to the users profile.

Now I am most likely wrong, but from what I understand It has to be done in the outbox area?

federation.setOutboxDispatcher("/users/{handle}/outbox", async (ctx, handle, cursor) => {
      // If a whole collection is requested, returns nothing as we prefer
      // collection pages over the whole collection:
      console.log("hello I ran");
      if (cursor == null) return null;
      // Generate a simple "Hello World" Create activity:
      const items = [
        new Create({
          id: new URL(`/posts/156157615761#activity`, ctx.url),
          actor: ctx.getActorUri(handle),
          object: new Article({
            id: new URL(`/posts/156157615761`, ctx.url),
            summary: "test",
            content: "Hello World",
          }),
        })
      ];
      return {
        items,
        nextCursor: null, // Since this is a static example, there's no pagination
      };
    }).setCounter(async (ctx, handle) => {
      // The following `countPostsByUserHandle` is a hypothetical function:
      return 1;
    });

Additionally I tried to make one that as all the functions setOutboxDispatcher, setActorDispatcher

federation
    .setActorDispatcher("/users/{handle}", async (ctx, handle, key) => {
      const userKey = await findUser({ username: handle });
      if (!userKey) return null;

      let actor;
      let actorIcon;
      let actorImage;
      let actorAttachments = [];

      // Add icon if it exists
      if (userKey.iconPic) {
        actorIcon = new Image({
          mediaType: userKey.iconPic.type,
          url: new URL(userKey.iconPic.url),
        });
      }

      // Add image if it exists
      if (userKey.image) {
        actorImage = new Image({
          mediaType: userKey.image.type,
          url: new URL(userKey.image.url),
        });
      }

      // Add attachments if they exist
      if (userKey.attachment && Array.isArray(userKey.attachment)) {
        actorAttachments = userKey.attachment.map(att => new PropertyValue({
          name: att.name,
          value: att.value,
        }));
      }

      const commonProperties = {
        id: ctx.getActorUri(handle),
        name: userKey.name,
        summary: "This is me!",
        preferredUsername: handle,
        url: new URL("/", ctx.url),
        inbox: ctx.getInboxUri(handle),
        icon: actorIcon,
        image: actorImage,
        publicKey: key,  // The public key of the actor; it's provided by the key
        attachments: actorAttachments
      };

      if (userKey.type === "Person") {
        actor = new Person(commonProperties);
      } else if (userKey.type === "Group") {
        actor = new Group(commonProperties);
      } else {
        console.error(`Unknown user type: ${userKey.type}`);
        return null;
      }

      return actor;
    })
    .setKeyPairDispatcher(async (ctx, handle) => {
      if (handle != "me") return null;  // Other than "me" is not found.
      const user = await kvGet(handle);
      if (!user) {
        console.error(`User ${handle} not found in database.`);
        return null;
      }

      if (!user.privateKey || !user.publicKey) {
        // Generate a new key pair if they do not exist
        const { privateKey, publicKey } = await generateCryptoKeyPair();
        const privateKeyJwk = await exportJwk(privateKey);
        const publicKeyJwk = await exportJwk(publicKey);

        await kvSet(handle, {
          privateKey: privateKeyJwk,
          publicKey: publicKeyJwk,
        });

        return { privateKey, publicKey };
      }

      // Load the key pair from the database
      const privateKey = await importJwk(user.privateKey, "private");
      const publicKey = await importJwk(user.publicKey, "public");
      return { privateKey, publicKey };
    })
    .setFollowersDispatcher(
      "/users/{handle}/followers",
      async (ctx, handle, cursor) => {
        // If a whole collection is requested, return nothing as we prefer
        // collection pages over the whole collection:
        if (cursor == null) return null;
        // Retrieve followers from the database:
        const { users, nextCursor, last } = await getFollowersByUserHandle(
          handle,
          cursor === "" ? { limit: 10 } : { cursor, limit: 10 }
        );
        // Turn the users into `Recipient` objects:
        const items = users.map(follower => ({
          id: new URL(follower.followerUrl),
          inboxId: new URL(follower.actorId),
        }));
        return { items, nextCursor: last ? null : nextCursor };
      }
    )
    .setFirstCursor(async (ctx, handle) => "")
    .setOutboxDispatcher("/users/{handle}/outbox", async (ctx, handle, cursor) => {
      // If a whole collection is requested, returns nothing as we prefer
      // collection pages over the whole collection:
      if (cursor == null) return null;
      // Generate a simple "Hello World" Create activity:
      const items = [
        new Create({
          id: new URL(`/posts/156157615761#activity`, ctx.url),
          actor: ctx.getActorUri(handle),
          object: new Article({
            id: new URL(`/posts/156157615761`, ctx.url),
            summary: "test",
            content: "Hello World",
          }),
        })
      ];
      return {
        items,
        nextCursor: null, // Since this is a static example, there's no pagination
      };
    });

and that doesn't work so seems every function needs to be a seperate federation.

[dahlia]

Mastodon does not show posts of an actor published before it follows the actor. Even if you properly implement the outbox. (Mastodon sees the outbox only for fetching the number of posts.) Did you implement an inbox listener for Follow?

[redimongo]

Update totalItems are now showing :) seems I missed

.setCounter(async (ctx, handle) => {
    // Use static array to count posts for testing
    return await countPosts(handle);
  })

Also the issue with the number of post for outbox is we get NULL but when you go to the next page you see the post

curl -H "Accept: application/activity+json" "https://fedi.podcastperformance.com/users/fresh7at7/outbox"   
{"@context":"https://www.w3.org/ns/activitystreams","type":"OrderedCollection","first":"https://fedi.podcastperformance.com/users/fresh7at7/outbox?cursor=0","last":"https://fedi.podcastperformance.com/users/fresh7at7/outbox?cursor=0","totalItems":null}%  

I believe I did it correctly as when a user follows it gets accepted and the user is added to the followers array in our database.

federation
    .setInboxListeners("/users/{handle}/inbox", "/inbox")
    .on(Create, async (ctx, create) => {
      console.log("Received Create Activity:");
      console.log(JSON.stringify(create, null, 2));  // Log the entire Create activity
      
      const noteis = await fetchData(create.id);
      console.log(JSON.stringify(noteis));
    })
    .on(Follow, async (ctx, follow) => {
      if (follow.id == null || follow.actorId == null || follow.objectId == null) {
        return;
      }
      const parsed = ctx.parseUri(follow.objectId);
      if (!parsed || !("handle" in parsed)) {
        throw new Error("Invalid follow request: No handle or incorrect type");
      }
      
      
      //if (parsed?.type !== "actor" || parsed.handle !== "russell") return;
      const follower = await follow.getActor(ctx);
      await ctx.sendActivity(
        { handle: parsed.handle },
        follower,
        new Accept({ actor: follow.objectId, object: follow }),
      );
      await followUser(parsed.handle, follow.id.href, follow.actorId.href);
      console.debug(follower);
    });

test user - https://fedi.podcastperformance.com/users/fresh7at7

after following

{
  "_id": {
    "$oid": "66673a10b0f426c2eeab51d4"
  },
  "name": "Fresh7@7",
  "username": "fresh7at7",
  "email": "fresh7at7@radiomedia.com.au",
  "type": "Group",
  "attachment": [
    {
      "name": "Location",
      "value": "Perth, Western Australia"
    },
    {
      "name": "Website",
      "value": "https://drn1.com.au"
    }
  ],
  "createdAt": "2024-06-11T18:41:26Z",
  "iconPic": {
    "type": "image/jpeg",
    "url": "https://cdn.podtoo.com/syndication/2024/05/500x500_653ca45a7afb07044fd035aa.jpg"
  },
  "image": {
    "type": "image/jpeg",
    "url": "https://cdn.podtoo.com/syndication/2024/01/1704951039685DRN1-5.jpg"
  },
(PRIVATE AND PUBLIC KEY REMOVED TO MAKE THIS MORE READABLE)
  "followers": [
    {
      "followerUrl": "https://mastodon.social/631254ee-2585-4b18-935f-15f1dc899821",
      "actorId": "https://mastodon.social/users/DRN1LIVE"
    },
    {
      "followerUrl": "https://podcastindex.social/141e2447-baf2-4ac1-bbce-84043b0d2b42",
      "actorId": "https://podcastindex.social/users/russell"
    }
  ]
}

[dahlia]

Also the issue with the number of post for outbox is we get NULL but when you go to the next page you see the post

That's strange. Did you check if your countPosts() returns null?