norbipeti/ChatServer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Did getUser, started register

Browse source
This commit is contained in:
Norbi Peti 2016-07-19 14:07:54 +02:00
parent c07a0d6207
commit ddbcc536a7
4 changed files with 46 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
pages/register.html
View file

@ -1,5 +1,37 @@
<!DOCTYPE html> <!DOCTYPE html>
<html> <html>
<h1>Register</h1> <h1>Register</h1>
<p>Hello</p> <table>
<form action="register" method="POST">
<tr>
<td>Name:</td>
<td>
<input type="text" name="name" />
</td>
</tr>
<tr>
<td>E-mail:</td>
<td>
<input type="email" name="email" />
</td>
</tr>
<tr>
<td>Password</td>
<td>
<input type="password" name="pass" />
</td>
</tr>
<tr>
<td>Password confirm</td>
<td>
<input type="password" name="pass2" />
</td>
</tr>
<tr>
<td>
<input type="submit" value="Register" />
</td>
</tr>
</form>
</table>
</html> </html>

11
src/io/github/norbipeti/chat/server/IOHelper.java
View file

@ -18,16 +18,21 @@ public class IOHelper {
} }
public static boolean SendPage(int code, Page page, HttpExchange exchange) throws IOException { public static boolean SendPage(int code, Page page, HttpExchange exchange) throws IOException {
String content = GetPage(page, exchange);
SendResponse(code, content, exchange);
return true;
}
public static String GetPage(Page page, HttpExchange exchange) throws IOException {
File file = new File(page.GetHTMLPath()); File file = new File(page.GetHTMLPath());
if (!file.exists()) { if (!file.exists()) {
SendResponse(501, SendResponse(501,
"<h1>501 Not Implemented</h1><p>The page \"" + page.GetName() + "\" cannot be found on disk.</h1>", "<h1>501 Not Implemented</h1><p>The page \"" + page.GetName() + "\" cannot be found on disk.</h1>",
exchange); exchange);
return false; return null;
} }
FileInputStream inputStream = new FileInputStream(file); FileInputStream inputStream = new FileInputStream(file);
String content = IOUtils.toString(inputStream, StandardCharsets.UTF_8); String content = IOUtils.toString(inputStream, StandardCharsets.UTF_8);
SendResponse(code, content, exchange); return content;
return true;
} }
} }

4
src/io/github/norbipeti/chat/server/Main.java
View file

@ -5,9 +5,6 @@ import java.net.InetAddress;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
import java.util.Set; import java.util.Set;
import javax.persistence.EntityManager;
import org.hibernate.Hibernate;
import org.reflections.Reflections; import org.reflections.Reflections;
import org.reflections.scanners.SubTypesScanner; import org.reflections.scanners.SubTypesScanner;
import org.reflections.util.ClasspathHelper; import org.reflections.util.ClasspathHelper;
@ -36,6 +33,7 @@ public class Main {
user2.getContacts().add(user.getId()); user2.getContacts().add(user.getId());
provider.addUser(user2); provider.addUser(user2);
System.out.println(provider.getUsers()); System.out.println(provider.getUsers());
System.out.println("Contact: " + provider.getUser(user2.getContacts().get(0)));
} }
System.out.println("Starting webserver..."); System.out.println("Starting webserver...");
HttpServer server = HttpServer.create(new InetSocketAddress(InetAddress.getLocalHost(), 8080), 10); HttpServer server = HttpServer.create(new InetSocketAddress(InetAddress.getLocalHost(), 8080), 10);

8
src/io/github/norbipeti/chat/server/db/DataProvider.java
View file

@ -36,12 +36,12 @@ public class DataProvider implements AutoCloseable {
return users; return users;
} }
public List<User> getUser(Long id) { //TODO public User getUser(Long id) {
EntityManager em = emf.createEntityManager(); EntityManager em = emf.createEntityManager();
TypedQuery<User> query = em.createQuery("SELECT u FROM User u", User.class); TypedQuery<User> query = em.createQuery("SELECT u FROM User u WHERE u.id = " + id, User.class);
List<User> users = query.getResultList(); User user = query.getResultList().get(0);
em.close(); em.close();
return users; return user;
} }
public void removeUser(User user) { public void removeUser(User user) {