@@ -47,28 +47,31 @@ const _addSalesforceLead = (token, logger, project) => {
4747 * @param {[type] } channel channel to ack, nack
4848 */
4949const projectCreatedHandler = ( logger , msg , channel ) => {
50- let project = JSON . parse ( msg . content )
51- return util . getSystemUserToken ( logger )
52- . then ( token => {
53- const req = {
54- id : 1 ,
55- log : logger ,
56- headers : {
57- authorization : `Bearer ${ token } `
58- }
59- }
60- return Promise . all ( [
61- _addSalesforceLead ( token , logger , project ) . then ( ( resp ) => logger . debug ( 'web to lead response:' , resp . status ) )
62- ] ) ;
63- } )
64- . then ( ( ) => {
65- channel . ack ( msg )
66- } )
67- . catch ( err => {
68- // don't requeue for now
69- logger . error ( 'Error processing' , msg , err )
70- channel . nack ( msg , false , false )
71- } )
50+ // disabling salesforce integration for now,
51+ // see https://github.com/topcoder-platform/tc-project-service/issues/38
52+ return channel . ack ( msg )
53+ // let project = JSON.parse(msg.content)
54+ // return util.getSystemUserToken(logger)
55+ // .then(token => {
56+ // const req = {
57+ // id: 1,
58+ // log: logger,
59+ // headers: {
60+ // authorization: `Bearer ${token}`
61+ // }
62+ // }
63+ // return Promise.all([
64+ // _addSalesforceLead(token, logger, project).then((resp)=> logger.debug('web to lead response:', resp.status))
65+ // ]);
66+ // })
67+ // .then(() => {
68+ // channel.ack(msg)
69+ // })
70+ // .catch(err => {
71+ // // don't requeue for now
72+ // logger.error('Error processing', msg, err)
73+ // channel.nack(msg, false, false)
74+ // })
7275}
7376
7477module . exports = {
0 commit comments