interactor

package
v0.0.0-...-fc7db47 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 10, 2025 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New 

func New(r *repo.Container, g *gateway.Container,
	ar *accountrepo.Container, ag *accountgateway.Container,
	config ContainerConfig) interfaces.Container

func NewAsset 

func NewAsset(r *repo.Container, g *gateway.Container) interfaces.Asset

func NewGroup 

func NewGroup(r *repo.Container, g *gateway.Container) interfaces.Group

func NewIntegration 

func NewIntegration(r *repo.Container, g *gateway.Container) interfaces.Integration

func NewModel 

func NewModel(r *repo.Container, g *gateway.Container) interfaces.Model

func NewProject 

func NewProject(r *repo.Container, g *gateway.Container) interfaces.Project

func NewSchema 

func NewSchema(r *repo.Container, g *gateway.Container) interfaces.Schema

func NewThread 

func NewThread(r *repo.Container, g *gateway.Container) interfaces.Thread

func NewView 

func NewView(r *repo.Container, g *gateway.Container) interfaces.View

func NewWorkspaceSettings 

func NewWorkspaceSettings(r *repo.Container, g *gateway.Container) interfaces.WorkspaceSettings

func Run0 

func Run0(ctx context.Context, op *usecase.Operator, r *repo.Container, e *uc, f func(context.Context) error) (err error)

func Run1 

func Run1[A any](ctx context.Context, op *usecase.Operator, r *repo.Container, e *uc, f func(context.Context) (A, error)) (a A, err error)

func Run2 

func Run2[A, B any](ctx context.Context, op *usecase.Operator, r *repo.Container, e *uc, f func(context.Context) (A, B, error)) (a A, b B, err error)

func Run3 

func Run3[A, B, C any](ctx context.Context, op *usecase.Operator, r *repo.Container, e *uc, f func(context.Context) (A, B, C, error)) (a A, b B, c C, err error)

func Usecase 

func Usecase() *uc

Types

type Asset 

type Asset struct {
	// contains filtered or unexported fields
}

func (*Asset) Create 

func (i *Asset) Create(ctx context.Context, inp interfaces.CreateAssetParam, op *usecase.Operator) (result *asset.Asset, afile *asset.File, err error)

func (*Asset) CreateUpload 

func (i *Asset) CreateUpload(ctx context.Context, inp interfaces.CreateAssetUploadParam, op *usecase.Operator) (*interfaces.AssetUpload, error)

func (*Asset) DecompressByID 

func (i *Asset) DecompressByID(ctx context.Context, aId id.AssetID, operator *usecase.Operator) (*asset.Asset, error)

func (*Asset) Delete 

func (i *Asset) Delete(ctx context.Context, aId id.AssetID, operator *usecase.Operator) (result id.AssetID, err error)

func (*Asset) DownloadByID 

func (i *Asset) DownloadByID(ctx context.Context, aid id.AssetID, headers map[string]string, _ *usecase.Operator) (io.ReadCloser, map[string]string, error)

func (*Asset) FindByID 

func (i *Asset) FindByID(ctx context.Context, aid id.AssetID, _ *usecase.Operator) (*asset.Asset, error)

func (*Asset) FindByIDs 

func (i *Asset) FindByIDs(ctx context.Context, assets []id.AssetID, _ *usecase.Operator) (asset.List, error)

func (*Asset) FindByProject 

func (i *Asset) FindByProject(ctx context.Context, pid id.ProjectID, filter interfaces.AssetFilter, _ *usecase.Operator) (asset.List, *usecasex.PageInfo, error)

func (*Asset) FindFileByID 

func (i *Asset) FindFileByID(ctx context.Context, aid id.AssetID, _ *usecase.Operator) (*asset.File, error)

func (*Asset) FindFilesByIDs 

func (i *Asset) FindFilesByIDs(ctx context.Context, ids id.AssetIDList, _ *usecase.Operator) (map[id.AssetID]*asset.File, error)

func (*Asset) GetURL 

