Class ListeningActivityHandler

Listens to an ActivityEmitter and calls the stored NotificationHandlers in case of an event for every matching notification channel found.

Takes the rate feature into account so only channels that want a new notification will receive one.

Extends StaticHandler so it can be more easily injected into a Components.js configuration. No class takes this one as input, so to make sure Components.js instantiates it, it needs to be added somewhere where its presence has no impact, such as the list of initializers.

Hierarchy

Constructors

Properties

Methods

Constructors

Properties

logger: Logger = ...

Methods

  • Checks whether the input can be handled by this class. If it cannot handle the input, rejects with an error explaining why.

    Parameters

    • input: unknown

      Input that could potentially be handled.

    Returns Promise<void>

    A promise resolving if the input can be handled, rejecting with an Error if not.

  • Parameters

    • topic: ResourceIdentifier
    • activity: NamedNode<"https://www.w3.org/ns/activitystreams#Create"> | NamedNode<"https://www.w3.org/ns/activitystreams#object"> | NamedNode<"https://www.w3.org/ns/activitystreams#target"> | NamedNode<"https://www.w3.org/ns/activitystreams#Add"> | NamedNode<"https://www.w3.org/ns/activitystreams#Delete"> | NamedNode<"https://www.w3.org/ns/activitystreams#Remove"> | NamedNode<"https://www.w3.org/ns/activitystreams#Update">
    • metadata: RepresentationMetadata

    Returns Promise<void>

  • Helper function that first runs canHandle followed by handle. Throws the error of canHandle if the data cannot be handled, or returns the result of handle otherwise.

    Parameters

    • input: unknown

      Input data that will be handled if it can be handled.

    Returns Promise<void>

    A promise resolving if the input can be handled, rejecting with an Error if not.