From 98d15e9dece007f42f7307f3c4a9b00ae7667588 Mon Sep 17 00:00:00 2001
From: Drew DeVault <sir@cmpwn.com>
Date: Thu, 7 Sep 2017 18:35:15 +0900
Subject: [PATCH] Add WIP connection screen

Does the basics but still needs to implement:

- Autoconnect
- "Connecting..." UI
- Disconnect by request
- Disconnect by circumstance
---
 scss/main.scss         | 18 +++++++++++++-
 src/actions/socket.js  |  5 ++++
 src/index.js           | 34 ++++++++++++++------------
 src/reducers/index.js  |  2 ++
 src/reducers/socket.js | 12 +++++++++
 src/socket.js          |  4 +--
 src/ui/connection.js   | 55 ++++++++++++++++++++++++++++++++++++++++--
 src/ui/main.js         |  7 +++++-
 8 files changed, 116 insertions(+), 21 deletions(-)
 create mode 100644 src/actions/socket.js
 create mode 100644 src/reducers/socket.js

diff --git a/scss/main.scss b/scss/main.scss
index 22f7f7f..f09a01c 100644
--- a/scss/main.scss
+++ b/scss/main.scss
@@ -49,6 +49,22 @@
   background-position: left bottom;
 }
 
+.connection-overlay {
+  position: fixed;
+  display: flex;
+  justify-content: center;
+  align-items: center;
+  left: 0;
+  right: 0;
+  top: 0;
+  bottom: 0;
+  background: rgba(0, 0, 0, 0.5);
+
+  .card {
+    min-width: 20rem;
+  }
+}
+
 input[type="text"], input[type="number"] {
   padding: 0.05rem 0.25rem;
   border-radius: 0;
@@ -127,7 +143,7 @@ select.form-control {
   font-size: 0.9rem;
 }
 
-.form-check-input:only-child {
+fieldset .form-check-input:only-child {
   position: absolute;
 }
 
diff --git a/src/actions/socket.js b/src/actions/socket.js
new file mode 100644
index 0000000..172e772
--- /dev/null
+++ b/src/actions/socket.js
@@ -0,0 +1,5 @@
+export const SOCKET_CONNECTED = "SOCKET_CONNECTED";
+export const SOCKET_DISCONNECTED = "SOCKET_DISCONNECTED";
+
+export const socket_connected = () => ({ type: SOCKET_CONNECTED });
+export const socket_disconnected = () => ({ type: SOCKET_DISCONNECTED });
diff --git a/src/index.js b/src/index.js
index 9e349e8..ac17c8f 100644
--- a/src/index.js
+++ b/src/index.js
@@ -10,29 +10,33 @@ import store, { history } from './store';
 import scss from '../scss/main.scss';
 import { ws_init } from './socket';
 import { filter_subscribe } from './actions/filter_subscribe';
+import { socket_connected, socket_disconnected } from './actions/socket';
 
 import Nav from './ui/navigation';
 import Main from './ui/main';
 import Connection from './ui/connection';
 
 const root = document.getElementById('root');
-ReactDOM.render(<Connection />, root);
 
-ws_init(() => {
-  store.dispatch(filter_subscribe());
-  store.dispatch(filter_subscribe('server'));
-  ReactDOM.render(
-    <Provider store={store}>
-      <ConnectedRouter history={history}>
-        <div>
-          <Nav />
-          <div className="container">
-            <Main />
-          </div>
+export function initialize(uri) {
+  ws_init(uri, () => {
+    store.dispatch(socket_connected());
+    store.dispatch(filter_subscribe());
+    store.dispatch(filter_subscribe('server'));
+  });
+}
+
+ReactDOM.render(
+  <Provider store={store}>
+    <ConnectedRouter history={history}>
+      <div>
+        <Nav />
+        <div className="container">
+          <Main />
         </div>
-      </ConnectedRouter>
-    </Provider>, root);
-});
+      </div>
+    </ConnectedRouter>
+  </Provider>, root);
 
 navigator.registerProtocolHandler("magnet",
   window.location.origin + "/add-torrent/%s",
diff --git a/src/reducers/index.js b/src/reducers/index.js
index 2fed523..47ce565 100644
--- a/src/reducers/index.js
+++ b/src/reducers/index.js
@@ -1,5 +1,6 @@
 import { combineReducers } from 'redux';
 import { routerReducer } from 'react-router-redux'
+import socket from './socket';
 import selection from './selection';
 import subscribe from './subscribe';
 import filter_subscribe from './filter_subscribe';
@@ -11,6 +12,7 @@ import trackers from './trackers';
 import pieces from './pieces';
 
 const root = combineReducers({
+  socket,
   selection,
   subscribe,
   filter_subscribe,
diff --git a/src/reducers/socket.js b/src/reducers/socket.js
new file mode 100644
index 0000000..2d332fd
--- /dev/null
+++ b/src/reducers/socket.js
@@ -0,0 +1,12 @@
+import { SOCKET_CONNECTED, SOCKET_DISCONNECTED } from '../actions/socket';
+
+export default function socket(state = { connected: false }, action) {
+  switch (action.type) {
+    case SOCKET_CONNECTED:
+      return { ...state, connected: true };
+    case SOCKET_DISCONNECTED:
+      return { ...state, connected: false };
+    default:
+      return state;
+  }
+}
diff --git a/src/socket.js b/src/socket.js
index d355947..5724ce6 100644
--- a/src/socket.js
+++ b/src/socket.js
@@ -35,8 +35,8 @@ function ws_recv(e) {
   handler && handler(msg);
 }
 
-export function ws_init(cb) {
-  ws = new WebSocket("ws://127.0.0.1:8412");
+export function ws_init(uri, cb) {
+  ws = new WebSocket(uri);
   ws.addEventListener("open", cb);
   ws.addEventListener("message", ws_recv);
   ws.addEventListener("close", () => console.log("ws closed"));
diff --git a/src/ui/connection.js b/src/ui/connection.js
index 7d547dc..6373397 100644
--- a/src/ui/connection.js
+++ b/src/ui/connection.js
@@ -1,9 +1,60 @@
 import React, { Component } from 'react';
+import {
+  Card,
+  CardHeader,
+  CardBlock,
+  FormGroup,
+  Label,
+  Input
+} from 'reactstrap';
+import { initialize } from '..';
+
+export default class ConnectionOverlay extends Component {
+  constructor() {
+    super();
+    this.state = {
+      uri: "ws://127.0.0.1:8412",
+      autoconnect: false,
+      connecting: false
+    };
+    // TODO: "connecting..." UI
+    // TODO: autoconnect
+    // TODO: gracefully handle dis/reconnections
+  }
 
-export default class Connection extends Component {
   render() {
+    const { uri, autoconnect } = this.state;
     return (
-      <p>Connecting...</p>
+      <div className="connection-overlay">
+        <Card>
+          <CardHeader>Connect to synapse</CardHeader>
+          <CardBlock>
+            <FormGroup>
+              <Label for="socket-uri">Server URI</Label>
+              <Input
+                id="socket-uri"
+                value={uri}
+                onChange={e => this.setState({ uri: e.target.value })}
+              />
+            </FormGroup>
+            <FormGroup>
+              <Label for="autoconnect" check>
+                <Input
+                  id="autoconnect"
+                  type="checkbox"
+                  checked={autoconnect}
+                  onChange={e => this.setState({ autoconnect: !autoconnect })}
+                  check
+                /> Autoconnect to this server
+              </Label>
+            </FormGroup>
+            <button
+              className="btn btn-primary"
+              onClick={() => initialize(this.state.uri)}
+            >Connect</button>
+          </CardBlock>
+        </Card>
+      </div>
     );
   }
 }
diff --git a/src/ui/main.js b/src/ui/main.js
index dc206f9..66e9fa6 100644
--- a/src/ui/main.js
+++ b/src/ui/main.js
@@ -1,11 +1,13 @@
 import React, { Component } from 'react';
 import { Route, DefaultRoute } from 'react-router';
+import { connect } from 'react-redux';
 import TorrentTable from './torrent_table';
 import AddTorrent from './add_torrent';
 import TorrentDetails from './torrent_details';
 import Server from './server';
+import ConnectionOverlay from './connection';
 
-export default class Main extends Component {
+class Main extends Component {
   render() {
     return (
       <div className="row">
@@ -18,7 +20,10 @@ export default class Main extends Component {
           <Route path="/torrents/:ids" component={TorrentDetails} />
           <Route exact path="/" component={Server} />
         </div>
+        {this.props.socket.connected || <ConnectionOverlay />}
       </div>
     );
   }
 }
+
+export default connect(state => ({ socket: state.socket }))(Main);