fix(tiphereth): sync pull account on linking

Author: MuZhou233

app/sephirah/internal/biz/bizangela/account.go

@@ -34,7 +34,7 @@ func NewPullAccountTopic(
 			if err != nil {
 				return err
 			}
-			err = a.repo.UpdateAccount(ctx, modeltiphereth.Account{
+			err = a.repo.UpsertAccount(ctx, modeltiphereth.Account{
 				ID:                info.ID,
 				Platform:          info.Platform,
 				PlatformAccountID: info.PlatformAccountID,

app/sephirah/internal/biz/bizangela/angela.go

@@ -48,7 +48,7 @@ type AngelaBase struct {
 }
 
 type AngelaRepo interface {
-	UpdateAccount(context.Context, modeltiphereth.Account) error
+	UpsertAccount(context.Context, modeltiphereth.Account) error
 	UpsertAppInfo(context.Context, *modelgebura.AppInfo, *modelgebura.AppInfo) error
 	UpsertAppInfos(context.Context, []*modelgebura.AppInfo) error
 	AccountPurchaseAppInfos(context.Context, model.InternalID, []model.InternalID) error

app/sephirah/internal/biz/biztiphereth/account.go

@@ -29,16 +29,17 @@ func (t *Tiphereth) LinkAccount(
 		return nil, pb.ErrorErrorReasonUnspecified("%s", err)
 	}
 	a.ID = id
-	a.ID, err = t.repo.LinkAccount(ctx, a, claims.UserID)
-	if err != nil {
-		return nil, pb.ErrorErrorReasonUnspecified("%s", err.Error())
-	}
-	if err = t.pullAccount.Publish(ctx, modeltiphereth.PullAccountInfo{
+	if err = t.pullAccount.LocalCall(ctx, modeltiphereth.PullAccountInfo{
 		ID:                a.ID,
 		Platform:          a.Platform,
 		PlatformAccountID: a.PlatformAccountID,
 	}); err != nil {
-		logger.Errorf("Publish PullAccountInfo failed %s", err.Error())
+		logger.Errorf("PullAccountInfo failed %s", err.Error())
+		return nil, pb.ErrorErrorReasonUnspecified("Get Account Info failed, %s", err.Error())
+	}
+	a.ID, err = t.repo.LinkAccount(ctx, a, claims.UserID)
+	if err != nil {
+		return nil, pb.ErrorErrorReasonUnspecified("%s", err.Error())
 	}
 	return &a, nil
 }

app/sephirah/internal/data/angela.go

@@ -32,15 +32,22 @@ func NewAngelaRepo(data *Data) bizangela.AngelaRepo {
 	}
 }
 
-func (a *angelaRepo) UpdateAccount(ctx context.Context, acc modeltiphereth.Account) error {
-	return a.data.db.Account.Update().Where(
-		account.IDEQ(acc.ID),
-		account.PlatformEQ(acc.Platform),
-		account.PlatformAccountIDEQ(acc.PlatformAccountID),
-	).
+func (a *angelaRepo) UpsertAccount(ctx context.Context, acc modeltiphereth.Account) error {
+	return a.data.db.Account.Create().
+		SetID(acc.ID).
+		SetPlatform(acc.Platform).
+		SetPlatformAccountID(acc.PlatformAccountID).
 		SetName(acc.Name).
 		SetProfileURL(acc.ProfileURL).
 		SetAvatarURL(acc.AvatarURL).
+		OnConflict(
+			sql.ConflictColumns(account.FieldPlatform, account.FieldPlatformAccountID),
+			resolveWithIgnores([]string{
+				account.FieldID,
+				account.FieldPlatform,
+				account.FieldPlatformAccountID,
+			}),
+		).
 		Exec(ctx)
 }