client.cpp

chronolaw · chronolaw · commit 7dbdceaaa9de · 2020-04-10T14:11:26.000+08:00
diff --git a/section5/SalesData.hpp b/section5/SalesData.hpp
@@ -79,6 +79,13 @@ class SalesData final
         return sbuf;
     }
 
+    SalesData(const msgpack::sbuffer& sbuf)
+    {
+        auto obj = msgpack::unpack(
+                    sbuf.data(), sbuf.size()).get();
+        obj.convert(*this);
+    }
+
 public:
     void inc_sold(uint_type s) noexcept
     {
diff --git a/section5/client.cpp b/section5/client.cpp
@@ -14,6 +14,9 @@
 // you should put json.hpp in ../common
 #include "json.hpp"
 
+USING_NAMESPACE(std);
+USING_NAMESPACE(cpp_study);
+
 static
 auto debug_print = [](auto& b)
 {
@@ -29,39 +32,60 @@ auto debug_print = [](auto& b)
     std::cout << j.dump(2) << std::endl;
 };
 
-int main()
-try
+// sales data
+static
+auto make_sales = [=](const auto& id, auto s, auto r)
+//-> msgpack::sbuffer
 {
-    USING_NAMESPACE(std);
-    USING_NAMESPACE(cpp_study);
-
-    cout << "hello cpp_study" << endl;
+    return SalesData(id, s, r).pack();
 
-    // sales data
+#if 0
+    SalesData book(id);
 
-    SalesData book1("isbn001");
+    book.inc_sold(s);
+    book.inc_revenue(r);
 
-    book1.inc_sold(10);
-    book1.inc_revenue(100);
+    debug_print(book);
 
-    debug_print(book1);
-
-    auto buf = book1.pack();
+    auto buf = book.pack();
     cout << buf.size() << endl;
 
-    // zmq send
+    //SalesData book2 {buf};
+    //assert(book.id() == book2.id());
+    //debug_print(book2);
+
+    return buf;
+#endif
+};
 
+// zmq send
+static
+auto send_sales = [](const auto& addr, const auto& buf)
+{
     using zmq_ctx = ZmqContext<1>;
 
     auto sock = zmq_ctx::send_sock();
 
-    sock.connect("tcp://127.0.0.1:5555");
+    sock.connect(addr);
     assert(sock.connected());
 
     auto len = sock.send(buf.data(), buf.size());
     assert(len == buf.size());
 
     cout << "send len = " << len << endl;
+};
+
+int main()
+try
+{
+    cout << "hello cpp_study client" << endl;
+
+    //auto buf = make_sales("001", 10, 100);
+    //send_sales("tcp://127.0.0.1:5555", buf);
+
+    send_sales("tcp://127.0.0.1:5555",
+             make_sales("001", 10, 100));
+
 }
 catch(std::exception& e)
 {

Original file line number	Diff line number	Diff line change
`@@ -79,6 +79,13 @@ class SalesData final`
`79`	`79`	`return sbuf;`
`80`	`80`	`}`
`81`	`81`
	`82`	`+ SalesData(const msgpack::sbuffer& sbuf)`
	`83`	`+ {`
	`84`	`+ auto obj = msgpack::unpack(`
	`85`	`+ sbuf.data(), sbuf.size()).get();`
	`86`	`+ obj.convert(*this);`
	`87`	`+ }`
	`88`	`+`
`82`	`89`	`public:`
`83`	`90`	`void inc_sold(uint_type s) noexcept`
`84`	`91`	`{`