refactor

3 files changed, 0 insertions, 164 deletions

diff --git a/resources/outbox.go b/resources/outbox.go
deleted file mode 100644
index e7004c4..0000000
--- a/resources/outbox.go
+++ /dev/null
@@ -1,111 +0,0 @@
-package resources
-
-import (
-	"git.capotej.com/capotej/communique/urls"
-	"github.com/dgraph-io/badger/v3"
-	"github.com/go-fed/activity/streams"
-)
-
-func RenderOutboxPage(name, domain string, db *badger.DB) (map[string]interface{}, error) {
-	id, err := urls.UrlOutboxPage(name, domain)
-	if err != nil {
-		return nil, err
-	}
-
-	partOf, err := urls.UrlOutbox(name, domain)
-	if err != nil {
-		return nil, err
-	}
-
-	oc := streams.NewActivityStreamsOrderedCollectionPage()
-
-	idProp := streams.NewJSONLDIdProperty()
-	idProp.Set(id)
-	oc.SetJSONLDId(idProp)
-
-	partOfProp := streams.NewActivityStreamsPartOfProperty()
-	partOfProp.SetIRI(partOf)
-	oc.SetActivityStreamsPartOf(partOfProp)
-
-	itemsProp := streams.NewActivityStreamsOrderedItemsProperty()
-
-	err = db.View(func(txn *badger.Txn) error {
-		opts := badger.DefaultIteratorOptions
-		opts.PrefetchValues = false
-		it := txn.NewIterator(opts)
-		defer it.Close()
-		prefix := []byte("outbox:sample") // TODO
-		for it.Seek(prefix); it.ValidForPrefix(prefix); it.Next() {
-			item := it.Item()
-			err := item.Value(func(v []byte) error {
-				crea := streams.NewActivityStreamsCreate()
-				obj := streams.NewActivityStreamsObjectProperty()
-				crea.SetActivityStreamsObject(obj)
-
-				note := streams.NewActivityStreamsNote()
-				contentProp := streams.NewActivityStreamsContentProperty()
-				contentProp.AppendXMLSchemaString(string(v))
-				note.SetActivityStreamsContent(contentProp)
-				obj.AppendActivityStreamsNote(note)
-
-				itemsProp.AppendActivityStreamsCreate(crea)
-				return nil
-			})
-			if err != nil {
-				return err
-			}
-		}
-		return nil
-	})
-	if err != nil {
-		return nil, err
-	}
-
-	oc.SetActivityStreamsOrderedItems(itemsProp)
-	return streams.Serialize(oc)
-}
-
-func RenderOutbox(name, domain string, db *badger.DB) (map[string]interface{}, error) {
-	id, err := urls.UrlOutbox(name, domain)
-
-	if err != nil {
-		return nil, err
-	}
-
-	first, err := urls.UrlOutboxPage(name, domain)
-	if err != nil {
-		return nil, err
-	}
-
-	oc := streams.NewActivityStreamsOrderedCollection()
-
-	idProp := streams.NewJSONLDIdProperty()
-	idProp.Set(id)
-	oc.SetJSONLDId(idProp)
-
-	var i int
-	// err = db.View(func(txn *badger.Txn) error {
-	// 	opts := badger.DefaultIteratorOptions
-	// 	opts.PrefetchValues = false
-	// 	it := txn.NewIterator(opts)
-	// 	defer it.Close()
-	// 	prefix := []byte("outbox:sample") // TODO
-	// 	for it.Seek(prefix); it.ValidForPrefix(prefix); it.Next() {
-	// 		i++
-	// 	}
-	// 	return nil
-	// })
-	// if err != nil {
-	// 	return nil, err
-	// }
-
-	itemsProp := streams.NewActivityStreamsTotalItemsProperty()
-	itemsProp.Set(i)
-	oc.SetActivityStreamsTotalItems(itemsProp)
-
-	ocProp := streams.NewActivityStreamsFirstProperty()
-	ocProp.SetIRI(first)
-	oc.SetActivityStreamsFirst(ocProp)
-
-	return streams.Serialize(oc)
-}
diff --git a/resources/profile.go b/resources/profile.go
deleted file mode 100644
index 971b11c..0000000
--- a/resources/profile.go
+++ /dev/null
@@ -1,21 +0,0 @@
-package resources
-
-import (
-	"git.capotej.com/capotej/communique/urls"
-	"github.com/go-fed/activity/streams"
-)
-
-func RenderProfile(name, domain string) (map[string]interface{}, error) {
-	u, err := urls.UrlInbox(name, domain)
-	if err != nil {
-		return nil, err
-	}
-
-	inb := streams.NewActivityStreamsInboxProperty()
-	inb.SetIRI(u)
-
-	p := streams.NewActivityStreamsService()
-	p.SetActivityStreamsInbox(inb)
-
-	return streams.Serialize(p)
-}
diff --git a/resources/webfinger.go b/resources/webfinger.go
deleted file mode 100644
index e7c47ea..0000000
--- a/resources/webfinger.go
+++ /dev/null
@@ -1,32 +0,0 @@
-package resources
-
-import (
-	"fmt"
-	"path"
-)
-
-type Link struct {
-	Rel  string `json:"rel"`
-	Type string `json:"type"`
-	Href string `json:"href"`
-}
-
-type WebfingerResource struct {
-	Subject string   `json:"subject"`
-	Aliases []string `json:"aliases"`
-	Links   []Link   `json:"links"`
-}
-
-func RenderWebfingerResource(name, domain string) (*WebfingerResource, error) {
-	rs := WebfingerResource{
-		// TODO clean up
-		Subject: fmt.Sprintf("acct:%s@%s", name, domain),
-		Aliases: []string{},
-		Links: []Link{{
-			Rel:  "self",
-			Href: path.Join("https://", domain, "actors", name),
-			Type: "application/activity+json",
-		}},
-	}
-	return &rs, nil
-}