Added Totient's server

Author: pin3da

.gitignore

@@ -2,6 +2,7 @@ bin/peer
 bin/tracker
 bin/files
 bin/pieces
+bin/t_server
 *.totient
 *~
 *.o

Makefile

@@ -4,7 +4,7 @@ LDFLAGS=-lzmqpp -lzmq -lpthread -lsfml-audio -luuid
 SOURCE=./src
 TARGET=./bin
 
-all: dir $(TARGET)/peer $(TARGET)/tracker
+all: dir $(TARGET)/peer $(TARGET)/tracker $(TARGET)/t_server
 
 dir:
 	mkdir -p $(TARGET)/files
@@ -16,6 +16,9 @@ $(TARGET)/peer: $(SOURCE)/peer.cc
 $(TARGET)/tracker: $(SOURCE)/tracker.cc
 	$(CC) $(CFLAGS) $(LDFLAGS) -o $(TARGET)/tracker $(SOURCE)/tracker.cc
 
+$(TARGET)/t_server: $(SOURCE)/t_server.cc
+	$(CC) $(CFLAGS) $(LDFLAGS) -o $(TARGET)/t_server $(SOURCE)/t_server.cc
+
 
 clean:
-	rm -rf $(TARGET)/peer $(TARGET)/tracker
+	rm -rf $(TARGET)/peer $(TARGET)/tracker $(TARGET)/t_server

src/t_server.cc

@@ -0,0 +1,56 @@
+#include <set>
+#include <string>
+#include <unordered_map>
+#include <zmqpp/zmqpp.hpp>
+#include "utils.cc"
+
+using namespace std;
+using namespace zmqpp;
+
+int main(int argc, char **argv) {
+  if (argc < 2) {
+    cout << "Usage " << argv[0] << " port " << endl;
+    exit (1);
+  }
+
+  string port = argv[1];
+  cout << string_color("Server running on port: " + port + "\n");
+
+  context ctx;
+  socket frontend(ctx, socket_type::rep);
+  frontend.connect("tcp://localhost:" + port);
+
+  poller pol;
+  pol.add(frontend);
+
+  while (true) {
+    if (pol.poll()) {
+      if (pol.has_input(frontend)) {
+        message request;
+        frontend.receive(request);
+        string filename;
+        request >> filename;
+        filename = "./totient/" + filename;
+        message response;
+        if (file_exists(filename)) {
+          ifstream file;
+          response << "OK";
+          file.open(filename);
+          file.seekg (0, file.end);
+          int length = file.tellg();
+          file.seekg (0, file.beg);
+          char *data = new char[length];
+          file.read(data, length);
+          string chunk(data, file.gcount());
+          response << chunk;
+          file.close();
+          delete[] data;
+        } else {
+          response << "NF";
+        }
+        frontend.send(response);
+      }
+    }
+  }
+
+}