func (i *Asset) GetURL(a *asset.Asset) string

func (*Asset) RetryDecompression 

func (i *Asset) RetryDecompression(ctx context.Context, id string) error

func (*Asset) Update 

func (i *Asset) Update(ctx context.Context, inp interfaces.UpdateAssetParam, operator *usecase.Operator) (result *asset.Asset, err error)

func (*Asset) UpdateFiles 

func (i *Asset) UpdateFiles(ctx context.Context, aid id.AssetID, s *asset.ArchiveExtractionStatus, op *usecase.Operator) (*asset.Asset, error)

type ContainerConfig 

type ContainerConfig struct {
	SignupSecret    string
	AuthSrvUIDomain string
}

type Event 

type Event struct {
	Project       *project.Project
	Workspace     accountdomain.WorkspaceID
	Type          event.Type
	Operator      operator.Operator
	Object        any
	WebhookObject any
}

func (*Event) EventProject 

func (e *Event) EventProject() *event.Project

type Group 

type Group struct {
	// contains filtered or unexported fields
}

func (Group) CheckKey 

func (i Group) CheckKey(ctx context.Context, pId id.ProjectID, s string) (bool, error)

func (Group) Create 

func (i Group) Create(ctx context.Context, param interfaces.CreateGroupParam, operator *usecase.Operator) (*group.Group, error)

func (Group) Delete 

func (i Group) Delete(ctx context.Context, groupID id.GroupID, operator *usecase.Operator) error

func (Group) FindByID 

func (i Group) FindByID(ctx context.Context, id id.GroupID, operator *usecase.Operator) (*group.Group, error)

func (Group) FindByIDs 

func (i Group) FindByIDs(ctx context.Context, ids id.GroupIDList, operator *usecase.Operator) (group.List, error)

func (Group) FindByKey 

func (i Group) FindByKey(ctx context.Context, pid id.ProjectID, group string, operator *usecase.Operator) (*group.Group, error)

func (Group) FindByModel 

func (i Group) FindByModel(ctx context.Context, modelID id.ModelID, operator *usecase.Operator) (group.List, error)

func (Group) FindByProject 

func (i Group) FindByProject(ctx context.Context, projectID id.ProjectID, operator *usecase.Operator) (group.List, error)

func (Group) FindModelsByGroup 

func (i Group) FindModelsByGroup(ctx context.Context, groupID id.GroupID, op *usecase.Operator) (model.List, error)

func (Group) Update 

func (i Group) Update(ctx context.Context, param interfaces.UpdateGroupParam, operator *usecase.Operator) (*group.Group, error)

func (Group) UpdateOrder 

func (i Group) UpdateOrder(ctx context.Context, ids id.GroupIDList, operator *usecase.Operator) (group.List, error)

type ImportRes 

type ImportRes interfaces.ImportItemsResponse

func NewImportRes 

func NewImportRes() ImportRes

func (*ImportRes) FieldAdded 

func (ir *ImportRes) FieldAdded(f *schema.Field)

func (*ImportRes) Into 

func (ir *ImportRes) Into() interfaces.ImportItemsResponse

func (*ImportRes) ItemInserted 

func (ir *ImportRes) ItemInserted()

func (*ImportRes) ItemSkipped 

func (ir *ImportRes) ItemSkipped()

func (*ImportRes) ItemUpdated 

func (ir *ImportRes) ItemUpdated()

type Integration 

type Integration struct {
	// contains filtered or unexported fields
}

func (Integration) Create 

func (i Integration) Create(ctx context.Context, param interfaces.CreateIntegrationParam, operator *usecase.Operator) (*integration.Integration, error)

func (Integration) CreateWebhook 

func (i Integration) CreateWebhook(ctx context.Context, iId id.IntegrationID, param interfaces.CreateWebhookParam, operator *usecase.Operator) (*integration.Webhook, error)

func (Integration) Delete 

func (i Integration) Delete(ctx context.Context, integrationId id.IntegrationID, operator *usecase.Operator) error

