|
499 | 499 | function getUsers(table, doneCallback) { |
500 | 500 | tableau.reportProgress("Retrieving users"); |
501 | 501 | foreachConnectionSync(function (connection, done) { |
502 | | - tableau.reportProgress("Retrieving users:" + connection.username); |
| 502 | + tableau.reportProgress("Retrieving users:" + connection.apiEndpoint); |
503 | 503 | var u = userNameForConnection(connection); |
504 | 504 | table.appendRows([{ id: u, username: u }]); |
505 | 505 | done(); |
|
538 | 538 | const events = []; |
539 | 539 | tableau.reportProgress("Retrieving events"); |
540 | 540 | foreachConnectionSync(function (connection, done) { |
541 | | - tableau.reportProgress("Retrieving events for " + connection.username); |
| 541 | + tableau.reportProgress("Retrieving events for " + connection.apiEndpoint); |
542 | 542 | var username = userNameForConnection(connection); |
| 543 | + let count = 0; |
543 | 544 | connection.getEventsStreamed(pryvFilter, function forEachEvent(event) { |
544 | 545 | if (postFilter(event)) { |
| 546 | + tableau.reportProgress("Retrieving events for " + connection.apiEndpoint + ": " + count); |
| 547 | + count++; |
545 | 548 | events.push(event); |
546 | 549 | } |
547 | 550 | }).then(function(res) { |
|
556 | 559 | // Retrieves Streams from Pryv |
557 | 560 | function getStreams(table, doneCallback) { |
558 | 561 | foreachConnectionSync(function (connection, done) { |
559 | | - tableau.reportProgress("Retrieving streams for " + connection.username); |
| 562 | + tableau.reportProgress("Retrieving streams for " + connection.apiEndpoint); |
560 | 563 | var username = userNameForConnection(connection); |
561 | 564 | var apiCalls = [{method: 'streams.get', params: {}}]; |
562 | 565 | connection.api(apiCalls).then(function (res) { |
|
0 commit comments