project4/LookupServer.cpp at master · samriffle/project4 · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
#include "Ref.h"
#include "Verse.h"
#include "Bible.h"
#include <iostream>
#include <fstream>
#include <string>
#include <stdio.h>
#include <stdlib.h>
#include "logfile.h"
#include "fifo.h"
// #define logging // enable log file
// #define LOG_FILENAME "/tmp/samriffle-LookupServer.log"
#include "logfile.h"
#include <stdio.h>
#include <string.h>
#include <sstream>
using namespace std;
// Using namespace bible
// #define logging // enable log file

int main() {
	string receive_pipe = "request";
	string send_pipe = "reply";
	Fifo recfifo(receive_pipe);
	Fifo sendfifo(send_pipe);
	#ifdef logging
		logFile.open(logFilename.c_str(), ios::out);
	#endif

	// build indices
	cout << "" << endl;
	Bible kjvBible("/home/class/csc3004/Bibles/kjv-complete");
	Bible dbyBible("/home/class/csc3004/Bibles/dby-complete");
	Bible yltBible("/home/class/csc3004/Bibles/ylt-complete");
	Bible websterBible("/home/class/csc3004/Bibles/webster-complete");
	Bible webBible("/home/class/csc3004/Bibles/web-complete");
	cout << "Indices built" << endl;


	recfifo.openread();
	log("Open request fifo");
	while (1) {
		// Process request
		string results = "";
		string tokenValue[5];
		cout << "" << endl;
		cout << "Waiting for request..." << endl;
		results = recfifo.recv();
		log(results);
		cout << "Info recieved by server: " << results;
		cout << endl;
		tokenValue[0] = GetNextToken(results, "&"); // Book
		tokenValue[1] = GetNextToken(results, "&"); // Chap
		tokenValue[2] = GetNextToken(results, "&"); // Verse
		tokenValue[3] = GetNextToken(results, "&"); // Number of verses
		tokenValue[4] = GetNextToken(results, "&"); // Bible Version

		// Parse string into usable variables for request
		int b = stoi(tokenValue[0]);
		int c = stoi(tokenValue[1]);
		int v = stoi(tokenValue[2]);
		int nv = stoi(tokenValue[3]);
		int bibleVers = stoi(tokenValue[4]);
		cout << "Bible version: " << bibleVers << endl;

		Ref ref(b, c, v);
		Verse lVerse;
		LookupResult result = OTHER;

		cout << "Now processing..." << endl;

		// Chose index to use for the request
		int bibleVersionNum = bibleVers;
		cout << bibleVersionNum << endl;
		Bible* bible;
		if (bibleVersionNum == 1) {
			bible = &webBible;
		}
		else if (bibleVersionNum == 2) {
			bible = &kjvBible;
		}
		else if (bibleVersionNum == 3) {
			bible = &dbyBible;
		}
		else if (bibleVersionNum == 4) {
			bible = &yltBible;
		}
		else if (bibleVersionNum == 5) {
			bible = &websterBible;
		}
		else {
			return 0;
		}
		sendfifo.openwrite(); // Open write to client

		// Return Verse(s)
		lVerse = bible->lookup(ref, result);
		if (result != SUCCESS) { Verse noVerse; stringstream ss; ss << noVerse.getRef().getBook() << "&" << noVerse.getRef().getChap() << "&" << noVerse.getRef().getVerse() << "&" << noVerse.getVerse() << "&" << result << "&"; string out = ss.str(); sendfifo.send(out); }
		else { // successful search
			int numVerses = nv;
			if (numVerses <= 0) { Verse noVerse; stringstream ss; ss << noVerse.getRef().getBook() << "&" << noVerse.getRef().getChap() << "&" << noVerse.getRef().getVerse() << "&" << noVerse.getVerse() << "&" << result << "&"; string out = ss.str(); sendfifo.send(out); }
			else {
				if (result != SUCCESS) { Verse noVerse; stringstream ss; ss << noVerse.getRef().getBook() << "&" << noVerse.getRef().getChap() << "&" << noVerse.getRef().getVerse() << "&" << noVerse.getVerse() << "&" << result << "&"; string out = ss.str(); sendfifo.send(out); }
				else {
					string out = "";
					stringstream ss;
					ss << lVerse.getRef().getBook() << "&" << lVerse.getRef().getChap() << "&" << lVerse.getRef().getVerse() << "&" << lVerse.getVerse() << "&" << result << "&";
					out = ss.str();
					sendfifo.send(out);
					ss.flush();
					ss.clear();
					if (numVerses > 0 && numVerses != NULL) {
						for (int i = 1; i < numVerses; i++) {
							string out2 = "";
							stringstream ss2;
							Verse verseNext = bible->nextVerse(result);
							ss2 << verseNext.getRef().getBook() << "&" << verseNext.getRef().getChap() << "&" << verseNext.getRef().getVerse() << "&" << verseNext.getVerse() << "&" << result << "&";
							out2 = ss2.str();
							sendfifo.send(out2);
							ss2.flush();
							ss2.clear();
							if (result != SUCCESS) {
								break;
							}
						}
					}
				}
			}
		}
		sendfifo.fifoclose();  // Close send pipe
		log("close reply fifo");
		cout << "Process complete" << endl;
	}
	//recfifo.fifoclose();
	//log("close request fifo");
}