@h2non, I'm still struggling to get this to work. I've added a service named my-service.

curl -X PUT -d '{"Datacenter": "vagrant-cloud", "Node": "my-node.example.com", "Address": "127.0.0.1", "Servi {"Service": "my-service", "Address": "127.0.0.1", "Port": 49000}}' http://127.0.0.1:8500/v1/catalog/register

When requesting it via CURL from Consul, I get:

[
  {
    "Node": "my-node.example.com",
    "Address": "127.0.0.1",
    "ServiceID": "my-service",
    "ServiceName": "my-service",
    "ServiceTags": [

    ],
    "ServiceAddress": "127.0.0.1",
    "ServicePort": 49000,
    "ServiceEnableTagOverride": false,
    "CreateIndex": 216,
    "ModifyIndex": 216
  }
]

However, when I run the following:

var resilient = require('resilient');
var consul = require('resilient-consul');
var client = resilient();

client.use(consul({
  service: 'my-service',
  discoveryService: 'consul',
  datacenter: 'vagrant-cloud',
  enableSelfRefresh: true,
  servers: [
    'http://127.0.0.1:8500'
  ],
  onlyHealthy: false
}));

client.get('/', function (err, res) {
  console.log('Error:', err);
  console.log('Response:', res);
});

I get the error Cannot resolve servers. Missing data. I've debugged it for a while, and I see that when calling hasValidServiceServers, the function resilient.servers() is returning { servers: [], updated: 1453764937643 }. However, I can see handleResolution being called for URL http://172.0.0.1:8500/v1/catalog/service/my-service?_time=1453765689463&dc=vagrant-cloud returning the service I added.

I've also tried adding a service to demo.consul.io, but I'm not allowed. Running the example (against demo.consul.io) from the README file throws Discovery server response is invalid or empty.

Any ideas?

My application crashes from time to time due to mapServersFromHealthEndpoint receiving a list of URLs for the service such as ['http://my-host-one:3000', 'http://my-host-two:3000'], whereas it should receive an array of service definition objects such as:

{
  "Node": {
    "Node": "my-host-one",
    "Address": "xx.xx.xx.xx",
    "CreateIndex": 65,
    "ModifyIndex": 120501
  },
  "Service": {
    "ID": "my-host-one:my-service:3000",
    "Service": "my-service",
    "Tags": null,
    "Address": "ip-172-31-24-131",
    "Port": 3000,
    "EnableTagOverride": false,
    "CreateIndex": 27226,
    "ModifyIndex": 27228
  },
  "Checks": []
}

The error is that s.Service in https://github.com/h2non/resilient-consul/blob/master/consul.js#L86 is obviously undefined. mapServersFromCatalogEndpoint is filtering these, which I didn't understand the first time I saw it, but I believe we shouldn't need to filter anything in these functions, but address the root cause.

The issue may be in resilient.js to be honest, but I don't have enough knowledge of it yet to have a clearer idea. Any suggestions?

Hi,
I am running consul in my local environment (http port : 8500).
When the middleware is querying the consul catalog service , following calls are made

1. Consul catalog service (http://localhost:8500/v1/catalog/service/consul)
2. Catalog service for the registered micro service. (http://172.31.50.81:8300/v1/catalog/service/account-service).
   Please take a note, in the second call port is changed to 8300 grpc server port.
   It should have been 8500.

Please suggest.

Hello, I'm trying to use https://github.com/resilient-http/resilient.js with Consul using this middleware, but I'm getting the error depicted in the title when following the example shown in the README file.

I've basically registered a service in Consul using CURL:
curl -X PUT -d '{"Node": "my-node", "Address": "127.0.0.1", "Service": {"Service": "my-service", "Port": 49000}}' http://127.0.0.1:8500/v1/catalog/register

The above is an HTTP server that will respond with 200 Ok when requesting /. Below is the code I'm using with resilient.js:

var resilient = require('resilient');
var consul = require('resilient-consul');
var client = resilient();

client.use(consul({
  service: 'my-service',
  // discoveryService: '..', // I've tried consul, my-node, my-service - made no difference
  enableSelfRefresh: true,
  servers: [
    '127.0.0.1:8500'
  ],
  onlyHealthy: false
}));

client.get('/', function (err, res) {
  console.log('Error:', err);
  console.log('Response:', res);
});

And here's the output I get:

Error: { [Error: Cannot update discovery servers. Empty or invalid response body]
  error: 
   { [Error: Missing discovery servers. Cannot resolve the server]
     status: 1002,
     message: 'Missing discovery servers. Cannot resolve the server' },
  status: 1001,
  message: 'Cannot update discovery servers. Empty or invalid response body' }
Response: undefined

What am I doing wrong? Thanks in advance!