FROM 086679231553.dkr.ecr.us-east-1.amazonaws.com/docker-parent-images:kafka-connect77

USER root

# Install Plugins SalesForce source connector plugin version ${SALESFORCE_CONNECTOR_VERSION}"
ENV SALESFORCE_CONNECTOR_VERSION='3.18.2'
ENV CAMEL_REPOSITORY_BASE_URL="https://repo.maven.apache.org/maven2/org/apache/camel/kafkaconnector"
RUN mkdir /usr/share/camel && \
    wget -O /usr/share/camel/camel-salesforce-kafka-connector-${SALESFORCE_CONNECTOR_VERSION}-package.tar.gz ${CAMEL_REPOSITORY_BASE_URL}/camel-salesforce-source-kafka-connector/${SALESFORCE_CONNECTOR_VERSION}/camel-salesforce-source-kafka-connector-${SALESFORCE_CONNECTOR_VERSION}-package.tar.gz && \
    tar -C /usr/share/camel -zxvf /usr/share/camel/camel-salesforce-kafka-connector-${SALESFORCE_CONNECTOR_VERSION}-package.tar.gz

COPY entry_point.sh /usr/local/bin/entry_point.sh
COPY --chown=appuser:appuser queries/${SF_SOBJECT_QUERY_FILE} /home/appuser/queries/${SF_SOBJECT_QUERY_FILE}
RUN chmod +x /usr/local/bin/entry_point.sh

# Copy connector config template
COPY config.template.json /tmp/

USER appuser

ENV CONNECTOR_NAME='salesforce_source'
ENV CONNECT_KEY_CONVERTER='org.apache.kafka.connect.storage.StringConverter'
ENV CONNECT_VALUE_CONVERTER='org.apache.kafka.connect.json.JsonConverter'
ENV CONNECT_PLUGIN_PATH='/usr/share/java,/usr/share/confluent-hub-components/,/usr/share/camel/'
ENV CONNECT_PRODUCER_MAX_REQUEST_SIZE=15728640
ENV SF_AUTH_TYPE='REFRESH_TOKEN'
ENV SF_INSTANCE='https://test.salesforce.com'
ENV RAW_PAYLOAD='true'
ENV SF_UPDATE_TOPIC='true'
# Read only new events
# https://developer.salesforce.com/docs/atlas.en-us.api_streaming.meta/api_streaming/using_streaming_api_durability.htm#generic_replay_event_replay_details
ENV SF_REPLAY_ID='-1'
ENV AWS_REGION='us-east-1'


EXPOSE ${CONNECT_REST_PORT}

ENTRYPOINT  ["/usr/local/bin/entry_point.sh"]

#FORCE REDEPLOY:1