diff --git a/index.js b/index.js
index 1ccb213cf42b22dfdf9f138720d94eabe15c73b2..bb78c996d8700ccaa29d57972103dc574e781e17 100644
--- a/index.js
+++ b/index.js
@@ -39,8 +39,8 @@ const {
terminateContract,
getContractStartDate,
} = __webpack_require__(1595)
-const { getAccount, saveAccountData } = __webpack_require__(1604)
-const { isLocal } = __webpack_require__(1605)
+const { getAccount, saveAccountData } = __webpack_require__(1605)
+const { isLocal } = __webpack_require__(1606)
moment.locale('fr') // set the language
moment.tz.setDefault('Europe/Paris') // set the timezone
@@ -124,7 +124,9 @@ async function start(fields, cozyParameters) {
user.firstname,
user.address,
user.postalCode,
- user.inseeCode
+ user.inseeCode,
+ user.city,
+ user.hasBeenThroughtSafetyOnBoarding
)
// handle user contract start date in order to preperly request data
@@ -223536,6 +223538,18 @@ function parseContractStartDate(result) {
'dateDerniereModificationFormuleTarifaireAcheminement'
]
}
+/**
+ * Return User address
+ * @param {string} result
+ * @returns {Address}
+ */
+function parseUserAddress(result) {
+ log('info', 'Parsing user Address')
+ const json = JSON.stringify(result)
+ return JSON.parse(json)['Envelope']['Body'][
+ 'consulterDonneesTechniquesContractuellesResponse'
+ ]['point']['donneesGenerales']['adresseInstallation']
+}
/**
* Return User contract start date
@@ -223634,6 +223648,24 @@ function parseValue(value, name) {
return value
}
+/**
+ * Remove SGE useless multiple white spaces
+ * @param {string} str
+ * @returns {string}
+ */
+function removeMultipleSpaces(str) {
+ return str.replace(/ +/g, ' ')
+}
+
+/**
+ * Remove SGE address number
+ * @param {string} str
+ * @returns {string}
+ */
+function removeAddressnumber(str) {
+ return str.replace(/\d+ |b |B |T |t |\d+/g, '')
+}
+
module.exports = {
parseSgeXmlData,
formateDataForDoctype,
@@ -223643,7 +223675,10 @@ module.exports = {
parseContracts,
parseContractStartDate,
parseServiceId,
+ parseUserAddress,
checkContractExists,
+ removeMultipleSpaces,
+ removeAddressnumber,
}
@@ -223755,7 +223790,11 @@ function consultationMesuresDetailleesMaxPower(
* @param {string} appLogin
* @returns {string}
*/
-function consulterDonneesTechniquesContractuelles(pointId, appLogin) {
+function consulterDonneesTechniquesContractuelles(
+ pointId,
+ appLogin,
+ consent = true
+) {
log('info', `Query consulterDonneesTechniquesContractuelles`)
return `<?xml version='1.0' encoding='utf-8'?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
@@ -223766,7 +223805,7 @@ function consulterDonneesTechniquesContractuelles(pointId, appLogin) {
<v2:consulterDonneesTechniquesContractuelles>
<pointId>${pointId}</pointId>
<loginUtilisateur>${appLogin}</loginUtilisateur>
- <autorisationClient>true</autorisationClient>
+ <autorisationClient>${consent}</autorisationClient>
</v2:consulterDonneesTechniquesContractuelles>
</soapenv:Body>
</soapenv:Envelope>
@@ -223778,14 +223817,45 @@ function consulterDonneesTechniquesContractuelles(pointId, appLogin) {
* @param {string} name
* @param {string} postalCode
* @param {string} inseeCode
- * @param {string} [address]
+ * @param {string} address
+ * @param {string} [escalierEtEtageEtAppartement]
* @returns {string} PDL
*/
-function rechercherPoint(appLogin, name, postalCode, inseeCode, address) {
+function rechercherPoint(
+ appLogin,
+ name,
+ postalCode,
+ inseeCode,
+ address,
+ escalierEtEtageEtAppartement
+) {
log(
'info',
- `Query rechercherPoint - postal code / insee code: ${postalCode} / ${inseeCode}`
+ `Query rechercherPoint - postal code : ${postalCode} / insee code: ${inseeCode}`
)
+ if (escalierEtEtageEtAppartement) {
+ return `<?xml version='1.0' encoding='utf-8'?>
+ <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
+ xmlns:v2="http://www.enedis.fr/sge/b2b/services/rechercherpoint/v2.0"
+ xmlns:v1="http://www.enedis.fr/sge/b2b/technique/v1.0">
+ <soapenv:Header/>
+ <soapenv:Body>
+ <v2:rechercherPoint>
+ <criteres>
+ <adresseInstallation>
+ <escalierEtEtageEtAppartement>${escalierEtEtageEtAppartement}</escalierEtEtageEtAppartement>
+ <numeroEtNomVoie>${address}</numeroEtNomVoie>
+ <codePostal>${postalCode}</codePostal>
+ <codeInseeCommune>${inseeCode}</codeInseeCommune>
+ </adresseInstallation>
+ <nomClientFinalOuDenominationSociale>${name}</nomClientFinalOuDenominationSociale>
+ <rechercheHorsPerimetre>true</rechercheHorsPerimetre>
+ </criteres>
+ <loginUtilisateur>${appLogin}</loginUtilisateur>
+ </v2:rechercherPoint>
+ </soapenv:Body>
+ </soapenv:Envelope>`
+ }
return `<?xml version='1.0' encoding='utf-8'?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
xmlns:v2="http://www.enedis.fr/sge/b2b/services/rechercherpoint/v2.0"
@@ -223960,6 +224030,8 @@ const { default: axios } = __webpack_require__(1558)
* @param {string} address
* @param {string} postalCode
* @param {string} inseeCode
+ * @param {string} city
+ * @param {boolean} safetyOnBoarding
* @returns {Promise<Consent>}
*/
async function createBoConsent(
@@ -223970,7 +224042,9 @@ async function createBoConsent(
firstname,
address,
postalCode,
- inseeCode
+ inseeCode,
+ city,
+ safetyOnBoarding
) {
log('info', `Query createBoConsent`)
const headers = {
@@ -223989,6 +224063,8 @@ async function createBoConsent(
address,
postalCode,
inseeCode,
+ city,
+ safetyOnBoarding,
},
headers
)
@@ -228007,6 +228083,7 @@ const { terminateContract } = __webpack_require__(1598)
const { verifyContract } = __webpack_require__(1599)
const { findUserPdl } = __webpack_require__(1601)
const { verifyUserIdentity } = __webpack_require__(1602)
+const { findUserAddress } = __webpack_require__(1604)
module.exports = {
activateContract,
@@ -228015,6 +228092,7 @@ module.exports = {
verifyContract,
findUserPdl,
verifyUserIdentity,
+ findUserAddress,
}
@@ -228366,7 +228444,8 @@ async function findUserPdl(
name,
address,
postalCode,
- inseeCode
+ inseeCode,
+ escalierEtEtageEtAppartement = ''
) {
log('info', 'Fetching user data')
const sgeHeaders = {
@@ -228377,7 +228456,14 @@ async function findUserPdl(
const { response } = await soapRequest({
url: url,
headers: sgeHeaders,
- xml: rechercherPoint(appLogin, name, postalCode, inseeCode, address),
+ xml: rechercherPoint(
+ appLogin,
+ name,
+ postalCode,
+ inseeCode,
+ address,
+ escalierEtEtageEtAppartement
+ ),
}).catch(err => {
log('error', 'rechercherPointResponse')
log('error', err)
@@ -228400,7 +228486,7 @@ async function findUserPdl(
`Enedis issue ${parsedReply.Envelope.Body.Fault.detail.erreur.resultat.$.code}: ${parsedReply.Envelope.Body.Fault.faultstring}`
)
}
- throw errors.LOGIN_FAILED
+ return null
}
}
@@ -228415,6 +228501,11 @@ module.exports = { findUserPdl }
const { log, errors } = __webpack_require__(1)
const { findUserPdl } = __webpack_require__(1601)
const { getInseeCode } = __webpack_require__(1603)
+const { findUserAddress } = __webpack_require__(1604)
+const {
+ removeMultipleSpaces,
+ removeAddressnumber,
+} = __webpack_require__(1555)
/**
* Verify user identity
@@ -228439,7 +228530,11 @@ async function verifyUserIdentity(
inseeCode = await getInseeCode(fields.postalCode, fields.city)
}
- const pdl = await findUserPdl(
+ // Store if user is going through safety sge onboarding
+ let userSafetyOnBoarding = false
+
+ // First try with user adresse
+ let pdl = await findUserPdl(
`${baseUrl}/enedis_SDE_recherche-point/1.0`,
apiAuthKey,
loginUtilisateur,
@@ -228449,8 +228544,52 @@ async function verifyUserIdentity(
inseeCode
)
+ if (!pdl) {
+ log('warn', 'Second chance for sge onboarding')
+ // Set safety onboarding in order to save it inside BO
+ userSafetyOnBoarding = true
+ // Backup verification
+ const userAddress = await findUserAddress(
+ baseUrl,
+ apiAuthKey,
+ loginUtilisateur,
+ fields.pointId
+ )
+
+ const escalierEtEtageEtAppartement = userAddress.escalierEtEtageEtAppartement
+ ? removeMultipleSpaces(userAddress.escalierEtEtageEtAppartement)
+ : ''
+
+ pdl = await findUserPdl(
+ `${baseUrl}/enedis_SDE_recherche-point/1.0`,
+ apiAuthKey,
+ loginUtilisateur,
+ fields.lastname,
+ removeMultipleSpaces(userAddress.numeroEtNomVoie),
+ userAddress.codePostal,
+ userAddress.commune.$.code,
+ escalierEtEtageEtAppartement
+ )
+
+ // Third try, remove address number because it's buggy on SGE side
+ if (!pdl) {
+ log('warn', 'Last chance onboarding for sge')
+ pdl = await findUserPdl(
+ `${baseUrl}/enedis_SDE_recherche-point/1.0`,
+ apiAuthKey,
+ loginUtilisateur,
+ fields.lastname,
+ removeMultipleSpaces(removeAddressnumber(userAddress.numeroEtNomVoie)),
+ userAddress.codePostal,
+ userAddress.commune.$.code,
+ escalierEtEtageEtAppartement
+ )
+ }
+ }
+
if (fields.pointId != pdl) {
log('error', 'PointId does not match')
+
if (isAlternateStart) {
throw errors.TERMS_VERSION_MISMATCH
} else {
@@ -228465,6 +228604,8 @@ async function verifyUserIdentity(
inseeCode,
postalCode: fields.postalCode,
address: fields.address,
+ hasBeenThroughtSafetyOnBoarding: userSafetyOnBoarding,
+ city: fields.city,
}
}
@@ -228520,8 +228661,68 @@ module.exports = {
/* 1604 */
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
+// @ts-check
+const { log, errors } = __webpack_require__(1)
+const soapRequest = __webpack_require__(1331)
+const {
+ parseTags,
+ parseValue,
+ parseUserAddress,
+} = __webpack_require__(1555)
+const xml2js = __webpack_require__(1513)
+const { consulterDonneesTechniquesContractuelles } = __webpack_require__(1556)
+
+/**
+ * Get user contract start date
+ * @param {string} url
+ * @param {string} apiAuthKey
+ * @param {string} userLogin
+ * @param {number} pointId
+ * @returns {Promise<Address>}
+ */
+async function findUserAddress(url, apiAuthKey, userLogin, pointId) {
+ log('info', 'Fetching user address')
+ const sgeHeaders = {
+ 'Content-Type': 'text/xml;charset=UTF-8',
+ apikey: apiAuthKey,
+ }
+
+ const { response } = await soapRequest({
+ url: `${url}/enedis_SGE_ConsultationDonneesTechniquesContractuelles/1.0`,
+ headers: sgeHeaders,
+ xml: consulterDonneesTechniquesContractuelles(pointId, userLogin, false),
+ }).catch(err => {
+ log('error', 'Error while fetching user : ' + err)
+ throw errors.VENDOR_DOWN
+ })
+
+ const result = await xml2js.parseStringPromise(response.body, {
+ tagNameProcessors: [parseTags],
+ valueProcessors: [parseValue],
+ explicitArray: false,
+ })
+
+ try {
+ return parseUserAddress(result)
+ } catch (error) {
+ log('error', 'Error while processing user address: ' + error)
+ log(
+ 'error',
+ `Enedis issue ${result.Envelope.Body.Fault.detail.erreur.resultat.$.code}: ${result.Envelope.Body.Fault.faultstring}`
+ )
+ throw errors.NOT_EXISTING_DIRECTORY
+ }
+}
+
+module.exports = { findUserAddress }
+
+
+/***/ }),
+/* 1605 */
+/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
+
const { log, updateOrCreate } = __webpack_require__(1)
-const { isLocal } = __webpack_require__(1605)
+const { isLocal } = __webpack_require__(1606)
const cozyClient = __webpack_require__(485)
async function saveAccountData(accountId, accountData) {
@@ -228564,7 +228765,7 @@ module.exports = { getAccount, saveAccountData, getAccountForDelete }
/***/ }),
-/* 1605 */
+/* 1606 */
/***/ ((module) => {
function isLocal() {
diff --git a/onDeleteAccount.js b/onDeleteAccount.js
index 22b06e4e00a0824397d41226166088c5344d0e74..9bb2d78ce07a5b17bd51bb3bd774258bc97750c8 100644
--- a/onDeleteAccount.js
+++ b/onDeleteAccount.js
@@ -222861,6 +222861,18 @@ function parseContractStartDate(result) {
'dateDerniereModificationFormuleTarifaireAcheminement'
]
}
+/**
+ * Return User address
+ * @param {string} result
+ * @returns {Address}
+ */
+function parseUserAddress(result) {
+ log('info', 'Parsing user Address')
+ const json = JSON.stringify(result)
+ return JSON.parse(json)['Envelope']['Body'][
+ 'consulterDonneesTechniquesContractuellesResponse'
+ ]['point']['donneesGenerales']['adresseInstallation']
+}
/**
* Return User contract start date
@@ -222959,6 +222971,24 @@ function parseValue(value, name) {
return value
}
+/**
+ * Remove SGE useless multiple white spaces
+ * @param {string} str
+ * @returns {string}
+ */
+function removeMultipleSpaces(str) {
+ return str.replace(/ +/g, ' ')
+}
+
+/**
+ * Remove SGE address number
+ * @param {string} str
+ * @returns {string}
+ */
+function removeAddressnumber(str) {
+ return str.replace(/\d+ |b |B |T |t |\d+/g, '')
+}
+
module.exports = {
parseSgeXmlData,
formateDataForDoctype,
@@ -222968,7 +222998,10 @@ module.exports = {
parseContracts,
parseContractStartDate,
parseServiceId,
+ parseUserAddress,
checkContractExists,
+ removeMultipleSpaces,
+ removeAddressnumber,
}
@@ -223080,7 +223113,11 @@ function consultationMesuresDetailleesMaxPower(
* @param {string} appLogin
* @returns {string}
*/
-function consulterDonneesTechniquesContractuelles(pointId, appLogin) {
+function consulterDonneesTechniquesContractuelles(
+ pointId,
+ appLogin,
+ consent = true
+) {
log('info', `Query consulterDonneesTechniquesContractuelles`)
return `<?xml version='1.0' encoding='utf-8'?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
@@ -223091,7 +223128,7 @@ function consulterDonneesTechniquesContractuelles(pointId, appLogin) {
<v2:consulterDonneesTechniquesContractuelles>
<pointId>${pointId}</pointId>
<loginUtilisateur>${appLogin}</loginUtilisateur>
- <autorisationClient>true</autorisationClient>
+ <autorisationClient>${consent}</autorisationClient>
</v2:consulterDonneesTechniquesContractuelles>
</soapenv:Body>
</soapenv:Envelope>
@@ -223103,14 +223140,45 @@ function consulterDonneesTechniquesContractuelles(pointId, appLogin) {
* @param {string} name
* @param {string} postalCode
* @param {string} inseeCode
- * @param {string} [address]
+ * @param {string} address
+ * @param {string} [escalierEtEtageEtAppartement]
* @returns {string} PDL
*/
-function rechercherPoint(appLogin, name, postalCode, inseeCode, address) {
+function rechercherPoint(
+ appLogin,
+ name,
+ postalCode,
+ inseeCode,
+ address,
+ escalierEtEtageEtAppartement
+) {
log(
'info',
- `Query rechercherPoint - postal code / insee code: ${postalCode} / ${inseeCode}`
+ `Query rechercherPoint - postal code : ${postalCode} / insee code: ${inseeCode}`
)
+ if (escalierEtEtageEtAppartement) {
+ return `<?xml version='1.0' encoding='utf-8'?>
+ <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
+ xmlns:v2="http://www.enedis.fr/sge/b2b/services/rechercherpoint/v2.0"
+ xmlns:v1="http://www.enedis.fr/sge/b2b/technique/v1.0">
+ <soapenv:Header/>
+ <soapenv:Body>
+ <v2:rechercherPoint>
+ <criteres>
+ <adresseInstallation>
+ <escalierEtEtageEtAppartement>${escalierEtEtageEtAppartement}</escalierEtEtageEtAppartement>
+ <numeroEtNomVoie>${address}</numeroEtNomVoie>
+ <codePostal>${postalCode}</codePostal>
+ <codeInseeCommune>${inseeCode}</codeInseeCommune>
+ </adresseInstallation>
+ <nomClientFinalOuDenominationSociale>${name}</nomClientFinalOuDenominationSociale>
+ <rechercheHorsPerimetre>true</rechercheHorsPerimetre>
+ </criteres>
+ <loginUtilisateur>${appLogin}</loginUtilisateur>
+ </v2:rechercherPoint>
+ </soapenv:Body>
+ </soapenv:Envelope>`
+ }
return `<?xml version='1.0' encoding='utf-8'?>
<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"
xmlns:v2="http://www.enedis.fr/sge/b2b/services/rechercherpoint/v2.0"
@@ -223285,6 +223353,8 @@ const { default: axios } = __webpack_require__(1558)
* @param {string} address
* @param {string} postalCode
* @param {string} inseeCode
+ * @param {string} city
+ * @param {boolean} safetyOnBoarding
* @returns {Promise<Consent>}
*/
async function createBoConsent(
@@ -223295,7 +223365,9 @@ async function createBoConsent(
firstname,
address,
postalCode,
- inseeCode
+ inseeCode,
+ city,
+ safetyOnBoarding
) {
log('info', `Query createBoConsent`)
const headers = {
@@ -223314,6 +223386,8 @@ async function createBoConsent(
address,
postalCode,
inseeCode,
+ city,
+ safetyOnBoarding,
},
headers
)
@@ -227404,11 +227478,12 @@ module.exports = { terminateContract }
/* 1601 */,
/* 1602 */,
/* 1603 */,
-/* 1604 */
+/* 1604 */,
+/* 1605 */
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
const { log, updateOrCreate } = __webpack_require__(1)
-const { isLocal } = __webpack_require__(1605)
+const { isLocal } = __webpack_require__(1606)
const cozyClient = __webpack_require__(485)
async function saveAccountData(accountId, accountData) {
@@ -227451,7 +227526,7 @@ module.exports = { getAccount, saveAccountData, getAccountForDelete }
/***/ }),
-/* 1605 */
+/* 1606 */
/***/ ((module) => {
function isLocal() {
@@ -227477,7 +227552,7 @@ module.exports = { isLocal, isDev }
/***/ }),
-/* 1606 */
+/* 1607 */
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
// @ts-check
@@ -227486,15 +227561,15 @@ const {
getAccountRev,
getAccountSecret,
getAccountId,
-} = __webpack_require__(1607)
+} = __webpack_require__(1608)
const { getBoConsent, deleteBoConsent } = __webpack_require__(1557)
const { terminateContract } = __webpack_require__(1598)
-const { getAccountForDelete } = __webpack_require__(1604)
+const { getAccountForDelete } = __webpack_require__(1605)
const moment = __webpack_require__(1373)
__webpack_require__(1510)
moment.locale('fr') // set the language
moment.tz.setDefault('Europe/Paris') // set the timezone
-const { isLocal, isDev } = __webpack_require__(1605)
+const { isLocal, isDev } = __webpack_require__(1606)
async function onDeleteAccount() {
log('info', 'Deleting account ...')
@@ -227578,11 +227653,11 @@ module.exports = { onDeleteAccount }
/***/ }),
-/* 1607 */
+/* 1608 */
/***/ ((module, __unused_webpack_exports, __webpack_require__) => {
const { log } = __webpack_require__(1)
-const { isLocal } = __webpack_require__(1605)
+const { isLocal } = __webpack_require__(1606)
function getAccountId() {
log('info', `getAccountId`)
@@ -227713,7 +227788,7 @@ module.exports = { getAccountId, getAccountRev, getAccountSecret }
/******/ // module cache are used so entry inlining is disabled
/******/ // startup
/******/ // Load entry module and return exports
-/******/ var __webpack_exports__ = __webpack_require__(__webpack_require__.s = 1606);
+/******/ var __webpack_exports__ = __webpack_require__(__webpack_require__.s = 1607);
/******/
/******/ })()
;
\ No newline at end of file