@@ -47,28 +47,31 @@ const _addSalesforceLead = (token, logger, project) => {
47
47
* @param {[type] } channel channel to ack, nack
48
48
*/
49
49
const 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
+ // })
72
75
}
73
76
74
77
module . exports = {
0 commit comments