all repos — honk @ 192aa222512284c16f8077fb4d42791f6ee2a015

my fork of honk

fun.go (view raw)

  1//
  2// Copyright (c) 2019 Ted Unangst <tedu@tedunangst.com>
  3//
  4// Permission to use, copy, modify, and distribute this software for any
  5// purpose with or without fee is hereby granted, provided that the above
  6// copyright notice and this permission notice appear in all copies.
  7//
  8// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
  9// WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 10// MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 11// ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 12// WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 13// ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 14// OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 15
 16package main
 17
 18import (
 19	"crypto/rand"
 20	"crypto/rsa"
 21	"fmt"
 22	"html"
 23	"html/template"
 24	"log"
 25	"net/http"
 26	"os"
 27	"regexp"
 28	"strings"
 29	"sync"
 30
 31	"humungus.tedunangst.com/r/webs/htfilter"
 32	"humungus.tedunangst.com/r/webs/httpsig"
 33)
 34
 35func reverbolate(userid int64, honks []*Honk) {
 36	filt := htfilter.New()
 37	zilences := getzilences(userid)
 38	for _, h := range honks {
 39		h.What += "ed"
 40		if h.What == "tonked" {
 41			h.What = "honked back"
 42			h.Style = "subtle"
 43		}
 44		if !h.Public {
 45			h.Style += " limited"
 46		}
 47		if h.Whofore == 2 || h.Whofore == 3 {
 48			h.URL = h.XID
 49			if h.What != "bonked" {
 50				h.Noise = mentionize(h.Noise)
 51				if bloat_iscounter(h) {
 52					bloat_counterhtml(h)
 53				}
 54			}
 55			h.Username, h.Handle = honkerhandle(h.Honker)
 56		} else {
 57			_, h.Handle = honkerhandle(h.Honker)
 58			h.Username = h.Handle
 59			if len(h.Username) > 20 {
 60				h.Username = h.Username[:20] + ".."
 61			}
 62			if h.URL == "" {
 63				h.URL = h.XID
 64			}
 65		}
 66		if h.Oonker != "" {
 67			_, h.Oondle = honkerhandle(h.Oonker)
 68		}
 69		zap := make(map[*Donk]bool)
 70		h.Noise = unpucker(h.Noise)
 71		h.Open = "open"
 72		if badword := unsee(zilences, h.Precis, h.Noise); badword != "" {
 73			if h.Precis == "" {
 74				h.Precis = badword
 75			}
 76			h.Open = ""
 77		} else if h.Precis == "unspecified horror" {
 78			h.Precis = ""
 79		}
 80		h.Precis = unpucker(h.Precis)
 81		h.HTML, _ = filt.String(h.Noise)
 82		emuxifier := func(e string) string {
 83			for _, d := range h.Donks {
 84				if d.Name == e {
 85					zap[d] = true
 86					if d.Local {
 87						return fmt.Sprintf(`<img class="emu" title="%s" src="/d/%s">`, d.Name, d.XID)
 88					}
 89				}
 90			}
 91			return e
 92		}
 93		h.HTML = template.HTML(re_emus.ReplaceAllStringFunc(string(h.HTML), emuxifier))
 94		j := 0
 95		for i := 0; i < len(h.Donks); i++ {
 96			if !zap[h.Donks[i]] {
 97				h.Donks[j] = h.Donks[i]
 98				j++
 99			}
100		}
101		h.Donks = h.Donks[:j]
102	}
103}
104
105func unsee(zilences []*regexp.Regexp, precis string, noise string) string {
106	for _, z := range zilences {
107		if z.MatchString(precis) || z.MatchString(noise) {
108			if precis == "" {
109				w := z.String()
110				return w[6 : len(w)-3]
111			}
112			return precis
113		}
114	}
115	return ""
116}
117
118func osmosis(honks []*Honk, userid int64) []*Honk {
119	zords := getzords(userid)
120	j := 0
121outer:
122	for _, h := range honks {
123		for _, z := range zords {
124			if z.MatchString(h.Precis) || z.MatchString(h.Noise) {
125				continue outer
126			}
127		}
128		honks[j] = h
129		j++
130	}
131	honks = honks[0:j]
132	return honks
133}
134
135func shortxid(xid string) string {
136	idx := strings.LastIndexByte(xid, '/')
137	if idx == -1 {
138		return xid
139	}
140	return xid[idx+1:]
141}
142
143func xfiltrate() string {
144	letters := "BCDFGHJKLMNPQRSTVWXYZbcdfghjklmnpqrstvwxyz1234567891234567891234"
145	var b [18]byte
146	rand.Read(b[:])
147	for i, c := range b {
148		b[i] = letters[c&63]
149	}
150	s := string(b[:])
151	return s
152}
153
154var re_hashes = regexp.MustCompile(`(?:^|\W)#[[:alnum:]]+`)
155
156func ontologies(s string) []string {
157	m := re_hashes.FindAllString(s, -1)
158	j := 0
159	for _, h := range m {
160		if h[0] == '&' {
161			continue
162		}
163		if h[0] != '#' {
164			h = h[1:]
165		}
166		m[j] = h
167		j++
168	}
169	return m[:j]
170}
171
172type Mention struct {
173	who   string
174	where string
175}
176
177var re_mentions = regexp.MustCompile(`@[[:alnum:]._-]+@[[:alnum:].-]*[[:alnum:]]`)
178var re_urltions = regexp.MustCompile(`@https://\S+`)
179
180func grapevine(s string) []string {
181	var mentions []string
182	m := re_mentions.FindAllString(s, -1)
183	for i := range m {
184		where := gofish(m[i])
185		if where != "" {
186			mentions = append(mentions, where)
187		}
188	}
189	m = re_urltions.FindAllString(s, -1)
190	for i := range m {
191		mentions = append(mentions, m[i][1:])
192	}
193	return mentions
194}
195
196func bunchofgrapes(s string) []Mention {
197	m := re_mentions.FindAllString(s, -1)
198	var mentions []Mention
199	for i := range m {
200		where := gofish(m[i])
201		if where != "" {
202			mentions = append(mentions, Mention{who: m[i], where: where})
203		}
204	}
205	m = re_urltions.FindAllString(s, -1)
206	for i := range m {
207		mentions = append(mentions, Mention{who: m[i][1:], where: m[i][1:]})
208	}
209	return mentions
210}
211
212type Emu struct {
213	ID   string
214	Name string
215}
216
217var re_link = regexp.MustCompile(`@?https?://[^\s"]+[\w/)]`)
218var re_emus = regexp.MustCompile(`:[[:alnum:]_-]+:`)
219
220func herdofemus(noise string) []Emu {
221	m := re_emus.FindAllString(noise, -1)
222	m = oneofakind(m)
223	var emus []Emu
224	for _, e := range m {
225		fname := e[1 : len(e)-1]
226		_, err := os.Stat("emus/" + fname + ".png")
227		if err != nil {
228			continue
229		}
230		url := fmt.Sprintf("https://%s/emu/%s.png", serverName, fname)
231		emus = append(emus, Emu{ID: url, Name: e})
232	}
233	return emus
234}
235
236var re_memes = regexp.MustCompile("meme: ?([[:alnum:]_.-]+)")
237
238func memetize(honk *Honk) {
239	repl := func(x string) string {
240		name := x[5:]
241		if name[0] == ' ' {
242			name = name[1:]
243		}
244		fd, err := os.Open("memes/" + name)
245		if err != nil {
246			log.Printf("no meme for %s", name)
247			return x
248		}
249		var peek [512]byte
250		n, _ := fd.Read(peek[:])
251		ct := http.DetectContentType(peek[:n])
252		fd.Close()
253
254		url := fmt.Sprintf("https://%s/meme/%s", serverName, name)
255		res, err := stmtSaveFile.Exec("", name, url, ct, 0, "")
256		if err != nil {
257			log.Printf("error saving meme: %s", err)
258			return x
259		}
260		var d Donk
261		d.FileID, _ = res.LastInsertId()
262		d.XID = ""
263		d.Name = name
264		d.Media = ct
265		d.URL = url
266		d.Local = false
267		honk.Donks = append(honk.Donks, &d)
268		return ""
269	}
270	honk.Noise = re_memes.ReplaceAllStringFunc(honk.Noise, repl)
271}
272
273var re_bolder = regexp.MustCompile(`(^|\W)\*\*([\w\s,.!?'-]+)\*\*($|\W)`)
274var re_italicer = regexp.MustCompile(`(^|\W)\*([\w\s,.!?'-]+)\*($|\W)`)
275var re_bigcoder = regexp.MustCompile("```\n?((?s:.*?))\n?```\n?")
276var re_coder = regexp.MustCompile("`([^`]*)`")
277var re_quoter = regexp.MustCompile(`(?m:^&gt; (.*)\n?)`)
278
279func markitzero(s string) string {
280	var bigcodes []string
281	bigsaver := func(code string) string {
282		bigcodes = append(bigcodes, code)
283		return "``````"
284	}
285	s = re_bigcoder.ReplaceAllStringFunc(s, bigsaver)
286	var lilcodes []string
287	lilsaver := func(code string) string {
288		lilcodes = append(lilcodes, code)
289		return "`x`"
290	}
291	s = re_coder.ReplaceAllStringFunc(s, lilsaver)
292	s = re_bolder.ReplaceAllString(s, "$1<b>$2</b>$3")
293	s = re_italicer.ReplaceAllString(s, "$1<i>$2</i>$3")
294	s = re_quoter.ReplaceAllString(s, "<blockquote>$1</blockquote><p>")
295	lilun := func(s string) string {
296		code := lilcodes[0]
297		lilcodes = lilcodes[1:]
298		return code
299	}
300	s = re_coder.ReplaceAllStringFunc(s, lilun)
301	bigun := func(s string) string {
302		code := bigcodes[0]
303		bigcodes = bigcodes[1:]
304		return code
305	}
306	s = re_bigcoder.ReplaceAllStringFunc(s, bigun)
307	s = re_bigcoder.ReplaceAllString(s, "<pre><code>$1</code></pre><p>")
308	s = re_coder.ReplaceAllString(s, "<code>$1</code>")
309	return s
310}
311
312func obfusbreak(s string) string {
313	s = strings.TrimSpace(s)
314	s = strings.Replace(s, "\r", "", -1)
315	s = html.EscapeString(s)
316	// dammit go
317	s = strings.Replace(s, "&#39;", "'", -1)
318	linkfn := func(url string) string {
319		if url[0] == '@' {
320			return url
321		}
322		addparen := false
323		adddot := false
324		if strings.HasSuffix(url, ")") && strings.IndexByte(url, '(') == -1 {
325			url = url[:len(url)-1]
326			addparen = true
327		}
328		if strings.HasSuffix(url, ".") {
329			url = url[:len(url)-1]
330			adddot = true
331		}
332		url = fmt.Sprintf(`<a class="mention u-url" href="%s">%s</a>`, url, url)
333		if adddot {
334			url += "."
335		}
336		if addparen {
337			url += ")"
338		}
339		return url
340	}
341	s = re_link.ReplaceAllStringFunc(s, linkfn)
342
343	s = markitzero(s)
344
345	s = strings.Replace(s, "\n", "<br>", -1)
346	return s
347}
348
349func mentionize(s string) string {
350	s = re_mentions.ReplaceAllStringFunc(s, func(m string) string {
351		where := gofish(m)
352		if where == "" {
353			return m
354		}
355		who := m[0 : 1+strings.IndexByte(m[1:], '@')]
356		return fmt.Sprintf(`<span class="h-card"><a class="u-url mention" href="%s">%s</a></span>`,
357			html.EscapeString(where), html.EscapeString(who))
358	})
359	s = re_urltions.ReplaceAllStringFunc(s, func(m string) string {
360		return fmt.Sprintf(`<span class="h-card"><a class="u-url mention" href="%s">%s</a></span>`,
361			html.EscapeString(m[1:]), html.EscapeString(m))
362	})
363	return s
364}
365
366var re_unurl = regexp.MustCompile("https://([^/]+).*/([^/]+)")
367var re_urlhost = regexp.MustCompile("https://([^/]+)")
368
369func originate(u string) string {
370	m := re_urlhost.FindStringSubmatch(u)
371	if len(m) > 1 {
372		return m[1]
373	}
374	return ""
375}
376
377func honkerhandle(h string) (string, string) {
378	m := re_unurl.FindStringSubmatch(h)
379	if len(m) > 2 {
380		return m[2], fmt.Sprintf("%s@%s", m[2], m[1])
381	}
382	return h, h
383}
384
385func prepend(s string, x []string) []string {
386	return append([]string{s}, x...)
387}
388
389// pleroma leaks followers addressed posts to followers
390func butnottooloud(aud []string) {
391	for i, a := range aud {
392		if strings.HasSuffix(a, "/followers") {
393			aud[i] = ""
394		}
395	}
396}
397
398func keepitquiet(aud []string) bool {
399	for _, a := range aud {
400		if a == thewholeworld {
401			return false
402		}
403	}
404	return true
405}
406
407func oneofakind(a []string) []string {
408	var x []string
409	for n, s := range a {
410		if s != "" {
411			x = append(x, s)
412			for i := n + 1; i < len(a); i++ {
413				if a[i] == s {
414					a[i] = ""
415				}
416			}
417		}
418	}
419	return x
420}
421
422var ziggies = make(map[string]*rsa.PrivateKey)
423var zaggies = make(map[string]*rsa.PublicKey)
424var ziggylock sync.Mutex
425
426func ziggy(username string) (keyname string, key *rsa.PrivateKey) {
427	ziggylock.Lock()
428	key = ziggies[username]
429	ziggylock.Unlock()
430	if key == nil {
431		db := opendatabase()
432		row := db.QueryRow("select seckey from users where username = ?", username)
433		var data string
434		row.Scan(&data)
435		var err error
436		key, _, err = httpsig.DecodeKey(data)
437		if err != nil {
438			log.Printf("error decoding %s seckey: %s", username, err)
439			return
440		}
441		ziggylock.Lock()
442		ziggies[username] = key
443		ziggylock.Unlock()
444	}
445	keyname = fmt.Sprintf("https://%s/%s/%s#key", serverName, userSep, username)
446	return
447}
448
449func zaggy(keyname string) (key *rsa.PublicKey) {
450	ziggylock.Lock()
451	key = zaggies[keyname]
452	ziggylock.Unlock()
453	if key != nil {
454		return
455	}
456	row := stmtGetXonker.QueryRow(keyname, "pubkey")
457	var data string
458	err := row.Scan(&data)
459	if err != nil {
460		log.Printf("hitting the webs for missing pubkey: %s", keyname)
461		j, err := GetJunk(keyname)
462		if err != nil {
463			log.Printf("error getting %s pubkey: %s", keyname, err)
464			return
465		}
466		keyobj, ok := j.GetMap("publicKey")
467		if ok {
468			j = keyobj
469		}
470		data, ok = j.GetString("publicKeyPem")
471		if !ok {
472			log.Printf("error finding %s pubkey", keyname)
473			return
474		}
475		_, ok = j.GetString("owner")
476		if !ok {
477			log.Printf("error finding %s pubkey owner", keyname)
478			return
479		}
480		_, key, err = httpsig.DecodeKey(data)
481		if err != nil {
482			log.Printf("error decoding %s pubkey: %s", keyname, err)
483			return
484		}
485		_, err = stmtSaveXonker.Exec(keyname, data, "pubkey")
486		if err != nil {
487			log.Printf("error saving key: %s", err)
488		}
489	} else {
490		_, key, err = httpsig.DecodeKey(data)
491		if err != nil {
492			log.Printf("error decoding %s pubkey: %s", keyname, err)
493			return
494		}
495	}
496	ziggylock.Lock()
497	zaggies[keyname] = key
498	ziggylock.Unlock()
499	return
500}
501
502func makeitworksomehowwithoutregardforkeycontinuity(keyname string, r *http.Request, payload []byte) (string, error) {
503	_, err := stmtDeleteXonker.Exec(keyname, "pubkey")
504	if err != nil {
505		log.Printf("error deleting key: %s", err)
506	}
507	ziggylock.Lock()
508	delete(zaggies, keyname)
509	ziggylock.Unlock()
510	return httpsig.VerifyRequest(r, payload, zaggy)
511}
512
513var thumbbiters map[int64]map[string]bool
514var zordses map[int64][]*regexp.Regexp
515var zilences map[int64][]*regexp.Regexp
516var thumblock sync.Mutex
517
518func bitethethumbs() {
519	rows, err := stmtThumbBiters.Query()
520	if err != nil {
521		log.Printf("error getting thumbbiters: %s", err)
522		return
523	}
524	defer rows.Close()
525
526	thumblock.Lock()
527	defer thumblock.Unlock()
528	thumbbiters = make(map[int64]map[string]bool)
529	zordses = make(map[int64][]*regexp.Regexp)
530	zilences = make(map[int64][]*regexp.Regexp)
531	for rows.Next() {
532		var userid int64
533		var name, wherefore string
534		err = rows.Scan(&userid, &name, &wherefore)
535		if err != nil {
536			log.Printf("error scanning zonker: %s", err)
537			continue
538		}
539		if wherefore == "zord" || wherefore == "zilence" {
540			zord := "\\b(?i:" + name + ")\\b"
541			re, err := regexp.Compile(zord)
542			if err != nil {
543				log.Printf("error compiling zord: %s", err)
544			} else {
545				if wherefore == "zord" {
546					zordses[userid] = append(zordses[userid], re)
547				} else {
548					zilences[userid] = append(zilences[userid], re)
549				}
550			}
551			continue
552		}
553		m := thumbbiters[userid]
554		if m == nil {
555			m = make(map[string]bool)
556			thumbbiters[userid] = m
557		}
558		m[name] = true
559	}
560}
561
562func getzords(userid int64) []*regexp.Regexp {
563	thumblock.Lock()
564	defer thumblock.Unlock()
565	return zordses[userid]
566}
567
568func getzilences(userid int64) []*regexp.Regexp {
569	thumblock.Lock()
570	defer thumblock.Unlock()
571	return zilences[userid]
572}
573
574func thoudostbitethythumb(userid int64, who []string, objid string) bool {
575	thumblock.Lock()
576	biters := thumbbiters[userid]
577	thumblock.Unlock()
578	objwhere := originate(objid)
579	if objwhere != "" && biters[objwhere] {
580		return true
581	}
582	for _, w := range who {
583		if biters[w] {
584			return true
585		}
586		where := originate(w)
587		if where != "" {
588			if biters[where] {
589				return true
590			}
591		}
592	}
593	return false
594}
595
596func keymatch(keyname string, actor string) string {
597	hash := strings.IndexByte(keyname, '#')
598	if hash == -1 {
599		hash = len(keyname)
600	}
601	owner := keyname[0:hash]
602	if owner == actor {
603		return originate(actor)
604	}
605	return ""
606}