InMemory 그룹을 redis로 변경

body를 marshaling하고 클라이언트에서 flatten함
gob 등록
2023-07-19 09:37:02 +09:00 · 2023-07-18 01:31:39 +09:00 · 2023-07-17 17:47:07 +09:00 · 2023-07-16 18:41:24 +09:00 · 2023-07-16 17:29:21 +09:00 · 2023-07-16 17:26:19 +09:00
11 changed files with 565 additions and 1419 deletions
--- a/config_template.json
+++ b/config_template.json
@ -3,37 +3,46 @@
        "default": {
            "mongo": "mongodb://192.168.8.94:27017/?replicaSet=repl01&retrywrites=false",
            "redis": {
-                "url" : "redis://192.168.8.94:6379",
-                "offset" : {
-                    "cache" : 0,
-                    "session" : 1,
-                    "ranking" : 2
-                }
+                "cache": "redis://192.168.8.94:6380/0",
+                "session": "redis://192.168.8.94:6380/1",
+                "ranking": "redis://192.168.8.94:6380/2",
+                "wshandler": "redis://192.168.8.94:6380/3",
+                "tavern": "redis://192.168.8.94:6380/4"
            }
        },
        "dev": {
            "mongo": "mongodb://192.168.8.94:27017/?replicaSet=repl01&retrywrites=false",
            "redis": {
-                "url" : "redis://192.168.8.94:6379",
-                "offset" : {
-                    "cache" : 0,
-                    "session" : 1,
-                    "ranking" : 2
-                }
+                "cache": "redis://192.168.8.94:6380/4",
+                "session": "redis://192.168.8.94:6380/5",
+                "ranking": "redis://192.168.8.94:6380/6",
+                "wshandler": "redis://192.168.8.94:6380/7",
+                "tavern": "redis://192.168.8.94:6380/8"
            }
        }
    },
    "maingate_mongodb_url": "mongodb://192.168.8.94:27017/?replicaSet=repl01&retrywrites=false",
    "maingate_service_url": "http://localhost/maingate",
    "maingate_api_token": "63d08aa34f0162622c11284b",
-
    "tavern_service_url": "http://localhost/tavern",
    "tavern_group_types": {
        "subjugate": {
-            "text_search_field" : ["name"],
-            "unique_index" : ["name,_id", "_id,members", "name,hidden"],
-            "search_index" : ["rules"],
-            "member_index" : ["_gid,candidate,luts","_gid,luts","_gid,expiring"],
+            "text_search_field": [
+                "name"
+            ],
+            "unique_index": [
+                "name,_id",
+                "_id,members",
+                "name,hidden"
+            ],
+            "search_index": [
+                "rules"
+            ],
+            "member_index": [
+                "_gid,candidate,luts",
+                "_gid,luts",
+                "_gid,expiring"
+            ],
            "invite_ttl": 30,
            "candidate_ttl": 3600,
            "invitee_exlusive": true,
@ -49,8 +58,6 @@
        }
    },
   