func (Integration) DeleteWebhook 

func (i Integration) DeleteWebhook(ctx context.Context, iId id.IntegrationID, wId id.WebhookID, operator *usecase.Operator) error

func (Integration) FindByIDs 

func (i Integration) FindByIDs(ctx context.Context, ids id.IntegrationIDList, operator *usecase.Operator) (integration.List, error)

func (Integration) FindByMe 

func (i Integration) FindByMe(ctx context.Context, operator *usecase.Operator) (integration.List, error)

func (Integration) RegenerateToken 

func (i Integration) RegenerateToken(ctx context.Context, iId id.IntegrationID, operator *usecase.Operator) (*integration.Integration, error)

func (Integration) Update 

func (i Integration) Update(ctx context.Context, iId id.IntegrationID, param interfaces.UpdateIntegrationParam, operator *usecase.Operator) (*integration.Integration, error)

func (Integration) UpdateWebhook 

func (i Integration) UpdateWebhook(ctx context.Context, iId id.IntegrationID, wId id.WebhookID, param interfaces.UpdateWebhookParam, operator *usecase.Operator) (*integration.Webhook, error)

type Item 

type Item struct {
	// contains filtered or unexported fields
}

func NewItem 

func NewItem(r *repo.Container, g *gateway.Container) *Item

func (Item) Create 

func (i Item) Create(ctx context.Context, param interfaces.CreateItemParam, operator *usecase.Operator) (item.Versioned, error)

func (Item) Delete 

func (i Item) Delete(ctx context.Context, itemID id.ItemID, operator *usecase.Operator) error

func (Item) FindAllVersionsByID 

func (i Item) FindAllVersionsByID(ctx context.Context, itemID id.ItemID, _ *usecase.Operator) (item.VersionedList, error)

func (Item) FindByAssets 

func (i Item) FindByAssets(ctx context.Context, list id.AssetIDList, _ *usecase.Operator) (map[id.AssetID]item.VersionedList, error)

func (Item) FindByID 

func (i Item) FindByID(ctx context.Context, itemID id.ItemID, _ *usecase.Operator) (item.Versioned, error)

func (Item) FindByIDs 

func (i Item) FindByIDs(ctx context.Context, ids id.ItemIDList, _ *usecase.Operator) (item.VersionedList, error)

func (Item) FindBySchema 

func (i Item) FindBySchema(ctx context.Context, schemaID id.SchemaID, sort *usecasex.Sort, p *usecasex.Pagination, _ *usecase.Operator) (item.VersionedList, *usecasex.PageInfo, error)

func (Item) FindPublicByID 

func (i Item) FindPublicByID(ctx context.Context, itemID id.ItemID, _ *usecase.Operator) (item.Versioned, error)

func (Item) FindPublicByModel 

func (i Item) FindPublicByModel(ctx context.Context, modelID id.ModelID, p *usecasex.Pagination, _ *usecase.Operator) (item.VersionedList, *usecasex.PageInfo, error)

func (Item) FindVersionByID 

func (i Item) FindVersionByID(ctx context.Context, itemID id.ItemID, ver version.VersionOrRef, _ *usecase.Operator) (item.Versioned, error)

func (Item) Import 

func (i Item) Import(ctx context.Context, param interfaces.ImportItemsParam, operator *usecase.Operator) (interfaces.ImportItemsResponse, error)

func (Item) IsItemReferenced 

func (i Item) IsItemReferenced(ctx context.Context, itemID id.ItemID, correspondingFieldID id.FieldID, _ *usecase.Operator) (bool, error)

func (Item) ItemStatus 

func (i Item) ItemStatus(ctx context.Context, itemsIds id.ItemIDList, _ *usecase.Operator) (map[id.ItemID]item.Status, error)

func (Item) ItemsAsCSV 

func (i Item) ItemsAsCSV(ctx context.Context, schemaPackage *schema.Package, page *int, perPage *int, operator *usecase.Operator) (interfaces.ExportItemsToCSVResponse, error)

