From 5100abe77e6b3017ef8155191937e2a59510b105 Mon Sep 17 00:00:00 2001
From: Hailey <me@haileyok.com>
Date: Wed, 24 Sep 2025 13:02:59 -0700
Subject: [PATCH] upgrade repo package

---
 go.mod                                  |  2 +-
 go.sum                                  |  2 ++
 server/handle_identity_update_handle.go |  9 ---------
 server/handle_server_create_account.go  |  9 ---------
 server/handle_sync_subscribe_repos.go   | 18 ------------------
 5 files changed, 3 insertions(+), 37 deletions(-)

diff --git a/go.mod b/go.mod
index db1add5..f971036 100644
--- a/go.mod
+++ b/go.mod
@@ -5,7 +5,7 @@ go 1.24.1
 require (
 	github.com/Azure/go-autorest/autorest/to v0.4.1
 	github.com/aws/aws-sdk-go v1.55.7
-	github.com/bluesky-social/indigo v0.0.0-20250414202759-826fcdeaa36b
+	github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f
 	github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792
 	github.com/domodwyer/mailyak/v3 v3.6.2
 	github.com/go-pkgz/expirable-cache/v3 v3.0.0
diff --git a/go.sum b/go.sum
index 5a2e39b..0bf67a5 100644
--- a/go.sum
+++ b/go.sum
@@ -18,6 +18,8 @@ github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932 h1:mXoPYz/Ul5HYE
 github.com/bitly/go-hostpool v0.0.0-20171023180738-a3a6125de932/go.mod h1:NOuUCSz6Q9T7+igc/hlvDOUdtWKryOrtFyIVABv/p7k=
 github.com/bluesky-social/indigo v0.0.0-20250414202759-826fcdeaa36b h1:elwfbe+W7GkUmPKFX1h7HaeHvC/kC0XJWfiEHC62xPg=
 github.com/bluesky-social/indigo v0.0.0-20250414202759-826fcdeaa36b/go.mod h1:yjdhLA1LkK8VDS/WPUoYPo25/Hq/8rX38Ftr67EsqKY=
+github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f h1:DJufFBQBXlekAk1aZF9MgmmBmk1zBQNQOs0AZl2uUos=
+github.com/bluesky-social/indigo v0.0.0-20250924132341-b4dd6383c76f/go.mod h1:n6QE1NDPFoi7PRbMUZmc2y7FibCqiVU4ePpsvhHUBR8=
 github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869 h1:DDGfHa7BWjL4YnC6+E63dPcxHo2sUxDIu8g3QgEJdRY=
 github.com/bmizerany/assert v0.0.0-20160611221934-b7ed37b82869/go.mod h1:Ekp36dRnpXw/yCqJaO+ZrUyxD+3VXMFFr56k5XYrpB4=
 github.com/btcsuite/websocket v0.0.0-20150119174127-31079b680792 h1:R8vQdOQdZ9Y3SkEwmHoWBmX1DNXhXZqlTpq6s4tyJGc=
diff --git a/server/handle_identity_update_handle.go b/server/handle_identity_update_handle.go
index ec5376c..8df7f22 100644
--- a/server/handle_identity_update_handle.go
+++ b/server/handle_identity_update_handle.go
@@ -85,15 +85,6 @@ func (s *Server) handleIdentityUpdateHandle(e echo.Context) error {
 		s.logger.Warn("error busting did doc", "error", err)
 	}
 
-	s.evtman.AddEvent(context.TODO(), &events.XRPCStreamEvent{
-		RepoHandle: &atproto.SyncSubscribeRepos_Handle{
-			Did:    repo.Repo.Did,
-			Handle: req.Handle,
-			Seq:    time.Now().UnixMicro(), // TODO: no
-			Time:   time.Now().Format(util.ISO8601),
-		},
-	})
-
 	s.evtman.AddEvent(context.TODO(), &events.XRPCStreamEvent{
 		RepoIdentity: &atproto.SyncSubscribeRepos_Identity{
 			Did:    repo.Repo.Did,
diff --git a/server/handle_server_create_account.go b/server/handle_server_create_account.go
index 27c7b9a..eadffbb 100644
--- a/server/handle_server_create_account.go
+++ b/server/handle_server_create_account.go
@@ -190,15 +190,6 @@ func (s *Server) handleCreateAccount(e echo.Context) error {
 			return helpers.ServerError(e, nil)
 		}
 
-		s.evtman.AddEvent(context.TODO(), &events.XRPCStreamEvent{
-			RepoHandle: &atproto.SyncSubscribeRepos_Handle{
-				Did:    urepo.Did,
-				Handle: request.Handle,
-				Seq:    time.Now().UnixMicro(), // TODO: no
-				Time:   time.Now().Format(util.ISO8601),
-			},
-		})
-
 		s.evtman.AddEvent(context.TODO(), &events.XRPCStreamEvent{
 			RepoIdentity: &atproto.SyncSubscribeRepos_Identity{
 				Did:    urepo.Did,
diff --git a/server/handle_sync_subscribe_repos.go b/server/handle_sync_subscribe_repos.go
index dbd13eb..6423ce6 100644
--- a/server/handle_sync_subscribe_repos.go
+++ b/server/handle_sync_subscribe_repos.go
@@ -2,7 +2,6 @@ package server
 
 import (
 	"fmt"
-	"net/http"
 
 	"github.com/bluesky-social/indigo/events"
 	"github.com/bluesky-social/indigo/lex/util"
@@ -10,14 +9,6 @@ import (
 	"github.com/labstack/echo/v4"
 )
 
-var upgrader = websocket.Upgrader{
-	ReadBufferSize:  1024,
-	WriteBufferSize: 1024,
-	CheckOrigin: func(r *http.Request) bool {
-		return true
-	},
-}
-
 func (s *Server) handleSyncSubscribeRepos(e echo.Context) error {
 	conn, err := websocket.Upgrade(e.Response().Writer, e.Request(), e.Response().Header(), 1<<10, 1<<10)
 	if err != nil {
@@ -54,9 +45,6 @@ func (s *Server) handleSyncSubscribeRepos(e echo.Context) error {
 		case evt.RepoCommit != nil:
 			header.MsgType = "#commit"
 			obj = evt.RepoCommit
-		case evt.RepoHandle != nil:
-			header.MsgType = "#handle"
-			obj = evt.RepoHandle
 		case evt.RepoIdentity != nil:
 			header.MsgType = "#identity"
 			obj = evt.RepoIdentity
@@ -66,12 +54,6 @@ func (s *Server) handleSyncSubscribeRepos(e echo.Context) error {
 		case evt.RepoInfo != nil:
 			header.MsgType = "#info"
 			obj = evt.RepoInfo
-		case evt.RepoMigrate != nil:
-			header.MsgType = "#migrate"
-			obj = evt.RepoMigrate
-		case evt.RepoTombstone != nil:
-			header.MsgType = "#tombstone"
-			obj = evt.RepoTombstone
 		default:
 			return fmt.Errorf("unrecognized event kind")
 		}
-- 
2.51.2