outbox.go (2320B)
1 // GoToSocial 2 // Copyright (C) GoToSocial Authors admin@gotosocial.org 3 // SPDX-License-Identifier: AGPL-3.0-or-later 4 // 5 // This program is free software: you can redistribute it and/or modify 6 // it under the terms of the GNU Affero General Public License as published by 7 // the Free Software Foundation, either version 3 of the License, or 8 // (at your option) any later version. 9 // 10 // This program is distributed in the hope that it will be useful, 11 // but WITHOUT ANY WARRANTY; without even the implied warranty of 12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 13 // GNU Affero General Public License for more details. 14 // 15 // You should have received a copy of the GNU Affero General Public License 16 // along with this program. If not, see <http://www.gnu.org/licenses/>. 17 18 package federatingdb 19 20 import ( 21 "context" 22 "net/url" 23 24 "github.com/superseriousbusiness/activity/streams" 25 "github.com/superseriousbusiness/activity/streams/vocab" 26 ) 27 28 // GetOutbox returns the first ordered collection page of the outbox 29 // at the specified IRI, for prepending new items. 30 // 31 // The library makes this call only after acquiring a lock first. 32 // 33 // Implementation note: we don't (yet) serve outboxes, so just return empty and nil here. 34 func (f *federatingDB) GetOutbox(ctx context.Context, outboxIRI *url.URL) (inbox vocab.ActivityStreamsOrderedCollectionPage, err error) { 35 return streams.NewActivityStreamsOrderedCollectionPage(), nil 36 } 37 38 // SetOutbox saves the outbox value given from GetOutbox, with new items 39 // prepended. Note that the new items must not be added as independent 40 // database entries. Separate calls to Create will do that. 41 // 42 // The library makes this call only after acquiring a lock first. 43 // 44 // Implementation note: we don't allow outbox setting so just return nil here. 45 func (f *federatingDB) SetOutbox(ctx context.Context, outbox vocab.ActivityStreamsOrderedCollectionPage) error { 46 return nil 47 } 48 49 // OutboxForInbox fetches the corresponding actor's outbox IRI for the 50 // actor's inbox IRI. 51 // 52 // The library makes this call only after acquiring a lock first. 53 func (f *federatingDB) OutboxForInbox(ctx context.Context, inboxIRI *url.URL) (outboxIRI *url.URL, err error) { 54 acct, err := f.getAccountForIRI(ctx, inboxIRI) 55 if err != nil { 56 return nil, err 57 } 58 return url.Parse(acct.OutboxURI) 59 }