Subscription withFilter

[sgentile]

Describe the issue
The documentation highlights where you can use subscribe using the withFilter. There isn't an example of this . The part I'm unsure about is how to use the pubsub.asyncIterator from type-graphql.

export const resolvers = {
  Subscription: {
    somethingChanged: {
      subscribe: withFilter(() => pubsub.asyncIterator(SOMETHING_CHANGED_TOPIC), (payload, variables) => {
        return payload.somethingChanged.id === variables.relevantId;
      }),
    },
  },
}

My example. With this, how would I access pubsub ?

@Subscription({
        subscribe: withFilter(
            () => pubsub.asyncIterator('MESSAGES'),
            (payload, args, context, info) => {
                const result =
                    ((context.user && context.user.id === payload?.message.conversation.initiator.id) ||
                        (context.user && context.user.id === payload?.message.conversation.participant.id)) &&
                    context.user &&
                    context.user.id != payload?.message.sender.id;
                //     context.user.id !== payload?.notification.actionUser?.id; // if they created it don't include it
                console.log(result);
                return result;
            }
        ),
    })
    messageSubscription(@Ctx('user') user: User, @Root() { message }: MessageNotificationPayload): MessageNotification {
        return {
            message,
        };
    }

Are you able to make a PR that fix this?
I could update it if I knew correct way to do that above

Additional context
NA

[MichalLytek]

The documentation highlights where you can use subscribe using the withFilter.

You should use the TypeGraphQL API:
https://github.com/MichalLytek/type-graphql/blob/master/examples/simple-subscriptions/resolver.ts#L49-L56

[sgentile]

This is good - thank you!

Sorry to bother with another question, in that example it's using the payload and args, I need the payload and context, I see it supports the context

messageSubscription(
        @Root() { message }: MessageNotificationPayload,
        @Ctx('user') user: User
    ): MessageNotification {
        return {
            message,
        };
    }

I'm not sure how to pass it the context ?

ie.

filter: ({ payload, args, context }: ResolverFilterData<MessageNotificationPayload, ?, ?) => {

[MichalLytek]

Sorry but I don't understand your question. You have context available and it's the same that in @Ctx.

The value returned in withFilter (or filter:) is boolean that indicates if TypeGraphQL should call the method and send subscription data or not. It does not inject the returned data into the messageSubscription method.

[sgentile]

I figured it out - thanks!

 @Subscription({
        topics: 'NOTIFICATIONS',
        filter: ({ payload, args, context }: ResolverFilterData<NotificationMessagePayload, null, Context>) => {
            const result = context?.user?.id !== payload?.notification?.actionUser?.id;
            console.log(result);
            return result;
        },
    })
    notificationSubscription(
        @Ctx('user') user: User,
        @Root() { notification }: NotificationMessagePayload
    ): NotificationMessage {
        return {
            notification,
        };
    }