Feature/auth 75 master

.gitignore

@@ -1,2 +1,2 @@
 node_modules
-js
+.idea

js/config.d.ts

@@ -0,0 +1,3 @@
+export declare const config: {
+    requestValidityPeriod: number;
+};

js/index.d.ts

@@ -0,0 +1,13 @@
+import { RedisClient } from 'redis';
+import { EpicurusRedisConfig, serverCallback, subscribeCallback } from './interface';
+export default function Epicurus(redisConfig?: EpicurusRedisConfig, requestTimeout?: number): EpicurusPublicInterface;
+export declare type EpicurusPublicInterface = {
+    getRedisClient: () => RedisClient;
+    getRedisSubClient: () => RedisClient;
+    subscribe: <T = any>(channel: string, callback: subscribeCallback<T>) => Promise<void>;
+    publish: (channel: string, body: any) => void;
+    server: <T = any, S = any>(channel: string, callback: serverCallback<T, S>) => Promise<void>;
+    request: <T = any>(channel: string, body: any) => Promise<T>;
+    shutdown: () => void;
+    close: () => void;
+};

js/integration/client.d.ts

@@ -0,0 +1 @@
+export {};

js/integration/server.d.ts

@@ -0,0 +1 @@
+export {};

js/interface.d.ts

@@ -0,0 +1,22 @@
+export declare type serverCallback<T, S> = (body: T & {
+    channel: string;
+}, responseCallback: (error: any, response?: S) => any) => any;
+export declare type subscribeCallback<T> = (body: T & {
+    channel: string;
+}) => any;
+export interface EpicurusPubSubCallbackReference {
+    [channel: string]: Function[];
+}
+export interface EpicurusRequest {
+    reqId: string;
+    body: any;
+    ttl: number;
+}
+export interface EpicurusResponse {
+    error?: any;
+    result?: any;
+}
+export interface EpicurusRedisConfig {
+    host: string;
+    port: number;
+}

js/lib/error.d.ts

@@ -0,0 +1,17 @@
+export declare class EpicurusError extends Error {
+    id: number;
+    context: {};
+    status: {};
+    severity: number;
+    constructor(message: string, meta: {
+        context?: {};
+        args?: any;
+        requestReference?: any;
+        severity: number;
+        status?: number;
+        id?: number;
+        stack?: string;
+        name?: string;
+    });
+    toString(): string;
+}

js/lib/pub_sub/index.d.ts

@@ -0,0 +1,6 @@
+import { subscribeCallback } from '../../interface';
+export declare function subscribe<T>(subClient: any, channel: string, callback: subscribeCallback<T>): Promise<void>;
+export declare function publish(redisClient: any, channel: string, body: any): void;
+export declare function setupSubscriptionListener(subClient: any): void;
+export declare function shutdownSubscribers(): void;
+export declare function removeCallbacks(): void;

js/lib/request_response/index.d.ts

@@ -0,0 +1,6 @@
+import { serverCallback } from '../../interface';
+export declare function request<T>(redisClient: any, channel: string, body: any, requestValidityPeriod: number): Promise<T>;
+export declare function server<T, S>(redisClient: any, channel: string, callback: serverCallback<T, S>, serverValidityPeriod: number): Promise<void>;
+export declare function disableServers(): void;
+export declare function enableServers(): void;
+export declare function closeAllClients(): void;