Update OS domain

app/config/index.js

@@ -3,8 +3,8 @@
 var path = require('path');
 var nconf = require('nconf');
 
-var DEFAULT_HOST = 'https://openspending.org';
-var DEFAULT_BASE_PATH = '';
+const DEFAULT_HOST = 'https://openspending.org';
+const DEFAULT_BASE_PATH = '';
 
 nconf.file({
   file: path.join(__dirname, '/../../settings.json')

app/front/scripts/controllers/download-package.js

@@ -1,11 +1,13 @@
 'use strict';
+var osAdminService = require('../services/admin');
 
 angular.module('Application')
   .controller('DownloadPackageController', [
     '$scope', 'PackageService', 'DownloadPackageService',
-    'Configuration', 'ApplicationLoader', 'LoginService',
+    'Configuration', 'ApplicationLoader', 'LoginService', '$interval', '$http', '$window',
     function($scope, PackageService, DownloadPackageService,
-      Configuration, ApplicationLoader, LoginService) {
+      Configuration, ApplicationLoader, LoginService, $interval, $http, $window) {
+
       ApplicationLoader.then(function() {
         $scope.fileName = Configuration.defaultPackageFileName;
         $scope.attributes = PackageService.getAttributes();
@@ -16,6 +18,85 @@ angular.module('Application')
         $scope.login = LoginService;
         $scope.publishDataPackage = DownloadPackageService.publishDataPackage;
         $scope.state = DownloadPackageService.getState(true);
+        $scope.packageOBEUStatus = null;
+        $scope.obeuUrl = 'http://apps.openbudgets.eu'
       });
+
+
+      $scope.publishAndRunWebHooks = function () {
+        $scope.publishDataPackage().finally(function (res) {
+          runWebHooks($scope.fiscalDataPackage.name);
+        });
+      };
+
+
+      $scope.redirectToViewer = function() {
+        console.log('querying');
+        var url = $scope.obeuUrl + '/search/package?q=' + encodeURIComponent($scope.fiscalDataPackage.name) + '&size=1';
+        $http.get(url, {withCredentials: false}).then(
+          function (res) {
+            console.log('good');
+            var packageId = '';
+            if (res.length > 0) {
+              packageId = res[0].name;
+            }
+            $window.open($scope.obeuUrl + '/' + packageId, '_blank');
+        },
+          function (err) {
+            console.log(err);
+            $window.open($scope.obeuUrl, '_blank');
+          }
+        )
+      };
+
+
+      function runWebHooks(packageId) {
+        $scope.packageOBEUStatus = 'processing';
+        // query data packages to extract the user's "owner id"
+        osAdminService.getDataPackages(LoginService.authToken, LoginService.userId).then(function (packages) {
+          console.log(packages);
+          var ownerId = packages[0].owner;
+          var dataPackageId = ownerId + ":" + packageId;
+
+          // set the data package status to "published" (a.k.a. public)
+          osAdminService.togglePackagePublicationStatus(LoginService.permissionToken, {id: dataPackageId}).then(
+            function (res) {
+              // run web hooks for the package
+              var dataPackage = _.find(packages, {id: dataPackageId});
+
+              if (dataPackage) {
+                var token = LoginService.permissionToken;
+                osAdminService.runWebHooks(token, dataPackage).then(function(res) {
+                  var iri = JSON.parse(res.response).iri;
+                  var executionId = iri.substr(1 + iri.lastIndexOf('/'), iri.length);
+                  var executionOverviewUrl =
+                    'http://apps.openbudgets.eu/linkedpipes/test/resources/executions/' + executionId + '/overview';
+                  pollPipelineUntilReady(executionOverviewUrl);
+                });
+              }
+            }
+          );
+        },
+        function (err) {
+          console.log(err);
+        });
+      };
+
+      function pollPipelineUntilReady(executionOverviewUrl) {
+        stop = $interval(function () {
+          $http.get('https://crossorigin.me/' + executionOverviewUrl, {withCredentials: false}).then(
+            function (res) {
+              console.log(res);
+              if (res.data.status['@id'].includes('finished')) {
+                $interval.cancel(stop);
+                $scope.packageOBEUStatus = 'ready';
+              }
+            },
+            function (err) {
+              console.log(err);
+            }
+          );
+        }, 3000);
+      }
     }
   ]);