Remove some unused things

messagix/events.go

@@ -199,23 +199,18 @@ type Event_Ready struct {
 	ConnectionCode ConnectionCode
 	CurrentUser    types.UserInfo `skip:"1"`
 	Table          *table.LSTable
-	//Threads []table.LSDeleteThenInsertThread `skip:"1"`
-	//Messages []table.LSUpsertMessage `skip:"1"`
-	//Contacts []table.LSVerifyContactRowExists `skip:"1"`
 }
 
 func (pb *Event_Ready) SetIdentifier(identifier uint16) {}
 
 func (e *Event_Ready) Finish() ResponseData {
+	// TODO this should not be in the ready event
 	if e.client.platform == types.Facebook {
 		e.CurrentUser = &e.client.configs.browserConfigTable.CurrentUserInitialData
 	} else {
 		e.CurrentUser = &e.client.configs.browserConfigTable.PolarisViewer
 	}
 	e.Table = e.client.configs.accountConfigTable
-	//e.Threads = e.client.configs.accountConfigTable.LSDeleteThenInsertThread
-	//e.Messages = e.client.configs.accountConfigTable.LSUpsertMessage
-	//e.Contacts = e.client.configs.accountConfigTable.LSVerifyContactRowExists
 	return e
 }
 

messagix/threads.go

@@ -7,32 +7,6 @@ import (
 	"go.mau.fi/mautrix-meta/messagix/table"
 )
 
-type Threads struct {
-	client *Client
-}
-
-func (t *Threads) FetchMessages(ThreadId int64, ReferenceTimestampMs int64, ReferenceMessageId string, Cursor string) (*table.LSTable, error) {
-	tskm := t.client.NewTaskManager()
-	tskm.AddNewTask(&socket.FetchMessagesTask{ThreadKey: ThreadId, Direction: 0, ReferenceTimestampMs: ReferenceTimestampMs, ReferenceMessageId: ReferenceMessageId, SyncGroup: 1, Cursor: Cursor})
-
-	payload, err := tskm.FinalizePayload()
-	if err != nil {
-		return nil, fmt.Errorf("failed to finalize payload: %v", err)
-	}
-
-	packetId, err := t.client.socket.makeLSRequest(payload, 3)
-	if err != nil {
-		return nil, fmt.Errorf("failed to send request: %v", err)
-	}
-
-	resp := t.client.socket.responseHandler.waitForPubResponseDetails(packetId)
-	if resp == nil {
-		return nil, fmt.Errorf("failed to receive response from socket while trying to fetch messages. (packetId=%d, thread_key=%d, cursor=%s, reference_message_id=%s, reference_timestamp_ms=%d)", packetId, ThreadId, Cursor, ReferenceMessageId, ReferenceTimestampMs)
-	}
-
-	return resp.Table, nil
-}
-
 func (c *Client) ExecuteTasks(tasks ...socket.Task) (*table.LSTable, error) {
 	tskm := c.NewTaskManager()
 	for _, task := range tasks {