Client Catalog

open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.Security

let createWidget (security: SecurityClient) accountId =
    task {
        let widget =
            AccountsTurnstileWidgetCreatePayload.Create([ "example.com" ], turnstile_widget_mode.Managed, "signup-form")
        match! security.AccountsTurnstileWidgetCreate(accountId, widget) with
        | AccountsTurnstileWidgetCreate.OK payload ->
            return payload.result |> Option.map (fun created -> created.sitekey, created.secret)
        | AccountsTurnstileWidgetCreate.Status4XX(status, failure) ->
            for error in failure.errors do
                printfn "HTTP %d: %s" status error.message
            return None
    }

open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.AI

let createGateway (ai: AIClient) accountId =
    task {
        let gateway =
            { AigConfigCreateGatewayPayload.Create(cache_invalidate_on_update = true, collect_logs = true, id = "chatbot") with
                cache_ttl = Some 300
                rate_limiting_limit = Some 100
                rate_limiting_interval = Some 60
                rate_limiting_technique = Some AigConfigCreateGatewayPayloadRate_limiting_technique.Fixed }
        match! ai.AigConfigCreateGateway(accountId, body = gateway) with
        | AigConfigCreateGateway.OK payload ->
            printfn "Gateway %s created at %O" payload.result.id payload.result.created_at
        | AigConfigCreateGateway.BadRequest failure ->
            printfn "Gateway rejected: %A" failure.errors
    }

open System
open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.Media

let uploadUrl (media: MediaClient) accountId (userId: string) =
    task {
        let expiry = DateTimeOffset.UtcNow.AddMinutes 30.
        match! media.CloudflareImagesCreateAuthenticatedDirectUploadUrlV2(accountId, creator = userId, expiry = expiry) with
        | CloudflareImagesCreateAuthenticatedDirectUploadUrlV2.OK payload ->
            return Some(string payload.result["uploadURL"])
        | CloudflareImagesCreateAuthenticatedDirectUploadUrlV2.Status4XX(status, failure) ->
            for error in failure.errors do
                printfn "HTTP %d: %s" status error.message
            return None
    }

open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.Observability

let topPages (observability: ObservabilityClient) accountId =
    task {
        let sql =
            "SELECT blob1 AS path, SUM(_sample_interval) AS views FROM page_views "
            + "WHERE timestamp > NOW() - INTERVAL '7' DAY "
            + "GROUP BY path ORDER BY views DESC LIMIT 10 FORMAT JSON"
        match! observability.AnalyticsEngineSqlQueryPost(accountId, sql) with
        | AnalyticsEngineSqlQueryPost.OK report ->
            for row in report.data do
                printfn "%O  %O" row["path"] row["views"]
        | AnalyticsEngineSqlQueryPost.BadRequest message ->
            printfn "Query rejected: %s" message
        | other ->
            printfn "%A" other
    }

open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.Messaging

let forwardContact (messaging: MessagingClient) zoneId =
    task {
        let toContact =
            { email_rule_matcher.Create email_rule_matcherType.Literal with
                field = Some Field.To
                value = Some "hello@example.com" }
        let forward = { email_rule_action.Create email_rule_actionType.Forward with value = Some [ "owner@example.net" ] }
        let rule = { email_create_rule_properties.Create([ forward ], [ toContact ]) with name = Some "Contact address" }
        match! messaging.EmailRoutingRoutingRulesCreateRoutingRule(zoneId, rule) with
        | EmailRoutingRoutingRulesCreateRoutingRule.OK _ ->
            printfn "hello@example.com forwards to owner@example.net"
        | EmailRoutingRoutingRulesCreateRoutingRule.BadRequest ->
            printfn "Rule rejected with HTTP 400"
        | EmailRoutingRoutingRulesCreateRoutingRule.UnprocessableEntity ->
            printfn "Rule rejected with HTTP 422"
    }

open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.ContentDelivery

let enable (delivery: ContentDeliveryClient) zoneId =
    task {
        let turnOn = cache_u002D_rules_smart_tiered_cache_patch.Create cache_u002D_rules_smart_tiered_cache_patchValue.On
        match! delivery.SmartTieredCachePatchSmartTieredCacheSetting(zoneId, turnOn) with
        | SmartTieredCachePatchSmartTieredCacheSetting.OK _ ->
            printfn "Smart Tiered Cache is on"
        | SmartTieredCachePatchSmartTieredCacheSetting.Status4XX(status, failure) ->
            printfn "HTTP %d: %O" status failure.errors
    }

open System.Text.Json
open FSharp.CloudEdge.Core.Api.Types
open FSharp.CloudEdge.Management.Networking

let addRecord (networking: NetworkingClient) zoneId =
    task {
        let record =
            JsonSerializer.SerializeToElement
                {| ``type`` = "CNAME"; name = "shop.example.com"; content = "shop.example.net"; proxied = true; ttl = 1 |}
            |> dns_u002D_records_dns_u002D_record_u002D_post.FromJson
        match! networking.DnsRecordsForAZoneCreateDnsRecord(zoneId, record) with
        | DnsRecordsForAZoneCreateDnsRecord.OK payload ->
            printfn "DNS record created: %b" payload.success
        | DnsRecordsForAZoneCreateDnsRecord.Status4XX(status, failure) ->
            for error in failure.errors do
                printfn "HTTP %d: %s" status error.message
    }