-
Notifications
You must be signed in to change notification settings - Fork 0
/
valFile.cpp
382 lines (290 loc) · 11.9 KB
/
valFile.cpp
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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
/*
Gus Brigantino
Validator Simulator Module
Senior Design Spring 2020
Cubic Transportation
*/
#include "valFile.h"
Acct Account;
std::unordered_map<std::string, int> recentlyProcessedAddrs; //map of MAC addrs and time since last process
//made global var to eliminate seg faults, although passing pointer to local var is ideal
int main()
{
InitDesiredAddrs(); //From BLEService
InitRecentlyProcessedAddrs();
ValidationProcess();
}
int ValidationProcess()
{
std::string beaconAcctNum; //account number from beacon holder
int machineState = BLE_ST; //init state var of the state machine
while(true)
{
switch(machineState)
{
case BLE_ST:
beaconAcctNum = BLEService(); //returns beacon info or null string
if(beaconAcctNum.compare(NULL_STR) == 0) //no beacon found
{
UpdateRecentlyProcessedAddrs();
machineState = BLE_ST;
}
else
{
if(recentlyProcessedAddrs.find(beaconAcctNum) != recentlyProcessedAddrs.end()) //beacon not in recently processed state
{
if((recentlyProcessedAddrs.find(beaconAcctNum))->second == 0)
{
Account.setNumber(beaconAcctNum);
(recentlyProcessedAddrs.find(beaconAcctNum))->second = 1;
machineState = LOOKUP_ST;
}
else
{
UpdateRecentlyProcessedAddrs();
machineState = BLE_ST;
}
}
}
break;
case LOOKUP_ST: //finds given account number from beacon in csv file
AccountLookUp();
if(Account.getFoundStatus() && Account.getBalanceStatus())
{
machineState = DB_EDIT_ST;
}
else
{
machineState = UI_ST;
}
break;
case DB_EDIT_ST: //makes edits to exsisting csv file by creating new one and renaming
UpdateDataBase();
machineState = UI_ST;
break;
case UI_ST:
UIClient();
machineState = BLE_ST;
break;
}
Timer(ST_MACH_DELAY); //clocks the state machine to run on an interval
}
return 0;
}
int AccountLookUp()
{
std::fstream dataFile; //fstream = file read/write default
std::string line; //std string used in get line calls for reading the csv file
std::string dbAcctNum; //account number from database holder
std::string acctName; //account name from database holder
double acctBalance;
std::string balance; //vars used to convert balance from string to int and save
int acctIndex = 0; //account index in csv file tracker
dataFile.open(DB_FILE_NAME, std::ios::in); //open csv file
if(dataFile.is_open())
{
while(getline(dataFile, line, DELIMITER))
{
std::stringstream acctNumHolder(line); //determines if the account number
acctNumHolder >> dbAcctNum; //Assuming the number is contained in the first column of every row
if(dbAcctNum == Account.getNumber()) //if last account number read equals account number from beacon
{
getline(dataFile, acctName, DELIMITER);
Account.setName(acctName); //save account name
getline(dataFile, balance, DELIMITER);
std::stringstream balanceHolder(balance);
balanceHolder >> acctBalance;
Account.setBalance(acctBalance); //convert balance to an int and save
if(Account.getBalance() >= TICKET_PRICE) //Balance check so that the account does not go below $0
{
Account.setBalanceStatus(true);
}
else
{
Account.setBalanceStatus(false);
}
Account.setFoundStatus(true); //set found status to true
}
else
{
getline(dataFile, line); //reads to end of line to allow next read to be at the beginning of the next line
Account.setFoundStatus(false); //set found status to false
}
Account.setIndex(acctIndex); //update index for object
acctIndex++; //since account number not found yet inc
if(Account.getFoundStatus()) //if account number is found break out of loop to avoid unnecessary iterations
{
break;
}
}
dataFile.close();
}
else
{
std::cout << "File could not be opened." << std::endl;
}
return 0;
}
int UpdateDataBase()
{
std::fstream fileRead; //file to read from
std::fstream fileWrite; //file to write to
std::string line2; //std string used in get line calls for reading the csv file
std::vector<std::string> row; //vector of strings used to hold entire rows (lines) of csv file
std::string newRow; //string used to hold the updated row
int csvRowCnt; //count the total number of rows in the csv file
fileRead.open(DB_FILE_NAME, std::ios::in); //open existing database csv file
fileWrite.open(NEW_DB_FILE_NAME, std::ios::out); //create new csv file
if(fileRead.is_open() && fileWrite.is_open()) //if both are opened
{
csvRowCnt = 0;
while(getline(fileRead, line2))
{
row.push_back(line2); //store each line in the vector of strings
csvRowCnt++;
}
Account.setBalance(Account.getBalance() - TICKET_PRICE); //update balance of account
newRow = Account.getNumber() + DELIMITER
+ Account.getName() + DELIMITER
+ std::to_string(Account.getBalance()); //creates a new row based on current Acct Account info
row[Account.getIndex()] = newRow; //saves new row in correct index
for(int k = 0; k < csvRowCnt; k++)
{
fileWrite << row[k] << '\n'; //writes the entire database to the new csv file
}
fileWrite.close();
fileRead.close();
remove(DB_FILE_NAME); //removes the old file from directory
rename(NEW_DB_FILE_NAME, DB_FILE_NAME); //renames the new file to the original name
}
else
{
std::cout << "File could not be open." << std::endl;
}
return 0;
}
int UpdateRecentlyProcessedAddrs()
{
std::unordered_map<std::string, int>:: iterator recProcAddrsItr;
for(recProcAddrsItr = recentlyProcessedAddrs.begin(); recProcAddrsItr != recentlyProcessedAddrs.end(); recProcAddrsItr++) //iterate through recently processed addrs
{
recProcAddrsItr->second = (recProcAddrsItr->second + 1); //int var in map counts how many times state machine has iterated
if(recProcAddrsItr->second == PROCD_WAIT_TIME) //wait period is over
{
recProcAddrsItr->second = 0;
}
}
return 0;
}
int InitRecentlyProcessedAddrs()
{
std::unordered_set<std::string>:: iterator desiredAddrsItr;
for(desiredAddrsItr = desiredAddrs.begin(); desiredAddrsItr != desiredAddrs.end(); desiredAddrsItr++) //iterate through desired addrs
{
recentlyProcessedAddrs.insert(std::make_pair(*desiredAddrsItr, 0)); //adds addrs from desired addrs to recently processed addrs
}
return 0;
}
int UIClient()
{
int newSocket = 0;
struct sockaddr_in serverAddress;
if((newSocket = socket(AF_INET, SOCK_STREAM, IP_SOCKET_PRTCL)) < 0) //Create new socket
{
std::cout << "Socket creation error" << std::endl;
return -1;
}
serverAddress.sin_family = AF_INET;
serverAddress.sin_port = htons(PORT_NUMBER);
if(inet_pton(AF_INET, SERVER_ADDR, &serverAddress.sin_addr) <= 0) //Convert IPv4 and IPv6 addresses from text to binary form
{
std::cout << "Invalid address/ Address not supported" << std::endl;
return -1;
}
if(connect(newSocket, (struct sockaddr *)&serverAddress, sizeof(serverAddress)) < 0) //Connect to server
{
std::cout << "Communincation Failed" << std::endl;
return -1;
}
std::string strData = Account.getName() + DELIMITER
+ std::to_string(Account.getBalance()) + DELIMITER
+ (Account.getFoundStatus() ? "1" : "0") + DELIMITER //either 1 or 0 based on true or false
+ (Account.getBalanceStatus() ? "1" : "0") + NULL_STR;
const char *data = strData.c_str();
send(newSocket, data, BUFFER_SIZE, IP_SOCKET_PRTCL); //send message to server
return 0;
}
int Timer(int milliseconds)
{
clock_t startTime = clock();
int millisecondsPassed;
int millisecondsToDelay = milliseconds;
bool timerFlag = true;
while(timerFlag)
{
millisecondsPassed = (clock() - startTime) / MS_PER_SEC;
if(millisecondsPassed >= millisecondsToDelay)
{
timerFlag = false;
}
}
return 0;
}
//Acct Class Functions
Acct::Acct()
{
name = "";
number = "";
balance = 0.0;
index = 0;
foundStatus = false;
balanceStatus = false;
}
std::string Acct::getName()
{
return name;
}
void Acct::setName(std::string newName)
{
name = newName;
}
std::string Acct::getNumber()
{
return number;
}
void Acct::setNumber(std::string newNumber)
{
number = newNumber;
}
double Acct::getBalance()
{
return balance;
}
void Acct::setBalance(double newBalance)
{
balance = newBalance;
}
int Acct::getIndex()
{
return index;
}
void Acct::setIndex(int newIndex)
{
index = newIndex;
}
bool Acct::getFoundStatus()
{
return foundStatus;
}
void Acct::setFoundStatus(bool newFoundStatus)
{
foundStatus = newFoundStatus;
}
bool Acct::getBalanceStatus()
{
return balanceStatus;
}
void Acct::setBalanceStatus(bool newBalanceStatus)
{
balanceStatus = newBalanceStatus;
}