-
Notifications
You must be signed in to change notification settings - Fork 0
/
Assistant.c
201 lines (150 loc) · 4.89 KB
/
Assistant.c
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
#include <stdio.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <string.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include "structure.h"
#define PORT 8080
/*
Assistant.c is the first half of the assistant
This process connects to the server and then starts a loop that reads in employee
info from the fifo pipe, checks the history file for the employee, and sends the
information to the server if the search returns false
Written by Kayla Walkup
*/
//function declaration
int fileSearch();
struct User *userPtr, user;
int main(int argc, char const *argv[])
{
printf("Assistant Started! \n");
//====== Socket Setup ======================================================
//initializing socket vars
int sock = 0, valread;
struct sockaddr_in serv_addr;
char buffer[1024] = {0};
//create socket, print error and exit if fail
if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
{
perror("socket");
return -1;
}
//setting addresses
serv_addr.sin_family = AF_INET;
serv_addr.sin_port = htons(PORT);
// Converting IPv4 and IPv6 addresses to binary, exit if fail
if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0)
{
perror("inet_pton");
return -1;
}
//==================================================================================
//=====Pipe setup=================================================================
//struct pointer to store employee info
userPtr = &user;
//pipe file descriptor
int fd1;
// FIFO file path
char *myfifo = "myfifo.txt";
//chars to store read data in
char str1[100];
char str2[100];
char str3[100];
//open pipe for read
fd1 = open(myfifo, O_RDONLY);
//==================================================================================
//print error if connection fails
if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0)
{
perror("connect");
}
//token to split up string from pipe
char *token;
//loop to read from pipe, check history file for employee, and send employee to server if not there
while(1)
{
//reading from pipe if pipe is not empty
if(read(fd1, str1, 100) > 0)
{
//feedback on if read was successful or not
perror("read");
//splitting up info from pipe and entering it into the struct
token = strtok(str1, ",");
strcpy(userPtr->employeeName, token);
printf("Name: %s\n", userPtr->employeeName);
token = strtok(NULL, ",");
strcpy(userPtr->jobTitle, token);
printf("Job Title: %s\n", userPtr->jobTitle);
token = strtok(NULL, ",");
strcpy(userPtr->status, token);
printf("Status: %s\n", userPtr->status);
//--------------------------------------------------------------
//search file, if employee not in file, send to server
if(fileSearch() == 1)
{
//sending employee information to server from struct
if(send(sock, userPtr->employeeName, 100, 0)){
perror("send");
}
send(sock, userPtr->jobTitle, 100, 0);
send(sock, userPtr->status, 100, 0);
//print statement to test the send worked
printf("Employee sent!\n");
}
sleep(2);
assistantReceive();
}
}
//======================================================================================
return 0;
}
//fuction to search history file for employee
int fileSearch()
{
//opening file------------------
FILE *filep;
char *filename = "history.txt";
filep = fopen(filename, "a+");
if (filep == NULL)
{
perror("Error: ");
exit(0);
}
//-------------------------------
//return false (1) if file is empty
int size;
fseek (filep, 0, SEEK_END);
size = ftell(filep);
if (0 == size) {
//printf("file is empty\n");
return 1;
}
//----------------------------------
//search the file for employee info------------------------------------------
char line[256];
while (fgets(line, sizeof(line), filep))
{
if(strstr(line, userPtr->employeeName))
{
if(strstr(line, userPtr->jobTitle) && strstr(line, userPtr->status))
{
//Emplyee in history file, can print
printf("%s\n", line);
return 0;
}
}
else
{
return 1;
}
return 1;
}
//--------------------------------------------------------------------------------
//close file
fclose(filep);
return 1;
}