Method AttachmentRepository

api/pkg/di/container.go:1574–1601

AttachmentRepository creates a cached AttachmentRepository based on configuration

()

// AttachmentRepository creates a cached AttachmentRepository based on configuration
func (container *Container) AttachmentRepository() repositories.AttachmentRepository {
	if container.attachmentRepository != nil {
		return container.attachmentRepository
	}

	bucket := os.Getenv("GCS_BUCKET_NAME")
	if bucket != "" {
		container.logger.Debug("creating GoogleCloudStorageAttachmentRepository")
		client, err := storage.NewClient(context.Background(), option.WithAuthCredentialsJSON(option.ServiceAccount, container.FirebaseCredentials()))
		if err != nil {
			container.logger.Fatal(stacktrace.Propagate(err, "cannot create GCS client"))
		}
		container.attachmentRepository = repositories.NewGoogleCloudStorageAttachmentRepository(
			container.Logger(),
			container.Tracer(),
			client,
			bucket,
		)
	} else {
		container.logger.Debug("creating MemoryAttachmentRepository (GCS_BUCKET_NAME not set)")
		container.attachmentRepository = repositories.NewMemoryAttachmentRepository(
			container.Logger(),
			container.Tracer(),
		)
	}

	return container.attachmentRepository
}

// APIBaseURL returns the API base URL derived from EVENTS_QUEUE_ENDPOINT
func (container *Container) APIBaseURL() string {