From 1927b04d7a3ac3b8558ec2b2b54f6f4115d8e251 Mon Sep 17 00:00:00 2001 From: argirok Date: Wed, 18 May 2022 12:40:31 +0300 Subject: [PATCH] update data transfer service - add selection for dois and destination Storages --- src/app/utils/transferData.component.ts | 118 +++++++++++++----------- src/app/utils/transferData.module.ts | 2 +- 2 files changed, 64 insertions(+), 56 deletions(-) diff --git a/src/app/utils/transferData.component.ts b/src/app/utils/transferData.component.ts index 6a21c7e..a9f4ae9 100644 --- a/src/app/utils/transferData.component.ts +++ b/src/app/utils/transferData.component.ts @@ -1,11 +1,10 @@ import {Component, Input} from '@angular/core'; import {Subscriber} from "rxjs"; -import {HttpClient} from "@angular/common/http"; +import {HttpClient, HttpHeaders} from "@angular/common/http"; import {Validators} from "@angular/forms"; import {Location} from '@angular/common'; import {StringUtils} from "../openaireLibrary/utils/string-utils.class"; -import {COOKIE, Session} from "../openaireLibrary/login/utils/helper.class"; -import {UserManagementService} from "../openaireLibrary/services/user-management.service"; +import {COOKIE} from "../openaireLibrary/login/utils/helper.class"; import {Router} from "@angular/router"; declare var UIkit; @@ -13,7 +12,7 @@ declare var UIkit; selector: 'egi-transfer-data', template: ` @@ -24,12 +23,12 @@ declare var UIkit;
-
+
-

Title

+

EOSC data transfer service

Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut @@ -37,14 +36,13 @@ declare var UIkit; laboris nisi ut aliquip ex ea commodo consequat.
-
-

Title

+

EOSC data transfer service

Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut @@ -54,18 +52,27 @@ declare var UIkit;

Lorem ipsum ....

-
- +
+
+
Files to be transfered:
+
    + +
  • {{ element.filename}} +
    • +
+

Lorem ipsum ....

+
-
+
@@ -102,31 +109,36 @@ export class EGIDataTransferComponent { accessToken = null; @Input() dois; loginURL = "http://rudie.di.uoa.gr:8580/openid_connect_login" - sourceUrl = null; + sourceUrls = [] + selectedSourceUrl = null; destinationPath = ""; - destinationURL = "https://egi.storage.eu"; + destinationOptions = [{label: "EGI storage", value: { url: "https://egi.storage.eu", id: "egi" } }]; + selectedDestination = null; + downloadElements = null; @Input() isOpen = false; APIURL = "https://virtserver.swaggerhub.com/thebe14/eosc-future-data-transfer/1.0.0"; status: "loading" | "success" | "errorParser" | "errorUser" | "errorTransfer" | "init" = "init"; message; validators = [Validators.required, StringUtils.urlValidator()]; - constructor(private http: HttpClient, private location: Location, private userManagementsService: UserManagementService, private _router: Router) { + constructor(private http: HttpClient, private location: Location, private _router: Router) { } ngOnInit() { - console.log(COOKIE.getCookie("EGISession")) - this.accessToken = COOKIE.getCookie("EGISession"); + console.log(COOKIE.getCookie("EGIAccessToken")) + this.accessToken = COOKIE.getCookie("EGIAccessToken"); for(let doi of this.dois){ console.log(doi) if(doi.indexOf("zenodo.")!=-1){ - this.sourceUrl = "https://doi.org/" + doi; - break; + this.sourceUrls.push("https://doi.org/" + doi); } } + this.selectedSourceUrl = this.sourceUrls[0]; + this.selectedDestination = this.destinationOptions[0].value; + this.parse(); } ngOnDestroy() { @@ -142,8 +154,10 @@ export class EGIDataTransferComponent { } close(){ this.isOpen = false; - this.downloadElements = null; + // this.downloadElements = []; this.destinationPath = ""; + this.selectedDestination = this.destinationOptions[0].value; + this.selectedSourceUrl = this.sourceUrls[0]; this.message = null; this.status = "init"; if(this._router.url.indexOf("&egiTransfer")){ @@ -152,23 +166,12 @@ export class EGIDataTransferComponent { } checkin(){ - // this.loggedIn = true; - - console.log(COOKIE.getCookie("EGISession")) - // this.accessToken = COOKIE.getCookie("EGISession"); - COOKIE.setCookie("EGISession", "test!!!!!!",10,"/" ); - this.userManagementsService.setRedirectUrl(this._router.url+"&egiTransfer=t"); - // this.location.go("/reload"); - window.location.href = "/reload"; - // window.location.href = this.loginURL; + window.location.href = this.loginURL+"?redirect="+ encodeURIComponent("http://scoobydoo.di.uoa.gr:4400"+this._router.url+"&egiTransfer=t"); } parse(){ - this.status = "loading"; - this.subscriptions.push(this.http.get(this.APIURL + "/user/info").subscribe( - res => { - console.log(res) - this.subscriptions.push(this.http.get(this.APIURL + "/parser/zenodo?source=" + this.sourceUrl ).subscribe( + + this.subscriptions.push(this.http.get(this.APIURL + "/parser/zenodo?source=" + this.selectedSourceUrl ).subscribe( res => { console.log(res) this.downloadElements = []; @@ -182,7 +185,7 @@ export class EGIDataTransferComponent { } console.log(this.downloadElements) - this.transfer(); + // this.transfer(); }, error => { this.status = "errorParser"; @@ -195,21 +198,16 @@ export class EGIDataTransferComponent { } )); - }, error => { - this.status = "errorUser"; - this.message = "User can't be authenticated!"; - UIkit.notification("User can't be authenticated!", { - status: 'error', - timeout: 6000, - pos: 'bottom-right' - }); - } - )); } transfer() { - + console.log(this.selectedDestination) + this.status = "loading"; + let headers = new HttpHeaders({'Authorization': 'Bearer '+this.accessToken}); + this.subscriptions.push(this.http.get(this.APIURL + "/user/info", {headers: headers}).subscribe( + res => { + console.log(res) let body = { "files": [], "params": { @@ -218,6 +216,7 @@ export class EGIDataTransferComponent { "retry": 3 } }; + console.log(this.selectedDestination) for (let element of this.downloadElements) { let file = { @@ -228,7 +227,7 @@ export class EGIDataTransferComponent { ], "destinations": [ { - "url": this.destinationURL + this.destinationPath + element.filename + "url": this.selectedDestination.url + this.destinationPath + element.filename } ], "filesize": element['size'] @@ -237,9 +236,8 @@ export class EGIDataTransferComponent { body.files.push(file); } - - - this.subscriptions.push(this.http.post(this.APIURL + "/transfer" ,body ).subscribe( + let headers = new HttpHeaders({'Authorization': 'Bearer '+this.accessToken}); + this.subscriptions.push(this.http.post(this.APIURL + "/transfer" ,body, {headers: headers}).subscribe( res => { console.log(res) UIkit.notification('Data transfer has began! ', { @@ -251,8 +249,8 @@ export class EGIDataTransferComponent { this.status = "success" this.message = `
Data transfer has began!
-
Transfering ` + this.downloadElements.length + ` files to EGI Storage: -
    +
    Transfering ` + this.downloadElements.length + ` files to EGI Storage: +
      `; // TODO LATER we can call status for each file and see if the transfer has been complete for(let element of this.downloadElements){ @@ -275,7 +273,17 @@ export class EGIDataTransferComponent { } )); + }, error => { + this.status = "errorUser"; + this.message = "User can't be authenticated!"; + UIkit.notification("User can't be authenticated!", { + status: 'error', + timeout: 6000, + pos: 'bottom-right' + }); + } + )); } private parseFilename(url){ let filename = url.split("/")[url.split("/").length - 1]; diff --git a/src/app/utils/transferData.module.ts b/src/app/utils/transferData.module.ts index 621ebf6..8bc4286 100644 --- a/src/app/utils/transferData.module.ts +++ b/src/app/utils/transferData.module.ts @@ -6,7 +6,7 @@ import {InputModule} from "../openaireLibrary/sharedComponents/input/input.modul @NgModule({ imports: [ - CommonModule, FormsModule, InputModule, + CommonModule, FormsModule, InputModule ], declarations: [