From c99d0c2be8d6e377102085ebe84a5acb55979775 Mon Sep 17 00:00:00 2001 From: bill bittner Date: Wed, 7 Mar 2018 13:45:51 -0800 Subject: [PATCH] wrote a task to fill in channelNames --- task-scripts/update-channel-names.js | 57 ++++++++++++++++++++++++++++ 1 file changed, 57 insertions(+) create mode 100644 task-scripts/update-channel-names.js diff --git a/task-scripts/update-channel-names.js b/task-scripts/update-channel-names.js new file mode 100644 index 00000000..e3032ddb --- /dev/null +++ b/task-scripts/update-channel-names.js @@ -0,0 +1,57 @@ +// load dependencies +const logger = require('winston'); +const db = require('../models'); // require our models for syncing +// configure logging +const config = require('../config/speechConfig.js'); +const { logLevel } = config.logging; +require('../config/loggerConfig.js')(logger, logLevel); + +let totalClaims = 0; +let totalClaimsNoCertificate = 0; + +db.sequelize.sync() // sync sequelize + .then(() => { + logger.info('finding claims with no channels'); + return db.Claim.findAll({ + where: { + channelName : null, + certificateId: { + $ne: null, + }, + }, + }); + }) + .then(claimsArray => { + totalClaims = claimsArray.length; + const claimsUpdatePromises = claimsArray.map(claim => { + return db.Certificate + .findOne({ + where: { claimId: claim.get('certificateId') }, + }) + .then(certificate => { + // if a certificate is found... + if (certificate) { + logger.debug('certificate found'); + // update the claim's channel name with the certificate's name + return claim + .update({ + channelName: certificate.get('name'), + }) + .then(() => {}) + .catch(error => logger.error(error)); + } + logger.warn('no record found for certificate: ', claim.get('certificateId')); + totalClaimsNoCertificate += 1; + }) + .catch(error => logger.error(error)); + }); + return Promise.all(claimsUpdatePromises); + }) + .then(() => { + logger.info('total claims found', totalClaims); + logger.info('total claims found with no matching certificate record', totalClaimsNoCertificate); + logger.debug('all done'); + }) + .catch((error) => { + logger.error(error); + });