109 lines
2.8 KiB
Go
109 lines
2.8 KiB
Go
//
|
|
// Copyright (c) 2019 Ted Unangst <tedu@tedunangst.com>
|
|
//
|
|
// Permission to use, copy, modify, and distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice appear in all copies.
|
|
//
|
|
// THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
// WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
// MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
// ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
// WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
|
// ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
|
// OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
|
|
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"fmt"
|
|
"log"
|
|
"strings"
|
|
"sync"
|
|
)
|
|
|
|
var bloat_mtx sync.Mutex
|
|
|
|
func bloat_counterplusone(s string) string {
|
|
bloat_mtx.Lock()
|
|
defer bloat_mtx.Unlock()
|
|
|
|
var bloat_counter int
|
|
getconfig("bloat_counter", &bloat_counter)
|
|
|
|
if bloat_counter < 9001 {
|
|
bloat_counter++
|
|
saveconfig("bloat_counter", bloat_counter)
|
|
}
|
|
// 1st 2nd 3rd 4th 5th 6th 7th 8th 9th 10th 11th 12th 13th
|
|
suf := "th"
|
|
switch bloat_counter % 10 {
|
|
case 1:
|
|
suf = "st"
|
|
case 2:
|
|
suf = "nd"
|
|
case 3:
|
|
suf = "rd"
|
|
}
|
|
if bloat_counter == 11 || bloat_counter == 12 || bloat_counter == 13 {
|
|
suf = "th"
|
|
}
|
|
val := fmt.Sprintf("%d%s", bloat_counter, suf)
|
|
log.Printf("now producing %s counter", val)
|
|
s = strings.Replace(s, "<bloat_counter>", val, -1)
|
|
return s
|
|
}
|
|
|
|
func bloat_counterfixhonk(honk *Honk) {
|
|
honk.Noise = bloat_counterplusone(honk.Noise)
|
|
}
|
|
|
|
func bloat_counterhtml(honk *Honk) {
|
|
honk.Noise = strings.Replace(honk.Noise, "<bloat_counter>", "1st", -1)
|
|
}
|
|
|
|
func bloat_counterannounce(user *WhatAbout, honk *Honk) {
|
|
rcpts := make(map[string]bool)
|
|
for _, a := range honk.Audience {
|
|
if a != thewholeworld && a != user.URL && !strings.HasSuffix(a, "/followers") {
|
|
box, _ := getboxes(a)
|
|
if box != nil && honk.Public && box.Shared != "" {
|
|
rcpts["%"+box.Shared] = true
|
|
} else {
|
|
rcpts[a] = true
|
|
}
|
|
}
|
|
}
|
|
if honk.Public {
|
|
for _, f := range getdubs(user.ID) {
|
|
box, _ := getboxes(f.XID)
|
|
if box != nil && box.Shared != "" {
|
|
rcpts["%"+box.Shared] = true
|
|
} else {
|
|
rcpts[f.XID] = true
|
|
}
|
|
}
|
|
}
|
|
orignoise := honk.Noise
|
|
for a := range rcpts {
|
|
honk.Noise = orignoise
|
|
bloat_counterfixhonk(honk)
|
|
jonk, _ := jonkjonk(user, honk)
|
|
jonk["@context"] = itiswhatitis
|
|
var buf bytes.Buffer
|
|
jonk.Write(&buf)
|
|
msg := buf.Bytes()
|
|
go deliverate(0, user.Name, a, msg)
|
|
}
|
|
}
|
|
|
|
func bloat_iscounter(honk *Honk) bool {
|
|
return strings.Contains(honk.Noise, "<bloat_counter>")
|
|
}
|
|
|
|
func bloat_undocounter() {
|
|
db := opendatabase()
|
|
db.Exec("update honks set noise = 'This post has expired' where noise like '%<bloat_counter>%' and whofore = 2 and what = 'honk'")
|
|
}
|