in internal/subscriber/subscribe.go [42:49]
func NewSubscriberService(client *pubsub.Client, subscriptionId string, directoryRepo repo.DirectoryRepository, metadataRepo repo.MetadataRepository) *SubscriberService {
return &SubscriberService{
client,
subscriptionId,
directoryRepo,
metadataRepo,
}
}