From 856cffb67fc1cb6f66fae6c1becdf20ab65221ae Mon Sep 17 00:00:00 2001 From: "insanity@loafle.com" Date: Mon, 5 Jun 2017 18:22:02 +0900 Subject: [PATCH] email auth chcek --- glide.yaml | 13 +++++- proxy/agent/agent_service.go | 68 +++++++++++++++++++++++++++++++ proxy/agent/agent_service_test.go | 31 ++++++++++++++ 3 files changed, 111 insertions(+), 1 deletion(-) create mode 100644 proxy/agent/agent_service.go create mode 100644 proxy/agent/agent_service_test.go diff --git a/glide.yaml b/glide.yaml index 25a4223..de08748 100644 --- a/glide.yaml +++ b/glide.yaml @@ -1,4 +1,4 @@ -package: git.loafle.net/overflow/overflow_proxy_service +package: loafle.com/overflow/overflow_proxy_service import: - package: git.loafle.net/overflow/commons_go subpackages: @@ -7,8 +7,19 @@ import: - package: git.loafle.net/overflow/overflow_api_db subpackages: - build/golang +- package: git.loafle.net/overflow/overflow_proxy_service + vcs: git + version: master + repo: https://git.loafle.net/overflow/overflow_proxy_service.git + subpackages: + - proxy + - proxy/apikey + - proxy/keystore + - proxy/member - package: github.com/google/uuid - package: golang.org/x/net subpackages: - context - package: google.golang.org/grpc +testImport: +- package: github.com/golang/glog diff --git a/proxy/agent/agent_service.go b/proxy/agent/agent_service.go new file mode 100644 index 0000000..29b6c20 --- /dev/null +++ b/proxy/agent/agent_service.go @@ -0,0 +1,68 @@ +package agent + +import ( + "encoding/json" + "fmt" + "git.loafle.net/overflow/overflow_proxy_service/proxy" + "git.loafle.net/overflow/overflow_proxy_service/proxy/member" + "time" +) + +type AgentService struct { +} + +type Agent struct { + Id json.Number `json:"id,Number,omitempty"` + AuthorizedDate int64 `json:"authorizedDate,Number,omitempty"` + Description string `json:"description,omitempty"` + Member member.Member `json:"member,omitempty"` + LastPollingDate int64 `json:"description,omitempty"` + Status string `json:"Status,omitempty"` +} + +func NewAgentService() *AgentService { + return &AgentService{} +} + +func NewAgent(desc string, member member.Member) *Agent { + + na := &Agent{ + AuthorizedDate: time.Now().Unix(), + Description: desc, + Member: member, + } + return na +} + +func (as *AgentService) SaveAgent(agent *Agent) (string, error) { + bytes, err := json.Marshal(agent) + if err != nil { + return "", err + } + fmt.Println(agent.Member.Id) + fmt.Println(string(bytes)) + paramMap := make(map[string]string) + paramMap["com.loafle.overflow.agent.model.Agent"] = string(bytes) + + out := proxy.InvokeDB("agent", "create", paramMap) + + return out, nil +} + +func (as *AgentService) getAgentList(memberId string) (string, error) { + paramMap := make(map[string]string) + + mem := member.NewMember() + mem.Id = json.Number(memberId) + + bytes, err := json.Marshal(mem) + if err != nil { + return "", err + } + + paramMap["com.loafle.overflow.member.model.Member"] = string(bytes) + + out := proxy.InvokeDB("agent", "findAgentListByMemberId", paramMap) + + return out, nil +} diff --git a/proxy/agent/agent_service_test.go b/proxy/agent/agent_service_test.go new file mode 100644 index 0000000..7cde4a0 --- /dev/null +++ b/proxy/agent/agent_service_test.go @@ -0,0 +1,31 @@ +package agent + +import ( + "encoding/json" + "testing" + "git.loafle.net/overflow/overflow_proxy_service/proxy/member" +) + +func TestSaveAgent(t *testing.T) { + m := member.Member{} + m.Id = json.Number("1") + + agt := NewAgent("test agent424", m) + as := NewAgentService() + + res, err := as.SaveAgent(agt) + if err != nil { + t.Log(res) + } +} + + +func TestListAgent(t *testing.T) { + as := NewAgentService() + if res, err := as.getAgentList("1"); err != nil { + t.Fatal(err) + }else { + t.Log(res) + } + +}