ItemsAsCSV exports items data in content to csv file by schema package.

func (Item) ItemsAsGeoJSON 

func (i Item) ItemsAsGeoJSON(ctx context.Context, schemaPackage *schema.Package, page *int, perPage *int, operator *usecase.Operator) (interfaces.ExportItemsToGeoJSONResponse, error)

ItemsAsGeoJSON converts items to Geo JSON type given the schema package

func (Item) LastModifiedByModel 

func (i Item) LastModifiedByModel(ctx context.Context, model id.ModelID, _ *usecase.Operator) (time.Time, error)

func (Item) Publish 

func (i Item) Publish(ctx context.Context, itemIDs id.ItemIDList, operator *usecase.Operator) (item.VersionedList, error)

func (Item) Search 

func (i Item) Search(ctx context.Context, sp schema.Package, q *item.Query, p *usecasex.Pagination, _ *usecase.Operator) (item.VersionedList, *usecasex.PageInfo, error)

func (Item) TriggerImportJob 

func (i Item) TriggerImportJob(ctx context.Context, aId id.AssetID, mId id.ModelID, format, strategy, geoFieldKey string, mutateSchema bool, operator *usecase.Operator) error

func (Item) Unpublish 

func (i Item) Unpublish(ctx context.Context, itemIDs id.ItemIDList, operator *usecase.Operator) (item.VersionedList, error)

func (Item) Update 

func (i Item) Update(ctx context.Context, param interfaces.UpdateItemParam, operator *usecase.Operator) (item.Versioned, error)

type Model 

type Model struct {
	// contains filtered or unexported fields
}

func (Model) CheckKey 

func (i Model) CheckKey(ctx context.Context, pId id.ProjectID, s string) (bool, error)

func (Model) Copy 

func (i Model) Copy(ctx context.Context, params interfaces.CopyModelParam, operator *usecase.Operator) (*model.Model, error)

func (Model) Create 

func (i Model) Create(ctx context.Context, param interfaces.CreateModelParam, operator *usecase.Operator) (*model.Model, error)

func (Model) Delete 

func (i Model) Delete(ctx context.Context, modelID id.ModelID, operator *usecase.Operator) error

func (Model) FindByID 

func (i Model) FindByID(ctx context.Context, id id.ModelID, _ *usecase.Operator) (*model.Model, error)

func (Model) FindByIDOrKey 

func (i Model) FindByIDOrKey(ctx context.Context, p id.ProjectID, q model.IDOrKey, _ *usecase.Operator) (*model.Model, error)

func (Model) FindByIDs 

func (i Model) FindByIDs(ctx context.Context, ids []id.ModelID, _ *usecase.Operator) (model.List, error)

func (Model) FindByKey 

func (i Model) FindByKey(ctx context.Context, pid id.ProjectID, model string, _ *usecase.Operator) (*model.Model, error)

func (Model) FindByProject 

func (i Model) FindByProject(ctx context.Context, projectID id.ProjectID, pagination *usecasex.Pagination, _ *usecase.Operator) (model.List, *usecasex.PageInfo, error)

func (Model) FindByProjectAndKeyword 

func (i Model) FindByProjectAndKeyword(ctx context.Context, projectID id.ProjectID, k string, pagination *usecasex.Pagination, _ *usecase.Operator) (model.List, *usecasex.PageInfo, error)

func (Model) FindBySchema 

func (i Model) FindBySchema(ctx context.Context, id id.SchemaID, _ *usecase.Operator) (*model.Model, error)

func (Model) FindOrCreateSchema 

func (i Model) FindOrCreateSchema(ctx context.Context, param interfaces.FindOrCreateSchemaParam, operator *usecase.Operator) (*schema.Schema, error)

func (Model) Publish 

func (i Model) Publish(ctx context.Context, modelID id.ModelID, b bool, operator *usecase.Operator) (bool, error)

func (Model) Update 

func (i Model) Update(ctx context.Context, param interfaces.UpdateModelParam, operator *usecase.Operator) (*model.Model, error)

