​

@conductor/cloudflare

​

Installation

pnpm add @conductor/cloudflare

​

Configuration

import { createCloudflarePlugin } from '@conductor/cloudflare'

export default {
  plugins: [
    createCloudflarePlugin({
      apiToken: env.CLOUDFLARE_API_TOKEN,
      accountId: env.CLOUDFLARE_ACCOUNT_ID,
      zoneId: env.CLOUDFLARE_ZONE_ID
    })
  ]
}

​

Environment Variables

• CLOUDFLARE_API_TOKEN - Cloudflare API token (required for API operations)
• CLOUDFLARE_ACCOUNT_ID - Cloudflare Account ID
• CLOUDFLARE_ZONE_ID - Cloudflare Zone ID (for DNS operations)

​

R2 Storage Operations

​

cloudflare:r2:put

• bucket (string, required) - R2 bucket binding name
• key (string, required) - Object key
• value (string | ReadableStream | ArrayBuffer, required) - Object value
• contentType (string, optional) - Content type
• metadata (object, optional) - Custom metadata

operations:
  - operation: cloudflare:r2:put
    config:
      bucket: MY_BUCKET
      key: uploads/file.txt
      value: ${input.content}
      contentType: text/plain

​

cloudflare:r2:get

• bucket (string, required) - R2 bucket binding name
• key (string, required) - Object key

• found (boolean)
• key (string)
• size (number)
• body (string) - Object content

operations:
  - operation: cloudflare:r2:get
    config:
      bucket: MY_BUCKET
      key: uploads/file.txt

​

cloudflare:r2:delete

• bucket (string, required) - R2 bucket binding name
• key (string, required) - Object key

​

cloudflare:r2:list

• bucket (string, required) - R2 bucket binding name
• prefix (string, optional) - Prefix filter
• limit (number, optional) - Results limit
• cursor (string, optional) - Pagination cursor

​

KV Storage Operations

​

cloudflare:kv:put

• namespace (string, required) - KV namespace binding name
• key (string, required) - Key
• value (string, required) - Value
• expirationTtl (number, optional) - Expiration TTL in seconds
• metadata (object, optional) - Metadata

operations:
  - operation: cloudflare:kv:put
    config:
      namespace: MY_KV
      key: user:${input.userId}
      value: ${JSON.stringify(input.userData)}
      expirationTtl: 3600

​

cloudflare:kv:get

• namespace (string, required) - KV namespace binding name
• key (string, required) - Key
• type (string, optional) - Return type: ‘text’, ‘json’, ‘arrayBuffer’, ‘stream’

operations:
  - operation: cloudflare:kv:get
    config:
      namespace: MY_KV
      key: user:${input.userId}
      type: json

​

cloudflare:kv:delete

• namespace (string, required) - KV namespace binding name
• key (string, required) - Key

​

cloudflare:kv:list

• namespace (string, required) - KV namespace binding name
• prefix (string, optional) - Prefix filter
• limit (number, optional) - Results limit
• cursor (string, optional) - Pagination cursor

​

D1 Database Operations

​

cloudflare:d1:query

• database (string, required) - D1 database binding name
• query (string, required) - SQL query
• params (array, optional) - Query parameters

operations:
  - operation: cloudflare:d1:query
    config:
      database: MY_DB
      query: SELECT * FROM users WHERE id = ?
      params: [${input.userId}]

​

cloudflare:d1:batch

• database (string, required) - D1 database binding name
• statements (array, required) - Array of

operations:
  - operation: cloudflare:d1:batch
    config:
      database: MY_DB
      statements:
        - query: INSERT INTO logs (event, user_id) VALUES (?, ?)
          params: [login, ${input.userId}]
        - query: UPDATE users SET last_login = ? WHERE id = ?
          params: [${Date.now()}, ${input.userId}]

​

Cloudflare API Operations

​

cloudflare:api:request

• endpoint (string, required) - API endpoint path
• method (string, required) - HTTP method: ‘GET’, ‘POST’, ‘PUT’, ‘PATCH’, ‘DELETE’
• body (object, optional) - Request body
• params (object, optional) - Query parameters

operations:
  - operation: cloudflare:api:request
    config:
      endpoint: /zones/${env.CLOUDFLARE_ZONE_ID}/purge_cache
      method: POST
      body:
        purge_everything: true

​

cloudflare:dns:create

• type (string, required) - Record type: ‘A’, ‘AAAA’, ‘CNAME’, ‘TXT’, ‘MX’, ‘SRV’
• name (string, required) - Record name
• content (string, required) - Record content
• ttl (number, optional) - TTL (1 = automatic)
• proxied (boolean, optional) - Proxied through Cloudflare
• priority (number, optional) - Priority (for MX/SRV)
• comment (string, optional) - Comment

operations:
  - operation: cloudflare:dns:create
    config:
      type: A
      name: api.example.com
      content: 192.0.2.1
      proxied: true
      comment: API server

​

Complete Example

name: file-storage-workflow
flow:
  # Upload file to R2
  - name: upload-file
    operation: cloudflare:r2:put
    config:
      bucket: MY_BUCKET
      key: uploads/${input.filename}
      value: ${input.fileContent}
      contentType: ${input.contentType}

  # Store metadata in KV
  - name: store-metadata
    operation: cloudflare:kv:put
    config:
      namespace: MY_KV
      key: file:${input.filename}
      value: ${JSON.stringify({
        size: input.fileSize,
        uploadedAt: Date.now(),
        userId: input.userId
      })}

  # Log to D1
  - name: log-upload
    operation: cloudflare:d1:query
    config:
      database: MY_DB
      query: INSERT INTO uploads (filename, user_id, size) VALUES (?, ?, ?)
      params: [${input.filename}, ${input.userId}, ${input.fileSize}]

​

Links

• Cloudflare Developers Documentation
• R2 Documentation
• KV Documentation
• D1 Documentation
• GitHub Repository