[fin]json형태를 msgtype에 따라 바꾸기

src/broker/modules/init.go

@@ -53,20 +53,76 @@ type Args struct { // 매개변수
 
 func (receiver Receiver) MM_Receive(args Args, reply *Reply) error {
 	// 메세지 별로 나눠서 언마샬하면 됨
+	switch args.Kind {
 
-	var msg PublishMsg
-
-	//msg
-	err := json.Unmarshal(args.JsonMsg, &msg)
-	if err != nil {
-		return err
-	}
-	go func() {
-		_, err := receiver.moscato.Receive(msg)
+	case KSM:
+		var msg KeyGenMsg
+		err:=json.Unmarshal(args.JsonMsg,&msg)
 		if err != nil {
-
+			return err
+		}
+		go func() {
+			_, err := receiver.moscato.Receive(msg)
+			if err != nil {
+
+			}
+		}()
+		reply.CompleteLog = "received completely"
+	case PM:
+		var msg PublishMsg
+		err:=json.Unmarshal(args.JsonMsg,&msg)
+		if err != nil {
+			return err
+		}
+		go func() {
+			_, err := receiver.moscato.Receive(msg)
+			if err != nil {
+
+			}
+		}()
+		reply.CompleteLog = "received completely"
+	case SM:
+		var msg SubscriptionMsg
+		err:=json.Unmarshal(args.JsonMsg,&msg)
+		if err != nil {
+			return err
 		}
-	}()
+		go func() {
+			_, err := receiver.moscato.Receive(msg)
+			if err != nil {
+
+			}
+		}()
+		reply.CompleteLog = "received completely"
+	case RM:
+		var msg RegisterMsg
+		err:=json.Unmarshal(args.JsonMsg,&msg)
+		if err != nil {
+			return err
+		}
+		go func() {
+			_, err := receiver.moscato.Receive(msg)
+			if err != nil {
+
+			}
+		}()
+		reply.CompleteLog = "received completely"
+	case WM:
+		var msg WithdrawMsg
+		err:=json.Unmarshal(args.JsonMsg,&msg)
+		if err != nil {
+			return err
+		}
+		go func() {
+			_, err := receiver.moscato.Receive(msg)
+			if err != nil {
+
+			}
+		}()
+		reply.CompleteLog = "received completely"
+	default:
+		return errors.New("Message type Error: Not registered message type")
+	}
 	reply.CompleteLog = "received completely"
 	return nil
 }
@@ -114,7 +170,6 @@ func (moscato *Moscato) Run() {
 	//rpc 등록 -> Receive 함수
 	err := rpc.Register(receiver)
 	if err != nil {
-		fmt.Println("fuck")
 		log.Println(err)
 		return
 	}