mirror of
				https://github.com/superseriousbusiness/gotosocial.git
				synced 2025-10-30 21:12:24 -05:00 
			
		
		
		
	
		
			
				
	
	
		
			80 lines
		
	
	
	
		
			2.9 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			80 lines
		
	
	
	
		
			2.9 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| /*
 | |
|    GoToSocial
 | |
|    Copyright (C) 2021 GoToSocial Authors admin@gotosocial.org
 | |
| 
 | |
|    This program is free software: you can redistribute it and/or modify
 | |
|    it under the terms of the GNU Affero General Public License as published by
 | |
|    the Free Software Foundation, either version 3 of the License, or
 | |
|    (at your option) any later version.
 | |
| 
 | |
|    This program is distributed in the hope that it will be useful,
 | |
|    but WITHOUT ANY WARRANTY; without even the implied warranty of
 | |
|    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 | |
|    GNU Affero General Public License for more details.
 | |
| 
 | |
|    You should have received a copy of the GNU Affero General Public License
 | |
|    along with this program.  If not, see <http://www.gnu.org/licenses/>.
 | |
| */
 | |
| 
 | |
| package media
 | |
| 
 | |
| import (
 | |
| 	"bytes"
 | |
| 	"errors"
 | |
| 	"fmt"
 | |
| 	"io"
 | |
| 
 | |
| 	apimodel "github.com/superseriousbusiness/gotosocial/internal/api/model"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/gtsmodel"
 | |
| 	"github.com/superseriousbusiness/gotosocial/internal/text"
 | |
| )
 | |
| 
 | |
| func (p *processor) Create(account *gtsmodel.Account, form *apimodel.AttachmentRequest) (*apimodel.Attachment, error) {
 | |
| 	// open the attachment and extract the bytes from it
 | |
| 	f, err := form.File.Open()
 | |
| 	if err != nil {
 | |
| 		return nil, fmt.Errorf("error opening attachment: %s", err)
 | |
| 	}
 | |
| 	buf := new(bytes.Buffer)
 | |
| 	size, err := io.Copy(buf, f)
 | |
| 	if err != nil {
 | |
| 		return nil, fmt.Errorf("error reading attachment: %s", err)
 | |
| 	}
 | |
| 	if size == 0 {
 | |
| 		return nil, errors.New("could not read provided attachment: size 0 bytes")
 | |
| 	}
 | |
| 
 | |
| 	// allow the mediaHandler to work its magic of processing the attachment bytes, and putting them in whatever storage backend we're using
 | |
| 	attachment, err := p.mediaHandler.ProcessAttachment(buf.Bytes(), account.ID, "")
 | |
| 	if err != nil {
 | |
| 		return nil, fmt.Errorf("error reading attachment: %s", err)
 | |
| 	}
 | |
| 
 | |
| 	// now we need to add extra fields that the attachment processor doesn't know (from the form)
 | |
| 	// TODO: handle this inside mediaHandler.ProcessAttachment (just pass more params to it)
 | |
| 
 | |
| 	// first description
 | |
| 	attachment.Description = text.RemoveHTML(form.Description) // remove any HTML from the image description
 | |
| 
 | |
| 	// now parse the focus parameter
 | |
| 	focusx, focusy, err := parseFocus(form.Focus)
 | |
| 	if err != nil {
 | |
| 		return nil, err
 | |
| 	}
 | |
| 	attachment.FileMeta.Focus.X = focusx
 | |
| 	attachment.FileMeta.Focus.Y = focusy
 | |
| 
 | |
| 	// prepare the frontend representation now -- if there are any errors here at least we can bail without
 | |
| 	// having already put something in the database and then having to clean it up again (eugh)
 | |
| 	mastoAttachment, err := p.tc.AttachmentToMasto(attachment)
 | |
| 	if err != nil {
 | |
| 		return nil, fmt.Errorf("error parsing media attachment to frontend type: %s", err)
 | |
| 	}
 | |
| 
 | |
| 	// now we can confidently put the attachment in the database
 | |
| 	if err := p.db.Put(attachment); err != nil {
 | |
| 		return nil, fmt.Errorf("error storing media attachment in db: %s", err)
 | |
| 	}
 | |
| 
 | |
| 	return &mastoAttachment, nil
 | |
| }
 |