message.go

modified

modules/message.go

@@ -27,8 +27,6 @@ type MsgUnit interface {
 	ConvertToJson() ([]byte, error)
 	// CheckType - Message의 타입을 알려줌
 	CheckType() int
-	// SetType - Message 객체가 생성 되었을때 종류 정하기
-	//SetType(int)
 }
 
 //*****각 메세지 형식 및 정의**********
@@ -48,14 +46,16 @@ type KeyShareMsg struct {
 //전달할 내용을 담은 메세지
 type PublishMsg struct {
 	Message
-	subscription []int64 //선호도
+	subscription []int64 //대주제
 	content      []int64 // 내용
 }
 
 //구독 정보를 담은 메세지
 type SubscriptionMsg struct {
 	Message
-	subscription []int64 //선호도
+	subscription []int64 //대주제
+	content []int64 //내용
+	value string //범위
 }
 
 //Microservice 등록 메세지
@@ -110,27 +110,11 @@ func (msg Message) CheckType() int {
 	return msg.kind
 }
 
-/*
-func (msg Message)SetType(t int){
-   msg.kind=t
-}
-
-func NewMessage() *Message{
-	//m:=&Message{
-	//from: ip
-	//version: version
-	//time : time
-	//kind : kind(종류)
-	//}
-}
-*/
-
-//*********************************
-
-// Send - rpc를 이용하여 msg전송
-//func (msg *MsgUnit) Send(ipaddr string, message MsgUnit) (error){}
-
-// Recieve - rpc를 이용하여 msg전달 받음(rpc call)
-//func Recieve(msg *MsgUnit) (MsgUnit, error){ }
-
-//*********************************
+//KeyGenMsg 생성자
+func NewKeyGenMsg(table *MStable) *KeyGenMsg{
+	m:= &KeyGenMsg{}
+	for _,value:= range table.NodeTable{
+		m.iptable=append(m.iptable,value.Getipaddr())
+	}
+	return m
+}