aboutsummaryrefslogtreecommitdiff
path: root/juick-demo/src/main/java/com/juick/demo
diff options
context:
space:
mode:
authorGravatar Vitaly Takmazov2016-10-12 15:15:57 +0300
committerGravatar Vitaly Takmazov2016-10-12 15:15:57 +0300
commit36c679330d1bc0c6f0dfd7ec3dd1fb631259a8d9 (patch)
treef3a1ccdc25171687879debb2e2dcfb9423c1461c /juick-demo/src/main/java/com/juick/demo
parent688eefb6db3ddeb9da583d5e1109e4639cf4e642 (diff)
juick-demo: add console
Diffstat (limited to 'juick-demo/src/main/java/com/juick/demo')
-rw-r--r--juick-demo/src/main/java/com/juick/demo/Demo.java41
1 files changed, 39 insertions, 2 deletions
diff --git a/juick-demo/src/main/java/com/juick/demo/Demo.java b/juick-demo/src/main/java/com/juick/demo/Demo.java
index 6940bfd0..c3d45b44 100644
--- a/juick-demo/src/main/java/com/juick/demo/Demo.java
+++ b/juick-demo/src/main/java/com/juick/demo/Demo.java
@@ -1,13 +1,23 @@
package com.juick.demo;
+import ch.vorburger.exec.ManagedProcessException;
+import ch.vorburger.mariadb4j.DB;
import com.juick.Tag;
+import com.juick.User;
import com.juick.server.MessagesQueries;
import com.juick.server.PMQueries;
import com.juick.server.TagQueries;
import com.juick.server.UserQueries;
+import com.juick.server.protocol.JuickProtocol;
+import com.juick.server.protocol.ProtocolReply;
+import jline.UnsupportedTerminal;
+import jline.console.ConsoleReader;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.logging.Logger;
@@ -16,8 +26,14 @@ import java.util.logging.Logger;
*/
public class Demo {
private static final Logger logger = Logger.getLogger(Demo.class.getName());
- public static void main(String ...args) {
- DriverManagerDataSource dataSource = new DriverManagerDataSource("jdbc:mysql://localhost/juick?user=root");
+ public static void main(String ...args) throws ManagedProcessException {
+ DB db = DB.newEmbeddedDB(33306);
+ db.start();
+ db.createDB("juick");
+ db.source("schema.sql");
+ DriverManagerDataSource dataSource = new DriverManagerDataSource();
+ dataSource.setDriverClassName("com.mysql.jdbc.Driver");
+ dataSource.setUrl("jdbc:mysql://localhost:33306/juick?autoReconnect=true&user=root");
JdbcTemplate jdbc = new JdbcTemplate(dataSource);
logger.info("initializing demo database");
@@ -35,5 +51,26 @@ public class Demo {
MessagesQueries.setMessagePopular(jdbc, ugn_mid, 1);
PMQueries.createPM(jdbc, freefd_id, ugnich_id, "Hi ugnich!");
jdbc.execute("UPDATE tags SET top=1");
+ jline.TerminalFactory.registerFlavor(jline.TerminalFactory.Flavor.WINDOWS, UnsupportedTerminal.class);
+ try (ConsoleReader reader = new ConsoleReader()) {
+ reader.setPrompt("ugnich>");
+ PrintWriter out = new PrintWriter(reader.getOutput());
+ User ugnich = UserQueries.getUserByUID(jdbc, ugnich_id).get();
+ out.println(String.format("logged in as @%s", ugnich.getUName()));
+ out.flush();
+ String input;
+ JuickProtocol protocol = new JuickProtocol(jdbc, "http://localhost/");
+ while ((input = reader.readLine()) != null) {
+ ProtocolReply reply = protocol.getReply(ugnich, input);
+ out.println(reply.getDescription());
+ out.flush();
+ }
+ } catch (IOException | NoSuchMethodException e) {
+ e.printStackTrace();
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ } catch (InvocationTargetException e) {
+ e.printStackTrace();
+ }
}
}