TerraScale
Public Alpha

C# TypeScript

using System.Net.Http.Headers;
using System.Net.Http.Json;

// Server-side: TERRABASE_API_KEY holds a tb_ key.
// Supply a resolver and trusted origins from server configuration.
// The override skips discovery.
static class DocumentsExample
{
    private static readonly HttpClient Http = new(new SocketsHttpHandler {
        AllowAutoRedirect = false,
        PooledConnectionLifetime = TimeSpan.FromMinutes(5)
    });

    public static async Task<string> CreateAndQueryCustomers(
        Func<CancellationToken, Task<Uri>> resolveRegion, IReadOnlyCollection<Uri> trustedOrigins,
        string project, string database, string collection, Uri? staticOrigin = null,
        CancellationToken cancellationToken = default)
    {
        using var deadline = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken);
        deadline.CancelAfter(TimeSpan.FromSeconds(30));
        var token = deadline.Token;
        token.ThrowIfCancellationRequested();
        var origin = staticOrigin ?? await resolveRegion(token).WaitAsync(token);
        if (!origin.IsAbsoluteUri || origin.Scheme != Uri.UriSchemeHttps ||
            origin.UserInfo.Length != 0 || origin.AbsolutePath != "/" ||
            origin.Query.Length != 0 || origin.Fragment.Length != 0 ||
            !trustedOrigins.Contains(origin))
            throw new ArgumentException("Expected a trusted HTTPS origin");
        if (new[] { project, database, collection }.Any(name =>
            string.IsNullOrEmpty(name) || name == "." || name == ".."))
            throw new ArgumentException("Resource names are required");
        var apiKey = Environment.GetEnvironmentVariable("TERRABASE_API_KEY");
        if (string.IsNullOrWhiteSpace(apiKey))
            throw new InvalidOperationException("TERRABASE_API_KEY is required");

        var path = "/v1/projects/" + Uri.EscapeDataString(project) +
            "/databases/" + Uri.EscapeDataString(database) +
            "/collections/" + Uri.EscapeDataString(collection);
        using var create = new HttpRequestMessage(HttpMethod.Post, new Uri(origin, path + "/documents"));
        create.Headers.Authorization = new AuthenticationHeaderValue("Bearer", apiKey);
        create.Content = JsonContent.Create(new { email = "[email protected]", plan = "pro" });
        using (var created = await Http.SendAsync(create, HttpCompletionOption.ResponseHeadersRead, token))
            created.EnsureSuccessStatusCode();
        using var request = new HttpRequestMessage(HttpMethod.Post, new Uri(origin, path + "/query"));
        request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", apiKey);
        request.Content = JsonContent.Create(new {
            filter = new { eq = new[] { "/plan", "pro" } },
            limit = 25
        });
        using var response = await Http.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, token);
        response.EnsureSuccessStatusCode();
        return await response.Content.ReadAsStringAsync(token);
    }
}