HACK do not merge

Signed-off-by: Sumner Evans <[email protected]>

chatwoot.go

@@ -2,12 +2,14 @@ package main
 
 import (
 	"context"
+	"encoding/json"
 	"errors"
 	"flag"
 	"fmt"
 	"net/http"
 	"os"
 	"os/signal"
+	"strings"
 	"sync"
 	"syscall"
 	"time"
@@ -218,6 +220,68 @@ func main() {
 		}
 	}()
 
+	go func() {
+		// TEMP HACK: Go through all of the rooms and check for corresponding
+		// contacts over in Chatwoot.
+
+		log := log.With().Str("component", "contact_sync").Logger()
+
+		log.Info().Msg("starting contact fixing")
+
+		joined, err := client.JoinedRooms()
+		if err != nil {
+			log.Fatal().Err(err).Msg("Failed to get joined rooms")
+		}
+
+		for _, roomID := range joined.JoinedRooms {
+			stateMap, err := client.State(roomID)
+			if err != nil {
+				log.Warn().Err(err).Msg("Failed to get state for room")
+				continue
+			}
+
+			for mxid, membership := range stateMap[event.StateMember] {
+				if !strings.HasPrefix(mxid, "@twitter_") {
+					continue
+				}
+
+				req, err := http.NewRequest(http.MethodGet, chatwootAPI.MakeUri("contacts/search"), nil)
+				if err != nil {
+					log.Warn().Err(err).Msg("Failed to create request")
+					continue
+				}
+
+				q := req.URL.Query()
+				q.Add("q", mxid)
+				req.URL.RawQuery = q.Encode()
+
+				resp, err := chatwootAPI.DoRequest(req)
+				if err != nil {
+					log.Warn().Err(err).Msg("Failed to do request")
+					continue
+				}
+				if resp.StatusCode != 200 {
+					log.Warn().Int("status_code", resp.StatusCode).Msg("GET contacts/search returned non-200 status code")
+					continue
+				}
+
+				var contactsPayload chatwootapi.ContactsPayload
+				if err := json.NewDecoder(resp.Body).Decode(&contactsPayload); err != nil {
+					log.Warn().Err(err).Msg("Failed to decode response body")
+					continue
+				}
+
+				for _, contact := range contactsPayload.Payload {
+					if contact.Identifier == mxid {
+						log.Info().Str("mxid", mxid).Any("membership", membership).Msg("Found contact")
+						break
+					}
+				}
+			}
+			break // TODO remove
+		}
+	}()
+
 	// Make sure that there are conversations for all of the rooms that the bot
 	// is in.
 	// This is run every 24 hours.