'use strict'; const $request = require('request'); const constants = require('./consts'); const Keys = require('./keymanagers/Keys'); const defaultKeyEncryptor = require('./keymanagers/defaultKeyEncryptor'); const signer = require('./middleware/signer'); const serializer = require('./middleware/serializer'); const response = require('./middleware/response'); module.exports = class Client { constructor({ url, partnerId, userId, hostId, passphrase, keyStorage, }) { if (!url) throw new Error('EBICS URL is requierd'); if (!partnerId) throw new Error('partnerId is requierd'); if (!userId) throw new Error('userId is requierd'); if (!hostId) throw new Error('hostId is requierd'); if (!passphrase) throw new Error('passphrase is requierd'); if (!keyStorage || typeof keyStorage.read !== 'function' || typeof keyStorage.write !== 'function') throw new Error('keyStorage implemntation missing or wrong'); this.url = url; this.partnerId = partnerId; this.userId = userId; this.hostId = hostId; this.keyStorage = keyStorage; this.keyEncryptor = defaultKeyEncryptor({ passphrase }); } send(order) { const isInObject = ('operation' in order); if (!isInObject) throw new Error('Operation for the order needed'); if (order.operation.toUpperCase() === constants.orderOperations.ini) return this.initialization(order); if (order.operation.toUpperCase() === constants.orderOperations.upload) return this.upload(order); if (order.operation.toUpperCase() === constants.orderOperations.download) return this.download(order); throw new Error('Wrong order operation provided'); } async initialization(order) { const res = await this.ebicsRequest(order); const xml = res.orderData(); return { orderData: xml, orderId: res.orderId(), returnCode: res.returnCode(), reportText: res.reportText(), bankKeys: res.bankKeys(), }; } async download(order) { const res = await this.ebicsRequest(order); order.transactionId = res.transactionId(); if (res.isSegmented() && res.isLastSegment()) await this.ebicsRequest(order); return { orderData: res.orderData(), orderId: res.orderId(), returnCode: res.returnCode(), reportText: res.reportText(), }; } async upload(order) { let res = await this.ebicsRequest(order); const transactionId = res.transactionId(); const orderId = res.orderId(); order.transactionId = transactionId; res = await this.ebicsRequest(order); return [transactionId, orderId]; } ebicsRequest(order) { return new Promise((resolve, reject) => { const { version } = order; const keys = this.keys(); $request.post({ url: this.url, body: signer.version(version).sign(serializer.use(order, this).toXML(), keys.x()), // s, // new (signer.version(version))(serializer.use(order).toXML(), keys).digest().sign().toXML(), headers: { 'content-type': 'text/xml;charset=UTF-8' }, }, (err, res, data) => (err ? reject(err) : resolve(response.version(version)(data, keys)))); }); } ini(order) { return this.initialization(order); } payment(order) { return this.upload(order); } statement(order) { return this.download(order); } status(order) { return this.download(order); } keys() { const keysString = this.keyStorage.read(); return new Keys(JSON.parse(this.keyEncryptor.decrypt(keysString))); } setBankKeys(bankKeys) { const keysObject = this.keys(); keysObject.setBankKeys(bankKeys); const { keys } = keysObject; Object.keys(keys).map((key) => { keys[key] = keys[key] === null ? null : keys[key].toPem(); return key; }); this.keyStorage.write(this.keyEncryptor.encrypt(JSON.stringify(keys))); } };