-    "ws_sync_pipeline" : "redis://192.168.8.94:6379/3",
-        
    "services": {
        "kingdom": {
            "개발중": {
--- a/core/apiimpl.go
+++ b/core/apiimpl.go
@ -1,15 +1,11 @@
 package core

 import (
-	"context"
-	"encoding/json"
-	"io"
 	"net/http"

 	common "repositories.action2quare.com/ayo/gocommon"
 	"repositories.action2quare.com/ayo/gocommon/logger"

-	"github.com/go-redis/redis/v8"
 	"go.mongodb.org/mongo-driver/bson"
 	"go.mongodb.org/mongo-driver/bson/primitive"
 )
@ -83,11 +79,11 @@ func (sub *subTavern) JoinGroup(w http.ResponseWriter, r *http.Request) {
 	if candidate, ok := common.ReadBoolFormValue(r.Form, "candidate"); ok && candidate {
 		err = group.Candidate(gidobj, midobj, doc)
 	} else {
-		tidobj, err = group.Join(gidobj, midobj, tidobj, doc)
+		err = group.Join(gidobj, midobj, doc)
 	}

 	if err == nil {
-		json.NewEncoder(w).Encode(map[string]string{
+		writeBsonDoc(w, map[string]string{
 			"gid": gidobj.Hex(),
 			"tid": tidobj.Hex(),
 		})
@ -131,14 +127,14 @@ func (sub *subTavern) Invite(w http.ResponseWriter, r *http.Request) {
 		Invitee bson.M `bson:"invitee"`
 	}
 	if err := readBsonDoc(r.Body, &reqdoc); err != nil {
-		logger.Error("Invite failed. readBsonDoc returns err :", err)
+		logger.Println("Invite failed. readBsonDoc returns err :", err)
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}

 	result, err := group.Invite(gid, mid, reqdoc.Inviter, reqdoc.Invitee)
 	if err != nil {
-		logger.Error("Invite failed. group.Invite returns err :", err)
+		logger.Println("Invite failed. group.Invite returns err :", err)
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
@ -184,12 +180,6 @@ func (sub *subTavern) AcceptInvitation(w http.ResponseWriter, r *http.Request) {

 	gid, _ := common.ReadObjectIDFormValue(r.Form, "gid")
 	mid, _ := common.ReadObjectIDFormValue(r.Form, "mid")
-	tid, ok := common.ReadObjectIDFormValue(r.Form, "tid")
-	if !ok {
-		logger.Println("CancelInvitation failed. form value 'tid' is missing")
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}

 	var member bson.M
 	if err := readBsonDoc(r.Body, &member); err != nil {
@ -198,14 +188,12 @@ func (sub *subTavern) AcceptInvitation(w http.ResponseWriter, r *http.Request) {
 		return
 	}

-	gidbytes, err := group.AcceptInvitation(gid, mid, tid, member)
+	err := group.AcceptInvitation(gid, mid, member)
 	if err != nil {
-		logger.Error("AcceptInvitation failed. group.AcceptInvitation returns err :", err)
+		logger.Println("AcceptInvitation failed. group.AcceptInvitation returns err :", err)
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
-
-	w.Write([]byte(gidbytes.Hex()))
 }

 func (sub *subTavern) DenyInvitation(w http.ResponseWriter, r *http.Request) {
@ -270,49 +258,6 @@ func (sub *subTavern) QueryInvitations(w http.ResponseWriter, r *http.Request) {
 	}
 }

-func (sub *subTavern) QueryOnlineGroup(w http.ResponseWriter, r *http.Request) {
-	typename, _ := common.ReadStringFormValue(r.Form, "type")
-	group := sub.groups[typename]
-	if group == nil {
-		logger.Println("QueryOnlineGroup failed. group type is missing :", r.Form)
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	var cmd *redis.StringSliceCmd
-	scoreStart, _ := common.ReadStringFormValue(r.Form, "score_start")
-	scoreStop, _ := common.ReadStringFormValue(r.Form, "score_stop")
-
-	if len(scoreStart) > 0 || len(scoreStop) > 0 {
-		if len(scoreStart) == 0 {
-			scoreStart = "-inf"
-		}
-		if len(scoreStop) == 0 {
-			scoreStop = "+inf"
-		}
-		cmd = sub.wsh.RedisSync.ZRangeArgs(context.Background(), redis.ZRangeArgs{
-			Key:     onlineGroupQueryKey(typename),
-			ByScore: true,
-			Start:   scoreStart,
-			Stop:    scoreStop,
-			Rev:     true,
-			Count:   1,
-		})
-	} else {
-		// 아무거나
-		cmd = sub.wsh.RedisSync.ZRandMember(context.Background(), onlineGroupQueryKey(typename), 1, false)
-	}
-
-	result, err := cmd.Result()
-	if err != nil {
-		logger.Error("QueryOnlineGroup failed. redid.ZRandMember returns err :", err)
-		w.WriteHeader(http.StatusInternalServerError)
-		return
-	}
-
-	writeBsonDoc(w, bson.M{"r": result})
-}
-
 func (sub *subTavern) SearchGroup(w http.ResponseWriter, r *http.Request) {
 	typename, _ := common.ReadStringFormValue(r.Form, "type")
 	group := sub.groups[typename]
@ -343,7 +288,7 @@ func (sub *subTavern) SearchGroup(w http.ResponseWriter, r *http.Request) {
 	}

 	if err := writeBsonArr(w, result); err != nil {
-		logger.Error("json marshal failed :", err)
+		logger.Error("bson marshal failed :", err)
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
@ -420,96 +365,7 @@ func (sub *subTavern) QueryGroup(w http.ResponseWriter, r *http.Request) {
 	}

 	if err := writeBsonDoc(w, result); err != nil {
-		logger.Error("json marshal failed :", err)
-		w.WriteHeader(http.StatusInternalServerError)
-		return
-	}
-}
-
-// QueryGroupMembers : 그룹내 멤버 조회
-// - type : 그룹 타입
-// - 그룹 타입에 맞는 키(주로 _id)
-// - projection : select할 필드. ,로 구분
-func (sub *subTavern) QueryGroupMembers(w http.ResponseWriter, r *http.Request) {
-	typename, _ := common.ReadStringFormValue(r.Form, "type")
-	group := sub.groups[typename]
-	if group == nil {
-		logger.Println("QueryGroupMembers failed. group type is missing :", r.Form)
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	gidobj, ok := common.ReadObjectIDFormValue(r.Form, "gid")
-	if !ok {
-		logger.Println("QueryGroupMembers failed. _id is missing :", r.Form)
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	midobj, _ := common.ReadObjectIDFormValue(r.Form, "mid")
-	var after primitive.Timestamp
-	if ts, ok := common.ReadStringFormValue(r.Form, "after"); ok && ts != "0.0" {
-		after = common.DotStringToTimestamp(ts)
-	}
-	projection, _ := common.ReadStringFormValue(r.Form, "projection")
-
-	result, err := group.QueryMembers(gidobj, midobj, projection, after)
-	if err != nil {
-		logger.Error("QueryGroupMembers failed. FindAll err :", err)
-		w.WriteHeader(http.StatusInternalServerError)
-		return
-	}
-
-	if result == nil {
-		return
-	}
-
-	if err := writeBsonDoc(w, result); err != nil {
-		logger.Error("QueryGroupMembers failed. writeBsonArr err :", err)
-		w.WriteHeader(http.StatusInternalServerError)
-		return
-	}
-}
-
-func (sub *subTavern) QueryGroupMember(w http.ResponseWriter, r *http.Request) {
-	typename, _ := common.ReadStringFormValue(r.Form, "type")
-	group := sub.groups[typename]
-	if group == nil {
-		logger.Println("QueryGroupMember failed. group type is missing :", r.Form)
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	gid, ok := common.ReadObjectIDFormValue(r.Form, "gid")
-	if !ok {
-		logger.Println("QueryGroupMember failed. gid is missing :", r.Form)
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	mid, midok := common.ReadObjectIDFormValue(r.Form, "mid")
-	tid, tidok := common.ReadObjectIDFormValue(r.Form, "tid")
-	if !midok && !tidok {
-		// 둘 중 하나는 있어야지
-		logger.Println("QueryGroupMember failed. tid and mid are both missing")
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	projection, _ := common.ReadStringFormValue(r.Form, "projection")
-	result, err := group.QueryMember(gid, mid, tid, projection)
-	if err != nil {
-		logger.Println("QueryGroupMember failed. group.QueryMember returns err :", err)
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	if result == nil {
-		return
-	}
-
-	if err := writeBsonDoc(w, result); err != nil {
-		logger.Error("QueryGroupMember failed. writeBsonDoc err :", err)
+		logger.Error("bson marshal failed :", err)
 		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
@ -535,15 +391,14 @@ func (sub *subTavern) LeaveGroup(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 	mid, midok := common.ReadObjectIDFormValue(r.Form, "mid")
-	tid, tidok := common.ReadObjectIDFormValue(r.Form, "tid")
-	if !midok && !tidok {
-		// 둘 중 하나는 있어야지
-		logger.Println("LeaveGroup failed. tid and mid are both missing")
+
+	if !midok {
+		logger.Println("LeaveGroup failed. mid is missing")
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}

-	if err := group.Leave(gid, mid, tid); err != nil {
+	if err := group.Leave(gid, mid); err != nil {
 		// 둘 중 하나는 있어야지
 		logger.Println("LeaveGroup failed. group.Leave returns err :", err)
 		w.WriteHeader(http.StatusBadRequest)
@ -626,125 +481,46 @@ func (sub *subTavern) UpdateGroupDocument(w http.ResponseWriter, r *http.Request
 		return
 	}

-	body, err := io.ReadAll(r.Body)
-	if err != nil {
+	var frag bson.M
+	if err := readBsonDoc(r.Body, &frag); err != nil {
 		logger.Error("UpdateGroupDocument failed. readBsonDoc err :", err)
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}

-	if err := group.UpdateGroupDocument(gid, body); err != nil {
+	if err := group.UpdateGroupDocument(gid, frag); err != nil {
 		logger.Error("UpdateGroupDocument failed. group.UpdateGroupDocument returns err :", err)
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}
 }

-func (sub *subTavern) PauseGroupMember(w http.ResponseWriter, r *http.Request) {
+func (sub *subTavern) QueryGroupMembers(w http.ResponseWriter, r *http.Request) {
 	typename, _ := common.ReadStringFormValue(r.Form, "type")
 	group := sub.groups[typename]
 	if group == nil {
-		logger.Println("DismissGroup failed. type is missing")
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	midobj, ok := common.ReadObjectIDFormValue(r.Form, "mid")
-	if !ok {
-		logger.Println("UpdateMemberDocument failed. member_id is missing")
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	gidobj, ok := common.ReadObjectIDFormValue(r.Form, "gid")
-	if !ok {
-		logger.Println("UpdateMemberDocument failed. _id is missing")
-		w.WriteHeader(http.StatusBadRequest)
-		return
-	}
-
-	group.PauseMember(gidobj, midobj)
-}
-
-func (sub *subTavern) DropPausedMember(w http.ResponseWriter, r *http.Request) {
-	typename, _ := common.ReadStringFormValue(r.Form, "type")
-	group := sub.groups[typename]
-	if group == nil {
-		logger.Println("DropDeadMember failed. type is missing")
+		logger.Println("QueryGroupMembers failed. type is missing")
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}

 	gid, ok := common.ReadObjectIDFormValue(r.Form, "gid")
 	if !ok {
-		logger.Println("DropDeadMember failed. gid is missing")
+		logger.Println("QueryGroupMembers failed. gid is missing")
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}

-	mid, ok := common.ReadObjectIDFormValue(r.Form, "mid")
-	if !ok {
-		logger.Println("DropDeadMember failed. mid is missing")
+	members, err := group.QueryGroupMembers(gid)
+	if err != nil {
+		logger.Error("QueryGroupMembers failed. group.QueryGroupMembers returns err :", err)
 		w.WriteHeader(http.StatusBadRequest)
 		return
 	}

-	if err := group.DropPausedMember(gid, mid); err != nil {
-		logger.Error("DropDeadMember failed. group.DropDeadMember returns err :", err)
-		w.WriteHeader(http.StatusBadRequest)
+	if err := writeBsonDoc(w, members); err != nil {
+		logger.Error("QueryGroupMembers failed. writeBsonDoc return err :", err)
+		w.WriteHeader(http.StatusInternalServerError)
 		return
 	}
 }
-
-// func (sub *subTavern) deliveryMessageHandler(deliveryChan <-chan wshandler.DeliveryMessage) {
-// 	defer func() {
-// 		r := recover()
-// 		if r != nil {
-// 			logger.Error(r)
-// 		}
-// 	}()
-
-// 	redisSync := sub.wsh.RedisSync
-// 	for msg := range deliveryChan {
-// 		mid := msg.Alias
-// 		if msg.Body != nil {
-// 			buffer := msg.Body
-
-// 			var channame string
-// 			for i, ch := range buffer {
-// 				if ch == 0 {
-// 					channame = string(buffer[:i])
-// 					buffer = buffer[i+1:]
-// 					break
-// 				}
-// 			}
-
-// 			if len(channame) == 0 {
-// 				continue
-// 			}
-
-// 			buffer = append(mid[:], buffer...)
-// 			_, err := redisSync.Publish(context.Background(), channame, buffer).Result()
-// 			if err != nil {
-// 				logger.Error(err)
-// 			}
-// 		}
-
-// 		if len(msg.Command) > 0 {
-// 			switch msg.Command {
-// 			case "pause":
-// 				gidtype := msg.Conn.GetTag("gid")
-// 				if len(gidtype) > 0 {
-// 					tokens := strings.SplitN(gidtype, "@", 2)
-// 					gidobj, _ := primitive.ObjectIDFromHex(tokens[0])
-// 					gtype := tokens[1]
-// 					group := sub.groups[gtype]
-// 					if group != nil {
-// 						group.PauseMember(gidobj, msg.Alias, msg.Conn)
-// 					}
-// 				}
-// 			}
-// 		}
-// 	}
-// 	logger.Println("delivery chan fin")
-// }
--- a/core/config.json
+++ b/core/config.json
@ -0,0 +1 @@
+{}
--- a/core/group.go
+++ b/core/group.go
@ -25,22 +25,18 @@ type groupConfig struct {
 type group interface {
 	Create(form url.Values, doc bson.M) (primitive.ObjectID, error)
 	Candidate(groupID primitive.ObjectID, memberID primitive.ObjectID, doc bson.M) error
-	Join(groupID primitive.ObjectID, memberID primitive.ObjectID, ticketID primitive.ObjectID, doc bson.M) (newTicketID primitive.ObjectID, err error)
-	FindTicketID(groupID primitive.ObjectID, memberID primitive.ObjectID) primitive.ObjectID
+	Join(groupID primitive.ObjectID, memberID primitive.ObjectID, doc bson.M) error
 	Invite(groupID primitive.ObjectID, memberID primitive.ObjectID, inviterDoc bson.M, inviteeDoc bson.M) (string, error)
 	CancelInvitation(groupID primitive.ObjectID, ticketID primitive.ObjectID) error
-	AcceptInvitation(groupID primitive.ObjectID, mid primitive.ObjectID, ticketID primitive.ObjectID, member bson.M) (primitive.ObjectID, error)
+	AcceptInvitation(groupID primitive.ObjectID, mid primitive.ObjectID, member bson.M) error
 	DenyInvitation(groupID primitive.ObjectID, mid primitive.ObjectID, ticketID primitive.ObjectID) error
 	QueryInvitations(memberID primitive.ObjectID, after primitive.Timestamp) ([]bson.M, error)
 	Exist(groupID primitive.ObjectID, filter bson.M) (bool, error)
 	FindAll(filter bson.M, projection string, after primitive.Timestamp) ([]bson.M, error)
 	FindOne(groupID primitive.ObjectID, projection string) (bson.M, error)
-	QueryMembers(groupID primitive.ObjectID, requesterID primitive.ObjectID, projection string, after primitive.Timestamp) (map[string]bson.M, error)
-	QueryMember(groupID primitive.ObjectID, memberID primitive.ObjectID, ticketID primitive.ObjectID, projection string) (bson.M, error)
-	Leave(groupID primitive.ObjectID, memberID primitive.ObjectID, ticketID primitive.ObjectID) error
-	DropPausedMember(groupID primitive.ObjectID, memberID primitive.ObjectID) error
-	PauseMember(groupID primitive.ObjectID, memberID primitive.ObjectID) error
+	Leave(groupID primitive.ObjectID, memberID primitive.ObjectID) error
 	UpdateMemberDocument(groupID primitive.ObjectID, memberID primitive.ObjectID, doc bson.M) error
 	Dismiss(groupID primitive.ObjectID) error
-	UpdateGroupDocument(groupID primitive.ObjectID, body []byte) error
+	UpdateGroupDocument(groupID primitive.ObjectID, doc bson.M) error
+	QueryGroupMembers(groupID primitive.ObjectID) (bson.M, error)
 }
--- a/core/group_memory.go
+++ b/core/group_memory.go
--- a/core/richconn.go
+++ b/core/richconn.go
@ -1,97 +0,0 @@
-package core
-
-import (
-	"fmt"
-	"strings"
-	"sync"
-)
-
-type connection struct {
-	locker  sync.Mutex
-	alias   string
-	tags    []string
-	onClose map[string]func()
-}
-
-func (rc *connection) addTag(name, val string) {
-	rc.locker.Lock()
-	defer rc.locker.Unlock()
-
-	prefix := name + "="
-	for i, tag := range rc.tags {
-		if strings.HasPrefix(tag, prefix) {
-			rc.tags[i] = prefix + val
-			return
-		}
-	}
-	rc.tags = append(rc.tags, prefix+val)
-}
-
-func (rc *connection) removeTag(name string, val string) {
-	rc.locker.Lock()
-	defer rc.locker.Unlock()
-
-	whole := fmt.Sprintf("%s=%s", name, val)
-	for i, tag := range rc.tags {
-		if tag == whole {
-			if i == 0 && len(rc.tags) == 1 {
-				rc.tags = nil
-			} else {
-				lastidx := len(rc.tags) - 1
-				if i < lastidx {
-					rc.tags[i] = rc.tags[lastidx]
-				}
-				rc.tags = rc.tags[:lastidx]
-			}
-			return
-		}
-	}
-}
-
-func (rc *connection) registOnCloseFunc(name string, f func()) {
-	rc.locker.Lock()
-	defer rc.locker.Unlock()
-
-	if rc.onClose == nil {
-		f()
-		return
-	}
-	rc.onClose[name] = f
-}
-
-func (rc *connection) hasOnCloseFunc(name string) bool {
-	rc.locker.Lock()
-	defer rc.locker.Unlock()
-
-	if rc.onClose == nil {
-		return false
-	}
-
-	_, ok := rc.onClose[name]
-	return ok
-}
-
-func (rc *connection) unregistOnCloseFunc(name string) (out func()) {
-	rc.locker.Lock()
-	defer rc.locker.Unlock()
-
-	if rc.onClose == nil {
-		return
-	}
-	out = rc.onClose[name]
-	delete(rc.onClose, name)
-	return
-}
-
-func (rc *connection) cleanup() {
-	rc.locker.Lock()
-	defer rc.locker.Unlock()
-
-	cp := rc.onClose
-	rc.onClose = nil
-	go func() {
-		for _, f := range cp {
-			f()
-		}
-	}()
-}
--- a/core/tavern.go
+++ b/core/tavern.go
@ -9,8 +9,9 @@ import (
 	"net/http"
 	"reflect"
 	"strings"
-	"sync"
+	"time"

+	"github.com/go-redis/redis/v8"
 	"repositories.action2quare.com/ayo/gocommon"
 	"repositories.action2quare.com/ayo/gocommon/logger"
 	"repositories.action2quare.com/ayo/gocommon/wshandler"
@ -30,10 +31,6 @@ func writeBsonArr(w io.Writer, src []bson.M) error {
 	})
 }

-func onlineGroupQueryKey(prefix string) string {
-	return prefix + "_olg"
-}
-
 func writeBsonDoc[T any](w io.Writer, src T) error {
 	rw, err := bsonrw.NewBSONValueWriter(w)
 	if err != nil {
@ -82,43 +79,6 @@ type TavernConfig struct {

 var config TavernConfig

-type connectionMap struct {
-	sync.Mutex
-	conns map[primitive.ObjectID]*connection
-}
-
-func (cm *connectionMap) add(accid accountID, alias string) {
-	cm.Lock()
-	defer cm.Unlock()
-
-	old := cm.conns[accid]
-	if old != nil {
-		old.cleanup()
-	}
-	cm.conns[accid] = &connection{
-		alias:   alias,
-		onClose: make(map[string]func()),
-	}
-}
-
-func (cm *connectionMap) remove(accid accountID) {
-	cm.Lock()
-	defer cm.Unlock()
-
-	old := cm.conns[accid]
-	if old != nil {
-		delete(cm.conns, accid)
-		old.cleanup()
-	}
-}
-
-func (cm *connectionMap) get(accid accountID) *connection {
-	cm.Lock()
-	defer cm.Unlock()
-
-	return cm.conns[accid]
-}
-
 type Tavern struct {
 	subTaverns []*subTavern
 	wsh        *wshandler.WebsocketHandler
@ -126,11 +86,11 @@ type Tavern struct {

 type subTavern struct {
 	mongoClient gocommon.MongoClient
+	redisClient *redis.Client
 	wsh         *wshandler.WebsocketHandler
 	region      string
 	groups      map[string]group
 	methods     map[string]reflect.Method
-	cm          connectionMap
 }

 func getMacAddr() (string, error) {
@ -183,25 +143,8 @@ func (tv *Tavern) Cleanup() {
 	}
 }

-// func (tv *Tavern) SocketMessageReceived(accid primitive.ObjectID, alias string, messageType wshandler.WebSocketMessageType, body io.Reader) {
-// 	switch messageType {
-// 	case wshandler.Connected:
-
-// 	case wshandler.Disconnected:
-// 	}
-// 	// 				gidtype := msg.Conn.GetTag("gid")
-// 	// 				if len(gidtype) > 0 {
-// 	// 					tokens := strings.SplitN(gidtype, "@", 2)
-// 	// 					gidobj, _ := primitive.ObjectIDFromHex(tokens[0])
-// 	// 					gtype := tokens[1]
-// 	// 					group := sub.groups[gtype]
-// 	// 					if group != nil {
-// 	// 						group.PauseMember(gidobj, msg.Alias, msg.Conn)
-// 	// 					}
-// }
-
 func (tv *Tavern) prepare(ctx context.Context) error {
-	for region := range config.RegionStorage {
+	for region, addr := range config.RegionStorage {
 		var dbconn gocommon.MongoClient
 		var err error
 		var groupinstance group
@ -214,14 +157,17 @@ func (tv *Tavern) prepare(ctx context.Context) error {
 			methods[method.Name] = method
 		}

+		redisClient, err := gocommon.NewRedisClient(addr.Redis["tavern"])
+		if err != nil {
+			return err
+		}
+
 		sub := &subTavern{
 			wsh:         tv.wsh,
 			mongoClient: dbconn,
+			redisClient: redisClient,
 			region:      region,
 			methods:     methods,
-			cm: connectionMap{
-				conns: make(map[primitive.ObjectID]*connection),
-			},
 		}

 		groups := make(map[string]group)
@ -254,7 +200,7 @@ func (tv *Tavern) prepare(ctx context.Context) error {

 func (tv *Tavern) RegisterHandlers(ctx context.Context, serveMux *http.ServeMux, prefix string) error {
 	for _, sub := range tv.subTaverns {
-		tv.wsh.RegisterReceiver(sub.region, sub.clientMessageReceived)
+		tv.wsh.RegisterReceiver(sub.region, sub)
 		var pattern string
 		if sub.region == "default" {
 			pattern = gocommon.MakeHttpHandlerPattern(prefix, "api")
@ -267,11 +213,11 @@ func (tv *Tavern) RegisterHandlers(ctx context.Context, serveMux *http.ServeMux,
 	return nil
 }

-func (sub *subTavern) clientMessageReceived(sender *wshandler.Sender, messageType wshandler.WebSocketMessageType, body io.Reader) {
+func (sub *subTavern) OnClientMessageReceived(sender *wshandler.Sender, messageType wshandler.WebSocketMessageType, body io.Reader) {
 	if messageType == wshandler.Connected {
-		sub.cm.add(sender.Accid, sender.Alias)
+		logger.Println("OnClientMessageReceived : connected ", sender.Accid.Hex())
 	} else if messageType == wshandler.Disconnected {
-		sub.cm.remove(sender.Accid)
+		logger.Println("OnClientMessageReceived : disconnected ", sender.Accid.Hex())
 	} else if messageType == wshandler.BinaryMessage {
 		var msg map[string][]any
 		dec := json.NewDecoder(body)
@ -291,11 +237,33 @@ func (sub *subTavern) clientMessageReceived(sender *wshandler.Sender, messageTyp
 					if group := sub.groups[typename]; group != nil {
 						group.UpdateMemberDocument(gidobj, sender.Accid, doc)
 					}
+
+				case "UpdateGroupDocument":
+					typename := args[0].(string)
+					gidobj, _ := primitive.ObjectIDFromHex(args[1].(string))
+					doc := args[2].(map[string]any)
+					if group := sub.groups[typename]; group != nil {
+						group.UpdateGroupDocument(gidobj, doc)
 					}
 				}
 			}
 		}
 	}
+}
+
+func (sub *subTavern) OnRoomCreated(region, name string) {
+	_, err := sub.redisClient.Persist(context.Background(), name).Result()
+	if err != nil {
+		logger.Println("OnRoomCreate Persist failed :", err)
+	}
+}
+
+func (sub *subTavern) OnRoomDestroyed(region, name string) {
+	_, err := sub.redisClient.Expire(context.Background(), name, 3600*time.Second).Result()
+	if err != nil {
+		logger.Println("OnRoomDestroyed Persist failed :", err)
+	}
+}

 func (sub *subTavern) api(w http.ResponseWriter, r *http.Request) {
 	defer func() {
--- a/core/tavern_test.go
+++ b/core/tavern_test.go
@ -0,0 +1,77 @@
+// warroom project main.go
+package core
+
+import (
+	"context"
+	"fmt"
+	"testing"
+	"time"
+
+	"github.com/go-redis/redis/v8"
+	"go.mongodb.org/mongo-driver/bson/primitive"
+	"repositories.action2quare.com/ayo/gocommon"
+	"repositories.action2quare.com/ayo/gocommon/logger"
+)
+
+func TestPubSub(t *testing.T) {
+	opt0, _ := redis.ParseURL("redis://192.168.8.94:6380/0")
+	opt1, _ := redis.ParseURL("redis://192.168.8.94:6380/1")
+
+	rc0 := redis.NewClient(opt0)
+	rc1 := redis.NewClient(opt1)
+
+	go func() {
+		time.Sleep(time.Second)
+		rc1.Publish(context.Background(), "__testchan", "real???")
+		fmt.Println("published")
+	}()
+
+	pubsub := rc0.Subscribe(context.Background(), "__testchan")
+	msg, err := pubsub.ReceiveMessage(context.Background())
+	fmt.Println(msg.Payload, err)
+}
+
+func TestReJSON(t *testing.T) {
+	rc := redis.NewClient(&redis.Options{Addr: "192.168.8.94:6380"})
+	rh := gocommon.NewRedisonHandler(context.Background(), rc)
+
+	testDoc := map[string]any{
+		"members": map[string]any{
+			"mid2": map[string]any{
+				"key": "val",
+				"exp": 20202020,
+			},
+			"mid1": map[string]any{
+				"key": "val",
+				"exp": 10101010,
+			},
+		},
+	}
+
+	gd := groupDoc{
+		id: primitive.NewObjectID(),
+	}
+
+	midin := primitive.NewObjectID()
+	tid := gd.tid(midin)
+	midout := gd.mid(tid)
+	logger.Println(midin, tid, midout)
+
+	logger.Println(rh.JSONSet("jsontest", "$", testDoc))
+	logger.Println(rh.JSONGet("jsontest", "$"))
+	logger.Println(rh.JSONResp("jsontest", "$.members"))
+	logger.Println(rh.JSONGetString("jsontest", "$.members..key"))
+	logger.Println(rh.JSONGetInt64("jsontest", "$.members..exp"))
+	logger.Println(rh.JSONObjKeys("jsontest", "$.members"))
+
+	err := rh.JSONMSet("jsontest", map[string]any{
+		"$.members.mid1.key": "newval",
+		"$.members.mid2.key": "newval",
+	})
+	logger.Println(err)
+
+	logger.Println(rh.JSONGet("jsontest", "$"))
+	logger.Println(rh.JSONMDel("jsontest", []string{"$.members.mid1", "$.members.mid2"}))
+	logger.Println(rh.JSONGet("jsontest", "$"))
+	logger.Println(rh.JSONObjLen("jsontest", "$.members"))
+}
--- a/go.mod
+++ b/go.mod
@ -5,13 +5,14 @@ go 1.20
 require (
 	github.com/go-redis/redis/v8 v8.11.5
 	go.mongodb.org/mongo-driver v1.11.7
-	repositories.action2quare.com/ayo/gocommon v0.0.0-20230713080645-269fa0f8700e
+	repositories.action2quare.com/ayo/gocommon v0.0.0-20230719003337-29b2f258507d
 )

 require (
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
 	github.com/golang/snappy v0.0.4 // indirect
+	github.com/google/go-cmp v0.5.4 // indirect
 	github.com/gorilla/websocket v1.5.0 // indirect
 	github.com/klauspost/compress v1.16.6 // indirect
 	github.com/montanaflynn/stats v0.7.1 // indirect
@ -24,4 +25,5 @@ require (
 	golang.org/x/crypto v0.10.0 // indirect
 	golang.org/x/sync v0.3.0 // indirect
 	golang.org/x/text v0.10.0 // indirect
+	golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
 )
--- a/go.sum
+++ b/go.sum
@ -11,8 +11,9 @@ github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq
 github.com/golang/snappy v0.0.1/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
 github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
 github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
-github.com/google/go-cmp v0.5.2 h1:X2ev0eStA3AbceY54o37/0PQ/UWqKEiiO2dKL5OPaFM=
 github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.4 h1:L8R9j+yAqZuZjsqh/z+F1NCffTKKLShY6zXTItVIZ8M=
+github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/gorilla/websocket v1.5.0 h1:PPwGk2jz7EePpoHN/+ClbZu8SPxiqlu12wZP/3sWmnc=
 github.com/gorilla/websocket v1.5.0/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
 github.com/klauspost/compress v1.13.6/go.mod h1:/3/Vjq9QcHkK5uEr5lBEmyoZ1iFhe47etQ6QUkpK6sk=
@ -93,8 +94,9 @@ golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGm
 golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
 golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc=
 golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
 gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ=
@ -102,23 +104,31 @@ gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230710053024-a842845685ee h1:Aau1j/b9wI4nyvrM7m1Q+2xkcW1Qo7i3q+QBD4Umnzg=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230710053024-a842845685ee/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711003621-3bb985d0b617 h1:91mBIGIyxzcnvOaIdegUuV+i9xs8YTSRcmyRaIytzx8=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711003621-3bb985d0b617/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711005604-a42eb2888e97 h1:ARzXt3HBmiAUDyACfNm5Kvz1JMTn7+ryE03kB8x/km0=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711005604-a42eb2888e97/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711033135-d7b26608df94 h1:VrNj5gBFFN9/roWCxyBCZ2gu5k58eremNHQvQNPrfrU=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711033135-d7b26608df94/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711035757-9fd0dd00cb7d h1:RdxKmMc7kHrTk+SvTYse2IGxmdDhbEDeM0fKAUW+G+w=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711035757-9fd0dd00cb7d/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711053010-4acb81a20d9c h1:SktFqjnc/UOMjJrq/brSw5lQjW1IA+KkB5YgeovusmQ=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711053010-4acb81a20d9c/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711062613-74829b93ac1b h1:04rlgT+zeKSpekyleb8Mfi8kENIoka5DYJLuk65wqxc=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711062613-74829b93ac1b/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711084112-d48d4c0f2189 h1:4ugcv2AlTYjTEtw8ekjCfVzp+xNnNTOHpfWWRbugxvw=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230711084112-d48d4c0f2189/go.mod h1:ng62uGMGXyQSeuxePG5gJAMtip4Rnspu5Tu7hgvaXns=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230713064012-522bd4a597bc h1:ToHccG1AAGFoAVldbJxCv+yBh/GvNyCd74sBp1Hf7YY=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230713064012-522bd4a597bc/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230713080645-269fa0f8700e h1:94hUQRdZYbsYaTqm/cTI0pEBdp8zdfOSEfkxdO9kS9o=
-repositories.action2quare.com/ayo/gocommon v0.0.0-20230713080645-269fa0f8700e/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230715080833-f0f459332d1a h1:n2FF/GQYtCsi57Lh5m9LyQ2IZQ8pIppscBzhpvugmZg=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230715080833-f0f459332d1a/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230716073702-8f6c87a8aeb8 h1:+wfozysATxEl9NOm03gUF7/kpAr3Chxjn5wjCnJsfQw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230716073702-8f6c87a8aeb8/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230716093911-66aea48fb732 h1:Aq4E8kn1mN5z4ZpRYo5VFj2KektVNrTTuk0HocYMDCk=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230716093911-66aea48fb732/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230717084540-29843802ff0e h1:/eG6tAQzEaN178Aib+/erjHrE/+IjIVLRSmP4gx6D7E=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230717084540-29843802ff0e/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718004527-4b35e0e6386b h1:K3YQXnVP/W6LzwGzqOxwKmFUD5IrrNPEWYcN/fSinck=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718004527-4b35e0e6386b/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718005518-289af24a8ffa h1:YmzJ1YccK3BxC/NbfB11SEUG1S6Lkz6ejg4kS3q/3Qc=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718005518-289af24a8ffa/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718020415-82abcddb497b h1:baO9csa0Esnp7UW+L8zJW/ygpjGHRve4rU2/1pVvXQg=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718020415-82abcddb497b/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718020838-c21017d2cd8b h1:FqLKDrFji0+giFwAJ3oV6dIOR6Sd/aaay76WgWIEVR8=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718020838-c21017d2cd8b/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718032106-40a603522d40 h1:VyFfS0d6pTX2HbZoDHOxJwag4aVSLOh/LrQXqfSJLBg=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718032106-40a603522d40/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718083804-d724cc84fa94 h1:iQPrRcZ6XfFblpVHxe/CIoWyTj7imF+3edIGSX6ZMM8=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718083804-d724cc84fa94/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718084512-89fa9e4ac585 h1:Wy6qjZ0uHfp02/H688zotRfzYGRPjun7Qay0Z9B/hSg=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718084512-89fa9e4ac585/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718105124-72a683fed2c0 h1:8LmRo2nKaLi4QCmO/agSpNTmCD0EdwFycjHjOweQJp8=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230718105124-72a683fed2c0/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230719003101-256bfd030c29 h1:ADScrqJgmk/TfyOu/6oXD3WkSH8sh3Bw360O8GKuEV8=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230719003101-256bfd030c29/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230719003337-29b2f258507d h1:eMzrvVkQfbs5X5dcw80TGGKtJ+6XELl7zNsWiuq4gzs=
+repositories.action2quare.com/ayo/gocommon v0.0.0-20230719003337-29b2f258507d/go.mod h1:PdpZ16O1czKKxCxn+0AFNaEX/0kssYwC3G8jR0V7ybw=
--- a/main.go
+++ b/main.go
@ -24,12 +24,11 @@ func main() {
 		panic(err)
 	}

-	authcache, err := common.NewAuthCollectionGlobal(ctx, config.MaingateApiToken)
+	wsh, err := wshandler.NewWebsocketHandler()
 	if err != nil {
 		panic(err)
 	}

-	wsh := wshandler.NewWebsocketHandler(authcache)
 	if tv, err := core.New(ctx, wsh, &config); err != nil {
 		panic(err)
 	} else {
Author	SHA1	Message	Date
mountain	8e1b232d57	InMemory 그룹을 redis로 변경	2023-07-19 09:37:02 +09:00
mountain	01da5bb3a4	body를 marshaling하고 클라이언트에서 flatten함	2023-07-18 01:31:39 +09:00
mountain	ba61a11659	gob 등록	2023-07-17 17:47:07 +09:00
mountain	67cca13326	모듈 업데이트	2023-07-16 18:41:24 +09:00
mountain	272c696c59	json value 다시 되돌림	2023-07-16 17:29:21 +09:00
mountain	aa568ec3fa	SetOption 타입 변경	2023-07-16 17:26:19 +09:00
mountain	b9c4d8b21b	objvalue marshalling 수정	2023-07-16 17:15:08 +09:00
mountain	99834c1461	objlen 수정	2023-07-16 17:01:06 +09:00
mountain	592112219e	gocommon 업데이트	2023-07-16 16:38:05 +09:00
mountain	62485b6d54	redis json 마이그레이션 완료	2023-07-16 15:36:20 +09:00
mountain	d36dd13bb7	redis stack 사용	2023-07-16 02:51:41 +09:00