aboutsummaryrefslogtreecommitdiffstats
path: root/packages
diff options
context:
space:
mode:
Diffstat (limited to 'packages')
-rw-r--r--packages/0x.js/src/contract_wrappers/contract_wrapper.ts1
-rw-r--r--packages/long-lived-subscriptions-test/Dockerfile10
-rw-r--r--packages/long-lived-subscriptions-test/package.json25
-rw-r--r--packages/long-lived-subscriptions-test/src/index.ts32
-rw-r--r--packages/long-lived-subscriptions-test/tsconfig.json7
-rw-r--r--packages/long-lived-subscriptions-test/tslint.json3
6 files changed, 78 insertions, 0 deletions
diff --git a/packages/0x.js/src/contract_wrappers/contract_wrapper.ts b/packages/0x.js/src/contract_wrappers/contract_wrapper.ts
index 2d5818618..dcd59059f 100644
--- a/packages/0x.js/src/contract_wrappers/contract_wrapper.ts
+++ b/packages/0x.js/src/contract_wrappers/contract_wrapper.ts
@@ -196,6 +196,7 @@ export class ContractWrapper {
}
private async _reconcileBlockAsync(): Promise<void> {
const latestBlock = await this._web3Wrapper.getBlockAsync(BlockParamLiteral.Latest);
+ console.log('latestBlock', latestBlock.number);
// We need to coerce to Block type cause Web3.Block includes types for mempool blocks
if (!_.isUndefined(this._blockAndLogStreamerIfExists)) {
// If we clear the interval while fetching the block - this._blockAndLogStreamer will be undefined
diff --git a/packages/long-lived-subscriptions-test/Dockerfile b/packages/long-lived-subscriptions-test/Dockerfile
new file mode 100644
index 000000000..47d24ec08
--- /dev/null
+++ b/packages/long-lived-subscriptions-test/Dockerfile
@@ -0,0 +1,10 @@
+FROM node
+
+WORKDIR /src
+
+COPY package.json .
+RUN yarn install
+
+COPY . .
+
+CMD ["./lib/index.js"]
diff --git a/packages/long-lived-subscriptions-test/package.json b/packages/long-lived-subscriptions-test/package.json
new file mode 100644
index 000000000..ec45d631a
--- /dev/null
+++ b/packages/long-lived-subscriptions-test/package.json
@@ -0,0 +1,25 @@
+{
+ "name": "long-lived-subscriptions-test",
+ "version": "0.0.1",
+ "description": "",
+ "scripts": {
+ "build:watch": "tsc -w",
+ "build": "tsc",
+ "start": "node lib/index.js",
+ "clean": "shx rm -rf lib",
+ "lint": "tslint --project . 'src/**/*.ts'"
+ },
+ "dependencies": {
+ "0x.js": "^0.31.1",
+ "lodash": "^4.17.4",
+ "web3": "^0.20.0"
+ },
+ "devDependencies": {
+ "@0xproject/tslint-config": "^0.4.6",
+ "@types/lodash": "^4.14.86",
+ "shx": "^0.2.2",
+ "tslint": "5.8.0",
+ "typescript": "2.7.1",
+ "web3-typescript-typings": "^0.9.8"
+ }
+}
diff --git a/packages/long-lived-subscriptions-test/src/index.ts b/packages/long-lived-subscriptions-test/src/index.ts
new file mode 100644
index 000000000..2d79dcc89
--- /dev/null
+++ b/packages/long-lived-subscriptions-test/src/index.ts
@@ -0,0 +1,32 @@
+import { DecodedLogEvent, ExchangeEvents, LogFillContractEventArgs, ZeroEx } from '0x.js';
+import * as _ from 'lodash';
+import * as Web3 from 'web3';
+
+const zeroExConfig = {
+ networkId: 1,
+};
+
+const RPC_URL = 'https://mainnet.infura.io/T5WSC8cautR4KXyYgsRs';
+// const RPC_URL = 'https://mainnet.0xproject.com';
+
+const web3 = new Web3(new Web3.providers.HttpProvider(RPC_URL));
+const zeroEx = new ZeroEx(web3.currentProvider, zeroExConfig);
+
+const subscribe = () => {
+ console.log('subscribing...');
+ zeroEx.exchange.subscribe<LogFillContractEventArgs>(
+ ExchangeEvents.LogFill,
+ {},
+ (err: Error | null, event?: DecodedLogEvent<LogFillContractEventArgs>) => {
+ if (_.isNull(err)) {
+ console.log('EVENT');
+ console.log(event);
+ } else {
+ console.log('ERROR');
+ console.log(err);
+ subscribe();
+ }
+ },
+ );
+};
+subscribe();
diff --git a/packages/long-lived-subscriptions-test/tsconfig.json b/packages/long-lived-subscriptions-test/tsconfig.json
new file mode 100644
index 000000000..3d967d05f
--- /dev/null
+++ b/packages/long-lived-subscriptions-test/tsconfig.json
@@ -0,0 +1,7 @@
+{
+ "extends": "../../tsconfig",
+ "compilerOptions": {
+ "outDir": "lib"
+ },
+ "include": ["./src/**/*", "../../node_modules/web3-typescript-typings/index.d.ts"]
+}
diff --git a/packages/long-lived-subscriptions-test/tslint.json b/packages/long-lived-subscriptions-test/tslint.json
new file mode 100644
index 000000000..ffaefe83a
--- /dev/null
+++ b/packages/long-lived-subscriptions-test/tslint.json
@@ -0,0 +1,3 @@
+{
+ "extends": ["@0xproject/tslint-config"]
+}