Merge pull request #163 from ConductionNL/feature/CONNECTOR-172/expor…

…t-of-json-files

feature/CONNECTOR-172/export-of-json-files

README.md

@@ -1,4 +1,3 @@
 # OpenConector
 
 Provides gateway and service bus functionality like mapping, translation and synchronisation of data
-

src/store/modules/consumer.js

@@ -1,4 +1,3 @@
-/* eslint-disable no-console */
 import { defineStore } from 'pinia'
 import { Consumer } from '../../entities/index.js'
 import { MissingParameterError, ValidationError } from '../../services/errors/index.js'
@@ -11,13 +10,13 @@ export const useConsumerStore = defineStore('consumer', {
 	actions: {
 		setConsumerItem(consumerItem) {
 			this.consumerItem = consumerItem && new Consumer(consumerItem)
-			console.log('Active consumer item set to ' + consumerItem)
+			console.info('Active consumer item set to ' + consumerItem)
 		},
 		setConsumerList(consumerList) {
 			this.consumerList = consumerList.map(
 				(consumerItem) => new Consumer(consumerItem),
 			)
-			console.log('Consumer list set to ' + consumerList.length + ' items')
+			console.info('Consumer list set to ' + consumerList.length + ' items')
 		},
 		/* istanbul ignore next */ // ignore this for Jest until moved into a service
 		async refreshConsumerList(search = null) {
@@ -59,7 +58,7 @@ export const useConsumerStore = defineStore('consumer', {
 				throw new MissingParameterError('consumerItem')
 			}
 
-			console.log('Deleting consumer...')
+			console.info('Deleting consumer...')
 
 			const endpoint = `/index.php/apps/openconnector/api/consumers/${this.consumerItem.id}`
 
@@ -90,11 +89,11 @@ export const useConsumerStore = defineStore('consumer', {
 			const validationResult = consumerItem.validate()
 			if (!validationResult.success) {
 				console.error(validationResult.error)
-				console.log(consumerItem)
+				console.info(consumerItem)
 				throw new ValidationError(validationResult.error)
 			}
 
-			console.log('Saving consumer...')
+			console.info('Saving consumer...')
 
 			const isNewConsumer = !consumerItem.id
 			const endpoint = isNewConsumer

src/store/modules/consumer.spec.js

@@ -1,4 +1,3 @@
-/* eslint-disable no-console */
 import { setActivePinia, createPinia } from 'pinia'
 
 import { useConsumerStore } from './consumer.js'

src/store/modules/endpoints.js

@@ -1,7 +1,7 @@
-/* eslint-disable no-console */
 import { defineStore } from 'pinia'
 import { Endpoint } from '../../entities/index.js'
 import { MissingParameterError, ValidationError } from '../../services/errors/index.js'
+import { importExportStore } from '../../store/store.js'
 
 export const useEndpointStore = defineStore('endpoint', {
 	state: () => ({
@@ -11,13 +11,13 @@ export const useEndpointStore = defineStore('endpoint', {
 	actions: {
 		setEndpointItem(endpointItem) {
 			this.endpointItem = endpointItem && new Endpoint(endpointItem)
-			console.log('Active endpoint item set to ' + endpointItem)
+			console.info('Active endpoint item set to ' + endpointItem)
 		},
 		setEndpointList(endpointList) {
 			this.endpointList = endpointList.map(
 				(endpointItem) => new Endpoint(endpointItem),
 			)
-			console.log('Endpoint list set to ' + endpointList.length + ' items')
+			console.info('Endpoint list set to ' + endpointList.length + ' items')
 		},
 		/* istanbul ignore next */ // ignore this for Jest until moved into a service
 		async refreshEndpointList(search = null) {
@@ -59,7 +59,7 @@ export const useEndpointStore = defineStore('endpoint', {
 				throw new MissingParameterError('endpointItem')
 			}
 
-			console.log('Deleting endpoint...')
+			console.info('Deleting endpoint...')
 
 			const endpoint = `/index.php/apps/openconnector/api/endpoints/${endpointItem.id}`
 
@@ -88,7 +88,7 @@ export const useEndpointStore = defineStore('endpoint', {
 				throw new ValidationError(validationResult.error)
 			}
 
-			console.log('Saving endpoint...')
+			console.info('Saving endpoint...')
 
 			const isNewEndpoint = !endpointItem.id
 			const endpoint = isNewEndpoint
@@ -117,5 +117,22 @@ export const useEndpointStore = defineStore('endpoint', {
 
 			return { response, data, entity }
 		},
+		// Export an endpoint
+		exportEndpoint(endpointItem) {
+			if (!endpointItem) {
+				throw new Error('No endpoint item to export')
+			}
+			importExportStore.exportFile(
+				endpointItem.id,
+				'endpoint',
+			)
+				.then(({ download }) => {
+					download()
+				})
+				.catch((err) => {
+					console.error('Error exporting endpoint:', err)
+					throw err
+				})
+		},
 	},
 })

src/store/modules/endpoints.spec.js

@@ -1,4 +1,3 @@
-/* eslint-disable no-console */
 import { setActivePinia, createPinia } from 'pinia'
 
 import { useEndpointStore } from './endpoints.js'

src/store/modules/importExport.js

@@ -0,0 +1,49 @@
+import { defineStore } from 'pinia'
+
+export const useImportExportStore = defineStore(
+	'importExport', {
+		state: () => ({
+			exportSource: '',
+			exportSourceResults: '',
+			exportSourceError: '',
+		}),
+		actions: {
+			setExportSource(exportSource) {
+				this.exportSource = exportSource
+				console.info('Active exportSource set to ' + exportSource)
+			},
+			async exportFile(id, type) {
+				const apiEndpoint = `/index.php/apps/openconnector/api/export/${type}/${id}`
+
+				if (!id) {
+					throw Error('Passed id is falsy')
+				}
+				const response = await fetch(
+					apiEndpoint,
+					{
+						method: 'GET',
+						headers: {
+							Accept: 'application/json',
+						},
+					},
+				)
+				const filename = response.headers.get('Content-Disposition').split('filename=')[1].replace(/['"]/g, '')
+
+				const blob = await response.blob()
+
+				const download = () => {
+					const url = window.URL.createObjectURL(new Blob([blob]))
+					const link = document.createElement('a')
+					link.href = url
+
+					link.setAttribute('download', `${filename}`)
+					document.body.appendChild(link)
+					link.click()
+				}
+
+				return { response, blob, download }
+			},
+
+		},
+	},
+)

src/store/modules/job.js

@@ -1,6 +1,6 @@
-/* eslint-disable no-console */
 import { defineStore } from 'pinia'
 import { Job } from '../../entities/index.js'
+import { importExportStore } from '../../store/store.js'
 
 export const useJobStore = defineStore(
 	'job', {
@@ -16,29 +16,29 @@ export const useJobStore = defineStore(
 		actions: {
 			setJobItem(jobItem) {
 				this.jobItem = jobItem && new Job(jobItem)
-				console.log('Active job item set to ' + jobItem)
+				console.info('Active job item set to ' + jobItem)
 			},
 			setJobTest(jobTest) {
 				this.jobTest = jobTest
-				console.log('Job test set to ' + jobTest)
+				console.info('Job test set to ' + jobTest)
 			},
 			setJobRun(jobRun) {
 				this.jobRun = jobRun
-				console.log('Job run set to ' + jobRun)
+				console.info('Job run set to ' + jobRun)
 			},
 			setJobList(jobList) {
 				this.jobList = jobList.map(
 					(jobItem) => new Job(jobItem),
 				)
-				console.log('Job list set to ' + jobList.length + ' items')
+				console.info('Job list set to ' + jobList.length + ' items')
 			},
 			setJobLogs(jobLogs) {
 				this.jobLogs = jobLogs
-				console.log('Job logs set to ' + jobLogs.length + ' items')
+				console.info('Job logs set to ' + jobLogs.length + ' items')
 			},
 			setJobArgumentKey(jobArgumentKey) {
 				this.jobArgumentKey = jobArgumentKey
-				console.log('Active job argument key set to ' + jobArgumentKey)
+				console.info('Active job argument key set to ' + jobArgumentKey)
 			},
 			/* istanbul ignore next */ // ignore this for Jest until moved into a service
 			async refreshJobList(search = null) {
@@ -101,7 +101,7 @@ export const useJobStore = defineStore(
 					throw new Error('No job item to delete')
 				}
 
-				console.log('Deleting job...')
+				console.info('Deleting job...')
 
 				const endpoint = `/index.php/apps/openconnector/api/jobs/${this.jobItem.id}`
 
@@ -121,7 +121,7 @@ export const useJobStore = defineStore(
 				if (!this.jobItem) {
 					throw new Error('No job item to test')
 				}
-				console.log('Testing job...')
+				console.info('Testing job...')
 
 				const endpoint = `/index.php/apps/openconnector/api/jobs-test/${this.jobItem.id}`
 
@@ -136,7 +136,7 @@ export const useJobStore = defineStore(
 					.then((response) => response.json())
 					.then((data) => {
 						this.setJobTest(data)
-						console.log('Job tested')
+						console.info('Job tested')
 						// Refresh the job list
 						this.refreshJobLogs()
 					})
@@ -151,7 +151,7 @@ export const useJobStore = defineStore(
 				if (!id) {
 					throw new Error('No job item to run')
 				}
-				console.log('Running job...')
+				console.info('Running job...')
 
 				const endpoint = `/index.php/apps/openconnector/api/jobs-test/${id}`
 
@@ -165,7 +165,7 @@ export const useJobStore = defineStore(
 
 				const data = await response.json()
 				this.setJobRun(data)
-				console.log('Job run')
+				console.info('Job run')
 				// Refresh the job list
 				this.refreshJobLogs()
 
@@ -177,7 +177,7 @@ export const useJobStore = defineStore(
 					throw new Error('No job item to save')
 				}
 
-				console.log('Saving job...')
+				console.info('Saving job...')
 
 				const isNewJob = !jobItem.id
 				const endpoint = isNewJob
@@ -206,7 +206,7 @@ export const useJobStore = defineStore(
 					.then((response) => response.json())
 					.then((data) => {
 						this.setJobItem(data)
-						console.log('Job saved')
+						console.info('Job saved')
 						// Refresh the job list
 						return this.refreshJobList()
 					})
@@ -215,6 +215,23 @@ export const useJobStore = defineStore(
 						throw err
 					})
 			},
+			// Export a job
+			exportJob(jobItem) {
+				if (!jobItem) {
+					throw new Error('No job item to export')
+				}
+				importExportStore.exportFile(
+					jobItem.id,
+					'job',
+				)
+					.then(({ download }) => {
+						download()
+					})
+					.catch((err) => {
+						console.error('Error exporting job:', err)
+						throw err
+					})
+			},
 		},
 	},
 )

src/store/modules/job.spec.js

@@ -1,4 +1,3 @@
-/* eslint-disable no-console */
 import { setActivePinia, createPinia } from 'pinia'
 
 import { useJobStore } from './job.js'

src/store/modules/log.js

@@ -1,4 +1,3 @@
-/* eslint-disable no-console */
 import { defineStore } from 'pinia'
 import { Log } from '../../entities/index.js'
 
@@ -13,21 +12,21 @@ export const useLogStore = defineStore(
 		actions: {
 			setLogItem(logItem) {
 				this.logItem = logItem && new Log(logItem)
-				console.log('Active log item set to ' + logItem)
+				console.info('Active log item set to ' + logItem)
 			},
 			setLogList(logList) {
 				this.logList = logList.map(
 					(logItem) => new Log(logItem),
 				)
-				console.log('Log list set to ' + logList.length + ' items')
+				console.info('Log list set to ' + logList.length + ' items')
 			},
 			setViewLogItem(logItem) {
 				this.viewLogItem = logItem
-				console.log('Active log item set to ' + logItem)
+				console.info('Active log item set to ' + logItem)
 			},
 			setActiveLogKey(activeLogKey) {
 				this.activeLogKey = activeLogKey
-				console.log('Active log key set to ' + activeLogKey)
+				console.info('Active log key set to ' + activeLogKey)
 			},
 			/* istanbul ignore next */ // ignore this for Jest until moved into a service
 			async refreshLogList(search = null) {
@@ -75,7 +74,7 @@ export const useLogStore = defineStore(
 					throw new Error('No log item to delete')
 				}
 
-				console.log('Deleting log...')
+				console.info('Deleting log...')
 
 				const endpoint = `/index.php/apps/openconnector/api/logs/${this.logItem.id}`
 
@@ -96,7 +95,7 @@ export const useLogStore = defineStore(
 					throw new Error('No log item to save')
 				}
 
-				console.log('Saving log...')
+				console.info('Saving log...')
 
 				const isNewLog = !this.logItem.id
 				const endpoint = isNewLog
@@ -125,7 +124,7 @@ export const useLogStore = defineStore(
 					.then((response) => response.json())
 					.then((data) => {
 						this.setLogItem(data)
-						console.log('Log saved')
+						console.info('Log saved')
 						// Refresh the log list
 						return this.refreshLogList()
 					})

src/store/modules/log.spec.js

@@ -1,4 +1,3 @@
-/* eslint-disable no-console */
 import { setActivePinia, createPinia } from 'pinia'
 
 import { useLogStore } from './log.js'