From 1b5e3b6f331e77882838935c0713ba6b1e163bd8 Mon Sep 17 00:00:00 2001
From: bel <bel>
Date: Sun, 15 Feb 2026 19:33:01 -0700
Subject: [PATCH] wip

---
 src/matrix/.client.go.swp | Bin 0 -> 12288 bytes
 src/matrix/client.go      | 144 +++++++++++++++++++++++++++++++++++++-
 2 files changed, 142 insertions(+), 2 deletions(-)
 create mode 100644 src/matrix/.client.go.swp

diff --git a/src/matrix/.client.go.swp b/src/matrix/.client.go.swp
new file mode 100644
index 0000000000000000000000000000000000000000..2c04bfa5eecc6286057b97ee1c45d3d72561efdd
GIT binary patch
literal 12288
zcmeI2->(}-6~{LXzZ}}6Y6UL{F>%#sedVkZ5I^E366w8Zdez*f<fe^K6NUA9Y%h1c
z<Lr)eW2##yPY47L<sab31C@}FfGARV-~}O|pcV?PKvWex0OE%bc|k%*6`z?|uYG?t
z;Ssb}KJj|?%*>hZIdf*CZ0E=m%PZnoaMa^-x96=t^KAT*I8f8aJ+C7Z(|XI#YLtaK
z8r;(EX$EYaR;@gXTK!ndur&;I7GFE8)!|;Ka~Wk)9}c_WNXyJxx%;gsiDjyTzPjZU
zl|iLIrNFKV+~s}X{YQ_O+xOKEihJ*Qd{@irMx{WdK&3#XK&3#XK&3#XK&3#X!2h2D
zdbG#;G|Rf9SlXA1?>$?-i=Wk3r9h=Xr9h=Xr9h=Xr9h=Xr9h=Xr9h=Xr9h>?|DXb4
z*YiHfKlWeTi}U>d|McJgHxGE;Kj2UB8vFu&0zZat!585&T!M>m8V<pJ_~(AldmUbb
z-@-F+5zfM+;DZOR-sO3(z}Mkf_zY~o1z3Uu@W!2<cN6{&ufVV127C?9z%jTV1l$Ar
zVGq3iPVC`F@B{chT!*i~=U@yOT!H)HUbq_$z`yq~AN&>m0@vX?@NMY8!|(un1U?LR
z!0&3F_dWOqd=@s~GMs{wa0KoH0q=vo@cVb*Bm5FxhL_+u_!6wa0Q#^G{`Gdx`y2cj
z{s@17r{Orf8{P%azYSgBt8ft>fn)F?_#o8a=3DU<UWA{*3vdIj!*}81@LsqR_JRjL
zd<*yCoA4Z5flt5%I1lfEeXs}KAdh|nzlNWK$*Wi4d3YIq1~0%3_yT+$s*hD*!>jTB
z%Q#Dkl*}@5LJY%b5T`O&jr-}@^>ii7c`@b@Iq@+y*4uh)YuJ5=NMCE%QKpmD;+`<m
z9y}q^I1x|n;>41?8b{Knd$SxI-<G?)p%d$g-}vuFeMs`=&|;?Y+$=Iq`z$YiC{x2#
zK5mvZIl0xCm^7{P?Gu9QrBH{#6Ecf?lXEgsS7kO~Sf4w~-KNN9O}8<w=}`<>PEp1M
zAA{3UFUejwPBe3vnT^*CuQyI3!OZw@A=ZO=Ke#U<m1=oS2aE2z)KV-&*<_?ua5fpP
zxbQcGZ{h+fYY-Q&jItQWWF)hu2^dL3dl5|2V7>Kri>m7xET^${{?=M85%Vh!llW6o
z=z$bn7SjoHDZ;cX6fK#^^|;r&?Wv~j8TW~dTUjylqjG)GuJmEM2A_Alnqm}3Yl%e1
zrs#Ga3-zGET<*#YP%pIUcIuw-R}bP`@Fx@_Y=u_V?bVN+;pMWK_Y*Z1>v58ZF-yTF
z*D90ZYM8}poLe&ycGOr43^UPDnmJ2H%(PEl>P)os%eGZsT1)%n4lZPJD2E-CVPG?U
zD0q!+%=qMt=qcI}()F}WaVkcc>W(8FtJEb)&ZZx2)?%jwK_Ia(49Dh;xnR-05l3be
z=~9R~KZ=cikueJ`mmQ-pjU$syIKOSXUv~LToZRbnt1|7b$UG1G^3+v!w?EC<2g7Ks
zpQ&-$^&4y_rH0E(^ffktwJdryU6!ZXMA0PYgQ`1e3qEy%o+z=dvZO0|>~?Wl9jrGo
zS;_n7CnMP|hBH6eCfu=;r`p8B%{1?t-9@Q>%4;pmZx6FAYEckI5z9EQ)?`Xi&160b
zPR^Q)Mb{R!<?i&hD{{+An=>8Vc93lYEo-YLrxr75t6-SqZK1QVGz)qx%yZV+wd*!(
zCs$pIxw~Qhs<{<UW9v$3FP52Ue>`V{8zXbkHaV81;m{5}Gi+0eU1AukSvy61%it%+
zdSHf~y2a2&5Epv0M}s2zXH-8<T>(Bc9sHcUVw<T!TZ)a<WwX+pBlSAv$`(RD5)0Fu
zO{ODnFM{RjN|D&DcC)$ix4HT`PsuWuujRPSnM&n2(-d^JZ4t3>cWpB2(4rk;`?{<y
zWzezQwW8z3TsaGh+RbtJz~)ocDi@imdi-!E!|r5p5T<S7<j#Iqxj7+%Q(5MdT7{`;
zSyHL=8`$PDk&!k>^oB99v8c`O?Hb)ud#l*xHnOXeH1fClQ|l{XLgbsHrDl`4@Wf=W
z8Qjc(Rw|c%>9A>2X(aK<pY_g}KxV<&)XrqvcRcG%#?5NkIewWAO_9g+FC*Sj%07lr
zsfC$KnBf^b!mH8|6TM-$#sdj5QoL1SA{_;;60)D?qvEo5UZ`zFaNfM!6gyVvY2KL_
z1;&34ffLq8NtrOd(qO%FJCg&icusJ}COo%yVxvrPf=)N0IXrE~`U5qTY<bd>tdDtC
zsn?AFvu5Lh+e3M<I!ZY1omsoyc=G5auQuIsZ)SG{JI*>fiX>i>;-k|}?b$p*q=rn~
zl|7bSWFNstCE{YzuXx}w4?~L~;v{p=Nwf9rm@n4jvTV*jz?I437v;rDHG59la%LCi
z#!d4SOTjNbP9d*0e^i)T)ApiNOwDJ>>%!n^N~&<zrVq!vDOE(cPRP=DJPcB)TYbeF
z?=~A+F3*ZDcY5<o^XAsO8`M$0Zc@&e6wx-9h3IuJ9*$I|h3|PI4sT9$HjR0Z@csi{
Ce2!TF

literal 0
HcmV?d00001

diff --git a/src/matrix/client.go b/src/matrix/client.go
index 60e38d0..3b72da2 100644
--- a/src/matrix/client.go
+++ b/src/matrix/client.go
@@ -1,7 +1,147 @@
 package matrix
 
+import (
+	"context"
+	"strings"
+	"sync"
+
+	"maunium.net/go/mautrix"
+	"maunium.net/go/mautrix/crypto"
+	"maunium.net/go/mautrix/crypto/cryptohelper"
+)
+
 type Client struct {
-   client *mautrix.Client
+	client          *mautrix.Client
+	accessToken     string
+	deviceId        string
+	pickleKeyString string
 }
 
-func New // https://chrastecky.dev/post/11
+func NewClient(ctx context.Context, uid, password, recoveryKey string) (*Client, error) {
+	ctx, can := context.WithCancel(ctx)
+	defer can()
+
+	// uid like @username:homeserver.com
+	username := strings.Split(uid, ":")[0]
+	homeserver := strings.Split(uid, ":")[1]
+
+	c, err := mautrix.NewClient(homeserver, uid, "")
+	if err != nil {
+		return nil, err
+	}
+	syncer := mautrix.NewDefaultSyncer()
+	c.Syncer = syncer
+	cryptoHelper, err := setupCryptoHelper(ctx, client)
+	if err != nil {
+		panic(err)
+	}
+	c.Crypto = cryptoHelper
+
+	readyChan := make(chan bool)
+	var once sync.Once
+	syncer.OnSync(func(ctx context.Context, resp *mautrix.RespSync, since string) bool {
+		once.Do(func() {
+			close(readyChan)
+		})
+		return true
+	})
+	go func() {
+		if err := c.Sync(); err != nil {
+			can()
+			panic(err)
+		}
+	}()
+	select {
+	case <-ctx.Done():
+		return nil, ctx.Err()
+	case <-readyChan:
+	}
+
+	if err := verifyWithRecoveryKey(ctx, cryptoHelper.Machine()); err != nil {
+		return nil, err
+	}
+
+	client := &Client{
+		client: c,
+	}
+
+	return client, client.login(ctx, username, password)
+}
+
+func (c *Client) login(ctx context.Context, username, password string) error {
+	if c.accessToken != "" {
+		return nil
+	}
+
+	resp, err := c.client.Login(ctx, &mautrix.ReqLogin{
+		Type: mautrix.AuthTypePassword,
+		Identifier: mautrix.UserIdentifier{
+			User: username,
+			Type: mautrix.IdentifierTypeUser,
+		},
+		Password:         password,
+		StoreCredentials: true,
+	})
+	if err != nil {
+		return err
+	}
+
+	c.deviceId = resp.DeviceID
+	c.accessToken = resp.AccessToken
+	return nil
+}
+
+/*
+	content := event.MessageEventContent{
+		MsgType: event.MsgText,
+		Body:    "Hello world from Go!",
+	}
+
+	_, err = client.SendMessageEvent(context.Background(), roomID, event.EventMessage, content)
+	if err != nil {
+		panic(err)
+	}
+*/
+
+func setupCryptoHelper(ctx context.Context, cli *mautrix.Client) (*cryptohelper.CryptoHelper, error) {
+	// remember to use a secure key for the pickle key in production
+	pickleKey := []byte(pickleKeyString)
+
+	// this is a path to the SQLite database you will use to store various data about your bot
+	dbPath := "crypto.db"
+
+	helper, err := cryptohelper.NewCryptoHelper(cli, pickleKey, dbPath)
+	if err != nil {
+		return nil, err
+	}
+
+	// initialize the database and other stuff
+	err = helper.Init(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	return helper, nil
+}
+
+func verifyWithRecoveryKey(ctx context.Context, machine *crypto.OlmMachine) (err error) {
+	keyId, keyData, err := machine.SSSS.GetDefaultKeyData(ctx)
+	if err != nil {
+		return
+	}
+	key, err := keyData.VerifyRecoveryKey(keyId, recoveryKey)
+	if err != nil {
+		return
+	}
+	err = machine.FetchCrossSigningKeysFromSSSS(ctx, key)
+	if err != nil {
+		return
+	}
+	err = machine.SignOwnDevice(ctx, machine.OwnIdentity())
+	if err != nil {
+		return
+	}
+	err = machine.SignOwnMasterKey(ctx)
+
+	return
+}