diff options
author | 2021-07-05 13:23:03 +0200 | |
---|---|---|
committer | 2021-07-05 13:23:03 +0200 | |
commit | d389e7b150df6ecd215c7b661b294ea153ad0103 (patch) | |
tree | 8739e3103cb5130875d903cc7fc72fd9db3b8434 /internal/processing/synchronous/status/create.go | |
parent | Fix 404 contact (#74) (diff) | |
download | gotosocial-d389e7b150df6ecd215c7b661b294ea153ad0103.tar.xz |
Domain block (#76)
* start work on admin domain blocking
* move stuff around + further work on domain blocks
* move + restructure processor
* prep work for deleting account
* tidy
* go fmt
* formatting
* domain blocking more work
* check domain blocks way earlier on
* progress on delete account
* delete more stuff when an account is gone
* and more...
* domain blocky block block
* get individual domain block, delete a block
Diffstat (limited to 'internal/processing/synchronous/status/create.go')
-rw-r--r-- | internal/processing/synchronous/status/create.go | 106 |
1 files changed, 0 insertions, 106 deletions
diff --git a/internal/processing/synchronous/status/create.go b/internal/processing/synchronous/status/create.go deleted file mode 100644 index aa7468ae5..000000000 --- a/internal/processing/synchronous/status/create.go +++ /dev/null @@ -1,106 +0,0 @@ -package status - -import ( - "fmt" - "time" - - apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model" - "github.com/superseriousbusiness/gotosocial/internal/gtserror" - "github.com/superseriousbusiness/gotosocial/internal/gtsmodel" - "github.com/superseriousbusiness/gotosocial/internal/id" - "github.com/superseriousbusiness/gotosocial/internal/util" -) - -func (p *processor) Create(account *gtsmodel.Account, application *gtsmodel.Application, form *apimodel.AdvancedStatusCreateForm) (*apimodel.Status, gtserror.WithCode) { - uris := util.GenerateURIsForAccount(account.Username, p.config.Protocol, p.config.Host) - thisStatusID, err := id.NewULID() - if err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - thisStatusURI := fmt.Sprintf("%s/%s", uris.StatusesURI, thisStatusID) - thisStatusURL := fmt.Sprintf("%s/%s", uris.StatusesURL, thisStatusID) - - newStatus := >smodel.Status{ - ID: thisStatusID, - URI: thisStatusURI, - URL: thisStatusURL, - CreatedAt: time.Now(), - UpdatedAt: time.Now(), - Local: true, - AccountID: account.ID, - AccountURI: account.URI, - ContentWarning: form.SpoilerText, - ActivityStreamsType: gtsmodel.ActivityStreamsNote, - Sensitive: form.Sensitive, - Language: form.Language, - CreatedWithApplicationID: application.ID, - Text: form.Status, - } - - // check if replyToID is ok - if err := p.processReplyToID(form, account.ID, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - // check if mediaIDs are ok - if err := p.processMediaIDs(form, account.ID, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - // check if visibility settings are ok - if err := p.processVisibility(form, account.Privacy, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - // handle language settings - if err := p.processLanguage(form, account.Language, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - // handle mentions - if err := p.processMentions(form, account.ID, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - if err := p.processTags(form, account.ID, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - if err := p.processEmojis(form, account.ID, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - if err := p.processContent(form, account.ID, newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - // put the new status in the database, generating an ID for it in the process - if err := p.db.Put(newStatus); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - - // change the status ID of the media attachments to the new status - for _, a := range newStatus.GTSMediaAttachments { - a.StatusID = newStatus.ID - a.UpdatedAt = time.Now() - if err := p.db.UpdateByID(a.ID, a); err != nil { - return nil, gtserror.NewErrorInternalError(err) - } - } - - // send it back to the processor for async processing - p.fromClientAPI <- gtsmodel.FromClientAPI{ - APObjectType: gtsmodel.ActivityStreamsNote, - APActivityType: gtsmodel.ActivityStreamsCreate, - GTSModel: newStatus, - OriginAccount: account, - } - - // return the frontend representation of the new status to the submitter - mastoStatus, err := p.tc.StatusToMasto(newStatus, account) - if err != nil { - return nil, gtserror.NewErrorInternalError(fmt.Errorf("error converting status %s to frontend representation: %s", newStatus.ID, err)) - } - - return mastoStatus, nil -} |