Merge pull request Azure#88 from amarzavery/sendpart

Moving to amqp-common and updated structure of rhea-promise

.gitignore

@@ -33,6 +33,10 @@ node_modules
 # WebStorm
 .idea
 
+# coverage #
+.nyc_output
+coverage
+
 # Mac OS #
 .DS_Store
 .DS_Store?
@@ -51,4 +55,5 @@ typings/
 dist/
 output/
 client/examples/js/lib/
-processor/examples/js/lib/
+processor/examples/js/lib/
+typedoc

.travis.yml

@@ -2,6 +2,7 @@ language: node_js
 
 node_js:
   - "8"
+  - "10"
 
 before_install:
   - cd client

.vscode/launch.json

@@ -8,7 +8,7 @@
             "type": "node",
             "request": "launch",
             "name": "EPH Tests",
-            "program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
+            "program": "${workspaceFolder}/processor/node_modules/mocha/bin/_mocha",
             "args": [
                 "-u",
                 "tdd",
@@ -26,7 +26,7 @@
             "type": "node",
             "request": "launch",
             "name": "Client Tests",
-            "program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
+            "program": "${workspaceFolder}/client/node_modules/mocha/bin/_mocha",
             "args": [
                 "-u",
                 "tdd",
@@ -44,9 +44,9 @@
             "type": "node",
             "request": "launch",
             "name": "Client Example",
-            "program": "${workspaceFolder}/client/examples/simpleSendReceive.ts",
+            "program": "${workspaceFolder}/client/examples/simpleSender.ts",
             "outFiles": [
-                "${workspaceFolder}/dist/**/*.js"
+                "${workspaceFolder}/client/dist/**/*.js"
             ],
             "envFile": "${workspaceFolder}/client/.env" // You can take a look at the sample.env file for supported environment variables.
         },
@@ -56,7 +56,7 @@
             "name": "EPH Example",
             "program": "${workspaceFolder}/processor/examples/eph.ts",
             "outFiles": [
-                "${workspaceFolder}/dist/**/*.js"
+                "${workspaceFolder}/processor/dist/**/*.js"
             ],
             "envFile": "${workspaceFolder}/processor/.env" // You can take a look at the sample.env file for supported environment variables.
         },

client/.npmignore

@@ -41,3 +41,7 @@ webpack.config.ts
 .idea/
 changelog.md
 samples/
+typings/examples/
+dist/examples/
+docs/
+typedoc/

client/examples/batchReceive.ts

@@ -1,4 +1,4 @@
-import { EventHubClient, EventData } from "azure-event-hubs";
+import { EventHubClient, EventData } from "../lib";
 import * as dotenv from "dotenv";
 dotenv.config();
 

client/examples/batchSendReceive.ts

@@ -1,4 +1,4 @@
-import { EventHubClient, EventData, EventPosition, OnMessage, OnError, EventHubsError } from "azure-event-hubs";
+import { EventHubClient, EventData, EventPosition, OnMessage, OnError, MessagingError } from "../lib";
 import * as dotenv from "dotenv";
 dotenv.config();
 
@@ -21,7 +21,7 @@ async function main(): Promise<void> {
       client.close();
     }
   }
-  const onError: OnError = (err: EventHubsError | Error) => {
+  const onError: OnError = (err: MessagingError | Error) => {
     console.log(">>>>> Error occurred: ", err);
   };
   client.receive("0", onMessage, onError, { eventPosition: EventPosition.fromEnqueuedTime(Date.now()) });

client/examples/createEpochReceiver.ts

@@ -1,4 +1,4 @@
-import { EventHubClient, OnError, EventHubsError, OnMessage, delay } from "azure-event-hubs";
+import { EventHubClient, OnError, MessagingError, OnMessage, delay } from "../lib";
 import * as dotenv from "dotenv";
 dotenv.config();
 
@@ -16,7 +16,7 @@ async function main(): Promise<void> {
     console.log(">>> EventDataObject: ", eventData);
     console.log("### Actual message:", eventData.body ? eventData.body.toString() : null);
   }
-  const onError: OnError = (err: EventHubsError | Error) => {
+  const onError: OnError = (err: MessagingError | Error) => {
     console.log("@@@@ receiver with epoch 2.");
     console.log(">>>>> Error occurred for receiver with epoch 2: ", err);
   };
@@ -29,7 +29,7 @@ async function main(): Promise<void> {
     console.log(">>> EventDataObject: ", eventData);
     console.log("### Actual message:", eventData.body ? eventData.body.toString() : null);
   }
-  const onError2: OnError = (err: EventHubsError | Error) => {
+  const onError2: OnError = (err: MessagingError | Error) => {
     console.log("@@@@ receiver with epoch 1.");
     console.log(">>>>> Error occurred for receiver with epoch 1: ", err);
   };

client/examples/getHubRuntimeInfo.ts

@@ -1,4 +1,4 @@
-import { EventHubClient } from "azure-event-hubs";
+import { EventHubClient } from "../lib";
 import * as dotenv from "dotenv";
 dotenv.config();
 

client/examples/iotGetHubRuntimeInfo.ts

@@ -1,4 +1,4 @@
-import { EventHubClient } from "azure-event-hubs";
+import { EventHubClient } from "../lib";
 import * as dotenv from "dotenv";
 dotenv.config();