func (Model) UpdateOrder 

func (i Model) UpdateOrder(ctx context.Context, ids id.ModelIDList, operator *usecase.Operator) (model.List, error)

type Project 

type Project struct {
	// contains filtered or unexported fields
}

func (*Project) CheckAlias 

func (i *Project) CheckAlias(ctx context.Context, alias string) (bool, error)

func (*Project) Create 

func (i *Project) Create(ctx context.Context, p interfaces.CreateProjectParam, operator *usecase.Operator) (_ *project.Project, err error)

func (*Project) Delete 

func (i *Project) Delete(ctx context.Context, projectID id.ProjectID, operator *usecase.Operator) (err error)

func (*Project) Fetch 

func (i *Project) Fetch(ctx context.Context, ids []id.ProjectID, operator *usecase.Operator) (project.List, error)

func (*Project) FindByIDOrAlias 

func (i *Project) FindByIDOrAlias(ctx context.Context, id project.IDOrAlias, operator *usecase.Operator) (*project.Project, error)

func (*Project) FindByWorkspace 

func (i *Project) FindByWorkspace(ctx context.Context, wid accountdomain.WorkspaceID, p *usecasex.Pagination, operator *usecase.Operator) (project.List, *usecasex.PageInfo, error)

func (*Project) RegenerateToken 

func (i *Project) RegenerateToken(ctx context.Context, pId id.ProjectID, operator *usecase.Operator) (*project.Project, error)

func (*Project) Update 

func (i *Project) Update(ctx context.Context, p interfaces.UpdateProjectParam, operator *usecase.Operator) (_ *project.Project, err error)

type Request 

type Request struct {
	// contains filtered or unexported fields
}

func NewRequest 

func NewRequest(r *repo.Container, g *gateway.Container) *Request

func (Request) Approve 

func (r Request) Approve(ctx context.Context, requestID id.RequestID, operator *usecase.Operator) (*request.Request, error)

func (Request) CloseAll 

func (r Request) CloseAll(ctx context.Context, pid id.ProjectID, ids id.RequestIDList, operator *usecase.Operator) error

func (Request) Create 

func (r Request) Create(ctx context.Context, param interfaces.CreateRequestParam, operator *usecase.Operator) (*request.Request, error)

func (Request) FindByID 

func (r Request) FindByID(ctx context.Context, id id.RequestID, _ *usecase.Operator) (*request.Request, error)

func (Request) FindByIDs 

func (r Request) FindByIDs(ctx context.Context, list id.RequestIDList, _ *usecase.Operator) (request.List, error)

func (Request) FindByItem 

func (r Request) FindByItem(ctx context.Context, iId id.ItemID, filter *interfaces.RequestFilter, _ *usecase.Operator) (request.List, error)

func (Request) FindByProject 

func (r Request) FindByProject(ctx context.Context, pid id.ProjectID, filter interfaces.RequestFilter, sort *usecasex.Sort, pagination *usecasex.Pagination, _ *usecase.Operator) (request.List, *usecasex.PageInfo, error)

func (Request) Update 

func (r Request) Update(ctx context.Context, param interfaces.UpdateRequestParam, operator *usecase.Operator) (*request.Request, error)

type Schema 

type Schema struct {
	// contains filtered or unexported fields
}

func (Schema) CreateField 

func (i Schema) CreateField(ctx context.Context, param interfaces.CreateFieldParam, op *usecase.Operator) (*schema.Field, error)

func (Schema) DeleteField 

func (i Schema) DeleteField(ctx context.Context, schemaId id.SchemaID, fieldID id.FieldID, operator *usecase.Operator) error

func (Schema) FindByID 

func (i Schema) FindByID(ctx context.Context, id id.SchemaID, _ *usecase.Operator) (*schema.Schema, error)

func (Schema) FindByIDs 

func (i Schema) FindByIDs(ctx context.Context, ids []id.SchemaID, _ *usecase.Operator) (schema.List, error)

