add-survey.js

alterState(state => {
  var user = state.data.payload.survey.user_id;
  var time = state.data.unix_timestamp;
  state.data._surveyIdentifier = `${user}${time}`;
  return state;
});

upsert(
  'Every1Mobile_Activity__c',
  'Unique_ID__c',
  fields(
    field('Unique_ID__c', dataValue('_surveyIdentifier')),
    field('RecordTypeID', '0120N0000001XCnQAM'),
    relationship(
      'Contact__r',
      'Every1Mobile_ID__c',
      dataValue('payload.survey.user_id')
    ),
    field('Type__c', dataValue('type')),
    field('DateTime__c', state => {
      return new Date(state.data.unix_timestamp * 1000);
    }),
    field('Survey_ID__c', dataValue('payload.survey.id'))
  )
);

//for each question in survey, create 1 child Every1Mobile_Activity__c w/ self-lookup to parent above
//path to question array: $.payload.survey.questions[*]
each(
  merge(
    dataPath('$.payload.survey.questions[*]'),
    fields(
      field('userId', dataValue('payload.survey.user_id')),
      field('surveyId', dataValue('_surveyIdentifier'))
    )
  ),
  upsert(
    'Every1Mobile_Activity__c',
    'Unique_ID__c',
    fields(
      field('Unique_ID__c', state => {
        var questionId = dataValue('id')(state) //adding questionId to each question Unique_ID__c
        return `${state.data.surveyId}${state.data.id}${questionId}`;
      }),
      relationship('Contact__r', 'Every1Mobile_ID__c', dataValue('userId')),
      field('Survey_Question_Type__c', dataValue('type')),
      field('Survey_Questions_ID__c', dataValue('id')),
      field('Survey_Questions_Question__c', dataValue('question')),
      field('Surveey_Questions_Answer_ID__c', dataValue('answer.id')),
      field('Survey_Questions_Answer__c', dataValue('answer.answer')),
      relationship(
        'Every1Mobile_Activity__r',
        'Unique_ID__c',
        dataValue('surveyId')
      )
    )
  )
);