This worker trigger Super Slurper when an object is uploaded to source bucket and replicate objects to destination bucket .

steps :

• Create sourceId (source) and sinkId (destination) (use curl or postman to run below API ), this is required in src/index.ts

• create API token with R2 read/write permission for api.cloudflare.com

• create R2 API token with Bucket & Object read/write permission

curl --location 'https://api.cloudflare.com/client/v4/accounts/{ACCOUNTID}/r2migrator/v1/sources/connectivity-precheck' \
-H 'Content-Type: application/json' \
-H 'Authorization: ••••••' \
--data '{
    "bucket": "source_bucket_name",
    "secret": {
        "r2AccessKeyId": "123",
        "r2SecretAccessKey": "321"
    },
    "vendor": "r2",
    "account": "{ACCOUNTID}"
}'

curl --location 'https://api.cloudflare.com/client/v4/accounts/{ACCOUNTID}/r2migrator/v1/sinks/connectivity-precheck' \
  -H 'Content-Type: application/json' \
  -H 'header : 'Authorization: ••••••' \
--data '{
    "bucket": "destination_bucket_name",
    "secret": {
        "r2AccessKeyId": "123",
        "r2SecretAccessKey": "321"
    }
}'

• Save the sourceId and sinkId from the API response to substitute in index.ts
• Create and attach R2 event notification to the source bucket
• Create a Consumer Worker (git clone) and Connect the consumer Worker to your queue

Note:

• While creating this, cross region replication feature is not yet available for Cloudflare R2
• Store secrets in Environment variables as best practice instead of hardcoding
• This will not sync deletes ; Any new files uploaded to source will be replicated to desination
• Destination R2 bucket options is not to overwrite destination files. There are two options: overwrite and skip (this snippet uses skip)