all repos — honk @ 2870ad7b53f0154c1584f7a5243801b2c5da5124

my fork of honk

database.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	"bytes"
  20	"crypto/sha512"
  21	"database/sql"
  22	_ "embed"
  23	"encoding/json"
  24	"fmt"
  25	"html/template"
  26	"sort"
  27	"strconv"
  28	"strings"
  29	"sync"
  30	"time"
  31
  32	"humungus.tedunangst.com/r/webs/cache"
  33	"humungus.tedunangst.com/r/webs/httpsig"
  34	"humungus.tedunangst.com/r/webs/login"
  35	"humungus.tedunangst.com/r/webs/mz"
  36)
  37
  38//go:embed schema.sql
  39var sqlSchema string
  40
  41func userfromrow(row *sql.Row) (*WhatAbout, error) {
  42	user := new(WhatAbout)
  43	var seckey, options string
  44	err := row.Scan(&user.ID, &user.Name, &user.Display, &user.About, &user.Key, &seckey, &options)
  45	if err == nil {
  46		user.SecKey, _, err = httpsig.DecodeKey(seckey)
  47	}
  48	if err != nil {
  49		return nil, err
  50	}
  51	if user.ID > 0 {
  52		user.URL = fmt.Sprintf("https://%s/%s/%s", serverName, userSep, user.Name)
  53		err = unjsonify(options, &user.Options)
  54		if err != nil {
  55			elog.Printf("error processing user options: %s", err)
  56		}
  57	} else {
  58		user.URL = fmt.Sprintf("https://%s/%s", serverName, user.Name)
  59	}
  60	if user.Options.Reaction == "" {
  61		user.Options.Reaction = "none"
  62	}
  63
  64	return user, nil
  65}
  66
  67var somenamedusers = cache.New(cache.Options{Filler: func(name string) (*WhatAbout, bool) {
  68	row := stmtUserByName.QueryRow(name)
  69	user, err := userfromrow(row)
  70	if err != nil {
  71		return nil, false
  72	}
  73	var marker mz.Marker
  74	marker.HashLinker = ontoreplacer
  75	marker.AtLinker = attoreplacer
  76	user.HTAbout = template.HTML(marker.Mark(user.About))
  77	user.Onts = marker.HashTags
  78	return user, true
  79}})
  80
  81var somenumberedusers = cache.New(cache.Options{Filler: func(userid int64) (*WhatAbout, bool) {
  82	row := stmtUserByNumber.QueryRow(userid)
  83	user, err := userfromrow(row)
  84	if err != nil {
  85		return nil, false
  86	}
  87	// don't touch attoreplacer, which introduces a loop
  88	// finger -> getjunk -> keys -> users
  89	return user, true
  90}})
  91
  92func getserveruser() *WhatAbout {
  93	var user *WhatAbout
  94	ok := somenumberedusers.Get(serverUID, &user)
  95	if !ok {
  96		elog.Panicf("lost server user")
  97	}
  98	return user
  99}
 100
 101func butwhatabout(name string) (*WhatAbout, error) {
 102	var user *WhatAbout
 103	ok := somenamedusers.Get(name, &user)
 104	if !ok {
 105		return nil, fmt.Errorf("no user: %s", name)
 106	}
 107	return user, nil
 108}
 109
 110var honkerinvalidator cache.Invalidator
 111
 112func gethonkers(userid int64) []*Honker {
 113	rows, err := stmtHonkers.Query(userid)
 114	if err != nil {
 115		elog.Printf("error querying honkers: %s", err)
 116		return nil
 117	}
 118	defer rows.Close()
 119	var honkers []*Honker
 120	for rows.Next() {
 121		h := new(Honker)
 122		var combos, meta string
 123		err = rows.Scan(&h.ID, &h.UserID, &h.Name, &h.XID, &h.Flavor, &combos, &meta)
 124		if err == nil {
 125			err = unjsonify(meta, &h.Meta)
 126		}
 127		if err != nil {
 128			elog.Printf("error scanning honker: %s", err)
 129			continue
 130		}
 131		h.Combos = strings.Split(strings.TrimSpace(combos), " ")
 132		honkers = append(honkers, h)
 133	}
 134	return honkers
 135}
 136
 137func getdubs(userid int64) []*Honker {
 138	rows, err := stmtDubbers.Query(userid)
 139	return dubsfromrows(rows, err)
 140}
 141
 142func getnameddubs(userid int64, name string) []*Honker {
 143	rows, err := stmtNamedDubbers.Query(userid, name)
 144	return dubsfromrows(rows, err)
 145}
 146
 147func dubsfromrows(rows *sql.Rows, err error) []*Honker {
 148	if err != nil {
 149		elog.Printf("error querying dubs: %s", err)
 150		return nil
 151	}
 152	defer rows.Close()
 153	var honkers []*Honker
 154	for rows.Next() {
 155		h := new(Honker)
 156		err = rows.Scan(&h.ID, &h.UserID, &h.Name, &h.XID, &h.Flavor)
 157		if err != nil {
 158			elog.Printf("error scanning honker: %s", err)
 159			return nil
 160		}
 161		honkers = append(honkers, h)
 162	}
 163	return honkers
 164}
 165
 166func allusers() []login.UserInfo {
 167	var users []login.UserInfo
 168	rows, _ := opendatabase().Query("select userid, username from users where userid > 0")
 169	defer rows.Close()
 170	for rows.Next() {
 171		var u login.UserInfo
 172		rows.Scan(&u.UserID, &u.Username)
 173		users = append(users, u)
 174	}
 175	return users
 176}
 177
 178func getxonk(userid int64, xid string) *Honk {
 179	row := stmtOneXonk.QueryRow(userid, xid)
 180	return scanhonk(row)
 181}
 182
 183func getbonk(userid int64, xid string) *Honk {
 184	row := stmtOneBonk.QueryRow(userid, xid)
 185	return scanhonk(row)
 186}
 187
 188func getpublichonks() []*Honk {
 189	dt := time.Now().Add(-7 * 24 * time.Hour).UTC().Format(dbtimeformat)
 190	rows, err := stmtPublicHonks.Query(dt, 100)
 191	return getsomehonks(rows, err)
 192}
 193func geteventhonks(userid int64) []*Honk {
 194	rows, err := stmtEventHonks.Query(userid, 25)
 195	honks := getsomehonks(rows, err)
 196	sort.Slice(honks, func(i, j int) bool {
 197		var t1, t2 time.Time
 198		if honks[i].Time == nil {
 199			t1 = honks[i].Date
 200		} else {
 201			t1 = honks[i].Time.StartTime
 202		}
 203		if honks[j].Time == nil {
 204			t2 = honks[j].Date
 205		} else {
 206			t2 = honks[j].Time.StartTime
 207		}
 208		return t1.After(t2)
 209	})
 210	now := time.Now().Add(-24 * time.Hour)
 211	for i, h := range honks {
 212		t := h.Date
 213		if tm := h.Time; tm != nil {
 214			t = tm.StartTime
 215		}
 216		if t.Before(now) {
 217			honks = honks[:i]
 218			break
 219		}
 220	}
 221	reversehonks(honks)
 222	return honks
 223}
 224func gethonksbyuser(name string, includeprivate bool, wanted int64) []*Honk {
 225	dt := time.Now().Add(-7 * 24 * time.Hour).UTC().Format(dbtimeformat)
 226	limit := 50
 227	whofore := 2
 228	if includeprivate {
 229		whofore = 3
 230	}
 231	rows, err := stmtUserHonks.Query(wanted, whofore, name, dt, limit)
 232	return getsomehonks(rows, err)
 233}
 234func gethonksforuser(userid int64, wanted int64) []*Honk {
 235	dt := time.Now().Add(-7 * 24 * time.Hour).UTC().Format(dbtimeformat)
 236	rows, err := stmtHonksForUser.Query(wanted, userid, dt, userid, userid)
 237	return getsomehonks(rows, err)
 238}
 239func gethonksforuserfirstclass(userid int64, wanted int64) []*Honk {
 240	dt := time.Now().Add(-7 * 24 * time.Hour).UTC().Format(dbtimeformat)
 241	rows, err := stmtHonksForUserFirstClass.Query(wanted, userid, dt, userid, userid)
 242	return getsomehonks(rows, err)
 243}
 244
 245func gethonksforme(userid int64, wanted int64) []*Honk {
 246	dt := time.Now().Add(-7 * 24 * time.Hour).UTC().Format(dbtimeformat)
 247	rows, err := stmtHonksForMe.Query(wanted, userid, dt, userid)
 248	return getsomehonks(rows, err)
 249}
 250func gethonksfromlongago(userid int64, wanted int64) []*Honk {
 251	now := time.Now()
 252	var honks []*Honk
 253	for i := 1; i <= 4; i++ {
 254		dt := time.Date(now.Year()-i, now.Month(), now.Day(), now.Hour(), now.Minute(),
 255			now.Second(), 0, now.Location())
 256		dt1 := dt.Add(-36 * time.Hour).UTC().Format(dbtimeformat)
 257		dt2 := dt.Add(12 * time.Hour).UTC().Format(dbtimeformat)
 258		rows, err := stmtHonksFromLongAgo.Query(wanted, userid, dt1, dt2, userid)
 259		honks = append(honks, getsomehonks(rows, err)...)
 260	}
 261	return honks
 262}
 263func getsavedhonks(userid int64, wanted int64) []*Honk {
 264	rows, err := stmtHonksISaved.Query(wanted, userid)
 265	return getsomehonks(rows, err)
 266}
 267func gethonksbyhonker(userid int64, honker string, wanted int64) []*Honk {
 268	rows, err := stmtHonksByHonker.Query(wanted, userid, honker, userid)
 269	return getsomehonks(rows, err)
 270}
 271func gethonksbyxonker(userid int64, xonker string, wanted int64) []*Honk {
 272	rows, err := stmtHonksByXonker.Query(wanted, userid, xonker, xonker, userid)
 273	return getsomehonks(rows, err)
 274}
 275func gethonksbycombo(userid int64, combo string, wanted int64) []*Honk {
 276	combo = "% " + combo + " %"
 277	rows, err := stmtHonksByCombo.Query(wanted, userid, userid, combo, userid, wanted, userid, combo, userid)
 278	return getsomehonks(rows, err)
 279}
 280func gethonksbyconvoy(userid int64, convoy string, wanted int64) []*Honk {
 281	rows, err := stmtHonksByConvoy.Query(wanted, userid, userid, convoy)
 282	honks := getsomehonks(rows, err)
 283	return honks
 284}
 285func gethonksbysearch(userid int64, q string, wanted int64) []*Honk {
 286	var queries []string
 287	var params []interface{}
 288	queries = append(queries, "honks.honkid > ?")
 289	params = append(params, wanted)
 290	queries = append(queries, "honks.userid = ?")
 291	params = append(params, userid)
 292
 293	terms := strings.Split(q, " ")
 294	for _, t := range terms {
 295		if t == "" {
 296			continue
 297		}
 298		negate := " "
 299		if t[0] == '-' {
 300			t = t[1:]
 301			negate = " not "
 302		}
 303		if t == "" {
 304			continue
 305		}
 306		if t == "@me" {
 307			queries = append(queries, "whofore = 1")
 308			continue
 309		}
 310		if t == "@self" {
 311			queries = append(queries, "(whofore = 2 or whofore = 3)")
 312			continue
 313		}
 314		if strings.HasPrefix(t, "before:") {
 315			before := t[7:]
 316			queries = append(queries, "dt < ?")
 317			params = append(params, before)
 318			continue
 319		}
 320		if strings.HasPrefix(t, "after:") {
 321			after := t[6:]
 322			queries = append(queries, "dt > ?")
 323			params = append(params, after)
 324			continue
 325		}
 326		if strings.HasPrefix(t, "site:") {
 327			site := t[5:]
 328			site = "%" + site + "%"
 329			queries = append(queries, "xid"+negate+"like ?")
 330			params = append(params, site)
 331			continue
 332		}
 333		if strings.HasPrefix(t, "honker:") {
 334			honker := t[7:]
 335			xid := fullname(honker, userid)
 336			if xid != "" {
 337				honker = xid
 338			}
 339			queries = append(queries, negate+"(honks.honker = ? or honks.oonker = ?)")
 340			params = append(params, honker)
 341			params = append(params, honker)
 342			continue
 343		}
 344		t = "%" + t + "%"
 345		queries = append(queries, "noise"+negate+"like ?")
 346		params = append(params, t)
 347	}
 348
 349	selecthonks := "select honks.honkid, honks.userid, username, what, honker, oonker, honks.xid, rid, dt, url, audience, noise, precis, format, convoy, whofore, flags from honks join users on honks.userid = users.userid "
 350	where := "where " + strings.Join(queries, " and ")
 351	butnotthose := " and convoy not in (select name from zonkers where userid = ? and wherefore = 'zonvoy' order by zonkerid desc limit 100)"
 352	limit := " order by honks.honkid desc limit 250"
 353	params = append(params, userid)
 354	rows, err := opendatabase().Query(selecthonks+where+butnotthose+limit, params...)
 355	honks := getsomehonks(rows, err)
 356	return honks
 357}
 358func gethonksbyontology(userid int64, name string, wanted int64) []*Honk {
 359	rows, err := stmtHonksByOntology.Query(wanted, name, userid, userid)
 360	honks := getsomehonks(rows, err)
 361	return honks
 362}
 363
 364func reversehonks(honks []*Honk) {
 365	for i, j := 0, len(honks)-1; i < j; i, j = i+1, j-1 {
 366		honks[i], honks[j] = honks[j], honks[i]
 367	}
 368}
 369
 370func getsomehonks(rows *sql.Rows, err error) []*Honk {
 371	if err != nil {
 372		elog.Printf("error querying honks: %s", err)
 373		return nil
 374	}
 375	defer rows.Close()
 376	var honks []*Honk
 377	for rows.Next() {
 378		h := scanhonk(rows)
 379		if h != nil {
 380			honks = append(honks, h)
 381		}
 382	}
 383	rows.Close()
 384	donksforhonks(honks)
 385	return honks
 386}
 387
 388type RowLike interface {
 389	Scan(dest ...interface{}) error
 390}
 391
 392func scanhonk(row RowLike) *Honk {
 393	h := new(Honk)
 394	var dt, aud string
 395	err := row.Scan(&h.ID, &h.UserID, &h.Username, &h.What, &h.Honker, &h.Oonker, &h.XID, &h.RID,
 396		&dt, &h.URL, &aud, &h.Noise, &h.Precis, &h.Format, &h.Convoy, &h.Whofore, &h.Flags)
 397	if err != nil {
 398		if err != sql.ErrNoRows {
 399			elog.Printf("error scanning honk: %s", err)
 400		}
 401		return nil
 402	}
 403	h.Date, _ = time.Parse(dbtimeformat, dt)
 404	h.Audience = strings.Split(aud, " ")
 405	h.Public = loudandproud(h.Audience)
 406	return h
 407}
 408
 409func donksforhonks(honks []*Honk) {
 410	db := opendatabase()
 411	var ids []string
 412	hmap := make(map[int64]*Honk)
 413	for _, h := range honks {
 414		ids = append(ids, fmt.Sprintf("%d", h.ID))
 415		hmap[h.ID] = h
 416	}
 417	idset := strings.Join(ids, ",")
 418	// grab donks
 419	q := fmt.Sprintf("select honkid, donks.fileid, xid, name, description, url, media, local from donks join filemeta on donks.fileid = filemeta.fileid where honkid in (%s)", idset)
 420	rows, err := db.Query(q)
 421	if err != nil {
 422		elog.Printf("error querying donks: %s", err)
 423		return
 424	}
 425	defer rows.Close()
 426	for rows.Next() {
 427		var hid int64
 428		d := new(Donk)
 429		err = rows.Scan(&hid, &d.FileID, &d.XID, &d.Name, &d.Desc, &d.URL, &d.Media, &d.Local)
 430		if err != nil {
 431			elog.Printf("error scanning donk: %s", err)
 432			continue
 433		}
 434		d.External = !strings.HasPrefix(d.URL, serverPrefix)
 435		h := hmap[hid]
 436		h.Donks = append(h.Donks, d)
 437	}
 438	rows.Close()
 439
 440	// grab onts
 441	q = fmt.Sprintf("select honkid, ontology from onts where honkid in (%s)", idset)
 442	rows, err = db.Query(q)
 443	if err != nil {
 444		elog.Printf("error querying onts: %s", err)
 445		return
 446	}
 447	defer rows.Close()
 448	for rows.Next() {
 449		var hid int64
 450		var o string
 451		err = rows.Scan(&hid, &o)
 452		if err != nil {
 453			elog.Printf("error scanning donk: %s", err)
 454			continue
 455		}
 456		h := hmap[hid]
 457		h.Onts = append(h.Onts, o)
 458	}
 459	rows.Close()
 460
 461	// grab meta
 462	q = fmt.Sprintf("select honkid, genus, json from honkmeta where honkid in (%s)", idset)
 463	rows, err = db.Query(q)
 464	if err != nil {
 465		elog.Printf("error querying honkmeta: %s", err)
 466		return
 467	}
 468	defer rows.Close()
 469	for rows.Next() {
 470		var hid int64
 471		var genus, j string
 472		err = rows.Scan(&hid, &genus, &j)
 473		if err != nil {
 474			elog.Printf("error scanning honkmeta: %s", err)
 475			continue
 476		}
 477		h := hmap[hid]
 478		switch genus {
 479		case "place":
 480			p := new(Place)
 481			err = unjsonify(j, p)
 482			if err != nil {
 483				elog.Printf("error parsing place: %s", err)
 484				continue
 485			}
 486			h.Place = p
 487		case "time":
 488			t := new(Time)
 489			err = unjsonify(j, t)
 490			if err != nil {
 491				elog.Printf("error parsing time: %s", err)
 492				continue
 493			}
 494			h.Time = t
 495		case "mentions":
 496			err = unjsonify(j, &h.Mentions)
 497			if err != nil {
 498				elog.Printf("error parsing mentions: %s", err)
 499				continue
 500			}
 501		case "badonks":
 502			err = unjsonify(j, &h.Badonks)
 503			if err != nil {
 504				elog.Printf("error parsing badonks: %s", err)
 505				continue
 506			}
 507		case "oldrev":
 508		default:
 509			elog.Printf("unknown meta genus: %s", genus)
 510		}
 511	}
 512	rows.Close()
 513}
 514
 515func donksforchonks(chonks []*Chonk) {
 516	db := opendatabase()
 517	var ids []string
 518	chmap := make(map[int64]*Chonk)
 519	for _, ch := range chonks {
 520		ids = append(ids, fmt.Sprintf("%d", ch.ID))
 521		chmap[ch.ID] = ch
 522	}
 523	idset := strings.Join(ids, ",")
 524	// grab donks
 525	q := fmt.Sprintf("select chonkid, donks.fileid, xid, name, description, url, media, local from donks join filemeta on donks.fileid = filemeta.fileid where chonkid in (%s)", idset)
 526	rows, err := db.Query(q)
 527	if err != nil {
 528		elog.Printf("error querying donks: %s", err)
 529		return
 530	}
 531	defer rows.Close()
 532	for rows.Next() {
 533		var chid int64
 534		d := new(Donk)
 535		err = rows.Scan(&chid, &d.FileID, &d.XID, &d.Name, &d.Desc, &d.URL, &d.Media, &d.Local)
 536		if err != nil {
 537			elog.Printf("error scanning donk: %s", err)
 538			continue
 539		}
 540		ch := chmap[chid]
 541		ch.Donks = append(ch.Donks, d)
 542	}
 543}
 544
 545func savefile(name string, desc string, url string, media string, local bool, data []byte) (int64, error) {
 546	fileid, _, err := savefileandxid(name, desc, url, media, local, data)
 547	return fileid, err
 548}
 549
 550func hashfiledata(data []byte) string {
 551	h := sha512.New512_256()
 552	h.Write(data)
 553	return fmt.Sprintf("%x", h.Sum(nil))
 554}
 555
 556func savefileandxid(name string, desc string, url string, media string, local bool, data []byte) (int64, string, error) {
 557	var xid string
 558	if local {
 559		hash := hashfiledata(data)
 560		row := stmtCheckFileData.QueryRow(hash)
 561		err := row.Scan(&xid)
 562		if err == sql.ErrNoRows {
 563			xid = xfiltrate()
 564			switch media {
 565			case "image/png":
 566				xid += ".png"
 567			case "image/jpeg":
 568				xid += ".jpg"
 569			case "image/svg+xml":
 570				xid += ".svg"
 571			case "application/pdf":
 572				xid += ".pdf"
 573			case "text/plain":
 574				xid += ".txt"
 575			}
 576			_, err = stmtSaveFileData.Exec(xid, media, hash, data)
 577			if err != nil {
 578				return 0, "", err
 579			}
 580		} else if err != nil {
 581			elog.Printf("error checking file hash: %s", err)
 582			return 0, "", err
 583		}
 584		if url == "" {
 585			url = fmt.Sprintf("https://%s/d/%s", serverName, xid)
 586		}
 587	}
 588
 589	res, err := stmtSaveFile.Exec(xid, name, desc, url, media, local)
 590	if err != nil {
 591		return 0, "", err
 592	}
 593	fileid, _ := res.LastInsertId()
 594	return fileid, xid, nil
 595}
 596
 597func finddonkid(fileid int64, url string) *Donk {
 598	donk := new(Donk)
 599	row := stmtFindFileId.QueryRow(fileid, url)
 600	err := row.Scan(&donk.XID, &donk.Local, &donk.Desc)
 601	if err == nil {
 602		donk.FileID = fileid
 603		return donk
 604	}
 605	if err != sql.ErrNoRows {
 606		elog.Printf("error finding file: %s", err)
 607	}
 608	return nil
 609}
 610
 611func finddonk(url string) *Donk {
 612	donk := new(Donk)
 613	row := stmtFindFile.QueryRow(url)
 614	err := row.Scan(&donk.FileID, &donk.XID)
 615	if err == nil {
 616		return donk
 617	}
 618	if err != sql.ErrNoRows {
 619		elog.Printf("error finding file: %s", err)
 620	}
 621	return nil
 622}
 623
 624func savechonk(ch *Chonk) error {
 625	dt := ch.Date.UTC().Format(dbtimeformat)
 626	db := opendatabase()
 627	tx, err := db.Begin()
 628	if err != nil {
 629		elog.Printf("can't begin tx: %s", err)
 630		return err
 631	}
 632
 633	res, err := tx.Stmt(stmtSaveChonk).Exec(ch.UserID, ch.XID, ch.Who, ch.Target, dt, ch.Noise, ch.Format)
 634	if err == nil {
 635		ch.ID, _ = res.LastInsertId()
 636		for _, d := range ch.Donks {
 637			_, err := tx.Stmt(stmtSaveDonk).Exec(-1, ch.ID, d.FileID)
 638			if err != nil {
 639				elog.Printf("error saving donk: %s", err)
 640				break
 641			}
 642		}
 643		chatplusone(tx, ch.UserID)
 644		err = tx.Commit()
 645	} else {
 646		tx.Rollback()
 647	}
 648	return err
 649}
 650
 651func chatplusone(tx *sql.Tx, userid int64) {
 652	var user *WhatAbout
 653	ok := somenumberedusers.Get(userid, &user)
 654	if !ok {
 655		return
 656	}
 657	options := user.Options
 658	options.ChatCount += 1
 659	j, err := jsonify(options)
 660	if err == nil {
 661		_, err = tx.Exec("update users set options = ? where username = ?", j, user.Name)
 662	}
 663	if err != nil {
 664		elog.Printf("error plussing chat: %s", err)
 665	}
 666	somenamedusers.Clear(user.Name)
 667	somenumberedusers.Clear(user.ID)
 668}
 669
 670func chatnewnone(userid int64) {
 671	var user *WhatAbout
 672	ok := somenumberedusers.Get(userid, &user)
 673	if !ok || user.Options.ChatCount == 0 {
 674		return
 675	}
 676	options := user.Options
 677	options.ChatCount = 0
 678	j, err := jsonify(options)
 679	if err == nil {
 680		db := opendatabase()
 681		_, err = db.Exec("update users set options = ? where username = ?", j, user.Name)
 682	}
 683	if err != nil {
 684		elog.Printf("error noneing chat: %s", err)
 685	}
 686	somenamedusers.Clear(user.Name)
 687	somenumberedusers.Clear(user.ID)
 688}
 689
 690func meplusone(tx *sql.Tx, userid int64) {
 691	var user *WhatAbout
 692	ok := somenumberedusers.Get(userid, &user)
 693	if !ok {
 694		return
 695	}
 696	options := user.Options
 697	options.MeCount += 1
 698	j, err := jsonify(options)
 699	if err == nil {
 700		_, err = tx.Exec("update users set options = ? where username = ?", j, user.Name)
 701	}
 702	if err != nil {
 703		elog.Printf("error plussing me: %s", err)
 704	}
 705	somenamedusers.Clear(user.Name)
 706	somenumberedusers.Clear(user.ID)
 707}
 708
 709func menewnone(userid int64) {
 710	var user *WhatAbout
 711	ok := somenumberedusers.Get(userid, &user)
 712	if !ok || user.Options.MeCount == 0 {
 713		return
 714	}
 715	options := user.Options
 716	options.MeCount = 0
 717	j, err := jsonify(options)
 718	if err == nil {
 719		db := opendatabase()
 720		_, err = db.Exec("update users set options = ? where username = ?", j, user.Name)
 721	}
 722	if err != nil {
 723		elog.Printf("error noneing me: %s", err)
 724	}
 725	somenamedusers.Clear(user.Name)
 726	somenumberedusers.Clear(user.ID)
 727}
 728
 729func loadchatter(userid int64) []*Chatter {
 730	duedt := time.Now().Add(-3 * 24 * time.Hour).UTC().Format(dbtimeformat)
 731	rows, err := stmtLoadChonks.Query(userid, duedt)
 732	if err != nil {
 733		elog.Printf("error loading chonks: %s", err)
 734		return nil
 735	}
 736	defer rows.Close()
 737	chonks := make(map[string][]*Chonk)
 738	var allchonks []*Chonk
 739	for rows.Next() {
 740		ch := new(Chonk)
 741		var dt string
 742		err = rows.Scan(&ch.ID, &ch.UserID, &ch.XID, &ch.Who, &ch.Target, &dt, &ch.Noise, &ch.Format)
 743		if err != nil {
 744			elog.Printf("error scanning chonk: %s", err)
 745			continue
 746		}
 747		ch.Date, _ = time.Parse(dbtimeformat, dt)
 748		chonks[ch.Target] = append(chonks[ch.Target], ch)
 749		allchonks = append(allchonks, ch)
 750	}
 751	donksforchonks(allchonks)
 752	rows.Close()
 753	rows, err = stmtGetChatters.Query(userid)
 754	if err != nil {
 755		elog.Printf("error getting chatters: %s", err)
 756		return nil
 757	}
 758	for rows.Next() {
 759		var target string
 760		err = rows.Scan(&target)
 761		if err != nil {
 762			elog.Printf("error scanning chatter: %s", target)
 763			continue
 764		}
 765		if _, ok := chonks[target]; !ok {
 766			chonks[target] = []*Chonk{}
 767
 768		}
 769	}
 770	var chatter []*Chatter
 771	for target, chonks := range chonks {
 772		chatter = append(chatter, &Chatter{
 773			Target: target,
 774			Chonks: chonks,
 775		})
 776	}
 777	sort.Slice(chatter, func(i, j int) bool {
 778		a, b := chatter[i], chatter[j]
 779		if len(a.Chonks) == 0 || len(b.Chonks) == 0 {
 780			if len(a.Chonks) == len(b.Chonks) {
 781				return a.Target < b.Target
 782			}
 783			return len(a.Chonks) > len(b.Chonks)
 784		}
 785		return a.Chonks[len(a.Chonks)-1].Date.After(b.Chonks[len(b.Chonks)-1].Date)
 786	})
 787
 788	return chatter
 789}
 790
 791func savehonk(h *Honk) error {
 792	dt := h.Date.UTC().Format(dbtimeformat)
 793	aud := strings.Join(h.Audience, " ")
 794
 795	db := opendatabase()
 796	tx, err := db.Begin()
 797	if err != nil {
 798		elog.Printf("can't begin tx: %s", err)
 799		return err
 800	}
 801
 802	res, err := tx.Stmt(stmtSaveHonk).Exec(h.UserID, h.What, h.Honker, h.XID, h.RID, dt, h.URL,
 803		aud, h.Noise, h.Convoy, h.Whofore, h.Format, h.Precis,
 804		h.Oonker, h.Flags)
 805	if err == nil {
 806		h.ID, _ = res.LastInsertId()
 807		err = saveextras(tx, h)
 808	}
 809	if err == nil {
 810		if h.Whofore == 1 {
 811			meplusone(tx, h.UserID)
 812		}
 813		err = tx.Commit()
 814	} else {
 815		tx.Rollback()
 816	}
 817	if err != nil {
 818		elog.Printf("error saving honk: %s", err)
 819	}
 820	honkhonkline()
 821	return err
 822}
 823
 824func updatehonk(h *Honk) error {
 825	old := getxonk(h.UserID, h.XID)
 826	oldrev := OldRevision{Precis: old.Precis, Noise: old.Noise}
 827	dt := h.Date.UTC().Format(dbtimeformat)
 828
 829	db := opendatabase()
 830	tx, err := db.Begin()
 831	if err != nil {
 832		elog.Printf("can't begin tx: %s", err)
 833		return err
 834	}
 835
 836	err = deleteextras(tx, h.ID, false)
 837	if err == nil {
 838		_, err = tx.Stmt(stmtUpdateHonk).Exec(h.Precis, h.Noise, h.Format, h.Whofore, dt, h.ID)
 839	}
 840	if err == nil {
 841		err = saveextras(tx, h)
 842	}
 843	if err == nil {
 844		var j string
 845		j, err = jsonify(&oldrev)
 846		if err == nil {
 847			_, err = tx.Stmt(stmtSaveMeta).Exec(old.ID, "oldrev", j)
 848		}
 849		if err != nil {
 850			elog.Printf("error saving oldrev: %s", err)
 851		}
 852	}
 853	if err == nil {
 854		err = tx.Commit()
 855	} else {
 856		tx.Rollback()
 857	}
 858	if err != nil {
 859		elog.Printf("error updating honk %d: %s", h.ID, err)
 860	}
 861	return err
 862}
 863
 864func deletehonk(honkid int64) error {
 865	db := opendatabase()
 866	tx, err := db.Begin()
 867	if err != nil {
 868		elog.Printf("can't begin tx: %s", err)
 869		return err
 870	}
 871
 872	err = deleteextras(tx, honkid, true)
 873	if err == nil {
 874		_, err = tx.Stmt(stmtDeleteHonk).Exec(honkid)
 875	}
 876	if err == nil {
 877		err = tx.Commit()
 878	} else {
 879		tx.Rollback()
 880	}
 881	if err != nil {
 882		elog.Printf("error deleting honk %d: %s", honkid, err)
 883	}
 884	return err
 885}
 886
 887func saveextras(tx *sql.Tx, h *Honk) error {
 888	for _, d := range h.Donks {
 889		_, err := tx.Stmt(stmtSaveDonk).Exec(h.ID, -1, d.FileID)
 890		if err != nil {
 891			elog.Printf("error saving donk: %s", err)
 892			return err
 893		}
 894	}
 895	for _, o := range h.Onts {
 896		_, err := tx.Stmt(stmtSaveOnt).Exec(strings.ToLower(o), h.ID)
 897		if err != nil {
 898			elog.Printf("error saving ont: %s", err)
 899			return err
 900		}
 901	}
 902	if p := h.Place; p != nil {
 903		j, err := jsonify(p)
 904		if err == nil {
 905			_, err = tx.Stmt(stmtSaveMeta).Exec(h.ID, "place", j)
 906		}
 907		if err != nil {
 908			elog.Printf("error saving place: %s", err)
 909			return err
 910		}
 911	}
 912	if t := h.Time; t != nil {
 913		j, err := jsonify(t)
 914		if err == nil {
 915			_, err = tx.Stmt(stmtSaveMeta).Exec(h.ID, "time", j)
 916		}
 917		if err != nil {
 918			elog.Printf("error saving time: %s", err)
 919			return err
 920		}
 921	}
 922	if m := h.Mentions; len(m) > 0 {
 923		j, err := jsonify(m)
 924		if err == nil {
 925			_, err = tx.Stmt(stmtSaveMeta).Exec(h.ID, "mentions", j)
 926		}
 927		if err != nil {
 928			elog.Printf("error saving mentions: %s", err)
 929			return err
 930		}
 931	}
 932	return nil
 933}
 934
 935var baxonker sync.Mutex
 936
 937func addreaction(user *WhatAbout, xid string, who, react string) {
 938	baxonker.Lock()
 939	defer baxonker.Unlock()
 940	h := getxonk(user.ID, xid)
 941	if h == nil {
 942		return
 943	}
 944	h.Badonks = append(h.Badonks, Badonk{Who: who, What: react})
 945	j, _ := jsonify(h.Badonks)
 946	db := opendatabase()
 947	tx, _ := db.Begin()
 948	_, _ = tx.Stmt(stmtDeleteOneMeta).Exec(h.ID, "badonks")
 949	_, _ = tx.Stmt(stmtSaveMeta).Exec(h.ID, "badonks", j)
 950	tx.Commit()
 951}
 952
 953func deleteextras(tx *sql.Tx, honkid int64, everything bool) error {
 954	_, err := tx.Stmt(stmtDeleteDonks).Exec(honkid)
 955	if err != nil {
 956		return err
 957	}
 958	_, err = tx.Stmt(stmtDeleteOnts).Exec(honkid)
 959	if err != nil {
 960		return err
 961	}
 962	if everything {
 963		_, err = tx.Stmt(stmtDeleteAllMeta).Exec(honkid)
 964	} else {
 965		_, err = tx.Stmt(stmtDeleteSomeMeta).Exec(honkid)
 966	}
 967	if err != nil {
 968		return err
 969	}
 970	return nil
 971}
 972
 973func jsonify(what interface{}) (string, error) {
 974	var buf bytes.Buffer
 975	e := json.NewEncoder(&buf)
 976	e.SetEscapeHTML(false)
 977	e.SetIndent("", "")
 978	err := e.Encode(what)
 979	return buf.String(), err
 980}
 981
 982func unjsonify(s string, dest interface{}) error {
 983	d := json.NewDecoder(strings.NewReader(s))
 984	err := d.Decode(dest)
 985	return err
 986}
 987
 988func getxonker(what, flav string) string {
 989	var res string
 990	row := stmtGetXonker.QueryRow(what, flav)
 991	row.Scan(&res)
 992	return res
 993}
 994
 995func savexonker(what, value, flav, when string) {
 996	stmtSaveXonker.Exec(what, value, flav, when)
 997}
 998
 999func savehonker(user *WhatAbout, url, name, flavor, combos, mj string) (int64, error) {
1000	var owner string
1001	if url[0] == '#' {
1002		flavor = "peep"
1003		if name == "" {
1004			name = url[1:]
1005		}
1006		owner = url
1007	} else {
1008		info, err := investigate(url)
1009		if err != nil {
1010			ilog.Printf("failed to investigate honker: %s", err)
1011			return 0, err
1012		}
1013		url = info.XID
1014		if name == "" {
1015			name = info.Name
1016		}
1017		owner = info.Owner
1018	}
1019
1020	var x string
1021	db := opendatabase()
1022	row := db.QueryRow("select xid from honkers where xid = ? and userid = ? and flavor in ('sub', 'unsub', 'peep')", url, user.ID)
1023	err := row.Scan(&x)
1024	if err != sql.ErrNoRows {
1025		if err != nil {
1026			elog.Printf("honker scan err: %s", err)
1027		} else {
1028			err = fmt.Errorf("it seems you are already subscribed to them")
1029		}
1030		return 0, err
1031	}
1032
1033	res, err := stmtSaveHonker.Exec(user.ID, name, url, flavor, combos, owner, mj)
1034	if err != nil {
1035		elog.Print(err)
1036		return 0, err
1037	}
1038	honkerid, _ := res.LastInsertId()
1039	return honkerid, nil
1040}
1041
1042func cleanupdb(arg string) {
1043	db := opendatabase()
1044	days, err := strconv.Atoi(arg)
1045	var sqlargs []interface{}
1046	var where string
1047	if err != nil {
1048		honker := arg
1049		expdate := time.Now().Add(-3 * 24 * time.Hour).UTC().Format(dbtimeformat)
1050		where = "dt < ? and honker = ?"
1051		sqlargs = append(sqlargs, expdate)
1052		sqlargs = append(sqlargs, honker)
1053	} else {
1054		expdate := time.Now().Add(-time.Duration(days) * 24 * time.Hour).UTC().Format(dbtimeformat)
1055		where = "dt < ? and convoy not in (select convoy from honks where flags & 4 or whofore = 2 or whofore = 3)"
1056		sqlargs = append(sqlargs, expdate)
1057	}
1058	doordie(db, "delete from honks where flags & 4 = 0 and whofore = 0 and "+where, sqlargs...)
1059	doordie(db, "delete from donks where honkid > 0 and honkid not in (select honkid from honks)")
1060	doordie(db, "delete from onts where honkid not in (select honkid from honks)")
1061	doordie(db, "delete from honkmeta where honkid not in (select honkid from honks)")
1062
1063	doordie(db, "delete from filemeta where fileid not in (select fileid from donks)")
1064	for _, u := range allusers() {
1065		doordie(db, "delete from zonkers where userid = ? and wherefore = 'zonvoy' and zonkerid < (select zonkerid from zonkers where userid = ? and wherefore = 'zonvoy' order by zonkerid desc limit 1 offset 200)", u.UserID, u.UserID)
1066	}
1067
1068	filexids := make(map[string]bool)
1069	blobdb := openblobdb()
1070	rows, err := blobdb.Query("select xid from filedata")
1071	if err != nil {
1072		elog.Fatal(err)
1073	}
1074	for rows.Next() {
1075		var xid string
1076		err = rows.Scan(&xid)
1077		if err != nil {
1078			elog.Fatal(err)
1079		}
1080		filexids[xid] = true
1081	}
1082	rows.Close()
1083	rows, err = db.Query("select xid from filemeta")
1084	for rows.Next() {
1085		var xid string
1086		err = rows.Scan(&xid)
1087		if err != nil {
1088			elog.Fatal(err)
1089		}
1090		delete(filexids, xid)
1091	}
1092	rows.Close()
1093	tx, err := blobdb.Begin()
1094	if err != nil {
1095		elog.Fatal(err)
1096	}
1097	for xid, _ := range filexids {
1098		_, err = tx.Exec("delete from filedata where xid = ?", xid)
1099		if err != nil {
1100			elog.Fatal(err)
1101		}
1102	}
1103	err = tx.Commit()
1104	if err != nil {
1105		elog.Fatal(err)
1106	}
1107}
1108
1109var stmtHonkers, stmtDubbers, stmtNamedDubbers, stmtSaveHonker, stmtUpdateFlavor, stmtUpdateHonker *sql.Stmt
1110var stmtDeleteHonker *sql.Stmt
1111var stmtAnyXonk, stmtOneXonk, stmtPublicHonks, stmtUserHonks, stmtHonksByCombo, stmtHonksByConvoy *sql.Stmt
1112var stmtHonksByOntology, stmtHonksForUser, stmtHonksForMe, stmtSaveDub, stmtHonksByXonker *sql.Stmt
1113var stmtHonksFromLongAgo *sql.Stmt
1114var stmtHonksByHonker, stmtSaveHonk, stmtUserByName, stmtUserByNumber *sql.Stmt
1115var stmtEventHonks, stmtOneBonk, stmtFindZonk, stmtFindXonk, stmtSaveDonk *sql.Stmt
1116var stmtFindFile, stmtFindFileId, stmtGetFileData, stmtSaveFileData, stmtSaveFile *sql.Stmt
1117var stmtCheckFileData *sql.Stmt
1118var stmtAddDoover, stmtGetDoovers, stmtLoadDoover, stmtZapDoover, stmtOneHonker *sql.Stmt
1119var stmtUntagged, stmtDeleteHonk, stmtDeleteDonks, stmtDeleteOnts, stmtSaveZonker *sql.Stmt
1120var stmtGetZonkers, stmtRecentHonkers, stmtGetXonker, stmtSaveXonker, stmtDeleteXonker, stmtDeleteOldXonkers *sql.Stmt
1121var stmtAllOnts, stmtSaveOnt, stmtUpdateFlags, stmtClearFlags *sql.Stmt
1122var stmtHonksForUserFirstClass *sql.Stmt
1123var stmtSaveMeta, stmtDeleteAllMeta, stmtDeleteOneMeta, stmtDeleteSomeMeta, stmtUpdateHonk *sql.Stmt
1124var stmtHonksISaved, stmtGetFilters, stmtSaveFilter, stmtDeleteFilter *sql.Stmt
1125var stmtGetTracks *sql.Stmt
1126var stmtSaveChonk, stmtLoadChonks, stmtGetChatters *sql.Stmt
1127var stmtDeliquentCheck, stmtDeliquentUpdate *sql.Stmt
1128
1129func preparetodie(db *sql.DB, s string) *sql.Stmt {
1130	stmt, err := db.Prepare(s)
1131	if err != nil {
1132		elog.Fatalf("error %s: %s", err, s)
1133	}
1134	return stmt
1135}
1136
1137func prepareStatements(db *sql.DB) {
1138	stmtHonkers = preparetodie(db, "select honkerid, userid, name, xid, flavor, combos, meta from honkers where userid = ? and (flavor = 'presub' or flavor = 'sub' or flavor = 'peep' or flavor = 'unsub') order by name")
1139	stmtSaveHonker = preparetodie(db, "insert into honkers (userid, name, xid, flavor, combos, owner, meta, folxid) values (?, ?, ?, ?, ?, ?, ?, '')")
1140	stmtUpdateFlavor = preparetodie(db, "update honkers set flavor = ?, folxid = ? where userid = ? and name = ? and xid = ? and flavor = ?")
1141	stmtUpdateHonker = preparetodie(db, "update honkers set name = ?, combos = ?, meta = ? where honkerid = ? and userid = ?")
1142	stmtDeleteHonker = preparetodie(db, "delete from honkers where honkerid = ?")
1143	stmtOneHonker = preparetodie(db, "select xid from honkers where name = ? and userid = ?")
1144	stmtDubbers = preparetodie(db, "select honkerid, userid, name, xid, flavor from honkers where userid = ? and flavor = 'dub'")
1145	stmtNamedDubbers = preparetodie(db, "select honkerid, userid, name, xid, flavor from honkers where userid = ? and name = ? and flavor = 'dub'")
1146
1147	selecthonks := "select honks.honkid, honks.userid, username, what, honker, oonker, honks.xid, rid, dt, url, audience, noise, precis, format, convoy, whofore, flags from honks join users on honks.userid = users.userid "
1148	limit := " order by honks.honkid desc limit 250"
1149	smalllimit := " order by honks.honkid desc limit ?"
1150	butnotthose := " and convoy not in (select name from zonkers where userid = ? and wherefore = 'zonvoy' order by zonkerid desc limit 100)"
1151	stmtOneXonk = preparetodie(db, selecthonks+"where honks.userid = ? and xid = ?")
1152	stmtAnyXonk = preparetodie(db, selecthonks+"where xid = ? and what <> 'bonk' order by honks.honkid asc")
1153	stmtOneBonk = preparetodie(db, selecthonks+"where honks.userid = ? and xid = ? and what = 'bonk' and whofore = 2")
1154	stmtPublicHonks = preparetodie(db, selecthonks+"where whofore = 2 and dt > ?"+smalllimit)
1155	stmtEventHonks = preparetodie(db, selecthonks+"where (whofore = 2 or honks.userid = ?) and what = 'event'"+smalllimit)
1156	stmtUserHonks = preparetodie(db, selecthonks+"where honks.honkid > ? and (whofore = 2 or whofore = ?) and username = ? and dt > ?"+smalllimit)
1157	myhonkers := " and honker in (select xid from honkers where userid = ? and (flavor = 'sub' or flavor = 'peep' or flavor = 'presub') and combos not like '% - %')"
1158	stmtHonksForUser = preparetodie(db, selecthonks+"where honks.honkid > ? and honks.userid = ? and dt > ?"+myhonkers+butnotthose+limit)
1159	stmtHonksForUserFirstClass = preparetodie(db, selecthonks+"where honks.honkid > ? and honks.userid = ? and dt > ? and (rid = '' or what = 'bonk')"+myhonkers+butnotthose+limit)
1160	stmtHonksForMe = preparetodie(db, selecthonks+"where honks.honkid > ? and honks.userid = ? and dt > ? and whofore = 1"+butnotthose+limit)
1161	stmtHonksFromLongAgo = preparetodie(db, selecthonks+"where honks.honkid > ? and honks.userid = ? and dt > ? and dt < ? and whofore = 2"+butnotthose+limit)
1162	stmtHonksISaved = preparetodie(db, selecthonks+"where honks.honkid > ? and honks.userid = ? and flags & 4 order by honks.honkid desc")
1163	stmtHonksByHonker = preparetodie(db, selecthonks+"join honkers on (honkers.xid = honks.honker or honkers.xid = honks.oonker) where honks.honkid > ? and honks.userid = ? and honkers.name = ?"+butnotthose+limit)
1164	stmtHonksByXonker = preparetodie(db, selecthonks+" where honks.honkid > ? and honks.userid = ? and (honker = ? or oonker = ?)"+butnotthose+limit)
1165	stmtHonksByCombo = preparetodie(db, selecthonks+" where honks.honkid > ? and honks.userid = ? and honks.honker in (select xid from honkers where honkers.userid = ? and honkers.combos like ?) "+butnotthose+" union "+selecthonks+"join onts on honks.honkid = onts.honkid where honks.honkid > ? and honks.userid = ? and onts.ontology in (select xid from honkers where combos like ?)"+butnotthose+limit)
1166	stmtHonksByConvoy = preparetodie(db, selecthonks+"where honks.honkid > ? and (honks.userid = ? or (? = -1 and whofore = 2)) and convoy = ?"+limit)
1167	stmtHonksByOntology = preparetodie(db, selecthonks+"join onts on honks.honkid = onts.honkid where honks.honkid > ? and onts.ontology = ? and (honks.userid = ? or (? = -1 and honks.whofore = 2))"+limit)
1168
1169	stmtSaveMeta = preparetodie(db, "insert into honkmeta (honkid, genus, json) values (?, ?, ?)")
1170	stmtDeleteAllMeta = preparetodie(db, "delete from honkmeta where honkid = ?")
1171	stmtDeleteSomeMeta = preparetodie(db, "delete from honkmeta where honkid = ? and genus not in ('oldrev')")
1172	stmtDeleteOneMeta = preparetodie(db, "delete from honkmeta where honkid = ? and genus = ?")
1173	stmtSaveHonk = preparetodie(db, "insert into honks (userid, what, honker, xid, rid, dt, url, audience, noise, convoy, whofore, format, precis, oonker, flags) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")
1174	stmtDeleteHonk = preparetodie(db, "delete from honks where honkid = ?")
1175	stmtUpdateHonk = preparetodie(db, "update honks set precis = ?, noise = ?, format = ?, whofore = ?, dt = ? where honkid = ?")
1176	stmtSaveOnt = preparetodie(db, "insert into onts (ontology, honkid) values (?, ?)")
1177	stmtDeleteOnts = preparetodie(db, "delete from onts where honkid = ?")
1178	stmtSaveDonk = preparetodie(db, "insert into donks (honkid, chonkid, fileid) values (?, ?, ?)")
1179	stmtDeleteDonks = preparetodie(db, "delete from donks where honkid = ?")
1180	stmtSaveFile = preparetodie(db, "insert into filemeta (xid, name, description, url, media, local) values (?, ?, ?, ?, ?, ?)")
1181	blobdb := openblobdb()
1182	stmtSaveFileData = preparetodie(blobdb, "insert into filedata (xid, media, hash, content) values (?, ?, ?, ?)")
1183	stmtCheckFileData = preparetodie(blobdb, "select xid from filedata where hash = ?")
1184	stmtGetFileData = preparetodie(blobdb, "select media, content from filedata where xid = ?")
1185	stmtFindXonk = preparetodie(db, "select honkid from honks where userid = ? and xid = ?")
1186	stmtFindFile = preparetodie(db, "select fileid, xid from filemeta where url = ? and local = 1")
1187	stmtFindFileId = preparetodie(db, "select xid, local, description from filemeta where fileid = ? and url = ? and local = 1")
1188	stmtUserByName = preparetodie(db, "select userid, username, displayname, about, pubkey, seckey, options from users where username = ? and userid > 0")
1189	stmtUserByNumber = preparetodie(db, "select userid, username, displayname, about, pubkey, seckey, options from users where userid = ?")
1190	stmtSaveDub = preparetodie(db, "insert into honkers (userid, name, xid, flavor, combos, owner, meta, folxid) values (?, ?, ?, ?, '', '', '', ?)")
1191	stmtAddDoover = preparetodie(db, "insert into doovers (dt, tries, userid, rcpt, msg) values (?, ?, ?, ?, ?)")
1192	stmtGetDoovers = preparetodie(db, "select dooverid, dt from doovers")
1193	stmtLoadDoover = preparetodie(db, "select tries, userid, rcpt, msg from doovers where dooverid = ?")
1194	stmtZapDoover = preparetodie(db, "delete from doovers where dooverid = ?")
1195	stmtUntagged = preparetodie(db, "select xid, rid, flags from (select honkid, xid, rid, flags from honks where userid = ? order by honkid desc limit 10000) order by honkid asc")
1196	stmtFindZonk = preparetodie(db, "select zonkerid from zonkers where userid = ? and name = ? and wherefore = 'zonk'")
1197	stmtGetZonkers = preparetodie(db, "select zonkerid, name, wherefore from zonkers where userid = ? and wherefore <> 'zonk'")
1198	stmtSaveZonker = preparetodie(db, "insert into zonkers (userid, name, wherefore) values (?, ?, ?)")
1199	stmtGetXonker = preparetodie(db, "select info from xonkers where name = ? and flavor = ?")
1200	stmtSaveXonker = preparetodie(db, "insert into xonkers (name, info, flavor, dt) values (?, ?, ?, ?)")
1201	stmtDeleteXonker = preparetodie(db, "delete from xonkers where name = ? and flavor = ? and dt < ?")
1202	stmtDeleteOldXonkers = preparetodie(db, "delete from xonkers where flavor = ? and dt < ?")
1203	stmtRecentHonkers = preparetodie(db, "select distinct(honker) from honks where userid = ? and honker not in (select xid from honkers where userid = ? and flavor = 'sub') order by honkid desc limit 100")
1204	stmtUpdateFlags = preparetodie(db, "update honks set flags = flags | ? where honkid = ?")
1205	stmtClearFlags = preparetodie(db, "update honks set flags = flags & ~ ? where honkid = ?")
1206	stmtAllOnts = preparetodie(db, "select ontology, count(ontology) from onts join honks on onts.honkid = honks.honkid where (honks.userid = ? or honks.whofore = 2) group by ontology")
1207	stmtGetFilters = preparetodie(db, "select hfcsid, json from hfcs where userid = ?")
1208	stmtSaveFilter = preparetodie(db, "insert into hfcs (userid, json) values (?, ?)")
1209	stmtDeleteFilter = preparetodie(db, "delete from hfcs where userid = ? and hfcsid = ?")
1210	stmtGetTracks = preparetodie(db, "select fetches from tracks where xid = ?")
1211	stmtSaveChonk = preparetodie(db, "insert into chonks (userid, xid, who, target, dt, noise, format) values (?, ?, ?, ?, ?, ?, ?)")
1212	stmtLoadChonks = preparetodie(db, "select chonkid, userid, xid, who, target, dt, noise, format from chonks where userid = ? and dt > ? order by chonkid asc")
1213	stmtGetChatters = preparetodie(db, "select distinct(target) from chonks where userid = ?")
1214	stmtDeliquentCheck = preparetodie(db, "select dooverid, msg from doovers where userid = ? and rcpt = ?")
1215	stmtDeliquentUpdate = preparetodie(db, "update doovers set msg = ? where dooverid = ?")
1216}