From d389e7b150df6ecd215c7b661b294ea153ad0103 Mon Sep 17 00:00:00 2001 From: Tobi Smethurst <31960611+tsmethurst@users.noreply.github.com> Date: Mon, 5 Jul 2021 13:23:03 +0200 Subject: 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 --- internal/processing/synchronous/status/create.go | 106 ----------------------- 1 file changed, 106 deletions(-) delete mode 100644 internal/processing/synchronous/status/create.go (limited to 'internal/processing/synchronous/status/create.go') 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 -} -- cgit v1.2.3