From ac9c6b62513e0e56262c21ca108a4aa78d61a557 Mon Sep 17 00:00:00 2001 From: tsmethurst Date: Sun, 7 Mar 2021 13:05:33 +0100 Subject: tiny bit of moving around --- internal/federation/federation.go | 112 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 112 insertions(+) create mode 100644 internal/federation/federation.go (limited to 'internal/federation') diff --git a/internal/federation/federation.go b/internal/federation/federation.go new file mode 100644 index 000000000..dd75fa506 --- /dev/null +++ b/internal/federation/federation.go @@ -0,0 +1,112 @@ +/* + 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 . +*/ + +// Package federation provides ActivityPub/federation functionality for GoToSocial +package federation + +import ( + "context" + "net/http" + "net/url" + "time" + + "github.com/go-fed/activity/pub" + "github.com/go-fed/activity/streams/vocab" + "github.com/gotosocial/gotosocial/internal/db" +) + +func New(db db.DB) pub.FederatingActor { + fs := &FederationService{} + return pub.NewFederatingActor(fs, fs, db, fs) +} + +type FederationService struct { +} + +// AuthenticateGetInbox determines whether the request is for a GET call to the Actor's Inbox. +func (fs *FederationService) AuthenticateGetInbox(ctx context.Context, w http.ResponseWriter, r *http.Request) (context.Context, bool, error) { + // TODO + return nil, false, nil +} + +// AuthenticateGetOutbox determines whether the request is for a GET call to the Actor's Outbox. +func (fs *FederationService) AuthenticateGetOutbox(ctx context.Context, w http.ResponseWriter, r *http.Request) (context.Context, bool, error) { + // TODO + return nil, false, nil +} + +// GetOutbox returns a proper paginated view of the Outbox for serving in a response. +func (fs *FederationService) GetOutbox(ctx context.Context, r *http.Request) (vocab.ActivityStreamsOrderedCollectionPage, error) { + // TODO + return nil, nil +} + +// NewTransport returns a new pub.Transport for federating with peer software. +func (fs *FederationService) NewTransport(ctx context.Context, actorBoxIRI *url.URL, gofedAgent string) (pub.Transport, error) { + // TODO + return nil, nil +} + +func (fs *FederationService) PostInboxRequestBodyHook(ctx context.Context, r *http.Request, activity pub.Activity) (context.Context, error) { + // TODO + return nil, nil +} + +func (fs *FederationService) AuthenticatePostInbox(ctx context.Context, w http.ResponseWriter, r *http.Request) (context.Context, bool, error) { + // TODO + return nil, false, nil +} + +func (fs *FederationService) Blocked(ctx context.Context, actorIRIs []*url.URL) (bool, error) { + // TODO + return false, nil +} + +func (fs *FederationService) FederatingCallbacks(ctx context.Context) (pub.FederatingWrappedCallbacks, []interface{}, error) { + // TODO + return pub.FederatingWrappedCallbacks{}, nil, nil +} + +func (fs *FederationService) DefaultCallback(ctx context.Context, activity pub.Activity) error { + // TODO + return nil +} + +func (fs *FederationService) MaxInboxForwardingRecursionDepth(ctx context.Context) int { + // TODO + return 0 +} + +func (fs *FederationService) MaxDeliveryRecursionDepth(ctx context.Context) int { + // TODO + return 0 +} + +func (fs *FederationService) FilterForwarding(ctx context.Context, potentialRecipients []*url.URL, a pub.Activity) ([]*url.URL, error) { + // TODO + return nil, nil +} + +func (fs *FederationService) GetInbox(ctx context.Context, r *http.Request) (vocab.ActivityStreamsOrderedCollectionPage, error) { + // TODO + return nil, nil +} + +func (fs *FederationService) Now() time.Time { + return time.Now() +} -- cgit v1.3