publishFunction.ts

export const handler = async (event: SQSEvent) => {
   const body = JSON.parse(event.body);
   const subscriptions = await subscriptionRepository.getByRoutingKey(body.routingKey);
  
   for(subscription of subscriptions) {
      const document = parse(subscription.subscription);
      const subscriptionResult = await subscribe({
         schema,
         document,
         variableValues: subscription.variables,
         contextValue: contextDeserializer(subscription.context),
      });
     
      do {
         const next = await result.next();
         await client.send(subscription.connectionId, next.value);
      } while (!next.done);
    }
};