Merge pull request #1 from Simponic/network

Network

1 files changed, 37 insertions, 0 deletions

diff --git a/engine/network/index.ts b/engine/network/index.ts
new file mode 100644
index 0000000..5dc7ece
--- /dev/null
+++ b/engine/network/index.ts
@@ -0,0 +1,37 @@
+export enum MessageType {
+  NEW_ENTITIES = 'NEW_ENTITIES',
+  REMOVE_ENTITIES = 'REMOVE_ENTITIES',
+  UPDATE_ENTITIES = 'UPDATE_ENTITIES',
+  NEW_INPUT = 'NEW_INPUT',
+  REMOVE_INPUT = 'REMOVE_INPUT'
+}
+
+export type EntityAddBody = {
+  entityName: string;
+  id: string;
+  args: Record<string, any>;
+};
+
+export type EntityUpdateBody = {
+  id: string;
+  args: Record<string, any>;
+};
+
+export type Message = {
+  type: MessageType;
+  body: any;
+};
+
+export interface MessageQueueProvider {
+  getNewMessages(): Message[];
+  clearMessages(): void;
+}
+
+export interface MessagePublisher {
+  addMessage(message: Message): void;
+  publish(): void;
+}
+
+export interface MessageProcessor {
+  process(message: Message): void;
+}