From 2e930b98726a09e597106d43a6763dd36d038771 Mon Sep 17 00:00:00 2001 From: yipstanley Date: Sun, 10 Feb 2019 22:09:48 -0500 Subject: adsklfa --- src/Server.tsx | 14 ++++++++++++++ src/server/Client.ts | 15 +++++++++++++++ src/server/Message.ts | 27 +++++++++++++++++++++++++++ src/server/server.ts | 31 +++++++++++++++++++++++++++++++ 4 files changed, 87 insertions(+) create mode 100644 src/server/Client.ts create mode 100644 src/server/Message.ts create mode 100644 src/server/server.ts (limited to 'src') diff --git a/src/Server.tsx b/src/Server.tsx index 04473424a..729dfa873 100644 --- a/src/Server.tsx +++ b/src/Server.tsx @@ -2,10 +2,16 @@ import { Field, FieldWaiting, FIELD_ID, DOC_ID, FIELD_WAITING } from "./fields/F import { Key, KeyStore } from "./fields/Key" import { ObservableMap, computed, action, observable } from "mobx"; import { Document } from "./fields/Document" +import * as OpenSocket from 'socket.io-client'; +import { Utils } from "./Utils"; +import { MessageStore } from "./server/Message"; export class Server { static FieldStore: ObservableMap = new ObservableMap(); static DocumentStore: ObservableMap> = new ObservableMap(); + static Socket: SocketIOClient.Socket = OpenSocket("http://localhost:8080") + static GUID: string = Utils.GenerateGuid() + public static ClientFieldsCached: ObservableMap = new ObservableMap(); // 'hack' is here temoporarily for simplicity when debugging things. @@ -86,6 +92,12 @@ export class Server { } } + @action + static connected(message: string) { + console.log(message) + Server.Socket.emit("id", Server.GUID) + } + @action static receivedDocument(docid: DOC_ID, fieldlist: ObservableMap) { var cachedDoc = this.cacheField(new Document(docid)); @@ -104,3 +116,5 @@ export class Server { doc.fields.set(key, cachedField); } } + +Server.Socket.on(MessageStore.Handshake.Message, Server.connected); \ No newline at end of file diff --git a/src/server/Client.ts b/src/server/Client.ts new file mode 100644 index 000000000..6b8841658 --- /dev/null +++ b/src/server/Client.ts @@ -0,0 +1,15 @@ +import { computed } from "mobx"; + +export class Client { + constructor(guid: string) { + this.guid = guid + } + + private guid: string; + + @computed + public get GUID(): string { + return this.guid + } + +} \ No newline at end of file diff --git a/src/server/Message.ts b/src/server/Message.ts new file mode 100644 index 000000000..d5b9b4612 --- /dev/null +++ b/src/server/Message.ts @@ -0,0 +1,27 @@ +import { Utils } from "../Utils"; + +export class Message { + private name: string; + private guid: string; + + get Name(): string { + return this.name; + } + + get Message(): string { + return this.guid + } + + constructor(name: string) { + this.name = name; + this.guid = Utils.GenerateDeterministicGuid(name) + } + + GetValue() { + return this.Name; + } +} + +export namespace MessageStore { + export const Handshake = new Message("Handshake"); +} \ No newline at end of file diff --git a/src/server/server.ts b/src/server/server.ts new file mode 100644 index 000000000..db58ed662 --- /dev/null +++ b/src/server/server.ts @@ -0,0 +1,31 @@ +import { MessageStore } from "./Message"; + +// const express = require("express") +// const path = require("path") + +// const app = express(); +// app.set("port", process.env.PORT || 3000); + +// var http = require('http').Server(app); + +// app.get('/', function (req: any, res: any) { +// res.sendFile(path.resolve("./deploy/index.html")) +// }) + +// const server = http.listen(3000, function () { +// console.log("Listening on *:3000") +// }) + +const server = require("socket.io")(); +var clients = []; + +server.on("connection", function (socket: any) { + console.log("a user has connected") + + socket.emit(MessageStore.Handshake.Message, "handshake received") + + clients.push(socket) +}) + +server.listen(8080); +console.log("listening on port 8080") \ No newline at end of file -- cgit v1.2.3-70-g09d2