func (Schema) FindByModel 

func (i Schema) FindByModel(ctx context.Context, mID id.ModelID, _ *usecase.Operator) (*schema.Package, error)

func (Schema) GetSchemasAndGroupSchemasByIDs 

func (i Schema) GetSchemasAndGroupSchemasByIDs(ctx context.Context, list id.SchemaIDList, _ *usecase.Operator) (schemas schema.List, groupSchemas schema.List, err error)

func (Schema) UpdateField 

func (i Schema) UpdateField(ctx context.Context, param interfaces.UpdateFieldParam, op *usecase.Operator) (*schema.Field, error)

func (Schema) UpdateFields 

func (i Schema) UpdateFields(ctx context.Context, sid id.SchemaID, params []interfaces.UpdateFieldParam, operator *usecase.Operator) (schema.FieldList, error)

type Thread 

type Thread struct {
	// contains filtered or unexported fields
}

func (*Thread) AddComment 

func (i *Thread) AddComment(ctx context.Context, thid id.ThreadID, content string, op *usecase.Operator) (*thread.Thread, *thread.Comment, error)

func (*Thread) CreateThread 

func (i *Thread) CreateThread(ctx context.Context, wid accountdomain.WorkspaceID, op *usecase.Operator) (*thread.Thread, error)

func (*Thread) DeleteComment 

func (i *Thread) DeleteComment(ctx context.Context, thid id.ThreadID, cid id.CommentID, op *usecase.Operator) (*thread.Thread, error)

func (*Thread) FindByID 

func (i *Thread) FindByID(ctx context.Context, aid id.ThreadID, op *usecase.Operator) (*thread.Thread, error)

func (*Thread) FindByIDs 

func (i *Thread) FindByIDs(ctx context.Context, threads []id.ThreadID, operator *usecase.Operator) (thread.List, error)

func (*Thread) UpdateComment 

func (i *Thread) UpdateComment(ctx context.Context, thid id.ThreadID, cid id.CommentID, content string, op *usecase.Operator) (*thread.Thread, *thread.Comment, error)

type View 

type View struct {
	// contains filtered or unexported fields
}

func (View) Create 

func (i View) Create(ctx context.Context, param interfaces.CreateViewParam, op *usecase.Operator) (*view.View, error)

func (View) Delete 

func (i View) Delete(ctx context.Context, ID view.ID, op *usecase.Operator) error

func (View) FindByID 

func (i View) FindByID(ctx context.Context, ID view.ID, _ *usecase.Operator) (*view.View, error)

func (View) FindByIDs 

func (i View) FindByIDs(ctx context.Context, IDs view.IDList, _ *usecase.Operator) (view.List, error)

func (View) FindByModel 

func (i View) FindByModel(ctx context.Context, mID view.ModelID, _ *usecase.Operator) (view.List, error)

func (View) Update 

func (i View) Update(ctx context.Context, ID view.ID, param interfaces.UpdateViewParam, op *usecase.Operator) (*view.View, error)

func (View) UpdateOrder 

func (i View) UpdateOrder(ctx context.Context, ids view.IDList, operator *usecase.Operator) (view.List, error)

type WorkspaceSettings 

type WorkspaceSettings struct {
	// contains filtered or unexported fields
}

func (*WorkspaceSettings) Delete 

func (ws *WorkspaceSettings) Delete(ctx context.Context, inp interfaces.DeleteWorkspaceSettingsParam, op *usecase.Operator) error

func (*WorkspaceSettings) Fetch 

func (ws *WorkspaceSettings) Fetch(ctx context.Context, wid accountdomain.WorkspaceIDList, op *usecase.Operator) (result workspacesettings.List, err error)

func (*WorkspaceSettings) UpdateOrCreate 

func (ws *WorkspaceSettings) UpdateOrCreate(ctx context.Context, inp interfaces.UpdateOrCreateWorkspaceSettingsParam, op *usecase.Operator) (result *workspacesettings.WorkspaceSettings, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.