all repos — underbbs @ d552fc53b96be1f1d8fa28b48dba9e64b0ef87eb

decentralized social media client

adapter/mastodon.go (raw)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
 
package adapter

import (
	. "forge.lightcrystal.systems/lightcrystal/underbbs/models"
	madon "github.com/McKael/madon"
)

type MastoAdapter struct {
	data     chan SocketData
	nickname string
	server   string
	apiKey   string

	masto *madon.Client

	events chan madon.StreamEvent
	stop   chan bool
	done   chan bool
}

var scopes = []string{"read", "write", "follow"}

func (self *MastoAdapter) Init(settings Settings, data chan SocketData) error {
	self.nickname = settings.Nickname
	self.server = *settings.Server
	self.apiKey = *settings.ApiKey
	self.data = data

	masto, err := madon.NewApp("underbbs", "https://lightcrystal.systems", scopes, madon.NoRedirect, self.server)
	if err != nil {
		return err
	}
	self.masto = masto
	err = self.masto.SetUserToken(self.apiKey, "", "", []string{})
	return err
}

func (self *MastoAdapter) Subscribe(filter string) []error {
	// TODO: decode separate timelines and hashtags
	// for now, the filter is just the timeline

	// if any existing events channel, close it and create a new one
	if self.events != nil {
		close(self.events)
	}
	self.events = make(chan madon.StreamEvent)
	// if any existing stop channel, close it and create a new one
	if self.stop != nil {
		close(self.stop)
	}
	self.stop = make(chan bool)
	// make a new done channel
	self.done = make(chan bool)

	// call StreamListener
	self.masto.StreamListener(filter, "", self.events, self.stop, self.done)
	go func() {
		for e := range self.events {
			switch e.Event {
			case "error":
			case "update":
				var msg *Message
				switch v := e.Data.(type) {
				case int64:
					s, _ := self.masto.GetStatus(v)
					if s != nil {
						msg = mastoUpdateToMessage(*s)
					}
				case madon.Status:
					msg = mastoUpdateToMessage(v)
				}
				if msg != nil {
					self.data <- msg
				}
			case "notification":
			case "delete":
			}
		}
	}()
	// in the background, read and translate events from the stream
	// and check for doneCh closing
	// the stopCh will be closed by a subsequent call to subscribe
	errs := make([]error, 0)
	return errs
}
func (self *MastoAdapter) SendMessage(msg Message) error {
	return nil
}
func (self *MastoAdapter) Follow(author Author) error {
	return nil
}
func (self *MastoAdapter) Unfollow(author Author) error {
	return nil
}
func (self *MastoAdapter) GetFollowers() error {
	return nil
}
func (self *MastoAdapter) UpdateMetadata(data interface{}) error {
	return nil
}

func (self *MastoAdapter) DefaultSubscriptionFilter() string {
	return "home"
}

func mastoUpdateToMessage(status madon.Status) *Message {
	// decode that fucker
	return nil
}