[fin]message constructor

src/microservice/modules/message.go

@@ -1,6 +1,11 @@
 package modules
 
-import "encoding/json"
+import (
+	"encoding/json"
+	"net"
+	"os"
+	"time"
+)
 
 //import "strconv"
 //*****메세지 타입 상수화
@@ -59,19 +64,40 @@ type KeyShareMsg struct {
 	key string
 }
 
+func NewKeyShareMsg(message Message,key string) *KeyShareMsg {
+	addrs,err:=net.InterfaceAddrs()
+	var ipaddr string
+	if err !=nil{
+		os.Stderr.WriteString("Oops: "+err.Error()+"\n")
+		os.Exit(1)
+	}
+	for _,a:=range addrs{
+		if ipnet, ok:=a.(*net.IPNet); ok && !ipnet.IP.IsLoopback(){
+			ipaddr=ipnet.IP.String()
+		}
+	}
+	t := time.Now().String()
+	return &KeyShareMsg{Message{
+		from:    ipaddr,
+		version: "1",
+		time:    t,
+		kind:    KSM,
+	},key}
+}
+
 //전달할 내용을 담은 메세지
 type PublishMsg struct {
 	Message
-	topic   []int64 //대주제
-	value   []int64 //topic의 세부적인 내용
-	content []int64 // 내용
+	topic   string //대주제
+	value   string //topic의 세부적인 내용
+	content string // 내용
 }
 
 //구독 정보를 담은 메세지
 type SubscriptionMsg struct {
 	Message
-	topic    []int64  //대주제
-	value    []int64  //피연산자
+	topic    string  //대주제
+	value    string  //피연산자
 	operator []string //연산자
 	isAlpha  bool     // 범위연산인지 단순비교연산인지 구분 가능하게 함
 }
@@ -81,11 +107,102 @@ type RegisterMsg struct {
 	Message
 }
 
+
+
 //Microservice 탈퇴 메세지(없앰)
 type WithdrawMsg struct {
 	Message
 }
 
+//생성자
+func NewPublishMsg(message Message, topic string, value string, content string) *PublishMsg {
+	addrs,err:=net.InterfaceAddrs()
+	var ipaddr string
+	if err !=nil{
+		os.Stderr.WriteString("Oops: "+err.Error()+"\n")
+		os.Exit(1)
+	}
+	for _,a:=range addrs{
+		if ipnet, ok:=a.(*net.IPNet); ok && !ipnet.IP.IsLoopback(){
+			ipaddr=ipnet.IP.String()
+		}
+	}
+	t := time.Now().String()
+	return &PublishMsg{Message{
+		from:    ipaddr,
+		version: "1",
+		time:    t,
+		kind:    PM,
+	},topic,value,content}
+}
+
+func NewSubscriptionMsg(message Message,topic string, value string, operator []string, isAlpha bool) *SubscriptionMsg {
+	addrs,err:=net.InterfaceAddrs()
+	var ipaddr string
+	if err !=nil{
+		os.Stderr.WriteString("Oops: "+err.Error()+"\n")
+		os.Exit(1)
+	}
+	for _,a:=range addrs{
+		if ipnet, ok:=a.(*net.IPNet); ok && !ipnet.IP.IsLoopback(){
+			ipaddr=ipnet.IP.String()
+		}
+	}
+	t := time.Now().String()
+	return &SubscriptionMsg{Message{
+		from:    ipaddr,
+		version: "1",
+		time:    t,
+		kind:    SM,
+	},topic,value,operator,isAlpha}
+
+}
+
+func NewRegisterMsg(message Message) *RegisterMsg {
+	addrs,err:=net.InterfaceAddrs()
+	var ipaddr string
+	if err !=nil{
+		os.Stderr.WriteString("Oops: "+err.Error()+"\n")
+		os.Exit(1)
+	}
+	for _,a:=range addrs{
+		if ipnet, ok:=a.(*net.IPNet); ok && !ipnet.IP.IsLoopback(){
+			ipaddr=ipnet.IP.String()
+		}
+	}
+	t := time.Now().String()
+	return &RegisterMsg{Message{
+		from:    ipaddr,
+		version: "1",
+		time:    t,
+		kind:    RM,
+	}}
+}
+
+func NewWithdrawMsg(message Message) *WithdrawMsg {
+	addrs,err:=net.InterfaceAddrs()
+	var ipaddr string
+	if err !=nil{
+		os.Stderr.WriteString("Oops: "+err.Error()+"\n")
+		os.Exit(1)
+	}
+	for _,a:=range addrs{
+		if ipnet, ok:=a.(*net.IPNet); ok && !ipnet.IP.IsLoopback(){
+			ipaddr=ipnet.IP.String()
+		}
+	}
+	t := time.Now().String()
+	return &WithdrawMsg{Message{
+		from:    ipaddr,
+		version: "1",
+		time:    t,
+		kind:    WM,
+	}}
+}
+
+
+
+
 //**************************
 
 func (msg *KeyGenMsg) ConvertToJson() ([]byte, error) {