Method Url

service/admin/file.go:312–359

(c *gin.Context)

}

func (s *SingleFileService) Url(c *gin.Context) (string, error) {
	dep := dependency.FromContext(c)
	fileClient := dep.FileClient()

	ctx := context.WithValue(c, inventory.LoadFileEntity{}, true)
	file, err := fileClient.GetByID(ctx, s.ID)
	if err != nil {
		return "", serializer.NewError(serializer.CodeDBError, "Failed to get file", err)
	}

	// find primary entity
	var primaryEntity *ent.Entity
	for _, entity := range file.Edges.Entities {
		if entity.Type == int(types.EntityTypeVersion) && entity.ID == file.PrimaryEntity {
			primaryEntity = entity
			break
		}
	}

	if primaryEntity == nil {
		return "", serializer.NewError(serializer.CodeNotFound, "Primary entity not exist", nil)
	}

	// find policy
	policy, err := dep.StoragePolicyClient().GetPolicyByID(ctx, primaryEntity.StoragePolicyEntities)
	if err != nil {
		return "", serializer.NewError(serializer.CodeDBError, "Failed to get policy", err)
	}

	m := manager.NewFileManager(dep, inventory.UserFromContext(c))
	defer m.Recycle()

	driver, err := m.GetStorageDriver(ctx, policy)
	if err != nil {
		return "", serializer.NewError(serializer.CodeInternalSetting, "Failed to get storage driver", err)
	}

	es := entitysource.NewEntitySource(fs.NewEntity(primaryEntity), driver, policy, dep.GeneralAuth(),
		dep.SettingProvider(), dep.HashIDEncoder(), dep.RequestClient(), dep.Logger(), dep.ConfigProvider(), dep.MimeDetector(ctx), dep.EncryptorFactory(ctx))

	expire := time.Now().Add(time.Hour * 1)
	url, err := es.Url(ctx, entitysource.WithExpire(&expire), entitysource.WithDisplayName(file.Name))
	if err != nil {
		return "", serializer.NewError(serializer.CodeInternalSetting, "Failed to get url", err)
	}

	return url.Url, nil
}

type (
	BatchFileService struct {